|
14 | 14 | namespace xgboost {
|
15 | 15 | namespace federated {
|
16 | 16 |
|
17 |
| -grpc::Status FederatedService::Allgather(grpc::ServerContext* context, |
18 |
| - AllgatherRequest const* request, AllgatherReply* reply) { |
| 17 | +grpc::Status FederatedService::Allgather(grpc::ServerContext*, AllgatherRequest const* request, |
| 18 | + AllgatherReply* reply) { |
19 | 19 | handler_.Allgather(request->send_buffer().data(), request->send_buffer().size(),
|
20 | 20 | reply->mutable_receive_buffer(), request->sequence_number(), request->rank());
|
21 | 21 | return grpc::Status::OK;
|
22 | 22 | }
|
23 | 23 |
|
24 |
| -grpc::Status FederatedService::Allreduce(grpc::ServerContext* context, |
25 |
| - AllreduceRequest const* request, AllreduceReply* reply) { |
| 24 | +grpc::Status FederatedService::Allreduce(grpc::ServerContext*, AllreduceRequest const* request, |
| 25 | + AllreduceReply* reply) { |
26 | 26 | handler_.Allreduce(request->send_buffer().data(), request->send_buffer().size(),
|
27 | 27 | reply->mutable_receive_buffer(), request->sequence_number(), request->rank(),
|
28 | 28 | static_cast<xgboost::collective::DataType>(request->data_type()),
|
29 | 29 | static_cast<xgboost::collective::Operation>(request->reduce_operation()));
|
30 | 30 | return grpc::Status::OK;
|
31 | 31 | }
|
32 | 32 |
|
33 |
| -grpc::Status FederatedService::Broadcast(grpc::ServerContext* context, |
34 |
| - BroadcastRequest const* request, BroadcastReply* reply) { |
| 33 | +grpc::Status FederatedService::Broadcast(grpc::ServerContext*, BroadcastRequest const* request, |
| 34 | + BroadcastReply* reply) { |
35 | 35 | handler_.Broadcast(request->send_buffer().data(), request->send_buffer().size(),
|
36 | 36 | reply->mutable_receive_buffer(), request->sequence_number(), request->rank(),
|
37 | 37 | request->root());
|
|
0 commit comments