Skip to content

Commit

Permalink
Multiple slow workers.
Browse files Browse the repository at this point in the history
  • Loading branch information
vimes committed Aug 19, 2024
1 parent 684bcbb commit a4fae7e
Show file tree
Hide file tree
Showing 13 changed files with 1,732 additions and 1,455 deletions.
13 changes: 13 additions & 0 deletions common/type.h
Original file line number Diff line number Diff line change
Expand Up @@ -2545,6 +2545,19 @@ struct stats_t
uint64_t slowworker_drops;
uint64_t mempool_is_empty;
uint64_t unknown_dump_interface;

stats_t& operator+=(const stats_t& b)
{
repeat_packets += b.repeat_packets;
tofarm_packets += b.tofarm_packets;
farm_packets += b.farm_packets;
fwsync_multicast_ingress_packets += b.fwsync_multicast_ingress_packets;
slowworker_packets += b.slowworker_packets;
slowworker_drops += b.slowworker_drops;
mempool_is_empty += b.mempool_is_empty;
unknown_dump_interface += b.unknown_dump_interface;
return *this;
}
};

}
Expand Down
2 changes: 1 addition & 1 deletion dataplane/bus.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -212,7 +212,7 @@ void cBus::clientThread(int clientSocket)
}
else if (type == common::idp::requestType::getSlowWorkerStats)
{
response = callWithResponse(&cControlPlane::getSlowWorkerStats, request);
response = callWithResponse(&cControlPlane::SlowWorkerStatsResponse, request);
}
else if (type == common::idp::requestType::get_worker_gc_stats)
{
Expand Down
Loading

0 comments on commit a4fae7e

Please sign in to comment.