kore

Kore is a web application platform for writing scalable, concurrent web based processes in C or Python.
Commits | Files | Refs | README | LICENSE | git clone https://git.kore.io/kore.git

commit 8a6f4a935eb44c6f96247625b07553ee631cec42
parent 6ac15d37cb418c9c2959e41b9f7deea76d5ec386
Author: Joris Vink <joris@coders.se>
Date:   Thu, 10 Dec 2015 09:26:24 +0100

Set handle function pointer for message callbacks.

Diffstat:
src/msg.c | 2++
1 file changed, 2 insertions(+), 0 deletions(-)

diff --git a/src/msg.c b/src/msg.c @@ -73,6 +73,7 @@ kore_msg_parent_add(struct kore_worker *kw) kw->msg[0]->state = CONN_STATE_ESTABLISHED; kw->msg[0]->hdlr_extra = &kw->id; kw->msg[0]->disconnect = msg_disconnected_worker; + kw->msg[0]->handle = kore_connection_handle; TAILQ_INSERT_TAIL(&connections, kw->msg[0], list); kore_platform_event_all(kw->msg[0]->fd, kw->msg[0]); @@ -102,6 +103,7 @@ kore_msg_worker_init(void) worker->msg[1]->proto = CONN_PROTO_MSG; worker->msg[1]->state = CONN_STATE_ESTABLISHED; worker->msg[1]->disconnect = msg_disconnected_parent; + worker->msg[1]->handle = kore_connection_handle; TAILQ_INSERT_TAIL(&connections, worker->msg[1], list); kore_platform_event_all(worker->msg[1]->fd, worker->msg[1]);