| 114 | } |
| 115 | |
| 116 | static inline void GetIdx(const int nsub, const int sub_id, const int queue_id, size_t &idx) { |
| 117 | idx = queue_id * nsub + sub_id - 1; |
| 118 | } |
| 119 | |
| 120 | comm::RetCode SyncCtrl::AdjustNextCursorID(const int sub_id, const int queue_id, |
| 121 | uint64_t &prev_cursor_id, uint64_t &next_cursor_id) { |
no outgoing calls
no test coverage detected