, including all inherited members.
| add(pebble *p) | karoo::rock | |
| add(const struct timespec &ts, pebble *p) | karoo::rock | |
| add(int after_seconds, pebble *p) | karoo::rock | |
| addHandler(rock_datagram_message_handler *h) | karoo::rock | |
| bye() | karoo::rock | |
| create_client() | karoo::rock | [protected, virtual] |
| create_server() | karoo::rock | [protected, virtual] |
| createMessage(uint32_t msg_type, text recipient_host=null_string, int recipient_port=0, size_t message_size=0) | karoo::rock | [virtual] |
| createRockHelloMessage() | karoo::rock | [virtual] |
| createRockPingMessage() | karoo::rock | [virtual] |
| doBye(const text &name) | karoo::rock | |
| doHello(const text &name, const text &type, const text &host, int port) | karoo::rock | |
| doLongHeader(const text &name, const text &host, int port, uint32_t long_size, uint32_t num_packets, rock_datagram_message *msg, uint64_t seq) | karoo::rock | |
| doLongPacket(const text &name, const text &host, int port, uint64_t hdr_seq, uint32_t pkt_num, uint32_t this_size, unsigned char *data) | karoo::rock | |
| doPing(const text &name, const text &host, int port, bool create=false) | karoo::rock | |
| doPing(const text &name, const text &type, const text &host, int port, uint8_t load_factor) | karoo::rock | |
| findRockByType(const text &type) | karoo::rock | [protected] |
| getAckRetry() const | karoo::rock | [inline] |
| getArgument(const text &opt) const | karoo::rock | |
| getArgument(const text &opt, const text &def) const | karoo::rock | |
| getArguments(const vector< text > &opts, int argc, char *argv[]) | karoo::rock | [protected] |
| getBoolArgument(const text &opt, bool def) const | karoo::rock | |
| getGeneralPool() | karoo::rock | [inline] |
| getHost() const | karoo::rock | [inline] |
| getImminentCount(unsigned usecs=0) const | karoo::rock | |
| getLoadFactor() const (defined in karoo::rock) | karoo::rock | [inline, virtual] |
| getLogger() const | karoo::rock | [inline] |
| getLoggerLevel() const | karoo::rock | [inline] |
| getMaxRetry() const | karoo::rock | [inline] |
| getMessageSize() const | karoo::rock | [inline] |
| getName() const | karoo::rock | [inline] |
| getPort() const | karoo::rock | [inline] |
| getQueueCount() const | karoo::rock | |
| getRemoteRockType(const text &name, text &type) const | karoo::rock | |
| getSelfPort() const | karoo::rock | [inline] |
| getSequence() | karoo::rock | [inline] |
| getType() const | karoo::rock | [inline, virtual] |
| handle(rock_datagram_message *msg) | karoo::rock | [virtual] |
| init() | karoo::rock | [protected, virtual] |
| isStopping() const | karoo::rock | |
| logger | karoo::rock | [protected] |
| message_handler_runner::run() | karoo::rock | [friend] |
| notifyAcked(uint64_t seq, rock_datagram_message *msg) | karoo::rock | |
| refuse() | karoo::rock | [inline] |
| rock() | karoo::rock | |
| rock(const vector< text > &opts, int argc, char *argv[]) | karoo::rock | |
| rock_datagram_message_ack::run (defined in karoo::rock) | karoo::rock | [friend] |
| rock_datagram_message_handler::sendAck (defined in karoo::rock) | karoo::rock | [friend] |
| run() | karoo::rock | |
| sendMessage(rock_datagram_message *msg) | karoo::rock | |
| sendMessageByAddress(rock_datagram_message *msg) | karoo::rock | |
| sendMessageByType(rock_datagram_message *msg, const text &type) | karoo::rock | |
| startKeepConnectedHello(time_t poll_secs=5, time_t initial_delay=0) | karoo::rock | |
| stop(bool block=true) | karoo::rock | |
| syncChildren(map< text, remote_rock * > &rocks, vector< remote_rock * > &rocks_arr) | karoo::rock | [protected] |
| ~rock() | karoo::rock | [virtual] |
