A generic tcp socket class that offers i/o buffering. More...
#include <buffer.h>
Public Member Functions | |
void | blocking (timeout_t timeout=Timer::inf) |
Set timeout interval and blocking. | |
void | close (void) |
Close active connection. | |
void | open (TCPServer *server, size_t size=536) |
Connect a tcp socket to a client from a listener. | |
void | open (const char *host, size_t size=536) |
Connect a tcp client session to a specific host uri. | |
bool | pending (void) |
Check for pending tcp or ssl data. | |
TCPSocket (TCPServer *server, size_t size=536) | |
Construct a tcp server session from a listening socket. | |
TCPSocket (const char *service) | |
Construct an unconnected tcp client and specify our service profile. | |
TCPSocket (const char *service, const char *host, size_t size=536) | |
Construct a tcp client session connected to a specific host uri. | |
virtual | ~TCPSocket () |
Destroy the tcp socket and release all resources. | |
Protected Member Functions | |
virtual size_t | _pull (char *address, size_t size) |
virtual size_t | _push (const char *address, size_t size) |
short | getservice (void) const |
Get the effective "service" port identifier of the socket. | |
socket_t | getsocket (void) const |
Get the low level socket object. | |
size_t | peek (char *data, size_t size, timeout_t timeout=Timer::inf) |
Peek at socket input. | |
const char * | tag (void) const |
Get the tag used for this socket. |
A generic tcp socket class that offers i/o buffering.
All user i/o operations are directly inherited from the IOBuffer base class public members. Some additional members are added for layering ssl services.
Definition at line 493 of file buffer.h.
ucc::TCPSocket::TCPSocket | ( | const char * | service | ) |
Construct an unconnected tcp client and specify our service profile.
service | identifer, usually by name. |
ucc::TCPSocket::TCPSocket | ( | TCPServer * | server, | |
size_t | size = 536 | |||
) |
Construct a tcp server session from a listening socket.
server | socket we are created from. | |
size | of buffer and tcp fragments. |
ucc::TCPSocket::TCPSocket | ( | const char * | service, | |
const char * | host, | |||
size_t | size = 536 | |||
) |
Construct a tcp client session connected to a specific host uri.
service | identifier of our client. | |
host | and optional :port we are connecting to. | |
size | of buffer and tcp fragments. |
void ucc::TCPSocket::blocking | ( | timeout_t | timeout = Timer::inf |
) |
Set timeout interval and blocking.
timeout | to use. |
short ucc::TCPSocket::getservice | ( | void | ) | const [inline, protected] |
Get the effective "service" port identifier of the socket.
If the socket was created from a listener, this will be the port number of the listening socket, and hence can be useful to determine which service connected and whether ssl is needed. If this is a client socket, it will be the service port of the peer socket.
socket_t ucc::TCPSocket::getsocket | ( | void | ) | const [inline, protected] |
void ucc::TCPSocket::open | ( | const char * | host, | |
size_t | size = 536 | |||
) |
Connect a tcp client session to a specific host uri.
If the socket was already connected, it is automatically closed first.
host | and optional :port we are connecting to. | |
size | of buffer and tcp fragments. |
Reimplemented in ucc::SSocket.
void ucc::TCPSocket::open | ( | TCPServer * | server, | |
size_t | size = 536 | |||
) |
Connect a tcp socket to a client from a listener.
If the socket was already connected, it is automatically closed first.
server | we are connected from. | |
size | of buffer and tcp fragments. |
Reimplemented in ucc::SSocket.
size_t ucc::TCPSocket::peek | ( | char * | data, | |
size_t | size, | |||
timeout_t | timeout = Timer::inf | |||
) | [protected] |
Peek at socket input.
This might be used to get a header at connection and to see if ssl/tls service is needed.
data | buffer to store peek results. | |
size | of data to peek. | |
timeout | to wait for peek. |
bool ucc::TCPSocket::pending | ( | void | ) |
const char* ucc::TCPSocket::tag | ( | void | ) | const [inline, protected] |