con 238 plugin/ipc/connectionlist.cpp Connection& con = *i->second;
con 239 plugin/ipc/connectionlist.cpp uint32_t type = con.conType();
con 243 plugin/ipc/connectionlist.cpp con.serialize(o);
con 250 plugin/ipc/connectionlist.cpp Connection* con = NULL;
con 254 plugin/ipc/connectionlist.cpp con = createDummyConnection(type);
con 255 plugin/ipc/connectionlist.cpp JASSERT(con != NULL) (key);
con 256 plugin/ipc/connectionlist.cpp con->serialize(o);
con 257 plugin/ipc/connectionlist.cpp _connections[key] = con;
con 258 plugin/ipc/connectionlist.cpp const vector<int32_t>& fds = con->getFds();
con 260 plugin/ipc/connectionlist.cpp _fdToCon[fds[i]] = con;
con 327 plugin/ipc/connectionlist.cpp Connection *con = _fdToCon[fd];
con 329 plugin/ipc/connectionlist.cpp con->removeFd(fd);
con 330 plugin/ipc/connectionlist.cpp if (con->numFds() == 0) {
con 331 plugin/ipc/connectionlist.cpp _connections.erase(con->id());
con 332 plugin/ipc/connectionlist.cpp delete con;
con 355 plugin/ipc/connectionlist.cpp Connection *con = _fdToCon[oldfd];
con 356 plugin/ipc/connectionlist.cpp _fdToCon[newfd] = con;
con 357 plugin/ipc/connectionlist.cpp con->addFd(newfd);
con 378 plugin/ipc/connectionlist.cpp Connection *con = i->second;
con 379 plugin/ipc/connectionlist.cpp con->saveOptions();
con 387 plugin/ipc/connectionlist.cpp Connection *con = i->second;
con 388 plugin/ipc/connectionlist.cpp JASSERT(con->numFds() > 0);
con 389 plugin/ipc/connectionlist.cpp con->doLocking();
con 396 plugin/ipc/connectionlist.cpp Connection* con = i->second;
con 397 plugin/ipc/connectionlist.cpp con->checkLocking();
con 398 plugin/ipc/connectionlist.cpp if (con->hasLock()) {
con 399 plugin/ipc/connectionlist.cpp con->drain();
con 407 plugin/ipc/connectionlist.cpp Connection* con = i->second;
con 408 plugin/ipc/connectionlist.cpp if (con->hasLock()) {
con 409 plugin/ipc/connectionlist.cpp con->preCkpt();
con 417 plugin/ipc/connectionlist.cpp Connection *con = i->second;
con 418 plugin/ipc/connectionlist.cpp if (con->hasLock()) {
con 419 plugin/ipc/connectionlist.cpp con->refill(isRestart);
con 420 plugin/ipc/connectionlist.cpp con->restoreOptions();
con 433 plugin/ipc/connectionlist.cpp Connection *con = i->second;
con 434 plugin/ipc/connectionlist.cpp if (con->hasLock()) {
con 435 plugin/ipc/connectionlist.cpp con->resume(isRestart);
con 453 plugin/ipc/connectionlist.cpp Connection *con = i->second;
con 454 plugin/ipc/connectionlist.cpp if (!con->hasLock()) continue;
con 468 plugin/ipc/connectionlist.cpp con->postRestart();
con 500 plugin/ipc/connectionlist.cpp Connection *con = i->second;
con 503 plugin/ipc/connectionlist.cpp if (!con->hasLock() && !con->isStdio() && !con->isPreExistingCTTY()) {
con 505 plugin/ipc/connectionlist.cpp in << "\n\t" << con->str() << i->first;
con 507 plugin/ipc/connectionlist.cpp out << "\n\t" << con->str() << i->first;
con 527 plugin/ipc/connectionlist.cpp Connection *con = getConnection(*id);
con 528 plugin/ipc/connectionlist.cpp if (con != NULL && con->hasLock()) {
con 554 plugin/ipc/connectionlist.cpp Connection *con = getConnection(*id);
con 556 plugin/ipc/connectionlist.cpp JASSERT(Util::sendFd(restoreFd, con->getFds()[0], id, sizeof(*id),
con 565 plugin/ipc/connectionlist.cpp Connection *con = getConnection(id);
con 567 plugin/ipc/connectionlist.cpp JASSERT(con != NULL);
con 568 plugin/ipc/connectionlist.cpp Util::dupFds(fd, con->getFds());
con 187 plugin/ipc/event/eventwrappers.cpp EpollConnection *con =
con 189 plugin/ipc/event/eventwrappers.cpp con->onCTL(op, fd, event);
con 265 plugin/ipc/event/eventwrappers.cpp Connection *con = new InotifyConnection(0);
con 266 plugin/ipc/event/eventwrappers.cpp EventConnList::instance().add(ret, con);
con 286 plugin/ipc/event/eventwrappers.cpp Connection *con = new InotifyConnection(flags);
con 125 plugin/ipc/file/fileconnlist.cpp Connection* con = i->second;
con 126 plugin/ipc/file/fileconnlist.cpp if (con->hasLock() && con->conType() == Connection::FILE) {
con 127 plugin/ipc/file/fileconnlist.cpp FileConnection *fileCon = (FileConnection*) con;
con 156 plugin/ipc/file/fileconnlist.cpp Connection* con = i->second;
con 157 plugin/ipc/file/fileconnlist.cpp if (!con->hasLock() && con->conType() == Connection::PTY &&
con 158 plugin/ipc/file/fileconnlist.cpp con->isPreExistingCTTY()) {
con 159 plugin/ipc/file/fileconnlist.cpp PtyConnection *pcon = (PtyConnection*) con;
con 185 plugin/ipc/file/fileconnlist.cpp Connection* con = i->second;
con 186 plugin/ipc/file/fileconnlist.cpp if (con->hasLock() && con->conType() == Connection::PTY) {
con 187 plugin/ipc/file/fileconnlist.cpp PtyConnection *pcon = (PtyConnection*) con;
con 401 plugin/ipc/file/fileconnlist.cpp PtyConnection *con = new PtyConnection(fd, (const char*) device.c_str(),
con 405 plugin/ipc/file/fileconnlist.cpp con->markPreExistingCTTY();
con 406 plugin/ipc/file/fileconnlist.cpp add(fd, (Connection*)con);
con 436 plugin/ipc/file/fileconnlist.cpp Connection *con = i->second;
con 438 plugin/ipc/file/fileconnlist.cpp if( con->conType() != Connection::FILE )
con 441 plugin/ipc/file/fileconnlist.cpp FileConnection *fcon = (FileConnection*)con;
con 444 plugin/ipc/file/fileconnlist.cpp return con;
con 65 plugin/ipc/file/posixipcwrappers.cpp PosixMQConnection *con =(PosixMQConnection*)
con 67 plugin/ipc/file/posixipcwrappers.cpp con->on_mq_close();
con 93 plugin/ipc/file/posixipcwrappers.cpp PosixMQConnection *con =(PosixMQConnection*)
con 95 plugin/ipc/file/posixipcwrappers.cpp con->on_mq_notify(NULL);
con 123 plugin/ipc/file/posixipcwrappers.cpp PosixMQConnection *con =(PosixMQConnection*)
con 125 plugin/ipc/file/posixipcwrappers.cpp con->on_mq_notify(sevp);
con 109 plugin/ipc/socket/connectionrewirer.cpp Connection *con = i->second;
con 111 plugin/ipc/socket/connectionrewirer.cpp int fd = con->getFds()[0];
con 225 plugin/ipc/socket/connectionrewirer.cpp Connection* con,
con 232 plugin/ipc/socket/connectionrewirer.cpp _pendingIP4Incoming[local] = con;
con 235 plugin/ipc/socket/connectionrewirer.cpp _pendingIP6Incoming[local] = con;
con 237 plugin/ipc/socket/connectionrewirer.cpp _pendingIP4Incoming[local] = con;
con 240 plugin/ipc/socket/connectionrewirer.cpp _pendingUDSIncoming[local] = con;
con 250 plugin/ipc/socket/connectionrewirer.cpp Connection* con)
con 252 plugin/ipc/socket/connectionrewirer.cpp _pendingOutgoing[remote] = con;
con 318 plugin/ipc/socket/connectionrewirer.cpp Connection *con = i->second;
con 319 plugin/ipc/socket/connectionrewirer.cpp o << i->first << " numFds=" << con->getFds().size()
con 320 plugin/ipc/socket/connectionrewirer.cpp << " firstFd=" << con->getFds()[0] << '\n';
con 324 plugin/ipc/socket/connectionrewirer.cpp Connection *con = i->second;
con 325 plugin/ipc/socket/connectionrewirer.cpp o << i->first << " numFds=" << con->getFds().size()
con 326 plugin/ipc/socket/connectionrewirer.cpp << " firstFd=" << con->getFds()[0] << '\n';
con 42 plugin/ipc/socket/connectionrewirer.h Connection *con;
con 50 plugin/ipc/socket/connectionrewirer.h Connection *con,
con 53 plugin/ipc/socket/connectionrewirer.h Connection *con);
con 56 plugin/ipc/socket/socketconnlist.cpp TcpConnection *con =
con 63 plugin/ipc/socket/socketconnlist.cpp con->onError();
con 76 plugin/ipc/socket/socketconnlist.cpp Connection *con = i->second;
con 77 plugin/ipc/socket/socketconnlist.cpp if (con->hasLock() && con->conType() == Connection::TCP) {
con 78 plugin/ipc/socket/socketconnlist.cpp ((TcpConnection*)con)->doSendHandshakes(coordId);
con 84 plugin/ipc/socket/socketconnlist.cpp Connection *con = i->second;
con 85 plugin/ipc/socket/socketconnlist.cpp if (con->hasLock() && con->conType() == Connection::TCP) {
con 86 plugin/ipc/socket/socketconnlist.cpp ((TcpConnection*)con)->doRecvHandshakes(coordId);
con 94 plugin/ipc/socket/socketconnlist.cpp Connection *con = i->second;
con 95 plugin/ipc/socket/socketconnlist.cpp if (con->hasLock() && con->conType() == Connection::TCP) {
con 96 plugin/ipc/socket/socketconnlist.cpp int domain = ((TcpConnection*)con)->sockDomain();
con 180 plugin/ipc/socket/socketconnlist.cpp TcpConnection* con = new TcpConnection(0, 0, 0);
con 181 plugin/ipc/socket/socketconnlist.cpp con->markPreExisting();
con 182 plugin/ipc/socket/socketconnlist.cpp add(fd, con);
con 58 plugin/ipc/socket/socketwrappers.cpp Connection *con;
con 63 plugin/ipc/socket/socketwrappers.cpp con = new RawSocketConnection(domain, type, protocol);
con 65 plugin/ipc/socket/socketwrappers.cpp con = new TcpConnection(domain, type, protocol);
con 67 plugin/ipc/socket/socketwrappers.cpp SocketConnList::instance().add(ret, con);
con 109 plugin/ipc/socket/socketwrappers.cpp TcpConnection *con =
con 111 plugin/ipc/socket/socketwrappers.cpp if (con == NULL) {
con 114 plugin/ipc/socket/socketwrappers.cpp con->onConnect(serv_addr, addrlen);
con 117 plugin/ipc/socket/socketwrappers.cpp JTRACE("connected, sending 1-way handshake") (sockfd) (con->id());
con 118 plugin/ipc/socket/socketwrappers.cpp con->sendHandshake(sockfd, DmtcpWorker::instance().coordinatorId());
con 121 plugin/ipc/socket/socketwrappers.cpp JTRACE("connected") (sockfd) (con->id());
con 135 plugin/ipc/socket/socketwrappers.cpp TcpConnection *con =
con 137 plugin/ipc/socket/socketwrappers.cpp if (con == NULL) {
con 140 plugin/ipc/socket/socketwrappers.cpp con->onBind((struct sockaddr*) my_addr, addrlen);
con 141 plugin/ipc/socket/socketwrappers.cpp JTRACE("bind") (sockfd) (con->id());
con 153 plugin/ipc/socket/socketwrappers.cpp TcpConnection *con =
con 155 plugin/ipc/socket/socketwrappers.cpp if (con == NULL) {
con 158 plugin/ipc/socket/socketwrappers.cpp con->onListen(backlog);
con 159 plugin/ipc/socket/socketwrappers.cpp JTRACE("listen") (sockfd) (con->id()) (backlog);
con 172 plugin/ipc/socket/socketwrappers.cpp TcpConnection* con = new TcpConnection(*parent, ConnectionIdentifier::null());
con 173 plugin/ipc/socket/socketwrappers.cpp if (con == NULL) {
con 177 plugin/ipc/socket/socketwrappers.cpp SocketConnList::instance().add(ret, con);
con 180 plugin/ipc/socket/socketwrappers.cpp JTRACE("accepted, waiting for 1-way handshake") (sockfd) (con->id());
con 181 plugin/ipc/socket/socketwrappers.cpp con->recvHandshake(ret, DmtcpWorker::instance().coordinatorId());
con 182 plugin/ipc/socket/socketwrappers.cpp JTRACE("1-way handshake received") (con->getRemoteId());
con 184 plugin/ipc/socket/socketwrappers.cpp JTRACE("accepted incoming connection") (sockfd) (con->id());
con 238 plugin/ipc/socket/socketwrappers.cpp TcpConnection *con =
con 240 plugin/ipc/socket/socketwrappers.cpp if (con == NULL) {