From f89ae0b4b20758b0d2e7783a898c045546e19e34 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?IOhannes=20m=20zm=C3=B6lnig?=
 <zmoelnig@users.sourceforge.net>
Date: Tue, 30 Mar 2010 09:46:56 +0000
Subject: query queue sizes

with [tcpclient] use [bang(
with [tcpserver] use [client <x>(

svn path=/trunk/externals/iem/iemnet/; revision=13312
---
 iemnet_data.c | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

(limited to 'iemnet_data.c')

diff --git a/iemnet_data.c b/iemnet_data.c
index ce19693..5dc7ee5 100644
--- a/iemnet_data.c
+++ b/iemnet_data.c
@@ -296,7 +296,15 @@ t_iemnet_chunk* queue_pop(t_iemnet_queue* const _this) {
   return queue_pop_block(_this);
 }
 
-
+int queue_getsize(t_iemnet_queue* const _this) {
+  int size=-1;
+  if(_this) {
+    pthread_mutex_lock(&_this->mtx);
+    size=_this->size;
+    pthread_mutex_unlock(&_this->mtx);
+  }
+  return size;
+}
 void queue_finish(t_iemnet_queue* q) {
   DEBUG("queue_finish: %x", q);
   if(NULL==q) 
-- 
cgit v1.2.1