1

#ifndef SOCK_INTERNAL_H

     2

#define SOCK_INTERNAL_H

     3

     9

#include "sock.h"

    10

    12

 * Global config related to all sock_streams

    13

 */

    14

extern struct sock_stream_ctx {

    15

    /* Event core */

    16

    struct event_base *ev_base;

    17

    18

} _sock_stream_ctx;

    19

    21

 * The base type struct, which defines the method table.

    22

 */

    23

struct sock_stream_type {

    25

    struct sock_stream_methods {

    27

        err_t (*read) (struct sock_stream *sock, void *buf, size_t *len);

    28

    30

        err_t (*write) (struct sock_stream *sock, const void *buf, size_t *len);

    31

    33

        err_t (*event_init) (struct sock_stream *sock);

    34

    36

        err_t (*event_enable) (struct sock_stream *sock, short mask);

    40

    } methods;

    41

};

    42

    43

/*

    44

 * The base sock_stream type, as used by the sock_stream_* functions.

    45

 *

    46

 * The specific implementations should embed this at the start of their type-specific struct, and then cast around

    47

 * as appropriate.

    48

 */

    49

struct sock_stream {

    50

    /* The sock_stream_type for this socket */

    51

    struct sock_stream_type *type;

    52

    53

    /* Last error info */

    54

    struct error_info err;

    55

    56

    /* Callbacks */

    57

    const struct sock_stream_callbacks *cb_info;

    58

    59

    /* Callback arg */

    60

    void *cb_arg;

    61

};

    62

    63

#define SOCK_FROM_BASE(sock, type) ((type*) sock)

    64

#define SOCK_ERR(sock) (&(sock)->err)

    65

    66

/*

    67

 * Initialize a sock_stream with the given sock_stream_type.

    68

 *

    69

 * The sock_stream should be initialized to zero. It is a bug to call this twice.

    70

 */

    71

void sock_stream_init (struct sock_stream *sock, struct sock_stream_type *type);

    72

    73

/*

    74

 * Invoke the appropriate callbacks for the given EV_* bitmask.

    75

 */

    76

void sock_stream_invoke_callbacks (struct sock_stream *sock, short what);

    77

    78

#endif /* SOCK_INTERNAL_H */