源码搜藏网

[cpp] view plain copy  

1. typedef struct conn conn;  
2. struct conn {  
3.     int    sfd;  
4.     sasl_conn_t *sasl_conn;  
5.     enum conn_states  state;  
6.     enum bin_substates substate;  
7.     struct event event;  
8.     short  ev_flags;  
9.     short  which;   /** which events were just triggered */  
10.   
11.     char   *rbuf;   /** buffer to read commands into */  
12.     char   *rcurr;  /** but if we parsed some already, this is where we stopped */  
13.     int    rsize;   /** total allocated size of rbuf */  
14.     int    rbytes;  /** how much data, starting from rcur, do we have unparsed */  
15.   
16.     char   *wbuf;  
17.     char   *wcurr;  
18.     int    wsize;  
19.     int    wbytes;  
20.     /** which state to go into after finishing current write */  
21.     enum conn_states  write_and_go;  
22.     void   *write_and_free; /** free this memory after finishing writing */  
23.   
24.     char   *ritem;  /** when we read in an item's value, it goes here */  
25.     int    rlbytes;  
26.   
27.     /* data for the nread state */  
28.   
29.     /** 
30.      * item is used to hold an item structure created after reading the command 
31.      * line of set/add/replace commands, but before we finished reading the actual 
32.      * data. The data is read into ITEM_data(item) to avoid extra copying. 
33.      */  
34.   
35.     void   *item;     /* for commands set/add/replace  */  
36.   
37.     /* data for the swallow state */  
38.     int    sbytes;    /* how many bytes to swallow */  
39.   
40.     /* data for the mwrite state */  
41.     struct iovec *iov;  
42.     int    iovsize;   /* number of elements allocated in iov[] */  
43.     int    iovused;   /* number of elements used in iov[] */  
44.   
45.     struct msghdr *msglist;  
46.     int    msgsize;   /* number of elements allocated in msglist[] */  
47.     int    msgused;   /* number of elements used in msglist[] */  
48.     int    msgcurr;   /* element in msglist[] being transmitted now */  
49.     int    msgbytes;  /* number of bytes in current msg */  
50.   
51.     item   **ilist;   /* list of items to write out */  
52.     int    isize;  
53.     item   **icurr;  
54.     int    ileft;  
55.   
56.     char   **suffixlist;  
57.     int    suffixsize;  
58.     char   **suffixcurr;  
59.     int    suffixleft;  
60.   
61.     enum protocol protocol;   /* which protocol this con<pre name="code" class="cpp">  if (sigignore(SIGPIPE) == -1) {  
62.         perror("failed to ignore SIGPIPE; sigaction");  
63.         exit(EX_OSERR);  
64.     }  

nection speaks */ enum network_transport transport; /* what transport is used by this connection */ /* data for UDP clients */ int request_id; /* Incoming UDP request ID, if this is a UDP "connection" */ struct sockaddr request_addr; /* Who sent the most recent request */ socklen_t request_addr_size; unsigned char *hdrbuf; /* udp packet headers */ int hdrsize; /* number of headers' worth of space is allocated */ bool noreply; /* True if the reply should not be sent. */ /* current stats command */ struct { char *buffer; size_t size; size_t offset; } stats; /* Binary protocol stuff */ /* This is where the binary header goes */ protocol_binary_request_header binary_header; uint64_t cas; /* the cas to return */ short cmd; /* current command being processed */ int opaque; int keylen; conn *next; /* Used for generating a list of conn structures */ LIBEVENT_THREAD *thread; /* Pointer to the thread object serving this connection *