Class SIPpSocket

include/socket.hpp:68–153

This is an abstraction of a socket, which provides buffers for input and * output. */

/* This is an abstraction of a socket, which provides buffers for input and
 * output. */
class SIPpSocket {
public:
    SIPpSocket(bool use_ipv6, int transport, int fd, int accepting);
    static SIPpSocket* new_sipp_call_socket(bool use_ipv6, int transport, bool *existing);
    void set_bind_port(int bind_port);

    int connect(struct sockaddr_storage* dest = nullptr);
    int reconnect();

    // Reset a failed connection
    void reset_connection();

    // Accept new connections from a TCP socket
    SIPpSocket* accept();

    // Write data to the socket.
    int write(const char *buffer, ssize_t len, int flags, struct sockaddr_storage *dest);

    // Empty data from the socket into our buffer
    int empty();

    // Decrement the reference count of this socket, shutting it down when it reaches 0
    void close();

    int read_error(int ret);

    // Have we read a message from this socket?
    bool message_ready() { return ss_msglen > 0; };

#ifdef SO_BINDTODEVICE
    // Bind to specific network device.
    int bind_to_device(const char* device_name);
#endif

    static void pollset_process(int wait);

    int ss_count = 1;           /* How many users are there of this socket? */
    bool ss_ipv6 = false;
    int ss_transport = 0;       /* T_TCP, T_UDP, or T_TLS. */
    bool ss_control = false;    /* Is this a control socket? */
    int ss_fd = -1;             /* The underlying file descriptor for this socket. */
    int ss_port = 0;            /* The port used by this socket */
    int ss_bind_port = 0;       /* Optional local port used by this socket */
    void *ss_comp_state = nullptr;    /* The compression state. */

    bool ss_changed_dest = false;   /* Has the destination changed from default. */
    struct sockaddr_storage ss_dest; /* Who we are talking to. */

private:
    bool ss_congested = false; /* Is this socket congested? */
    bool ss_invalid = false; /* Has this socket been closed remotely? */

    int handleSCTPNotify(char* buffer);
    void sipp_sctp_peer_params();
    void invalidate();
    void buffer_read(struct socketbuf *newbuf);
    void buffer_write(const char *buffer, size_t len, struct sockaddr_storage *dest);
    ssize_t read_message(char *buf, size_t len, struct sockaddr_storage *src);