From c13d73b4c905783953e44f139e965018f6167dcc Mon Sep 17 00:00:00 2001 From: Stephanie Wang Date: Fri, 6 Jan 2017 22:14:51 -0800 Subject: [PATCH] Suppress duplicate transfer requests (#185) --- src/plasma/plasma_manager.c | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/plasma/plasma_manager.c b/src/plasma/plasma_manager.c index 876ec489a..277944a71 100644 --- a/src/plasma/plasma_manager.c +++ b/src/plasma/plasma_manager.c @@ -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); }