| 108 | } |
| 109 | |
| 110 | void GroupServerProxy::bcast_addr( |
| 111 | void* input_ptr, size_t input_len, std::string* output) { |
| 112 | INFO_INIT(mm_handler, BcastAddr); |
| 113 | std::string master_ip = req.master_ip(); |
| 114 | int port = req.port(); |
| 115 | m_mgr.bcast_addr(master_ip, port, req.key(), req.size(), req.rank(), req.root()); |
| 116 | rsp.set_master_ip(master_ip); |
| 117 | rsp.set_port(port); |
| 118 | rsp.SerializeToString(output); |
| 119 | } |
| 120 | |
| 121 | void GroupServerProxy::bcast_nccluniqueid( |
| 122 | void* input_ptr, size_t input_len, std::string* output) { |