id 175 coordinatorapi.cpp coordInfo->id = coordId.upid();
id 529 coordinatorapi.cpp *compId = coordInfo->id;
id 548 coordinatorapi.cpp coordInfo->id = hello_remote.from.upid();
id 605 coordinatorapi.cpp coordInfo->id = hello_remote.from.upid();
id 640 coordinatorapi.cpp int CoordinatorAPI::sendKeyValPairToCoordinator(const char *id,
id 651 coordinatorapi.cpp JWARNING(strlen(id) < sizeof(msg.nsid));
id 652 coordinatorapi.cpp strncpy(msg.nsid, id, 8);
id 685 coordinatorapi.cpp int CoordinatorAPI::sendQueryToCoordinator(const char *id,
id 692 coordinatorapi.cpp JWARNING(strlen(id) < sizeof(msg.nsid));
id 693 coordinatorapi.cpp strncpy(msg.nsid, id, 8);
id 98 coordinatorapi.h int sendKeyValPairToCoordinator(const char *id,
id 102 coordinatorapi.h int sendQueryToCoordinator(const char *id,
id 166 dmtcpmessagetypes.h static void setDefaultCoordinator ( const DmtcpUniqueProcessId& id );
id 167 dmtcpmessagetypes.h static void setDefaultCoordinator ( const UniquePid& id );
id 76 dmtcpnohijackstubs.cpp DmtcpUniqueProcessId id = {0, 0, 0, 0};
id 77 dmtcpnohijackstubs.cpp return id;
id 461 dmtcpplugin.cpp EXTERNC int dmtcp_send_key_val_pair_to_coordinator(const char *id,
id 467 dmtcpplugin.cpp return CoordinatorAPI::instance().sendKeyValPairToCoordinator(id, key, key_len,
id 471 dmtcpplugin.cpp EXTERNC int dmtcp_send_key_val_pair_to_coordinator_sync(const char *id,
id 477 dmtcpplugin.cpp return CoordinatorAPI::instance().sendKeyValPairToCoordinator(id, key, key_len,
id 486 dmtcpplugin.cpp EXTERNC int dmtcp_send_query_to_coordinator(const char *id,
id 490 dmtcpplugin.cpp return CoordinatorAPI::instance().sendQueryToCoordinator(id, key, key_len,
id 64 dmtcpworker.h static void eventHook(DmtcpEvent_t id, DmtcpEventData_t *data);
id 46 lookup_service.cpp void LookupService::addKeyValue(string id,
id 50 lookup_service.cpp KeyValueMap &kvmap = _maps[id];
id 60 lookup_service.cpp void LookupService::query(string id,
id 64 lookup_service.cpp KeyValueMap &kvmap = _maps[id];
id 79 lookup_service.h void addKeyValue(string id, const void *key, size_t keyLen,
id 81 lookup_service.h void query(string id, const void *key, size_t keyLen,
id 206 miscwrappers.cpp extern "C" int waitid(idtype_t idtype, id_t id, siginfo_t *infop, int options)
id 211 miscwrappers.cpp int retval = _real_waitid (idtype, id, &siginfop, options);
id 321 nosyscallsreal.c int _real_waitid(idtype_t idtype, id_t id, siginfo_t *infop, int options) {
id 322 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (waitid) (idtype, id, infop, options);
id 81 plugin/ipc/connection.h const ConnectionIdentifier& id() const { return _id; }
id 35 plugin/ipc/connectionidentifier.cpp ConnectionIdentifier::ConnectionIdentifier(int id)
id 38 plugin/ipc/connectionidentifier.cpp _id = id;
id 85 plugin/ipc/connectionidentifier.cpp ostream& dmtcp::operator<<(ostream& o, const ConnectionIdentifier& id)
id 87 plugin/ipc/connectionidentifier.cpp o << std::hex << id.hostid()
id 88 plugin/ipc/connectionidentifier.cpp << '-' << std::dec << id.pid()
id 89 plugin/ipc/connectionidentifier.cpp << '-' << std::hex << id.time()
id 90 plugin/ipc/connectionidentifier.cpp << std::dec << '(' << id.conId() << ')';
id 56 plugin/ipc/connectionidentifier.h ConnectionIdentifier (int id = -1);
id 57 plugin/ipc/connectionidentifier.h ConnectionIdentifier(DmtcpUniqueProcessId id) {
id 58 plugin/ipc/connectionidentifier.h _upid = id;
id 113 plugin/ipc/connectionidentifier.h ostream& operator<<(ostream& o, const ConnectionIdentifier& id);
id 210 plugin/ipc/connectionlist.cpp << "\t->\t" << c->id() << "\n";
id 287 plugin/ipc/connectionlist.cpp ConnectionList::getConnection(const ConnectionIdentifier& id)
id 289 plugin/ipc/connectionlist.cpp if (_connections.find(id) == _connections.end()) {
id 292 plugin/ipc/connectionlist.cpp return _connections[id];
id 318 plugin/ipc/connectionlist.cpp if( _connections.find(c->id()) == _connections.end() )
id 319 plugin/ipc/connectionlist.cpp _connections[c->id()] = c;
id 331 plugin/ipc/connectionlist.cpp _connections.erase(con->id());
id 526 plugin/ipc/connectionlist.cpp ConnectionIdentifier *id = (ConnectionIdentifier*) maps[i].id;
id 527 plugin/ipc/connectionlist.cpp Connection *con = getConnection(*id);
id 553 plugin/ipc/connectionlist.cpp ConnectionIdentifier *id = (ConnectionIdentifier*) maps[idx].id;
id 554 plugin/ipc/connectionlist.cpp Connection *con = getConnection(*id);
id 555 plugin/ipc/connectionlist.cpp JTRACE("Sending Missing Con") (*id);
id 556 plugin/ipc/connectionlist.cpp JASSERT(Util::sendFd(restoreFd, con->getFds()[0], id, sizeof(*id),
id 562 plugin/ipc/connectionlist.cpp ConnectionIdentifier id;
id 563 plugin/ipc/connectionlist.cpp int fd = Util::receiveFd(restoreFd, &id, sizeof(id));
id 565 plugin/ipc/connectionlist.cpp Connection *con = getConnection(id);
id 566 plugin/ipc/connectionlist.cpp JTRACE("Received Missing Con") (id);
id 56 plugin/ipc/connectionlist.h Connection *getConnection(const ConnectionIdentifier &id);
id 75 plugin/ipc/event/eventconnection.cpp JTRACE("Recreating epoll connection") (_fds[0]) (id());
id 97 plugin/ipc/event/eventconnection.cpp (id())
id 173 plugin/ipc/event/eventconnection.cpp JTRACE("Restoring EventFd Connection") (id());
id 234 plugin/ipc/event/eventconnection.cpp JTRACE("Restoring SignalFd Connection") (id());
id 269 plugin/ipc/event/eventconnection.cpp JTRACE("inotify restoreOptions") (_fds[0]) (id()) (num_of_descriptors);
id 382 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring invalid PTY.") (id());
id 614 plugin/ipc/file/fileconnection.cpp ConnectionIdentifier id;
id 616 plugin/ipc/file/fileconnection.cpp JASSERT(SharedData::getCkptLeaderForFile(_st_dev, _st_ino, &id));
id 617 plugin/ipc/file/fileconnection.cpp if (id == _id) {
id 793 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring File Connection") (id()) (_path);
id 1025 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring Fifo Connection") (id()) (_path);
id 97 plugin/ipc/file/fileconnection.h JTRACE("creating stdio connection") (fd) (id());
id 132 plugin/ipc/file/fileconnlist.cpp memcpy(map.id, &i->first, sizeof (i->first));
id 90 plugin/ipc/socket/connectionrewirer.cpp ConnectionIdentifier id;
id 91 plugin/ipc/socket/connectionrewirer.cpp JASSERT(Util::readAll(fd, &id, sizeof id) == sizeof id);
id 93 plugin/ipc/socket/connectionrewirer.cpp iterator i = conList->find(id);
id 94 plugin/ipc/socket/connectionrewirer.cpp JASSERT(i != conList->end()) (id)
id 99 plugin/ipc/socket/connectionrewirer.cpp JTRACE("restoring incoming connection") (id);
id 108 plugin/ipc/socket/connectionrewirer.cpp const ConnectionIdentifier& id = i->first;
id 110 plugin/ipc/socket/connectionrewirer.cpp struct RemoteAddr& remoteAddr = _remoteInfo[id];
id 115 plugin/ipc/socket/connectionrewirer.cpp (id) (JASSERT_ERRNO) .Text("failed to restore connection");
id 117 plugin/ipc/socket/connectionrewirer.cpp Util::writeAll(fd, &id, sizeof id);
id 273 plugin/ipc/socket/connectionrewirer.cpp const ConnectionIdentifier& id = i->first;
id 275 plugin/ipc/socket/connectionrewirer.cpp (const void *)&id,
id 276 plugin/ipc/socket/connectionrewirer.cpp (uint32_t) sizeof(id),
id 293 plugin/ipc/socket/connectionrewirer.cpp const ConnectionIdentifier& id = i->first;
id 297 plugin/ipc/socket/connectionrewirer.cpp (const void *)&id, (uint32_t) sizeof(id),
id 306 plugin/ipc/socket/connectionrewirer.cpp _remoteInfo[id] = remote;
id 149 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::beginDrainOf(int fd, const ConnectionIdentifier& id)
id 161 plugin/ipc/socket/kernelbufferdrainer.cpp _reverseLookup[fd]=id;
id 217 plugin/ipc/socket/kernelbufferdrainer.cpp const vector<char>& KernelBufferDrainer::getDrainedData(ConnectionIdentifier id)
id 219 plugin/ipc/socket/kernelbufferdrainer.cpp JASSERT(_disconnectedSockets.find(id) != _disconnectedSockets.end()) (id);
id 220 plugin/ipc/socket/kernelbufferdrainer.cpp return _disconnectedSockets[id];
id 43 plugin/ipc/socket/kernelbufferdrainer.h void beginDrainOf(int fd , const ConnectionIdentifier& id);
id 53 plugin/ipc/socket/kernelbufferdrainer.h const vector<char>& getDrainedData(ConnectionIdentifier id);
id 195 plugin/ipc/socket/socketconnection.cpp JTRACE("Creating TcpConnection.") (id()) (domain) (type) (protocol);
id 274 plugin/ipc/socket/socketconnection.cpp JTRACE("Binding.") (id()) (len);
id 309 plugin/ipc/socket/socketconnection.cpp JTRACE("Listening.") (id()) (backlog);
id 311 plugin/ipc/socket/socketconnection.cpp JASSERT(_type == TCP_BIND) (_type) (id())
id 324 plugin/ipc/socket/socketconnection.cpp JTRACE("Connecting.") (id());
id 326 plugin/ipc/socket/socketconnection.cpp JWARNING(_type == TCP_CREATED || _type == TCP_BIND) (_type) (id())
id 348 plugin/ipc/socket/socketconnection.cpp JTRACE("Accepting.") (id()) (parent.id()) (remote);
id 358 plugin/ipc/socket/socketconnection.cpp JTRACE("Error.") (id());
id 368 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0) (id());
id 372 plugin/ipc/socket/socketconnection.cpp JTRACE("Removing O_ASYNC flag during checkpoint.") (_fds[0]) (id());
id 376 plugin/ipc/socket/socketconnection.cpp (JASSERT_ERRNO) (_fds[0]) (id());
id 412 plugin/ipc/socket/socketconnection.cpp JTRACE("Sending handshake ...") (id()) (_fds[0]);
id 427 plugin/ipc/socket/socketconnection.cpp JTRACE("Received handshake.") (id()) (_remotePeerId) (_fds[0]);
id 438 plugin/ipc/socket/socketconnection.cpp JTRACE("Re-adding O_ASYNC flag.") (_fds[0]) (id());
id 473 plugin/ipc/socket/socketconnection.cpp (id()) (_sockDomain) (_sockType) (_sockProtocol)
id 477 plugin/ipc/socket/socketconnection.cpp JTRACE("Restoring socket.") (id()) (_fds[0]);
id 537 plugin/ipc/socket/socketconnection.cpp JTRACE("Binding socket.") (id());
id 541 plugin/ipc/socket/socketconnection.cpp (JASSERT_ERRNO) (id()) .Text("Bind failed.");
id 545 plugin/ipc/socket/socketconnection.cpp JTRACE("Listening socket.") (id());
id 549 plugin/ipc/socket/socketconnection.cpp (JASSERT_ERRNO) (id()) (_listenBacklog) .Text("listen failed.");
id 555 plugin/ipc/socket/socketconnection.cpp JASSERT(!_remotePeerId.isNull()) (id()) (_remotePeerId) (_fds[0])
id 559 plugin/ipc/socket/socketconnection.cpp JTRACE("registerIncoming") (id()) (_remotePeerId) (_fds[0]);
id 560 plugin/ipc/socket/socketconnection.cpp ConnectionRewirer::instance().registerIncoming(id(), this, _sockDomain);
id 576 plugin/ipc/socket/socketconnection.cpp JTRACE("registerOutgoing") (id()) (_remotePeerId) (_fds[0]);
id 596 plugin/ipc/socket/socketconnection.cpp msg.from = id();
id 646 plugin/ipc/socket/socketconnection.cpp JTRACE("Creating Raw socket.") (id()) (domain) (type) (protocol);
id 651 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0) (id());
id 655 plugin/ipc/socket/socketconnection.cpp JTRACE("Removing O_ASYNC flag during checkpoint.") (_fds[0]) (id());
id 659 plugin/ipc/socket/socketconnection.cpp (JASSERT_ERRNO) (_fds[0]) (id());
id 666 plugin/ipc/socket/socketconnection.cpp JTRACE("Re-adding O_ASYNC flag.") (_fds[0]) (id());
id 677 plugin/ipc/socket/socketconnection.cpp JTRACE("Restoring socket.") (id()) (_fds[0]);
id 55 plugin/ipc/socket/socketconnlist.cpp const ConnectionIdentifier& id = it->first;
id 57 plugin/ipc/socket/socketconnlist.cpp (TcpConnection*) SocketConnList::instance().getConnection(id);
id 58 plugin/ipc/socket/socketconnlist.cpp JTRACE("recreating disconnected socket") (id);
id 117 plugin/ipc/socket/socketwrappers.cpp JTRACE("connected, sending 1-way handshake") (sockfd) (con->id());
id 121 plugin/ipc/socket/socketwrappers.cpp JTRACE("connected") (sockfd) (con->id());
id 141 plugin/ipc/socket/socketwrappers.cpp JTRACE("bind") (sockfd) (con->id());
id 159 plugin/ipc/socket/socketwrappers.cpp JTRACE("listen") (sockfd) (con->id()) (backlog);
id 180 plugin/ipc/socket/socketwrappers.cpp JTRACE("accepted, waiting for 1-way handshake") (sockfd) (con->id());
id 184 plugin/ipc/socket/socketwrappers.cpp JTRACE("accepted incoming connection") (sockfd) (con->id());
id 277 plugin/ipc/socket/socketwrappers.cpp b = new TcpConnection(*a, a->id());
id 399 plugin/pid/pid_miscwrappers.cpp SYSCALL_GET_ARGS_4(int,idtype,id_t,id,siginfo_t*,infop,int,options);
id 400 plugin/pid/pid_miscwrappers.cpp ret = waitid((idtype_t)idtype, id, infop, options);
id 198 plugin/pid/pid_syscallsreal.c int _real_waitid(idtype_t idtype, id_t id, siginfo_t *infop, int options) {
id 199 plugin/pid/pid_syscallsreal.c REAL_FUNC_PASSTHROUGH ( waitid ) ( idtype, id, infop, options );
id 409 plugin/pid/pidwrappers.cpp extern "C" int waitid(idtype_t idtype, id_t id, siginfo_t *infop, int options)
id 430 plugin/pid/pidwrappers.cpp pid_t currPid = VIRTUAL_TO_REAL_PID (id);
id 197 plugin/pid/pidwrappers.h int _real_waitid(idtype_t idtype, id_t id, siginfo_t *infop, int options);
id 147 plugin/pid/virtualpidtable.cpp pid_t id = (virtualId < -1 ? abs(virtualId) : virtualId);
id 148 plugin/pid/virtualpidtable.cpp pid_t retVal = VirtualIdTable<pid_t>::virtualToReal(id);
id 149 plugin/pid/virtualpidtable.cpp if (retVal == id) {
id 150 plugin/pid/virtualpidtable.cpp retVal = SharedData::getRealPid(id);
id 152 plugin/pid/virtualpidtable.cpp retVal = id;
id 164 plugin/svipc/dmtcp-test.h EXTERNC int dmtcp_send_key_val_pair_to_coordinator(const char *id,
id 169 plugin/svipc/dmtcp-test.h EXTERNC int dmtcp_send_key_val_pair_to_coordinator_sync(const char *id,
id 174 plugin/svipc/dmtcp-test.h EXTERNC int dmtcp_send_query_to_coordinator(const char *id,
id 228 plugin/svipc/sysvipc.cpp SysVIPC::SysVIPC(const char *str, int32_t id, int type)
id 229 plugin/svipc/sysvipc.cpp : _virtIdTable(str, id),
id 339 plugin/svipc/sysvipc.cpp int32_t id;
id 340 plugin/svipc/sysvipc.cpp JASSERT(_virtIdTable.getNewVirtualId(&id)) (_virtIdTable.size())
id 343 plugin/svipc/sysvipc.cpp return id;
id 48 plugin/svipc/sysvipc.h #define REAL_TO_VIRTUAL_SHM_ID(id) SysVShm::instance().realToVirtualId(id)
id 49 plugin/svipc/sysvipc.h #define VIRTUAL_TO_REAL_SHM_ID(id) SysVShm::instance().virtualToRealId(id)
id 51 plugin/svipc/sysvipc.h #define REAL_TO_VIRTUAL_SEM_ID(id) SysVSem::instance().realToVirtualId(id)
id 52 plugin/svipc/sysvipc.h #define VIRTUAL_TO_REAL_SEM_ID(id) SysVSem::instance().virtualToRealId(id)
id 54 plugin/svipc/sysvipc.h #define REAL_TO_VIRTUAL_MSQ_ID(id) SysVMsq::instance().realToVirtualId(id)
id 55 plugin/svipc/sysvipc.h #define VIRTUAL_TO_REAL_MSQ_ID(id) SysVMsq::instance().virtualToRealId(id)
id 80 plugin/svipc/sysvipc.h SysVIPC(const char *str, int32_t id, int type);
id 169 plugin/svipc/sysvipc.h SysVObj(int id, int realId, int key, int flags) {
id 172 plugin/svipc/sysvipc.h _id = id;
id 192 plugin/timer/timerlist.cpp int TimerList::getoverrun(timer_t id)
id 195 plugin/timer/timerlist.cpp JASSERT(_timerInfo.find(id) != _timerInfo.end());
id 196 plugin/timer/timerlist.cpp int ret = _timerInfo[id].overrun;
id 197 plugin/timer/timerlist.cpp _timerInfo[id].overrun = 0;
id 33 plugin/timer/timerlist.h #define REAL_TO_VIRTUAL_TIMER_ID(id) \
id 34 plugin/timer/timerlist.h TimerList::instance().realToVirtualTimerId(id)
id 35 plugin/timer/timerlist.h #define VIRTUAL_TO_REAL_TIMER_ID(id) \
id 36 plugin/timer/timerlist.h TimerList::instance().virtualToRealTimerId(id)
id 43 plugin/timer/timerlist.h #define VIRTUAL_TO_REAL_CLOCK_ID(id) \
id 44 plugin/timer/timerlist.h TimerList::instance().virtualToRealClockId(id)
id 93 plugin/timer/timerlist.h int getoverrun(timer_t id);
id 281 shareddata.cpp return sharedDataHeader->coordInfo.id;
id 560 shareddata.cpp memcpy(sharedDataHeader->incomingConMap[n].id, ids[i], CON_ID_LEN);
id 587 shareddata.cpp bool SharedData::getCkptLeaderForFile(dev_t devnum, ino_t inode, void *id)
id 590 shareddata.cpp JASSERT(id != NULL);
id 595 shareddata.cpp memcpy(id, map.id, sizeof(map.id));
id 816 syscallsreal.c int _real_waitid(idtype_t idtype, id_t id, siginfo_t *infop, int options) {
id 817 syscallsreal.c REAL_FUNC_PASSTHROUGH (waitid) (idtype, id, infop, options);
id 445 syscallwrappers.h int _real_waitid(idtype_t idtype, id_t id, siginfo_t *infop, int options);
id 141 uniquepid.cpp ostream& dmtcp::operator<< ( dmtcp::ostream& o,const UniquePid& id )
id 143 uniquepid.cpp o << std::hex << id.hostid() << '-' << std::dec << id.pid() << '-' << std::hex << id.time() << std::dec;
id 147 uniquepid.cpp ostream& dmtcp::operator<< ( dmtcp::ostream& o,const DmtcpUniqueProcessId& id )
id 149 uniquepid.cpp o << std::hex << id._hostid<< '-' << std::dec << id._pid << '-' << std::hex << id._time << std::dec;
id 48 uniquepid.h UniquePid(DmtcpUniqueProcessId id) {
id 49 uniquepid.h _hostid = id._hostid;
id 50 uniquepid.h _pid = id._pid;
id 51 uniquepid.h _time = id._time;
id 52 uniquepid.h _computation_generation = id._computation_generation;
id 84 uniquepid.h ostream& operator << ( ostream& o,const UniquePid& id );
id 85 uniquepid.h ostream& operator << ( ostream& o,const DmtcpUniqueProcessId& id );