Added new queue and table to the RdmaTensorBuffer, where a semi-replica of the...
Added new queue and table to the RdmaTensorBuffer, where a semi-replica of the send_recv_ops waiter table is stored. Values are added to the local table when remote is not ready for receiving our tensor. When we get an BUFFER_RESPONSE, we use ReSendNextItem instead of sendNextItem. Splitted SendNextItem And ReSend to two functions, move callback to new function for code reuse Clanged formatted Fixed according to shamoya's review, Fixed send->resend flow squached, rebased on origin/master
Loading
Please sign in to comment