diff options
author | dormando <dormando@rydia.net> | 2022-08-06 22:53:56 -0700 |
---|---|---|
committer | dormando <dormando@rydia.net> | 2022-08-24 22:32:40 -0700 |
commit | 2bdf0ec3c8d89d7b75cb8ba7f1290cd937595669 (patch) | |
tree | 5d0c0a4222b99237b2490d4bb082876c8a96a43d /memcached.h | |
parent | acb89505d3361d025be112a958a0c45ece0135fd (diff) | |
download | memcached-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.h | 5 |
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. */ |