*
* This check should may be different.
*/
- if (connection_outbuf_too_full(conn->outbuf))
+ if (connection_outbuf_too_full(conn))
return 0;
n = decompress_buf_to_buf(
}
log(LOG_DEBUG,"connection_package_raw_inbuf(): receive_topicwindow at AP is %d",conn->p_receive_topicwindow);
}
- if (conn->inbuf_datalen) {
- log(LOG_DEBUG,"connection_package_raw_inbuf(): recursing.");
- goto repeat_connection_package_raw_inbuf;
- }
- return 0;
+ /* handle more if there's more, or return 0 if there isn't */
+ goto repeat_connection_package_raw_inbuf;
}
int connection_consider_sending_sendme(connection_t *conn, int edge_type) {