Skip to content

Commit

Permalink
FIxup
Browse files Browse the repository at this point in the history
  • Loading branch information
santigimeno committed Jul 12, 2024
1 parent 158345c commit b029cc2
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions agents/grpc/src/grpc_agent.cc
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,6 @@ void PopulateBlockedLoopEvent(grpcagent::BlockedLoopEvent* blocked_loop_event,
ASSERT(!body.is_discarded());

grpcagent::CommonResponse* common = blocked_loop_event->mutable_common();
common->set_agentid(GetAgentId());
common->set_command("loop_blocked");

grpcagent::BlockedLoopBody* blocked_body = blocked_loop_event->mutable_body();
Expand Down Expand Up @@ -96,7 +95,6 @@ void PopulateInfoEvent(grpcagent::InfoEvent* info_event,

// Fill in the fields of the InfoResponse.
grpcagent::CommonResponse* common = info_event->mutable_common();
common->set_agentid(GetAgentId());
common->set_command("info");
if (req_id) {
common->set_requestid(req_id);
Expand Down Expand Up @@ -180,7 +178,6 @@ void PopulatePackagesEvent(grpcagent::PackagesEvent* packages_event,

// Fill in the fields of the InfoResponse.
grpcagent::CommonResponse* common = packages_event->mutable_common();
common->set_agentid(GetAgentId());
common->set_command("packages");
if (req_id) {
common->set_requestid(req_id);
Expand Down Expand Up @@ -221,7 +218,6 @@ void PopulateUnblockedLoopEvent(grpcagent::UnblockedLoopEvent* blocked_loop_even
ASSERT(!body.is_discarded());

grpcagent::CommonResponse* common = blocked_loop_event->mutable_common();
common->set_agentid(GetAgentId());
common->set_command("loop_unblocked");

grpcagent::UnblockedLoopBody* blocked_body = blocked_loop_event->mutable_body();
Expand Down Expand Up @@ -841,7 +837,7 @@ message CommandRequest {
CommandBody body = 5;
}*/
void GrpcAgent::reconfigure(const grpcagent::CommandRequest& request) {
const grpcagent::ReconfigureBody& body = request.body().reconfigure();
const grpcagent::ReconfigureBody& body = request.args().reconfigure();
/*
message ReconfigureBody {
uint32 blockedLoopThreshold = 1;
Expand Down

0 comments on commit b029cc2

Please sign in to comment.