File tree Expand file tree Collapse file tree 2 files changed +10
-10
lines changed Expand file tree Collapse file tree 2 files changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -17,8 +17,8 @@ class Controller::BarrierController {
17
17
tasks_.push_back (std::move (msg));
18
18
if (static_cast <int >(tasks_.size ()) == Zoo::Get ()->size ()) {
19
19
MessagePtr my_reply; // my reply should be the last one
20
- for (auto & msg : tasks_) {
21
- MessagePtr reply (msg ->CreateReplyMessage ());
20
+ for (auto & task_msg : tasks_) {
21
+ MessagePtr reply (task_msg ->CreateReplyMessage ());
22
22
if (reply->dst () != Zoo::Get ()->rank ()) {
23
23
parent_->SendTo (actor::kCommunicator , reply);
24
24
} else {
Original file line number Diff line number Diff line change @@ -38,14 +38,14 @@ void Worker::ProcessGet(MessagePtr& msg) {
38
38
cache_[table_id]->Reset (msg_id, num);
39
39
40
40
for (auto & it : partitioned_key) {
41
- MessagePtr msg (new Message ());
42
- msg ->set_src (Zoo::Get ()->rank ());
43
- msg ->set_dst (it.first );
44
- msg ->set_type (MsgType::Request_Get);
45
- msg ->set_msg_id (msg_id);
46
- msg ->set_table_id (table_id);
47
- msg ->set_data (it.second );
48
- SendTo (actor::kCommunicator , msg );
41
+ MessagePtr new_msg (new Message ());
42
+ new_msg ->set_src (Zoo::Get ()->rank ());
43
+ new_msg ->set_dst (it.first );
44
+ new_msg ->set_type (MsgType::Request_Get);
45
+ new_msg ->set_msg_id (msg_id);
46
+ new_msg ->set_table_id (table_id);
47
+ new_msg ->set_data (it.second );
48
+ SendTo (actor::kCommunicator , new_msg );
49
49
}
50
50
MONITOR_END (WORKER_PROCESS_GET)
51
51
}
You can’t perform that action at this time.
0 commit comments