diff options
| author | IOhannes m zmölnig <zmoelnig@users.sourceforge.net> | 2010-03-30 09:46:56 +0000 |
|---|---|---|
| committer | IOhannes m zmölnig <zmoelnig@users.sourceforge.net> | 2010-03-30 09:46:56 +0000 |
| commit | f89ae0b4b20758b0d2e7783a898c045546e19e34 (patch) | |
| tree | a699c3450e9ea905d4de63c86ce1dbdfbb46683d /iemnet_data.c | |
| parent | c4836ce4a969a6493606fe1c136d654c8777d6ec (diff) | |
query queue sizes
with [tcpclient] use [bang(
with [tcpserver] use [client <x>(
svn path=/trunk/externals/iem/iemnet/; revision=13312
Diffstat (limited to 'iemnet_data.c')
| -rw-r--r-- | iemnet_data.c | 10 |
1 files changed, 9 insertions, 1 deletions
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) |