_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;