MCPcopy Create free account
hub / github.com/PlatformLab/Homa / checkMessageTimeouts

Method checkMessageTimeouts

src/Sender.cc:914–949  ·  view source on GitHub ↗

* Process any outbound messages in a given bucket that have timed out due to * lack of activity from the Receiver. * * Pulled out of checkTimeouts() for ease of testing. * * @param now * The rdtsc cycle that should be considered the "current" time. * @param bucket * The bucket whose message timeouts should be checked. */

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 2

TEST_FFunction · 0.45
TEST_FFunction · 0.45

Calls 6

anyElapsedMethod · 0.80
hasElapsedMethod · 0.80
containsMethod · 0.80
removeMethod · 0.80
cancelTimeoutMethod · 0.80
emptyMethod · 0.45

Tested by 2

TEST_FFunction · 0.36
TEST_FFunction · 0.36