plebble
us::gov::cli::rpc_api::rendezvous_t Class Referencefinal

#include <rpc_api.h>

Inheritance diagram for us::gov::cli::rpc_api::rendezvous_t:
Collaboration diagram for us::gov::cli::rpc_api::rendezvous_t:

Public Member Functions

 rendezvous_t ()
 
 ~rendezvous_t ()
 
bool arrived (datagram *)
 
std::pair< ko, datagram * > sendrecv (rpc_api &endpoint, datagram *d)
 
void flush ()
 
 rendezvous_t ()
 
void flush ()
 
boolean arrived (datagram d)
 
pair< ko, datagramsendrecv (rpc_api endpoint, datagram d)
 

Public Attributes

uint16_t next_seq {0}
 
mutex mx
 
condition_variable cv
 
bool finished {false}
 

Static Public Attributes

static const char * KO_76103
 

Package Attributes

int next_seq =0
 
ReentrantLock lock =new ReentrantLock()
 
Condition cv =lock.newCondition()
 
boolean finished =false
 

Constructor & Destructor Documentation

◆ rendezvous_t() [1/2]

us::gov::cli::rpc_api::rendezvous_t::rendezvous_t ( )

◆ ~rendezvous_t()

us::gov::cli::rpc_api::rendezvous_t::~rendezvous_t ( )

◆ rendezvous_t() [2/2]

us.gov.cli.rpc_api.rendezvous_t.rendezvous_t ( )
inline

Member Function Documentation

◆ arrived() [1/2]

bool us::gov::cli::rpc_api::rendezvous_t::arrived ( datagram )

Referenced by us::gov::cli::rpc_api::process_work2().

Here is the caller graph for this function:

◆ arrived() [2/2]

boolean us.gov.cli.rpc_api.rendezvous_t.arrived ( datagram  d)
inline

References us::gov::socket::datagram.decode_sequence(), and us::gov::cli::rpc_api.waiting_arrival.

Here is the call graph for this function:

◆ flush() [1/2]

void us::gov::cli::rpc_api::rendezvous_t::flush ( )

Referenced by us::gov::cli::rpc_api::stop().

Here is the caller graph for this function:

◆ flush() [2/2]

void us.gov.cli.rpc_api.rendezvous_t.flush ( )
inline

◆ sendrecv() [1/2]

std::pair<ko,datagram*> us::gov::cli::rpc_api::rendezvous_t::sendrecv ( rpc_api endpoint,
datagram d 
)

Referenced by us::gov::cli::rpc_api::sendrecv().

Here is the caller graph for this function:

◆ sendrecv() [2/2]

Member Data Documentation

◆ cv [1/2]

condition_variable us::gov::cli::rpc_api::rendezvous_t::cv

◆ cv [2/2]

Condition us.gov.cli.rpc_api.rendezvous_t.cv =lock.newCondition()
package

◆ finished [1/2]

bool us::gov::cli::rpc_api::rendezvous_t::finished {false}

◆ finished [2/2]

boolean us.gov.cli.rpc_api.rendezvous_t.finished =false
package

◆ KO_76103

const char* us::gov::cli::rpc_api::rendezvous_t::KO_76103
static

◆ lock

ReentrantLock us.gov.cli.rpc_api.rendezvous_t.lock =new ReentrantLock()
package

◆ mx

mutex us::gov::cli::rpc_api::rendezvous_t::mx

◆ next_seq [1/2]

uint16_t us::gov::cli::rpc_api::rendezvous_t::next_seq {0}

◆ next_seq [2/2]

int us.gov.cli.rpc_api.rendezvous_t.next_seq =0
package

The documentation for this class was generated from the following files: