1 #include <dragonnet/recv.h>
7 void dragonnet_recv_raw(DragonnetPeer *p, void *buf, size_t n)
9 pthread_rwlock_rdlock(&p->mu);
11 pthread_rwlock_unlock(&p->mu);
13 ssize_t len = recv(sock, buf, n, MSG_WAITALL);
16 dragonnet_peer_delete(p);
22 pthread_rwlock_wrlock(&p->mu);
28 pthread_rwlock_unlock(&p->mu);