summaryrefslogtreecommitdiff
path: root/thread.c
diff options
context:
space:
mode:
Diffstat (limited to 'thread.c')
-rw-r--r--thread.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/thread.c b/thread.c
index f46a4b9..d7ed2b8 100644
--- a/thread.c
+++ b/thread.c
@@ -20,7 +20,7 @@ struct conn_queue_item {
enum conn_states init_state;
int event_flags;
int read_buffer_size;
- enum protocol protocol;
+ enum network_transport transport;
CQ_ITEM *next;
};
@@ -246,9 +246,9 @@ static void thread_libevent_process(int fd, short which, void *arg) {
if (NULL != item) {
conn *c = conn_new(item->sfd, item->init_state, item->event_flags,
- item->read_buffer_size, item->protocol, me->base);
+ item->read_buffer_size, item->transport, me->base);
if (c == NULL) {
- if (IS_UDP(item->protocol)) {
+ if (IS_UDP(item->transport)) {
fprintf(stderr, "Can't listen for events on UDP socket\n");
exit(1);
} else {
@@ -274,7 +274,7 @@ static int last_thread = 0;
* of an incoming connection.
*/
void dispatch_conn_new(int sfd, enum conn_states init_state, int event_flags,
- int read_buffer_size, enum protocol prot) {
+ int read_buffer_size, enum network_transport transport) {
CQ_ITEM *item = cqi_new();
int tid = last_thread % (settings.num_threads - 1);
@@ -288,7 +288,7 @@ void dispatch_conn_new(int sfd, enum conn_states init_state, int event_flags,
item->init_state = init_state;
item->event_flags = event_flags;
item->read_buffer_size = read_buffer_size;
- item->protocol = prot;
+ item->transport = transport;
cq_push(thread->new_conn_queue, item);