191     Peer* peer;  member
208 static PeerProxy* peerProxyCreate(Peer* peer, Credentials credentials);
255 static void peerLock(Peer* peer) {  in peerLock()  argument
256     pthread_mutex_lock(&peer->mutex);  in peerLock()
260 static void peerUnlock(Peer* peer) {  in peerUnlock()  argument
261     pthread_mutex_unlock(&peer->mutex);  in peerUnlock()
304     Peer* peer = peerProxy->peer;  in peerProxyLockAndEnqueueOutgoingPacket()  local
305     peerLock(peer);  in peerProxyLockAndEnqueueOutgoingPacket()
307     peerUnlock(peer);  in peerProxyLockAndEnqueueOutgoingPacket()
315     Peer* peer = peerProxy->peer;  in peerProxyNextPacket()  local
316     peerLock(peer);  in peerProxyNextPacket()
322         peerUnlock(peer);  in peerProxyNextPacket()
333         peerUnlock(peer);  in peerProxyNextPacket()
336         peerUnlock(peer);  in peerProxyNextPacket()
348 static bool peerIsDead(Peer* peer, pid_t pid) {  in peerIsDead()  argument
351         pid_t deadPeer = peer->deadPeers[i];  in peerIsDead()
388     Peer* localPeer = peerProxy->peer;  in peerProxyKill()
566     peerLock(peerProxy->peer);  in peerProxyBeforeSelect()
568     peerUnlock(peerProxy->peer);  in peerProxyBeforeSelect()
601 static PeerProxy* peerProxyGetOrCreate(Peer* peer, pid_t pid,   in peerProxyGetOrCreate()  argument
603     if (pid == peer->pid) {  in peerProxyGetOrCreate()
608     if (peerIsDead(peer, pid)) {  in peerProxyGetOrCreate()
613     PeerProxy* peerProxy = hashmapGet(peer->peerProxies, &pid);  in peerProxyGetOrCreate()
619     if (peer->master) {  in peerProxyGetOrCreate()
648     peerProxy = peerProxyCreate(peer, credentials);  in peerProxyGetOrCreate()
656             PeerProxy* masterProxy = peer->masterProxy;  in peerProxyGetOrCreate()
681     Peer* localPeer = masterProxy->peer;  in masterProxyExpectConnection()
783         Peer* peer = masterProxy->peer;  in masterProxyAcceptConnection()  local
785         SelectableFd* selectableFd = selectorAdd(peer->selector, incomingFd);  in masterProxyAcceptConnection()
841     peerLock(peerA->peer);  in masterConnectPeers()
844     peerUnlock(peerA->peer);  in masterConnectPeers()
872     Peer* master = peerProxy->peer;  in masterHandleConnectionRequest()
895     Peer* peer = masterProxy->peer;  in masterProxyHandleConnectionError()  local
900     peerLock(peer);  in masterProxyHandleConnectionError()
901     peerProxy = hashmapGet(peer->peerProxies, &pid);  in masterProxyHandleConnectionError()
902     peerUnlock(peer);  in masterProxyHandleConnectionError()
984                 peerProxy->peer->onBytes(peerProxy->credentials,  in peerProxyRead()
999 static PeerProxy* peerProxyCreate(Peer* peer, Credentials credentials) {  in peerProxyCreate()  argument
1011     peerProxy->peer = peer;  in peerProxyCreate()
1020     hashmapPut(peer->peerProxies, pid, peerProxy);  in peerProxyCreate()
1094     Peer* peer = calloc(1, sizeof(Peer));  in peerCreate()  local
1095     if (peer == NULL) {  in peerCreate()
1098     peer->peerProxies = hashmapCreate(10, &pidHash, &pidEquals);  in peerCreate()
1099     peer->selector = selectorCreate();  in peerCreate()
1108     if (pthread_mutex_init(&peer->mutex, &attributes) != 0) {  in peerCreate()
1112     peer->pid = getpid();  in peerCreate()
1113     return peer;  in peerCreate()
1134 	Peer* peer = localPeer;  in peerSendBytes()  local
1135     assert(peer != NULL);  in peerSendBytes()
1160     peerLock(peer);  in peerSendBytes()
1162     PeerProxy* peerProxy = peerProxyGetOrCreate(peer, pid, true);  in peerSendBytes()
1166         peerUnlock(peer);  in peerSendBytes()
1171         peerUnlock(peer);  in peerSendBytes()
1172         selectorWakeUp(peer->selector);  in peerSendBytes()
1202     Peer* peer = localPeer;  in peerSendSharedBytes()  local
1203     assert(peer != NULL);  in peerSendSharedBytes()
1235     peerLock(peer);  in peerSendSharedBytes()
1237     PeerProxy* peerProxy = peerProxyGetOrCreate(peer, pid, true);  in peerSendSharedBytes()
1241         peerUnlock(peer);  in peerSendSharedBytes()
1246         peerUnlock(peer);  in peerSendSharedBytes()
1247         selectorWakeUp(peer->selector);  in peerSendSharedBytes()