Lines Matching defs:localPeer
388 Peer* localPeer = peerProxy->peer;
391 peerLock(localPeer);
394 localPeer->deadPeers[localPeer->deadPeerCursor]
396 localPeer->deadPeerCursor++;
397 if (localPeer->deadPeerCursor == PEER_HISTORY) {
398 localPeer->deadPeerCursor = 0;
402 hashmapRemove(localPeer->peerProxies, &pid);
406 peerUnlock(localPeer);
427 localPeer->onDeath(pid);
681 Peer* localPeer = masterProxy->peer;
686 peerLock(localPeer);
687 PeerProxy* peerProxy = peerProxyGetOrCreate(localPeer, pid, false);
694 peerUnlock(localPeer);
1117 static Peer* localPeer;
1134 Peer* peer = localPeer;
1202 Peer* peer = localPeer;
1285 if (localPeer != NULL) {
1288 localPeer = peerCreate();
1289 if (localPeer == NULL) {
1292 localPeer->master = true;
1293 localPeer->onBytes = bytesListener;
1294 localPeer->onDeath = deathListener;
1297 SelectableFd* listenerFd = selectorAdd(localPeer->selector, listenerSocket);
1301 listenerFd->data = localPeer;
1324 if (localPeer != NULL) {
1327 localPeer = peerCreate();
1328 if (localPeer == NULL) {
1331 localPeer->onBytes = bytesListener;
1332 localPeer->onDeath = deathListener;
1335 SelectableFd* masterFd = selectorAdd(localPeer->selector, masterSocket);
1341 PeerProxy* masterProxy = peerProxyCreate(localPeer, MASTER_CREDENTIALS);
1347 localPeer->masterProxy = masterProxy;
1352 assert(localPeer != NULL);
1355 selectorLoop(localPeer->selector);