|
Scopira
20080306
|
#include <context.h>
Public Member Functions | |
| recv_msg (scopira::agent::task_context &ctx, scopira::tool::uuid src) | |
| recv_msg (scopira::agent::task_context &ctx, int src) | |
| recv_msg (scopira::agent::task_context &ctx, const uuid_query &Q) | |
| virtual | ~recv_msg () |
| dtor | |
| scopira::tool::uuid | get_source (void) const |
Public Member Functions inherited from scopira::tool::bin64iflow | |
| bin64iflow (bool doref, iflow_i *in) | |
| virtual bool | read_size_t (size_t &) |
| virtual bool | read_long (long &) |
Public Member Functions inherited from scopira::tool::biniflow | |
| biniflow (bool doref, iflow_i *in) | |
| virtual | ~biniflow (void) |
| destructor | |
| virtual bool | failed (void) const |
| are we in a failed state? | |
| virtual size_t | read (byte_t *_buf, size_t _maxsize) |
| read raw block data, returns num read in | |
| virtual bool | read_bool (bool &) |
| virtual bool | read_char (char &) |
| virtual bool | read_short (short &) |
| virtual bool | read_int (int &) |
| virtual bool | read_int64_t (int64_t &) |
| virtual bool | read_float (float &) |
| virtual bool | read_double (double &) |
| virtual bool | read_string (std::string &) |
| void | open (iflow_i *in) |
| opens a new link | |
| void | close (void) |
| close the current link | |
Public Member Functions inherited from scopira::tool::itflow_i | |
| template<class TT > | |
| bool | read_generic (TT &v) |
Public Member Functions inherited from scopira::tool::iflow_i | |
| virtual size_t | read_byte (byte_t &out) |
| template<class TT > | |
| size_t | read_array (TT *_buf, size_t _numelem) |
| size_t | read_void (void *_buf, size_t _maxsize) |
Public Member Functions inherited from scopira::tool::object | |
| virtual | ~object () |
| int | add_ref (void) const |
| bool | sub_ref (void) const |
| void | auto_ref (void) const |
| int | current_ref (void) const |
| virtual scopira::tool::oflow_i & | print (scopira::tool::oflow_i &o) const |
| virtual bool | load (scopira::tool::iobjflow_i &in) |
| virtual void | save (scopira::tool::oobjflow_i &out) const |
| bool | is_alive_object (void) const |
| bool | is_dead_object (void) const |
Additional Inherited Members | |
Public Types inherited from scopira::tool::flow_i | |
| enum | { input_c = 1, output_c = 2 } |
| typedef scopira::tool::byte_t | byte_t |
| typedef int | mode_t |
Protected Member Functions inherited from scopira::tool::object | |
| object (void) | |
| object (bool neverusecounter) | |
Protected Attributes inherited from scopira::tool::biniflow | |
| count2_ptr< iflow_i > | dm_in |
| input flow | |
A recv msg.
| scopira::agent::recv_msg::recv_msg | ( | scopira::agent::task_context & | ctx, |
| scopira::tool::uuid | src | ||
| ) |
Prepare and receive a msg in a transaction.
ctx the context. src the source UUID youd like to check for messages from. A zero UUID implies that any source (in the universe) would be fine (in which case, use get_source() to find the actual source.
| scopira::agent::recv_msg::recv_msg | ( | scopira::agent::task_context & | ctx, |
| int | src | ||
| ) |
Prepare and receive a msg in a transaction. Group edition.
ctx the context. src the source index youd lke to receive from, or -1 for "any in your group"
| scopira::agent::recv_msg::recv_msg | ( | scopira::agent::task_context & | ctx, |
| const uuid_query & | Q | ||
| ) |
Prepare and receive a msg in a transaction.
ctx the context. src is the query you'd like to match (ie. this is the most general version)
|
inline |
Gets the source UUID of the msg.