class gather_receive_event

Declaration

class gather_receive_event : public async_event_impl { /* full declaration omitted */ };

Description

Event for receive_arbiter::gather_receive, which waits for incoming messages (or empty-box pilots) from all peers.

Declared at: src/receive_arbiter.cc:43

Inherits from: async_event_impl

Member Variables

weak_gather_request m_request

Member Function Overview

• gather_receive_event(const stable_gather_request & gr) → explicit
• is_complete() → bool

Inherited from async_event_impl:

• public get_native_execution_time
• public get_result
• public is_complete
• public operator=
• public operator=

Member Functions

¶explicit gather_receive_event(
    const stable_gather_request& gr)

Declared at: src/receive_arbiter.cc:45

Parameters

const stable_gather_request& gr

---

¶bool is_complete()

Description

If this function returns true once, the implementation must guarantee that it will always do so in the future. The event is expected to be cheap to poll repeatedly, and the operation must proceed in the background even while not being polled.

Declared at: src/receive_arbiter.cc:47

---