| 128 | } |
| 129 | |
| 130 | void GroupServerProxy::group_barrier( |
| 131 | void* input_ptr, size_t input_len, std::string* output) { |
| 132 | INFO_INIT(mm_handler, GroupBarrier); |
| 133 | uint32_t rsp_size = m_mgr.group_barrier(req.size(), req.rank()); |
| 134 | rsp.set_size(rsp_size); |
| 135 | rsp.SerializeToString(output); |
| 136 | } |
| 137 | #undef INFO_INIT |
| 138 | |
| 139 | /* ======================== GroupClientProxy ========================== */ |