Skip to content

Commit

Permalink
fix merge issues
Browse files Browse the repository at this point in the history
  • Loading branch information
zhijunfu committed Jun 4, 2018
1 parent 363d96c commit fb573ce
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions cpp/src/plasma/store.cc
Original file line number Diff line number Diff line change
Expand Up @@ -723,8 +723,7 @@ void PlasmaStore::send_notifications(int client_fd,
}

void PlasmaStore::push_notification(ObjectInfoT* object_info) {
auto it = pending_notifications_.begin();
while (it != pending_notifications_.end()) {
for (auto& element : pending_notifications_) {
auto notification = create_object_info_buffer(object_info);
element.second.object_notifications.emplace_back(std::move(notification));
send_notifications(element.first, pending_notifications_);
Expand Down Expand Up @@ -790,7 +789,6 @@ void PlasmaStore::subscribe_to_queue_updates(Client* client, const ObjectID& obj
}
send_notifications(fd);
*/
>>>>>>> d304c425... Rewrite code logic so that client gets queue items via notification instead of reading directly from raw buffer (right now only support local writer & reader)
}

Status PlasmaStore::process_message(Client* client) {
Expand Down

0 comments on commit fb573ce

Please sign in to comment.