mooncake-track
/
Mooncake
0
0
Fork 12
Code Issues Pull Requests 13 Actions Packages Projects Releases Wiki Activity

[CCF Archive] Store object type eviction policy submission #3

Closed
kancel wants to merge 382 commits from kancel:ccf-archive-pr2746 into main
pull from: kancel:ccf-archive-pr2746
merge into: mooncake-track:main
Conversation 0 Commits 382 Files Changed 654 +8
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 5893083ab1 - Show all commits

8
mooncake-transfer-engine/tent/src/runtime/control_plane.cpp
View File

@ -243,6 +243,10 @@ void ControlService::onBootstrapRdma(const std::string_view& request,
void ControlService::onSendData(const std::string_view& request,
std::string& response) {
if (request.size() < sizeof(XferDataDesc)) {
response = "SendData failed: request too short";
return;
}
XferDataDesc* desc = (XferDataDesc*)request.data();
auto local_desc = manager_->getLocal().get();
auto peer_mem_addr = le64toh(desc->peer_mem_addr);
@ -263,6 +267,10 @@ void ControlService::onSendData(const std::string_view& request,
void ControlService::onRecvData(const std::string_view& request,
std::string& response) {
if (request.size() < sizeof(XferDataDesc)) {
response = "RecvData failed: request too short";
return;
}
XferDataDesc* desc = (XferDataDesc*)request.data();
auto local_desc = manager_->getLocal().get();
auto peer_mem_addr = le64toh(desc->peer_mem_addr);