wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-08-04 13:14:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

Suppress duplicate transfer requests (#185)

Browse Source
This commit is contained in:
Stephanie Wang
2017-01-06 22:14:51 -08:00
committed by Robert Nishihara
parent 33d7004914
commit c13d73b4c9
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/plasma/plasma_manager.c
+8 -1
View File
@@ -762,7 +762,14 @@ void process_transfer_request(event_loop *loop,
event_loop_add_file(loop, manager_conn->fd, EVENT_LOOP_WRITE,
send_queued_request, manager_conn);
}
/* Add this transfer request to this connection's transfer queue. */
/* Add this transfer request to this connection's transfer queue if there
* isn't already a request with the same object ID. */
plasma_request_buffer *pending;
LL_FOREACH(manager_conn->transfer_queue, pending) {
if (object_ids_equal(pending->object_id, buf->object_id)) {
return;
}
}
LL_APPEND(manager_conn->transfer_queue, buf);
}