#include <repsock.h>

Public Types | |
| enum | { MaxSockets = 8 } |
Public Member Functions | |
| virtual int | read (void *buf, size_t min_size, size_t max_size, time_t timeout) |
| virtual bool | write (void const *buf, size_t size, time_t timeout) |
| virtual bool | is_ok () |
| virtual void | get_error_text (char *buf, size_t buf_size) |
| virtual bool | shutdown () |
| virtual bool | close () |
| virtual void | handleError (int socket, const char *operation, const char *error) |
| virtual socket_t * | accept () |
| virtual bool | cancel_accept () |
| virtual char * | get_peer_name () |
| virtual int | get_handle () |
| ~replication_socket_t () | |
Static Public Member Functions | |
| static replication_socket_t * | connect (char const *addresses[], int n_addresses, int max_attempts=DEFAULT_CONNECT_MAX_ATTEMPTS, time_t timeout=DEFAULT_RECONNECT_TIMEOUT) |
Protected Member Functions | |
| replication_socket_t (char const *addresses[], int n_adresses, int max_attempts, time_t timeout) | |
Protected Attributes | |
| socket_t ** | sockets |
| int | n_sockets |
| bool | succeed |
| ~replication_socket_t | ( | ) |
| replication_socket_t | ( | char const * | addresses[], | |
| int | n_adresses, | |||
| int | max_attempts, | |||
| time_t | timeout | |||
| ) | [protected] |
| int read | ( | void * | buf, | |
| size_t | min_size, | |||
| size_t | max_size, | |||
| time_t | timeout | |||
| ) | [virtual] |
Implements socket_t.
| bool write | ( | void const * | buf, | |
| size_t | size, | |||
| time_t | timeout | |||
| ) | [virtual] |
Implements socket_t.
| bool is_ok | ( | ) | [virtual] |
Implements socket_t.
| void get_error_text | ( | char * | buf, | |
| size_t | buf_size | |||
| ) | [virtual] |
Implements socket_t.
| bool shutdown | ( | ) | [virtual] |
Implements socket_t.
| bool close | ( | ) | [virtual] |
Implements socket_t.
| BEGIN_FASTDB_NAMESPACE void handleError | ( | int | socket, | |
| const char * | operation, | |||
| const char * | error | |||
| ) | [virtual] |
| replication_socket_t * connect | ( | char const * | addresses[], | |
| int | n_addresses, | |||
| int | max_attempts = DEFAULT_CONNECT_MAX_ATTEMPTS, |
|||
| time_t | timeout = DEFAULT_RECONNECT_TIMEOUT | |||
| ) | [static] |
| bool cancel_accept | ( | ) | [virtual] |
Implements socket_t.
| char * get_peer_name | ( | ) | [virtual] |
Implements socket_t.
| int get_handle | ( | ) | [virtual] |
Implements socket_t.
int n_sockets [protected] |
bool succeed [protected] |