commit 67bfdd456634b02c1b9b40de5f04f4abdd62c478 from: Omar Polo date: Tue Jul 27 21:50:30 2021 UTC adding various debugging printfs... commit - 9d5307de032e08526cf1b18917dfe99e5e5063d9 commit + 67bfdd456634b02c1b9b40de5f04f4abdd62c478 blob - 448a30005ad02587f71182494b6051d60a744763 blob + d00caae9f2f1169c853129fc485a5e1ece543397 --- listener.c +++ listener.c @@ -377,8 +377,8 @@ listener_dispatch_main(int fd, short event, void *d) * to never stop reading/writing; probably to * be revisited. */ - bufferevent_setwatermark(client->bev, EV_READ|EV_WRITE, - sizeof(struct np_msg_header), 0); + /* bufferevent_setwatermark(client->bev, EV_READ|EV_WRITE, */ + /* sizeof(struct np_msg_header), 0); */ bufferevent_enable(client->bev, EV_READ|EV_WRITE); break; @@ -669,17 +669,26 @@ client_read(struct bufferevent *bev, void *d) struct client *client = d; struct evbuffer *src = EVBUFFER_INPUT(bev); uint32_t len; + + log_debug("in client read"); for (;;) { + log_debug("buffer length %zu < 4? %s", EVBUFFER_LENGTH(src), + EVBUFFER_LENGTH(src) < 4 ? "true" : "false"); if (EVBUFFER_LENGTH(src) < 4) return; memcpy(&len, EVBUFFER_DATA(src), sizeof(len)); + log_debug("raw msg len=%"PRIu32, len); len = le32toh(len); + log_debug("msg len=%"PRIu32, len); + log_debug("%zu > %zu? %s", (size_t)len, EVBUFFER_LENGTH(src), + len > EVBUFFER_LENGTH(src) ? "true" : "false"); if (len > EVBUFFER_LENGTH(src)) return; + log_debug("forwarding a message"); listener_imsg_compose_client(client, IMSG_BUF, client->id, EVBUFFER_DATA(src), len); evbuffer_drain(src, len);