Lines Matching refs:pid
50 pid_t pid;
59 typedef void DeathListener(pid_t pid);
129 /** This peer's PID. */
130 pid_t pid;
133 * Map from pid to peer proxy. The peer has a peer proxy for each remote
195 * which the peer has been connected to. Maps pid to PeerProxy. Helps
231 pid_t* pid = (pid_t*) key;
232 return (int) (*pid);
348 static bool peerIsDead(Peer* peer, pid_t pid) {
355 if (deadPeer == pid) {
368 hashmapRemove(otherPeer->connections, &(deadPeer->credentials.pid));
377 LOGI("Peer %d died. errno: %s", peerProxy->credentials.pid,
380 LOGI("Peer %d died.", peerProxy->credentials.pid);
389 pid_t pid = peerProxy->credentials.pid;
395 = peerProxy->credentials.pid;
402 hashmapRemove(localPeer->peerProxies, &pid);
427 localPeer->onDeath(pid);
601 static PeerProxy* peerProxyGetOrCreate(Peer* peer, pid_t pid,
603 if (pid == peer->pid) {
608 if (peerIsDead(peer, pid)) {
613 PeerProxy* peerProxy = hashmapGet(peer->peerProxies, &pid);
626 credentials.pid = pid;
674 masterProxy->credentials.pid);
685 pid_t pid = header->credentials.pid;
687 PeerProxy* peerProxy = peerProxyGetOrCreate(localPeer, pid, false);
788 peerProxy->credentials.pid);
825 " dead.", peerA->credentials.pid, peerB->credentials.pid);
856 " dead.", peerProxy->credentials.pid, credentials.pid);
873 pid_t targetPid = header->credentials.pid;
898 pid_t pid = header->credentials.pid;
901 peerProxy = hashmapGet(peer->peerProxies, &pid);
905 LOGI("Couldn't connect to %d.", pid);
908 LOGW("Peer proxy for %d not found. This shouldn't happen.", pid);
932 LOGW("Invalid packet type from %d: %d", peerProxy->credentials.pid,
1019 pid_t* pid = &(peerProxy->credentials.pid);
1020 hashmapPut(peer->peerProxies, pid, peerProxy);
1049 credentials.pid = ucredentials.pid;
1053 LOGI("Accepted connection from process %d.", credentials.pid);
1061 = hashmapGet(masterPeer->peerProxies, &credentials.pid);
1064 LOGW("Alread connected to process %d.", credentials.pid);
1112 peer->pid = getpid();
1131 * to EINVAL if pid is the same as the local pid.
1133 int peerSendBytes(pid_t pid, const char* bytes, size_t size) {
1162 PeerProxy* peerProxy = peerProxyGetOrCreate(peer, pid, true);
1198 * to EINVAL if pid is the same as the local pid.
1200 int peerSendSharedBytes(pid_t pid, char* bytes, size_t size,
1237 PeerProxy* peerProxy = peerProxyGetOrCreate(peer, pid, true);
