stv0g/libnl
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

cache_mngr: Let nl_cache_mngr_data_ready() read multiple messages

Browse source 
Having nl_recvmsgs() return the number of read messages allows
to continue reading until the underlying recvmsg() will return
EAGAIN for the non blocking socket.
This commit is contained in:
Thomas Graf 2012-04-21 12:47:29 +02:00
parent e0482794a8
commit a518a318d4
1 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
lib/cache_mngr.c
View file

@ -324,7 +324,7 @@ int nl_cache_mngr_poll(struct nl_cache_mngr *mngr, int timeout)
*/
int nl_cache_mngr_data_ready(struct nl_cache_mngr *mngr)
{
int err;
int err, nread = 0;
struct nl_cb *cb;
NL_DBG(2, "Cache manager %p, reading new data from fd %d\n",
@ -336,12 +336,17 @@ int nl_cache_mngr_data_ready(struct nl_cache_mngr *mngr)
nl_cb_set(cb, NL_CB_VALID, NL_CB_CUSTOM, event_input, mngr);
err = nl_recvmsgs(mngr->cm_sock, cb);
while ((err = nl_recvmsgs(mngr->cm_sock, cb)) > 0) {
NL_DBG(2, "Cache manager %p, recvmsgs read %d messages\n",
mngr, err);
nread += err;
}
nl_cb_put(cb);
if (err < 0)
return err;
return 1;
return nread;
}
/**