sockfd 136 coordinatorapi.cpp JASSERT(coordAPI._coordinatorSocket.sockfd() != PROTECTED_COORD_FD);
sockfd 551 coordinatorapi.cpp JASSERT(getpeername(_coordinatorSocket.sockfd(),
sockfd 608 coordinatorapi.cpp JASSERT(getpeername(_coordinatorSocket.sockfd(),
sockfd 658 coordinatorapi.cpp if (_nsSock.sockfd() == -1) {
sockfd 962 dmtcp_coordinator.cpp JTRACE("accepting new connection") (remote.sockfd()) (JASSERT_ERRNO);
sockfd 1098 dmtcp_coordinator.cpp blockUntilDoneRemote = remote.sockfd();
sockfd 1671 dmtcp_coordinator.cpp JASSERT(epoll_ctl(epollFd, EPOLL_CTL_ADD, listenSock->sockfd(), &ev) != -1)
sockfd 1751 dmtcp_coordinator.cpp JASSERT(epoll_ctl(epollFd, EPOLL_CTL_ADD, client->sock().sockfd(), &ev) != -1)
sockfd 382 miscwrappers.cpp SYSCALL_GET_ARGS_3(int,sockfd,const struct sockaddr*,addr,socklen_t,addrlen);
sockfd 383 miscwrappers.cpp ret = connect(sockfd, addr, addrlen);
sockfd 388 miscwrappers.cpp SYSCALL_GET_ARGS_3(int,sockfd,const struct sockaddr*,addr,socklen_t,addrlen);
sockfd 389 miscwrappers.cpp ret = bind(sockfd,addr,addrlen);
sockfd 394 miscwrappers.cpp SYSCALL_GET_ARGS_2(int,sockfd,int,backlog);
sockfd 395 miscwrappers.cpp ret = listen(sockfd,backlog);
sockfd 400 miscwrappers.cpp SYSCALL_GET_ARGS_3(int,sockfd,struct sockaddr*,addr,socklen_t*,addrlen);
sockfd 401 miscwrappers.cpp ret = accept(sockfd, addr, addrlen);
sockfd 407 miscwrappers.cpp SYSCALL_GET_ARGS_4(int,sockfd,struct sockaddr*,addr,socklen_t*,addrlen,int,flags);
sockfd 408 miscwrappers.cpp ret = accept4(sockfd, addr, addrlen, flags);
sockfd 143 nosyscallsreal.c int _real_connect (int sockfd, const struct sockaddr *serv_addr, socklen_t addrlen)
sockfd 145 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (connect) (sockfd,serv_addr,addrlen);
sockfd 149 nosyscallsreal.c int _real_bind (int sockfd, const struct sockaddr *my_addr, socklen_t addrlen)
sockfd 151 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (bind) (sockfd,my_addr,addrlen);
sockfd 155 nosyscallsreal.c int _real_listen (int sockfd, int backlog)
sockfd 157 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (listen) (sockfd,backlog);
sockfd 161 nosyscallsreal.c int _real_accept (int sockfd, struct sockaddr *addr, socklen_t *addrlen)
sockfd 163 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (accept) (sockfd,addr,addrlen);
sockfd 43 plugin/ipc/socket/connectionrewirer.cpp static void markSocketNonBlocking(int sockfd)
sockfd 46 plugin/ipc/socket/connectionrewirer.cpp int flags = _real_fcntl(sockfd, F_GETFL, NULL);
sockfd 48 plugin/ipc/socket/connectionrewirer.cpp JASSERT(_real_fcntl(sockfd, F_SETFL,
sockfd 52 plugin/ipc/socket/connectionrewirer.cpp static void markSocketBlocking(int sockfd)
sockfd 55 plugin/ipc/socket/connectionrewirer.cpp int flags = _real_fcntl(sockfd, F_GETFL, NULL);
sockfd 57 plugin/ipc/socket/connectionrewirer.cpp JASSERT(_real_fcntl(sockfd, F_SETFL,
sockfd 173 plugin/ipc/socket/connectionrewirer.cpp JTRACE("opened listen socket") (restoreSocket.sockfd())
sockfd 61 plugin/ipc/socket/kernelbufferdrainer.cpp JWARNING(false) (sock.sockfd())
sockfd 69 plugin/ipc/socket/kernelbufferdrainer.cpp vector<char>& buffer = _drainedData[sock->socket().sockfd() ];
sockfd 81 plugin/ipc/socket/kernelbufferdrainer.cpp fd = sock->socket().sockfd();
sockfd 99 plugin/ipc/socket/kernelbufferdrainer.cpp vector<char>& buffer = _drainedData[_dataSockets[i]->socket().sockfd() ];
sockfd 105 plugin/ipc/socket/kernelbufferdrainer.cpp JTRACE("buffer drain complete") (_dataSockets[i]->socket().sockfd())
sockfd 123 plugin/ipc/socket/kernelbufferdrainer.cpp vector<char>& buffer = _drainedData[_dataSockets[i]->socket().sockfd() ];
sockfd 124 plugin/ipc/socket/kernelbufferdrainer.cpp JWARNING(false) (_dataSockets[i]->socket().sockfd())
sockfd 132 plugin/ipc/socket/kernelbufferdrainer.cpp _real_close(_dataSockets[i]->socket().sockfd());
sockfd 141 plugin/ipc/socket/kernelbufferdrainer.cpp _real_dup2(sp[0], _dataSockets[i]->socket().sockfd());
sockfd 181 plugin/ipc/socket/kernelbufferdrainer.cpp JTRACE("requesting repeat buffer...") (sock.sockfd()) (size);
sockfd 680 plugin/ipc/socket/socketconnection.cpp int sockfd = _real_socket(_sockDomain,_sockType,_sockProtocol);
sockfd 681 plugin/ipc/socket/socketconnection.cpp JASSERT(sockfd != -1);
sockfd 682 plugin/ipc/socket/socketconnection.cpp Util::dupFds(sockfd, _fds);
sockfd 73 plugin/ipc/socket/socketwrappers.cpp extern "C" int connect(int sockfd, const struct sockaddr *serv_addr,
sockfd 77 plugin/ipc/socket/socketwrappers.cpp int ret = _real_connect(sockfd,serv_addr,addrlen);
sockfd 87 plugin/ipc/socket/socketwrappers.cpp FD_SET(sockfd, &wfds);
sockfd 92 plugin/ipc/socket/socketwrappers.cpp retval = select(sockfd+1, NULL, &wfds, NULL, &tv);
sockfd 97 plugin/ipc/socket/socketwrappers.cpp else if (FD_ISSET(sockfd, &wfds))
sockfd 101 plugin/ipc/socket/socketwrappers.cpp getsockopt(sockfd,SOL_SOCKET,SO_ERROR,&val,&sz);
sockfd 110 plugin/ipc/socket/socketwrappers.cpp (TcpConnection*) SocketConnList::instance().getConnection(sockfd);
sockfd 117 plugin/ipc/socket/socketwrappers.cpp JTRACE("connected, sending 1-way handshake") (sockfd) (con->id());
sockfd 118 plugin/ipc/socket/socketwrappers.cpp con->sendHandshake(sockfd, DmtcpWorker::instance().coordinatorId());
sockfd 121 plugin/ipc/socket/socketwrappers.cpp JTRACE("connected") (sockfd) (con->id());
sockfd 129 plugin/ipc/socket/socketwrappers.cpp extern "C" int bind(int sockfd, const struct sockaddr *my_addr,
sockfd 133 plugin/ipc/socket/socketwrappers.cpp int ret = _real_bind(sockfd, my_addr, addrlen);
sockfd 136 plugin/ipc/socket/socketwrappers.cpp (TcpConnection*) SocketConnList::instance().getConnection(sockfd);
sockfd 141 plugin/ipc/socket/socketwrappers.cpp JTRACE("bind") (sockfd) (con->id());
sockfd 148 plugin/ipc/socket/socketwrappers.cpp extern "C" int listen(int sockfd, int backlog)
sockfd 151 plugin/ipc/socket/socketwrappers.cpp int ret = _real_listen(sockfd, backlog);
sockfd 154 plugin/ipc/socket/socketwrappers.cpp (TcpConnection*) SocketConnList::instance().getConnection(sockfd);
sockfd 159 plugin/ipc/socket/socketwrappers.cpp JTRACE("listen") (sockfd) (con->id()) (backlog);
sockfd 166 plugin/ipc/socket/socketwrappers.cpp static void process_accept(int ret, int sockfd, struct sockaddr *addr,
sockfd 171 plugin/ipc/socket/socketwrappers.cpp (TcpConnection*) SocketConnList::instance().getConnection(sockfd);
sockfd 180 plugin/ipc/socket/socketwrappers.cpp JTRACE("accepted, waiting for 1-way handshake") (sockfd) (con->id());
sockfd 184 plugin/ipc/socket/socketwrappers.cpp JTRACE("accepted incoming connection") (sockfd) (con->id());
sockfd 188 plugin/ipc/socket/socketwrappers.cpp extern "C" int accept(int sockfd, struct sockaddr *addr,
sockfd 207 plugin/ipc/socket/socketwrappers.cpp int ret = _real_accept(sockfd, addr, addrlen);
sockfd 209 plugin/ipc/socket/socketwrappers.cpp process_accept(ret, sockfd, addr, addrlen);
sockfd 214 plugin/ipc/socket/socketwrappers.cpp extern "C" int accept4(int sockfd, struct sockaddr *addr,
sockfd 225 plugin/ipc/socket/socketwrappers.cpp int ret = _real_accept4(sockfd, addr, addrlen, flags);
sockfd 227 plugin/ipc/socket/socketwrappers.cpp process_accept(ret, sockfd, addr, addrlen);
sockfd 232 plugin/ipc/socket/socketwrappers.cpp extern "C" int setsockopt(int sockfd, int level, int optname,
sockfd 235 plugin/ipc/socket/socketwrappers.cpp int ret = _real_setsockopt(sockfd, level, optname, optval, optlen);
sockfd 237 plugin/ipc/socket/socketwrappers.cpp JTRACE("setsockopt") (ret) (sockfd) (optname);
sockfd 239 plugin/ipc/socket/socketwrappers.cpp (TcpConnection*) SocketConnList::instance().getConnection(sockfd);
sockfd 249 plugin/ipc/socket/socketwrappers.cpp extern "C" int getsockopt(int sockfd, int level, int optname,
sockfd 259 plugin/ipc/socket/socketwrappers.cpp int ret = _real_getsockopt(sockfd, level, optname, optval, optlen);
sockfd 260 plugin/ipc/socket/socketwrappers.cpp PASSTHROUGH_DMTCP_HELPER(getsockopt,sockfd,level,optname,optval,optlen);
sockfd 22 plugin/ipc/ssh/sshdrainer.cpp vector<char>& buffer = _drainedData[sock->socket().sockfd() ];
sockfd 34 plugin/ipc/ssh/sshdrainer.cpp fd = sock->socket().sockfd();
sockfd 49 plugin/ipc/ssh/sshdrainer.cpp vector<char>& buffer = _drainedData[_dataSockets[i]->socket().sockfd()];
sockfd 55 plugin/ipc/ssh/sshdrainer.cpp JTRACE("buffer drain complete") (_dataSockets[i]->socket().sockfd())
sockfd 73 plugin/ipc/ssh/sshdrainer.cpp vector<char>& buffer = _drainedData[_dataSockets[i]->socket().sockfd()];
sockfd 74 plugin/ipc/ssh/sshdrainer.cpp JWARNING(false) (_dataSockets[i]->socket().sockfd())
sockfd 532 syscallsreal.c int _real_connect (int sockfd, const struct sockaddr *serv_addr,
sockfd 535 syscallsreal.c REAL_FUNC_PASSTHROUGH (connect) (sockfd,serv_addr,addrlen);
sockfd 539 syscallsreal.c int _real_bind (int sockfd, const struct sockaddr *my_addr,
sockfd 542 syscallsreal.c REAL_FUNC_PASSTHROUGH (bind) (sockfd,my_addr,addrlen);
sockfd 546 syscallsreal.c int _real_listen (int sockfd, int backlog)
sockfd 548 syscallsreal.c REAL_FUNC_PASSTHROUGH (listen) (sockfd,backlog);
sockfd 552 syscallsreal.c int _real_accept (int sockfd, struct sockaddr *addr, socklen_t *addrlen)
sockfd 554 syscallsreal.c REAL_FUNC_PASSTHROUGH (accept) (sockfd,addr,addrlen);
sockfd 558 syscallsreal.c int _real_accept4 (int sockfd, struct sockaddr *addr, socklen_t *addrlen,
sockfd 561 syscallsreal.c REAL_FUNC_PASSTHROUGH (accept4) (sockfd,addr,addrlen,flags);
sockfd 290 syscallwrappers.h int _real_connect (int sockfd, const struct sockaddr *serv_addr,
sockfd 292 syscallwrappers.h int _real_bind (int sockfd, const struct sockaddr *my_addr,
sockfd 294 syscallwrappers.h int _real_listen (int sockfd, int backlog);
sockfd 295 syscallwrappers.h int _real_accept (int sockfd, struct sockaddr *addr, socklen_t *addrlen);
sockfd 296 syscallwrappers.h int _real_accept4 (int sockfd, struct sockaddr *addr, socklen_t *addrlen,