_fds 40 plugin/ipc/connection.cpp _fds.push_back(fd);
_fds 45 plugin/ipc/connection.cpp JASSERT(_fds.size() > 0);
_fds 46 plugin/ipc/connection.cpp if (_fds.size() == 1) {
_fds 47 plugin/ipc/connection.cpp JASSERT(_fds[0] == fd);
_fds 48 plugin/ipc/connection.cpp _fds.clear();
_fds 50 plugin/ipc/connection.cpp for (size_t i = 0; i < _fds.size(); i++) {
_fds 51 plugin/ipc/connection.cpp if (_fds[i] == fd) {
_fds 52 plugin/ipc/connection.cpp _fds.erase(_fds.begin() + i);
_fds 62 plugin/ipc/connection.cpp _fcntlFlags = fcntl(_fds[0],F_GETFL);
_fds 63 plugin/ipc/connection.cpp JASSERT(_fcntlFlags >= 0) (_fds[0]) (_fcntlFlags) (_type) (JASSERT_ERRNO);
_fds 65 plugin/ipc/connection.cpp _fcntlOwner = fcntl(_fds[0],F_GETOWN);
_fds 68 plugin/ipc/connection.cpp _fcntlSignal = fcntl(_fds[0],F_GETSIG);
_fds 79 plugin/ipc/connection.cpp JASSERT(fcntl(_fds[0], F_SETFL, (int)_fcntlFlags) == 0)
_fds 80 plugin/ipc/connection.cpp (_fds[0]) (_fcntlFlags) (JASSERT_ERRNO);
_fds 83 plugin/ipc/connection.cpp JASSERT(fcntl(_fds[0], F_SETOWN, (int)_fcntlOwner) == 0)
_fds 84 plugin/ipc/connection.cpp (_fds[0]) (_fcntlOwner) (JASSERT_ERRNO);
_fds 93 plugin/ipc/connection.cpp JASSERT(fcntl(_fds[0], F_SETSIG, (int)_fcntlSignal) == 0)
_fds 94 plugin/ipc/connection.cpp (_fds[0]) (_fcntlSignal) (JASSERT_ERRNO);
_fds 101 plugin/ipc/connection.cpp JASSERT(fcntl(_fds[0], F_SETOWN, getpid()) == 0)
_fds 102 plugin/ipc/connection.cpp (_fds[0]) (JASSERT_ERRNO);
_fds 107 plugin/ipc/connection.cpp pid_t pid = fcntl(_fds[0], F_GETOWN);
_fds 116 plugin/ipc/connection.cpp o.serializeVector(_fds);
_fds 73 plugin/ipc/connection.h uint32_t numFds() const { return _fds.size(); }
_fds 74 plugin/ipc/connection.h const vector<int32_t>& getFds() const { return _fds; }
_fds 109 plugin/ipc/connection.h vector<int32_t> _fds;
_fds 53 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 58 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 64 plugin/ipc/event/eventconnection.cpp int ret = _real_epoll_ctl(_fds[0], EPOLL_CTL_ADD, fevt->first,
_fds 66 plugin/ipc/event/eventconnection.cpp JWARNING(ret == 0) (_fds[0]) (ret) (strerror(errno))
_fds 74 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size()>0);
_fds 75 plugin/ipc/event/eventconnection.cpp JTRACE("Recreating epoll connection") (_fds[0]) (id());
_fds 78 plugin/ipc/event/eventconnection.cpp Util::dupFds(tempFd, _fds);
_fds 117 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 118 plugin/ipc/event/eventconnection.cpp JTRACE("Checkpoint eventfd.") (_fds[0]);
_fds 121 plugin/ipc/event/eventconnection.cpp int evtfd = _fds[0];
_fds 151 plugin/ipc/event/eventconnection.cpp JTRACE("Checkpointing eventfd: end.") (_fds[0]) (_initval);
_fds 156 plugin/ipc/event/eventconnection.cpp JTRACE("Begin refill eventfd.") (_fds[0]);
_fds 157 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 158 plugin/ipc/event/eventconnection.cpp evtfd = _fds[0];
_fds 166 plugin/ipc/event/eventconnection.cpp JTRACE("End refill eventfd.") (_fds[0]);
_fds 171 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 177 plugin/ipc/event/eventconnection.cpp Util::dupFds(tempfd, _fds);
_fds 194 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 196 plugin/ipc/event/eventconnection.cpp JTRACE("Checkpoint signalfd.") (_fds[0]);
_fds 199 plugin/ipc/event/eventconnection.cpp signlfd = _fds[0];
_fds 217 plugin/ipc/event/eventconnection.cpp JTRACE("Checkpointing signlfd: end.") (_fds[0]) ;
_fds 222 plugin/ipc/event/eventconnection.cpp JTRACE("Begin refill signalfd.") (_fds[0]);
_fds 223 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 227 plugin/ipc/event/eventconnection.cpp JTRACE("End refill signalfd.") (_fds[0]);
_fds 232 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 238 plugin/ipc/event/eventconnection.cpp Util::dupFds(tempfd, _fds);
_fds 255 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 260 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
_fds 269 plugin/ipc/event/eventconnection.cpp JTRACE("inotify restoreOptions") (_fds[0]) (id()) (num_of_descriptors);
_fds 297 plugin/ipc/event/eventconnection.cpp Util::dupFds(tempfd, _fds);
_fds 303 plugin/ipc/file/fileconnection.cpp numRead = ptmxReadAll(_fds[0], buf, maxCount);
_fds 304 plugin/ipc/file/fileconnection.cpp _ptmxIsPacketMode = ptmxTestPacketMode(_fds[0]);
_fds 305 plugin/ipc/file/fileconnection.cpp JTRACE("_fds[0] is master(/dev/ptmx)") (_fds[0]) (_ptmxIsPacketMode);
_fds 306 plugin/ipc/file/fileconnection.cpp numWritten = ptmxWriteAll(_fds[0], buf, _ptmxIsPacketMode);
_fds 310 plugin/ipc/file/fileconnection.cpp if (tcgetpgrp(_fds[0]) != -1) {
_fds 325 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring PTY slave") (_fds[0]) (_ptsName) (_virtPtsName);
_fds 343 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring PTS real") (_ptsName) (_virtPtsName) (_fds[0]);
_fds 344 plugin/ipc/file/fileconnection.cpp Util::dupFds(tempfd, _fds);
_fds 363 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring /dev/tty for the process") (_fds[0]);
_fds 365 plugin/ipc/file/fileconnection.cpp Util::dupFds(tempfd, _fds);
_fds 371 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
_fds 427 plugin/ipc/file/fileconnection.cpp (controllingTty) (_fds[0]);
_fds 452 plugin/ipc/file/fileconnection.cpp ioctl(_fds[0], TIOCPKT, &packetMode); /* Restore old packet mode */
_fds 455 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring /dev/ptmx") (_fds[0]) (_ptsName) (_virtPtsName);
_fds 460 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring BSD Master Pty") (_masterName) (_fds[0]);
_fds 484 plugin/ipc/file/fileconnection.cpp Util::dupFds(tempfd, _fds);
_fds 534 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
_fds 539 plugin/ipc/file/fileconnection.cpp _offset = lseek(_fds[0], 0, SEEK_CUR);
_fds 540 plugin/ipc/file/fileconnection.cpp fstat(_fds[0], &statbuf);
_fds 558 plugin/ipc/file/fileconnection.cpp _path = jalib::Filesystem::GetDeviceName(_fds[0]);
_fds 568 plugin/ipc/file/fileconnection.cpp JTRACE("Pre-checkpoint Torque files") (_fds.size());
_fds 569 plugin/ipc/file/fileconnection.cpp for (unsigned int i=0; i< _fds.size(); i++)
_fds 570 plugin/ipc/file/fileconnection.cpp JTRACE("_fds[i]=") (i) (_fds[i]);
_fds 635 plugin/ipc/file/fileconnection.cpp writeFileFromFd(_fds[0], destFd);
_fds 657 plugin/ipc/file/fileconnection.cpp if (!areFilesEqual(_fds[0], savedFd, _st_size)) {
_fds 701 plugin/ipc/file/fileconnection.cpp Util::dupFds(tempfd, _fds);
_fds 708 plugin/ipc/file/fileconnection.cpp JASSERT(lseek(_fds[0], _offset, SEEK_SET) == _offset)
_fds 742 plugin/ipc/file/fileconnection.cpp string newpath = jalib::Filesystem::GetDeviceName(_fds[0]);
_fds 743 plugin/ipc/file/fileconnection.cpp JTRACE("This is Resource Manager file!") (_fds[0]) (newpath) (_path) (this);
_fds 789 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
_fds 833 plugin/ipc/file/fileconnection.cpp Util::dupFds(tempfd, _fds);
_fds 840 plugin/ipc/file/fileconnection.cpp int myfd = _fds[0];
_fds 947 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
_fds 950 plugin/ipc/file/fileconnection.cpp JTRACE("Checkpoint fifo.") (_fds[0]);
_fds 972 plugin/ipc/file/fileconnection.cpp JTRACE("Checkpointing fifo: end.") (_fds[0]) (_in_data.size());
_fds 990 plugin/ipc/file/fileconnection.cpp JASSERT(ret ==(ssize_t)j) (JASSERT_ERRNO) (ret) (j) (_fds[0]) (i);
_fds 1000 plugin/ipc/file/fileconnection.cpp JASSERT(ret ==(ssize_t)j) (JASSERT_ERRNO) (ret) (j) (_fds[0]);
_fds 1004 plugin/ipc/file/fileconnection.cpp flock(_fds[0],LOCK_UN);
_fds 1005 plugin/ipc/file/fileconnection.cpp JTRACE("End checkpointing fifo.") (_fds[0]);
_fds 1024 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
_fds 1028 plugin/ipc/file/fileconnection.cpp Util::dupFds(tempfd, _fds);
_fds 1065 plugin/ipc/file/fileconnection.cpp for (size_t i=0; i<_fds.size(); ++i) {
_fds 1066 plugin/ipc/file/fileconnection.cpp int fd = _fds[i];
_fds 1113 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
_fds 1115 plugin/ipc/file/fileconnection.cpp JTRACE("Checkpoint Posix Message Queue.") (_fds[0]);
_fds 1118 plugin/ipc/file/fileconnection.cpp JASSERT(fstat(_fds[0], &statbuf) != -1) (JASSERT_ERRNO);
_fds 1124 plugin/ipc/file/fileconnection.cpp JASSERT(mq_getattr(_fds[0], &attr) != -1) (JASSERT_ERRNO);
_fds 1137 plugin/ipc/file/fileconnection.cpp ssize_t numBytes = _real_mq_receive(_fds[0], buf, attr.mq_msgsize, &prio);
_fds 1149 plugin/ipc/file/fileconnection.cpp JASSERT(_real_mq_send(_fds[0], _msgInQueue[i].buffer(),
_fds 1158 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
_fds 1167 plugin/ipc/file/fileconnection.cpp Util::dupFds(tempfd, _fds);
_fds 291 plugin/ipc/socket/socketconnection.cpp JASSERT(getsockname(_fds[0], (struct sockaddr *)&_bindAddr, &_bindAddrlen) == 0)
_fds 360 plugin/ipc/socket/socketconnection.cpp JTRACE("Creating dead socket.") (_fds[0]) (_fds.size());
_fds 363 plugin/ipc/socket/socketconnection.cpp Util::dupFds(_makeDeadSocket(&buffer[0], buffer.size()), _fds);
_fds 368 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0) (id());
_fds 372 plugin/ipc/socket/socketconnection.cpp JTRACE("Removing O_ASYNC flag during checkpoint.") (_fds[0]) (id());
_fds 375 plugin/ipc/socket/socketconnection.cpp JASSERT(fcntl(_fds[0],F_SETFL,_fcntlFlags & ~O_ASYNC) == 0)
_fds 376 plugin/ipc/socket/socketconnection.cpp (JASSERT_ERRNO) (_fds[0]) (id());
_fds 389 plugin/ipc/socket/socketconnection.cpp JTRACE("Will drain socket") (_hasLock) (_fds[0]) (_id) (_remotePeerId);
_fds 390 plugin/ipc/socket/socketconnection.cpp KernelBufferDrainer::instance().beginDrainOf(_fds[0], _id);
_fds 393 plugin/ipc/socket/socketconnection.cpp KernelBufferDrainer::instance().addListenSocket(_fds[0]);
_fds 396 plugin/ipc/socket/socketconnection.cpp JWARNING(_type != TCP_BIND) (_fds[0])
_fds 402 plugin/ipc/socket/socketconnection.cpp JTRACE("Socket to External Process, won't be drained") (_fds[0]);
_fds 412 plugin/ipc/socket/socketconnection.cpp JTRACE("Sending handshake ...") (id()) (_fds[0]);
_fds 413 plugin/ipc/socket/socketconnection.cpp sendHandshake(_fds[0], coordId);
_fds 416 plugin/ipc/socket/socketconnection.cpp JTRACE("Socket to External Process, skipping handshake send") (_fds[0]);
_fds 426 plugin/ipc/socket/socketconnection.cpp recvHandshake(_fds[0], coordId);
_fds 427 plugin/ipc/socket/socketconnection.cpp JTRACE("Received handshake.") (id()) (_remotePeerId) (_fds[0]);
_fds 430 plugin/ipc/socket/socketconnection.cpp JTRACE("Socket to External Process, skipping handshake recv") (_fds[0]);
_fds 438 plugin/ipc/socket/socketconnection.cpp JTRACE("Re-adding O_ASYNC flag.") (_fds[0]) (id());
_fds 439 plugin/ipc/socket/socketconnection.cpp restoreSocketOptions(_fds);
_fds 442 plugin/ipc/socket/socketconnection.cpp restoreSocketOptions(_fds);
_fds 449 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0);
_fds 454 plugin/ipc/socket/socketconnection.cpp JTRACE("Creating dead socket.") (_fds[0]) (_fds.size());
_fds 455 plugin/ipc/socket/socketconnection.cpp Util::dupFds(_makeDeadSocket(), _fds);
_fds 463 plugin/ipc/socket/socketconnection.cpp Util::dupFds(_makeDeadSocket(&buffer[0], buffer.size()), _fds);
_fds 477 plugin/ipc/socket/socketconnection.cpp JTRACE("Restoring socket.") (id()) (_fds[0]);
_fds 482 plugin/ipc/socket/socketconnection.cpp Util::dupFds(fd, _fds);
_fds 522 plugin/ipc/socket/socketconnection.cpp (_fds[0]) (opt->first) (opt->second.size());
_fds 524 plugin/ipc/socket/socketconnection.cpp int ret = _real_setsockopt(_fds[0], lvl->first, opt->first,
_fds 527 plugin/ipc/socket/socketconnection.cpp JASSERT(ret == 0) (JASSERT_ERRNO) (_fds[0]) (lvl->first)
_fds 540 plugin/ipc/socket/socketconnection.cpp JWARNING(_real_bind(_fds[0], (sockaddr*) &_bindAddr,_bindAddrlen) == 0)
_fds 548 plugin/ipc/socket/socketconnection.cpp JWARNING(_real_listen(_fds[0], _listenBacklog) == 0)
_fds 555 plugin/ipc/socket/socketconnection.cpp JASSERT(!_remotePeerId.isNull()) (id()) (_remotePeerId) (_fds[0])
_fds 559 plugin/ipc/socket/socketconnection.cpp JTRACE("registerIncoming") (id()) (_remotePeerId) (_fds[0]);
_fds 571 plugin/ipc/socket/socketconnection.cpp Util::dupFds(fd, _fds);
_fds 573 plugin/ipc/socket/socketconnection.cpp JWARNING(_real_bind(_fds[0], (sockaddr*)&_bindAddr, _bindAddrlen) != -1)
_fds 576 plugin/ipc/socket/socketconnection.cpp JTRACE("registerOutgoing") (id()) (_remotePeerId) (_fds[0]);
_fds 651 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0) (id());
_fds 655 plugin/ipc/socket/socketconnection.cpp JTRACE("Removing O_ASYNC flag during checkpoint.") (_fds[0]) (id());
_fds 658 plugin/ipc/socket/socketconnection.cpp JASSERT(fcntl(_fds[0], F_SETFL, _fcntlFlags & ~O_ASYNC) == 0)
_fds 659 plugin/ipc/socket/socketconnection.cpp (JASSERT_ERRNO) (_fds[0]) (id());
_fds 666 plugin/ipc/socket/socketconnection.cpp JTRACE("Re-adding O_ASYNC flag.") (_fds[0]) (id());
_fds 667 plugin/ipc/socket/socketconnection.cpp restoreSocketOptions(_fds);
_fds 669 plugin/ipc/socket/socketconnection.cpp restoreSocketOptions(_fds);
_fds 675 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0);
_fds 677 plugin/ipc/socket/socketconnection.cpp JTRACE("Restoring socket.") (id()) (_fds[0]);
_fds 682 plugin/ipc/socket/socketconnection.cpp Util::dupFds(sockfd, _fds);