diff --git a/src/server/ramkomd.c b/src/server/ramkomd.c index fb1709b270f18a05c9adbe58c7a2a91364c08b9a..a38959d0d2b4b67d09f46e731355f991cc582b25 100644 --- a/src/server/ramkomd.c +++ b/src/server/ramkomd.c @@ -1,5 +1,5 @@ /* - * $Id: ramkomd.c,v 0.120 2003/07/31 23:02:47 ceder Exp $ + * $Id: ramkomd.c,v 0.121 2003/08/01 13:14:18 ceder Exp $ * Copyright (C) 1991-1999, 2001-2002 Lysator Academic Computer Association. * * This file is part of the LysKOM server. @@ -157,6 +157,15 @@ set_handler_sig_ign(struct sigaction *ptr) #endif +static isc_write_queue_change_cb write_queue_change_callback; + +static void +write_queue_change_callback(int delta) +{ + update_stat(STAT_SEND_QUEUE, delta); +} + + static void server_init(const char *host, const char * client_port) { @@ -216,7 +225,8 @@ server_init(const char *host, const char * client_port) &isc_realloc_wrapper, &isc_free_wrapper); - kom_server_mcb = isc_initialize(oop_sys_source(kom_server_oop_src)); + kom_server_mcb = isc_initialize(oop_sys_source(kom_server_oop_src), + write_queue_change_callback); if ( kom_server_mcb == NULL ) restart_kom("server_init: can't isc_initialize()\n"); isc_cfg_fd_relocate(kom_server_mcb, PROTECTED_FDS);