From e6c327b9e6f27ca512e2a43b07dac96ebc24d161 Mon Sep 17 00:00:00 2001
From: Per Cederqvist <ceder@lysator.liu.se>
Date: Fri, 1 Aug 2003 13:14:18 +0000
Subject: [PATCH] (write_queue_change_callback): New static function.  Update
 STAT_SEND_QUEUE. (server_init): Register write_queue_change_callback with
 isc.

---
 src/server/ramkomd.c | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

diff --git a/src/server/ramkomd.c b/src/server/ramkomd.c
index fb1709b27..a38959d0d 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);
-- 
GitLab