[sr-dev] git:master:a8adf3bd: evapi: more debug messages when processing received data

Module: kamailio Branch: master Commit: a8adf3bdb74dd3819bb23e2876eee704663f3cef URL: https://github.com/kamailio/kamailio/commit/a8adf3bdb74dd3819bb23e2876eee70… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2015-09-19T00:16:22+02:00 evapi: more debug messages when processing received data --- Modified: modules/evapi/evapi_dispatch.c --- Diff: https://github.com/kamailio/kamailio/commit/a8adf3bdb74dd3819bb23e2876eee70… Patch: https://github.com/kamailio/kamailio/commit/a8adf3bdb74dd3819bb23e2876eee70… --- diff --git a/modules/evapi/evapi_dispatch.c b/modules/evapi/evapi_dispatch.c index 2da4ed4..fd6ad6c 100644 --- a/modules/evapi/evapi_dispatch.c +++ b/modules/evapi/evapi_dispatch.c @@ -284,9 +284,10 @@ void evapi_recv_client(struct ev_loop *loop, struct ev_io *watcher, int revents) _evapi_clients[i].rbuffer[_evapi_clients[i].rpos+rlen] = '\0'; - LM_NOTICE("{%d} [%s:%d] - received [%.*s]\n", + LM_NOTICE("{%d} [%s:%d] - received [%.*s] (%d) (%d)\n", i, _evapi_clients[i].src_addr, _evapi_clients[i].src_port, - (int)rlen, _evapi_clients[i].rbuffer+_evapi_clients[i].rpos); + (int)rlen, _evapi_clients[i].rbuffer+_evapi_clients[i].rpos, + (int)rlen, (int)_evapi_clients[i].rpos); evenv.conidx = i; evenv.eset = 1; if(_evapi_netstring_format) { @@ -304,6 +305,7 @@ void evapi_recv_client(struct ev_loop *loop, struct ev_io *watcher, int revents) } if(k==_evapi_clients[i].rpos+rlen) { _evapi_clients[i].rpos = 0; + LM_DBG("empty content\n"); return; } /* pointer to start of whole frame */ @@ -316,6 +318,10 @@ void evapi_recv_client(struct ev_loop *loop, struct ev_io *watcher, int revents) break; /* invalid character - discard the rest */ _evapi_clients[i].rpos = 0; + LM_DBG("invalid char when searching for size [%c] [%.*s] (%d) (%d)\n", + _evapi_clients[i].rbuffer[k], + (int)(_evapi_clients[i].rpos+rlen), _evapi_clients[i].rbuffer, + (int)(_evapi_clients[i].rpos+rlen), k); return; } k++; @@ -329,6 +335,7 @@ void evapi_recv_client(struct ev_loop *loop, struct ev_io *watcher, int revents) efp = _evapi_clients[i].rbuffer + _evapi_clients[i].rpos + rlen; if(efp<=sfp) { _evapi_clients[i].rpos = 0; + LM_DBG("weird - invalid size for residual data\n"); return; } _evapi_clients[i].rpos = (unsigned int)(efp-sfp); @@ -339,12 +346,17 @@ void evapi_recv_client(struct ev_loop *loop, struct ev_io *watcher, int revents) _evapi_clients[i].rbuffer[k] = sfp[k]; } } + LM_DBG("residual data [%.*s] (%d)\n", + _evapi_clients[i].rpos, _evapi_clients[i].rbuffer, + _evapi_clients[i].rpos); return; } k++; frame.s = _evapi_clients[i].rbuffer + k; if(frame.s[frame.len]!=',') { /* invalid data - discard and reset buffer */ + LM_DBG("frame size mismatch the ending char (%c): [%.*s] (%d)\n", + frame.s[frame.len], frame.len, frame.s, frame.len); _evapi_clients[i].rpos = 0 ; return; }