summaryrefslogtreecommitdiff
path: root/memcached.h
diff options
context:
space:
mode:
authordormando <dormando@rydia.net>2022-08-06 22:53:56 -0700
committerdormando <dormando@rydia.net>2022-08-24 22:32:40 -0700
commit2bdf0ec3c8d89d7b75cb8ba7f1290cd937595669 (patch)
tree5d0c0a4222b99237b2490d4bb082876c8a96a43d /memcached.h
parentacb89505d3361d025be112a958a0c45ece0135fd (diff)
downloadmemcached-2bdf0ec3c8d89d7b75cb8ba7f1290cd937595669.tar.gz
core: add tagging to listener sockets
-l tag[asdfasdf]:0.0.0.0:11211 not presently used for anything outside of the proxy code.
Diffstat (limited to 'memcached.h')
-rw-r--r--memcached.h5
1 files changed, 3 insertions, 2 deletions
diff --git a/memcached.h b/memcached.h
index 2320086..a39ec64 100644
--- a/memcached.h
+++ b/memcached.h
@@ -852,6 +852,7 @@ struct conn {
/* This is where the binary header goes */
protocol_binary_request_header binary_header;
uint64_t cas; /* the cas to return */
+ uint64_t tag; /* listener stocket tag */
short cmd; /* current command being processed */
int opaque;
int keylen;
@@ -914,7 +915,7 @@ io_queue_t *conn_io_queue_get(conn *c, int type);
io_queue_cb_t *thread_io_queue_get(LIBEVENT_THREAD *t, int type);
void conn_io_queue_return(io_pending_t *io);
conn *conn_new(const int sfd, const enum conn_states init_state, const int event_flags, const int read_buffer_size,
- enum network_transport transport, struct event_base *base, void *ssl);
+ enum network_transport transport, struct event_base *base, void *ssl, uint64_t conntag);
void conn_worker_readd(conn *c);
extern int daemonize(int nochdir, int noclose);
@@ -945,7 +946,7 @@ void proxy_reload_notify(LIBEVENT_THREAD *t);
#endif
void return_io_pending(io_pending_t *io);
void dispatch_conn_new(int sfd, enum conn_states init_state, int event_flags, int read_buffer_size,
- enum network_transport transport, void *ssl);
+ enum network_transport transport, void *ssl, uint64_t conntag);
void sidethread_conn_close(conn *c);
/* Lock wrappers for cache functions that are called from main loop. */