1

#ifndef MEMCACHE_CONNECTION_H

     2

#define MEMCACHE_CONNECTION_H

     3

     4

#include <sys/queue.h>

     5

     6

#include <event2/event.h>

     7

#include <event2/event_struct.h>

     8

#include <event2/bufferevent.h>

     9

    10

#include "server.h"

    11

#include "command.h"

    12

    13

struct memcache_conn {

    14

    // the server we are connected to

    15

    struct memcache_server *server;

    16

    17

    // we are a member of struct memcache_server.conn_list

    18

    LIST_ENTRY(memcache_conn) connlist_node;

    19

    20

    // our socket fd

    21

    int fd;

    22

    23

    // socket events

    24

    struct event ev_connect;

    25

    struct event ev_read;

    26

    struct event ev_write;

    27

    28

    // socket bufferevent

    29

    struct bufferevent *bev;

    30

    31

    // have we succesfully connected yet?

    32

    int is_connected;

    33

    34

    // the request (if any) that we are currently processing - NULL for idle connections

    35

    struct memcache_req *req;

    36

    37

    // used to track our commands

    38

    struct memcache_cmd cmd;

    39

};

    40

    41

/*

    42

 * Allocate a memcache_conn struct, and initiate the connect

    43

 */

    44

struct memcache_conn *memcache_conn_open (struct memcache_server *server);

    45

    46

/*

    47

 * Attempt to connect to the server.

    48

 *

    49

 * Assumes we are not already connecting/connected

    50

 */

    51

int memcache_conn_connect (struct memcache_conn *conn);

    52

    53

/*

    54

 * Check if the given connection is available, that is, connected and not busy

    55

 */

    56

int memcache_conn_is_available (struct memcache_conn *conn);

    57

    58

/*

    59

 * The given connection must be idle, whereupon the given request is processed.

    60

 */

    61

void memcache_conn_do_req (struct memcache_conn *conn, struct memcache_req *req);

    62

    63

/*

    64

 * Free all resources associated with a closed/failed connection

    65

 */

    66

void memcache_conn_free (struct memcache_conn *conn);

    67

    68

#endif /* MEMCACHE_CONNECTION_H */