1 #include "hmbdc/Copyright.hpp"
3 #include "hmbdc/app/Client.hpp"
8 namespace hmbdc {
namespace app {
10 template <
typename Buffer>
12 :
Client<StuckClientPurger<Buffer>> {
15 : secondsBewteenPurges_(secondsBewteenPurges)
24 if (secondsBewteenPurges_ == secondsCurrent_) {
25 auto res = buffer_.purge();
27 cerr <<
"purgedMask=" << hex << res << dec << endl;
36 cerr << e.what() << endl;
39 char const* hmbdcName()
const {
43 std::tuple<char const*, int> schedSpec()
const {
44 return std::make_tuple(
"SCHED_IDLE", 0);
48 uint32_t secondsBewteenPurges_;
49 uint32_t secondsCurrent_;
Definition: StuckClientPurger.hpp:11
void invokedCb(uint16_t) override
this callback is called all the time (frequently) - the exact timing is after a batch of messages are...
Definition: StuckClientPurger.hpp:20
Definition: Message.hpp:112
void stoppedCb(std::exception const &e) override
callback called when this Client is taken out of message dispatching
Definition: StuckClientPurger.hpp:34
A Client represents a thread of execution/a task. The execution is managed by a Context. a Client object could participate in message dispatching as the receiver of specifed message types.
Definition: Client.hpp:57