|
|
@@ -39,6 +39,17 @@ static void dpnode_event_cb(struct bufferevent *bev, short events,
|
|
|
|
|
|
static void dpnode_reader(struct bufferevent *bev, void *ctx)
|
|
|
{
|
|
|
+ struct evbuffer *input = bufferevent_get_input(bev);
|
|
|
+ unsigned int dp[WORDS+6];
|
|
|
+ int num_read = 0;
|
|
|
+
|
|
|
+ while(1) {
|
|
|
+ size_t len = evbuffer_get_length(input);
|
|
|
+ if (len < ((WORDS+6)*sizeof(unsigned int))) break;
|
|
|
+ bufferevent_read(bev, dp, (WORDS+6)*sizeof(unsigned int));
|
|
|
+ ++num_read;
|
|
|
+ }
|
|
|
+ // cerr << num_read << " DPs read\n";
|
|
|
}
|
|
|
|
|
|
static void dpnode_accept_cb(struct evconnlistener *listener,
|