_coordinatorSocket 110 coordinatorapi.cpp coordAPIInst->_coordinatorSocket = jalib::JSocket(PROTECTED_COORD_FD);
_coordinatorSocket 125 coordinatorapi.cpp instance()._coordinatorSocket = jalib::JSocket(PROTECTED_COORD_FD);
_coordinatorSocket 126 coordinatorapi.cpp instance()._coordinatorSocket << msg;
_coordinatorSocket 127 coordinatorapi.cpp instance()._coordinatorSocket.writeAll(progname.c_str(),
_coordinatorSocket 135 coordinatorapi.cpp JASSERT(coordAPI._coordinatorSocket.isValid());
_coordinatorSocket 136 coordinatorapi.cpp JASSERT(coordAPI._coordinatorSocket.sockfd() != PROTECTED_COORD_FD);
_coordinatorSocket 138 coordinatorapi.cpp instance()._coordinatorSocket.changeFd(PROTECTED_COORD_FD);
_coordinatorSocket 148 coordinatorapi.cpp instance()._coordinatorSocket << msg;
_coordinatorSocket 162 coordinatorapi.cpp _coordinatorSocket = jalib::JServerSocket(jalib::JSockAddr::ANY, port);
_coordinatorSocket 163 coordinatorapi.cpp JASSERT(_coordinatorSocket.isValid()) (port) (JASSERT_ERRNO)
_coordinatorSocket 165 coordinatorapi.cpp _coordinatorSocket.changeFd(PROTECTED_COORD_FD);
_coordinatorSocket 166 coordinatorapi.cpp Util::setCoordPort(_coordinatorSocket.port());
_coordinatorSocket 229 coordinatorapi.cpp cmdSock = _coordinatorSocket.accept();
_coordinatorSocket 294 coordinatorapi.cpp _coordinatorSocket = createNewSocketToCoordinator(COORD_ANY);
_coordinatorSocket 295 coordinatorapi.cpp if (!_coordinatorSocket.isValid()) {
_coordinatorSocket 314 coordinatorapi.cpp _coordinatorSocket << msg;
_coordinatorSocket 324 coordinatorapi.cpp _coordinatorSocket >> reply;
_coordinatorSocket 341 coordinatorapi.cpp _coordinatorSocket.close();
_coordinatorSocket 350 coordinatorapi.cpp _coordinatorSocket << msg;
_coordinatorSocket 353 coordinatorapi.cpp _coordinatorSocket >> msg;
_coordinatorSocket 358 coordinatorapi.cpp _coordinatorSocket.readAll(buf, msg.extraBytes);
_coordinatorSocket 368 coordinatorapi.cpp _coordinatorSocket << msg;
_coordinatorSocket 369 coordinatorapi.cpp _coordinatorSocket.writeAll(dir, strlen(dir) + 1);
_coordinatorSocket 377 coordinatorapi.cpp _coordinatorSocket << msg;
_coordinatorSocket 381 coordinatorapi.cpp _coordinatorSocket.writeAll((const char *)extraData, msg.extraBytes);
_coordinatorSocket 389 coordinatorapi.cpp _coordinatorSocket >> (*msg);
_coordinatorSocket 396 coordinatorapi.cpp _coordinatorSocket.readAll((char*)buf, msg->extraBytes);
_coordinatorSocket 456 coordinatorapi.cpp _coordinatorSocket = createNewSocketToCoordinator(mode);
_coordinatorSocket 457 coordinatorapi.cpp JASSERT(_coordinatorSocket.isValid()) (JASSERT_ERRNO)
_coordinatorSocket 461 coordinatorapi.cpp _coordinatorSocket = createNewSocketToCoordinator(mode);
_coordinatorSocket 462 coordinatorapi.cpp JASSERT(_coordinatorSocket.isValid()) (JASSERT_ERRNO)
_coordinatorSocket 465 coordinatorapi.cpp _coordinatorSocket = createNewSocketToCoordinator(mode);
_coordinatorSocket 466 coordinatorapi.cpp if (!_coordinatorSocket.isValid()) {
_coordinatorSocket 469 coordinatorapi.cpp _coordinatorSocket = createNewSocketToCoordinator(mode);
_coordinatorSocket 470 coordinatorapi.cpp JASSERT(_coordinatorSocket.isValid()) (JASSERT_ERRNO)
_coordinatorSocket 476 coordinatorapi.cpp _coordinatorSocket.changeFd(PROTECTED_COORD_FD);
_coordinatorSocket 493 coordinatorapi.cpp _coordinatorSocket << msg;
_coordinatorSocket 494 coordinatorapi.cpp _coordinatorSocket.writeAll(hostname.c_str(), hostname.length() + 1);
_coordinatorSocket 495 coordinatorapi.cpp _coordinatorSocket.writeAll(progname.c_str(), progname.length() + 1);
_coordinatorSocket 498 coordinatorapi.cpp _coordinatorSocket >> msg;
_coordinatorSocket 551 coordinatorapi.cpp JASSERT(getpeername(_coordinatorSocket.sockfd(),
_coordinatorSocket 565 coordinatorapi.cpp _coordinatorSocket = jalib::JClientSocket((struct sockaddr *)&addr, addrlen);
_coordinatorSocket 566 coordinatorapi.cpp JASSERT(_coordinatorSocket.isValid());
_coordinatorSocket 608 coordinatorapi.cpp JASSERT(getpeername(_coordinatorSocket.sockfd(),
_coordinatorSocket 634 coordinatorapi.cpp _coordinatorSocket << msg;
_coordinatorSocket 635 coordinatorapi.cpp _coordinatorSocket.writeAll(ckptFilename.c_str(), ckptFilename.length() + 1);
_coordinatorSocket 636 coordinatorapi.cpp _coordinatorSocket.writeAll(hostname.c_str(), hostname.length() + 1);
_coordinatorSocket 656 coordinatorapi.cpp jalib::JSocket sock = _coordinatorSocket;
_coordinatorSocket 697 coordinatorapi.cpp jalib::JSocket sock = _coordinatorSocket;
_coordinatorSocket 50 coordinatorapi.h CoordinatorAPI (void) : _coordinatorSocket(-1), _nsSock(-1) {}
_coordinatorSocket 77 coordinatorapi.h void closeConnection() { _coordinatorSocket.close(); }
_coordinatorSocket 80 coordinatorapi.h bool isValid() { return _coordinatorSocket.isValid(); }
_coordinatorSocket 112 coordinatorapi.h jalib::JSocket _coordinatorSocket;