| 487 | inline void* buffer() const { return buffer_; } |
| 488 | inline ibv_mr* self() const { return self_; } |
| 489 | inline void SetBufferStatus(Location loc, BufferStatus status) { |
| 490 | mu_.lock(); |
| 491 | if (loc == local) { |
| 492 | local_status_ = status; |
| 493 | } else { |
| 494 | remote_status_ = status; |
| 495 | } |
| 496 | mu_.unlock(); |
| 497 | } |
| 498 | void FreeBuffer(); |
| 499 | void EnqueueItem(string Item); |
| 500 | void SendNextItem(); |
no test coverage detected