4 #include <dragonnet/recv.h>
6 void dragonnet_recv_raw(DragonnetPeer *p, void *buf, size_t n)
8 pthread_rwlock_rdlock(&p->mu);
10 pthread_rwlock_unlock(&p->mu);
12 ssize_t len = recv(sock, buf, n, MSG_WAITALL);
15 dragonnet_peer_delete(p);
21 pthread_rwlock_wrlock(&p->mu);
27 pthread_rwlock_unlock(&p->mu);