data 29 alarm.cpp dmtcp_Alarm_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 40 coordinatorapi.cpp void dmtcp_CoordinatorAPI_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 1670 dmtcp_coordinator.cpp ev.data.ptr = listenSock; data 1684 dmtcp_coordinator.cpp ev.data.ptr = (void*) STDIN_FILENO; data 1704 dmtcp_coordinator.cpp void *ptr = events[n].data.ptr; data 1750 dmtcp_coordinator.cpp ev.data.ptr = client; data 595 dmtcpworker.cpp void dmtcp_CoordinatorAPI_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 596 dmtcpworker.cpp void dmtcp_SharedData_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 597 dmtcpworker.cpp void dmtcp_ProcessInfo_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 598 dmtcpworker.cpp void dmtcp_UniquePid_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 599 dmtcpworker.cpp void dmtcp_ProcName_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 600 dmtcpworker.cpp void dmtcp_Terminal_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 601 dmtcpworker.cpp void dmtcp_Syslog_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 602 dmtcpworker.cpp void dmtcp_Alarm_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 604 dmtcpworker.cpp void DmtcpWorker::eventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 607 dmtcpworker.cpp dmtcp_Syslog_EventHook(event, data); data 608 dmtcpworker.cpp dmtcp_Terminal_EventHook(event, data); data 609 dmtcpworker.cpp dmtcp_ProcName_EventHook(event, data); data 610 dmtcpworker.cpp dmtcp_UniquePid_EventHook(event, data); data 611 dmtcpworker.cpp dmtcp_CoordinatorAPI_EventHook(event, data); data 612 dmtcpworker.cpp dmtcp_SharedData_EventHook(event, data); data 613 dmtcpworker.cpp dmtcp_ProcessInfo_EventHook(event, data); data 614 dmtcpworker.cpp dmtcp_Alarm_EventHook(event, data); data 616 dmtcpworker.cpp dmtcp_event_hook(event, data); data 64 dmtcpworker.h static void eventHook(DmtcpEvent_t id, DmtcpEventData_t *data); data 76 lookup_service.cpp memcpy(*val, v->data(), *valLen); data 80 lookup_service.cpp const void *data) data 85 lookup_service.cpp const void *key = data; data 34 lookup_service.h KeyValue(const void *data, const size_t len) { data 37 lookup_service.h memcpy(_data, data, len); data 46 lookup_service.h void *data() {return _data;} data 72 lookup_service.h void registerData(const DmtcpMessage& msg, const void *data); data 74 lookup_service.h const DmtcpMessage& msg, const void *data); data 90 plugin/ipc/connectionlist.cpp DmtcpEventData_t *data) data 103 plugin/ipc/connectionlist.cpp jalib::JBinarySerializeWriterRaw wr("", data->serializerInfo.fd); data 111 plugin/ipc/connectionlist.cpp jalib::JBinarySerializeReaderRaw rd("", data->serializerInfo.fd); data 145 plugin/ipc/connectionlist.cpp refill(data->refillInfo.isRestart); data 149 plugin/ipc/connectionlist.cpp resume(data->resumeInfo.isRestart); data 153 plugin/ipc/connectionlist.cpp registerNSData(data->nameserviceInfo.isRestart); data 157 plugin/ipc/connectionlist.cpp sendQueries(data->nameserviceInfo.isRestart); data 63 plugin/ipc/connectionlist.h void eventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 7 plugin/ipc/event/eventconnlist.cpp void dmtcp_EventConnList_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 9 plugin/ipc/event/eventconnlist.cpp EventConnList::instance().eventHook(event, data); data 81 plugin/ipc/file/fileconnlist.cpp void dmtcp_FileConnList_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 83 plugin/ipc/file/fileconnlist.cpp FileConnList::instance().eventHook(event, data); data 32 plugin/ipc/ipc.cpp void dmtcp_SSH_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 33 plugin/ipc/ipc.cpp void dmtcp_FileConnList_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 34 plugin/ipc/ipc.cpp void dmtcp_SocketConnList_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 35 plugin/ipc/ipc.cpp void dmtcp_EventConnList_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data); data 42 plugin/ipc/ipc.cpp void dmtcp_event_hook(DmtcpEvent_t event, DmtcpEventData_t *data) data 44 plugin/ipc/ipc.cpp dmtcp_SSH_EventHook(event, data); data 45 plugin/ipc/ipc.cpp dmtcp_FileConnList_EventHook(event, data); data 46 plugin/ipc/ipc.cpp dmtcp_SocketConnList_EventHook(event, data); data 47 plugin/ipc/ipc.cpp dmtcp_EventConnList_EventHook(event, data); data 49 plugin/ipc/ipc.cpp DMTCP_NEXT_EVENT_HOOK(event, data); data 18 plugin/ipc/socket/socketconnlist.cpp void dmtcp_SocketConnList_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 20 plugin/ipc/socket/socketconnlist.cpp SocketConnList::instance().eventHook(event, data); data 43 plugin/ipc/ssh/ssh.cpp void dmtcp_SSH_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 52 plugin/ipc/ssh/ssh.cpp refill(data->refillInfo.isRestart); data 94 plugin/ipc/ssh/ssh.cpp int data; data 95 plugin/ipc/ssh/ssh.cpp int ret = Util::receiveFd(SSHD_RECEIVE_FD, &data, sizeof(data)); data 99 plugin/ipc/ssh/ssh.cpp JASSERT(data == fd) (data) (fd); data 68 plugin/pid/pid.cpp static void pidVirt_AtForkParent(DmtcpEventData_t *data) data 75 plugin/pid/pid.cpp static void pidVirt_ResetOnFork(DmtcpEventData_t *data) data 80 plugin/pid/pid.cpp static void pidVirt_PrepareForExec(DmtcpEventData_t *data) data 86 plugin/pid/pid.cpp JASSERT(data != NULL); data 87 plugin/pid/pid.cpp jalib::JBinarySerializeWriterRaw wr ("", data->serializerInfo.fd); data 91 plugin/pid/pid.cpp static void pidVirt_PostExec(DmtcpEventData_t *data) data 93 plugin/pid/pid.cpp JASSERT(data != NULL); data 94 plugin/pid/pid.cpp jalib::JBinarySerializeReaderRaw rd ("", data->serializerInfo.fd); data 146 plugin/pid/pid.cpp static void pidVirt_PostRestart(DmtcpEventData_t *data) data 166 plugin/pid/pid.cpp static void pidVirt_PostRestartRefill(DmtcpEventData_t *data) data 173 plugin/pid/pid.cpp static void pidVirt_ThreadExit(DmtcpEventData_t *data) data 184 plugin/pid/pid.cpp extern "C" void dmtcp_event_hook(DmtcpEvent_t event, DmtcpEventData_t *data) data 188 plugin/pid/pid.cpp pidVirt_AtForkParent(data); data 192 plugin/pid/pid.cpp pidVirt_ResetOnFork(data); data 196 plugin/pid/pid.cpp pidVirt_PrepareForExec(data); data 200 plugin/pid/pid.cpp pidVirt_PostExec(data); data 204 plugin/pid/pid.cpp pidVirt_PostRestart(data); data 208 plugin/pid/pid.cpp if (data->refillInfo.isRestart) { data 209 plugin/pid/pid.cpp pidVirt_PostRestartRefill(data); data 215 plugin/pid/pid.cpp pidVirt_ThreadExit(data); data 222 plugin/pid/pid.cpp DMTCP_NEXT_EVENT_HOOK(event, data); data 239 plugin/pid/pid_syscallsreal.c void *data) { data 240 plugin/pid/pid_syscallsreal.c REAL_FUNC_PASSTHROUGH_TYPED ( long, ptrace ) ( request, pid, addr, data ); data 544 plugin/pid/pidwrappers.cpp void *data; data 549 plugin/pid/pidwrappers.cpp data = va_arg(ap, void *); data 553 plugin/pid/pidwrappers.cpp long ptrace_ret = _real_ptrace(request, realPid, addr, data); data 568 plugin/pid/pidwrappers.cpp unsigned long *ldata = (unsigned long*) data; data 209 plugin/pid/pidwrappers.h void *data); data 160 plugin/svipc/dmtcp-test.h EXTERNC void dmtcp_event_hook(DmtcpEvent_t event, DmtcpEventData_t *data) data 329 plugin/svipc/dmtcp-test.h static void DMTCP_NEXT_EVENT_HOOK(event, data) { data 337 plugin/svipc/dmtcp-test.h (*fn) (event, data); data 93 plugin/svipc/sysvipc.cpp extern "C" void dmtcp_event_hook(DmtcpEvent_t event, DmtcpEventData_t *data) data 120 plugin/svipc/sysvipc.cpp SysVShm::instance().refill(data->refillInfo.isRestart); data 121 plugin/svipc/sysvipc.cpp SysVSem::instance().refill(data->refillInfo.isRestart); data 122 plugin/svipc/sysvipc.cpp SysVMsq::instance().refill(data->refillInfo.isRestart); data 133 plugin/svipc/sysvipc.cpp jalib::JBinarySerializeWriterRaw wr("", data->serializerInfo.fd); data 142 plugin/svipc/sysvipc.cpp jalib::JBinarySerializeReaderRaw rd("", data->serializerInfo.fd); data 158 plugin/svipc/sysvipc.cpp DMTCP_NEXT_EVENT_HOOK(event, data); data 42 plugin/timer/timerlist.cpp void dmtcp_event_hook(DmtcpEvent_t event, DmtcpEventData_t *data) data 63 plugin/timer/timerlist.cpp DMTCP_NEXT_EVENT_HOOK(event, data); data 24 plugin/timer/tmp.cpp void dmtcp_event_hook(DmtcpEvent_t event, DmtcpEventData_t *data) data 26 plugin/timer/tmp.cpp DMTCP_NEXT_EVENT_HOOK(event,data); data 53 processinfo.cpp void dmtcp_ProcessInfo_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 62 processinfo.cpp jalib::JBinarySerializeWriterRaw wr("", data->serializerInfo.fd); data 70 processinfo.cpp jalib::JBinarySerializeReaderRaw rd("", data->serializerInfo.fd); data 86 processinfo.cpp if (data->refillInfo.isRestart) { data 96 processinfo.cpp if (data->refillInfo.isRestart) { data 33 procname.cpp void dmtcp_ProcName_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 46 procname.cpp if (data->resumeUserThreadInfo.isRestart) { data 53 procselfmaps.cpp data = (char*) JALLOC_HELPER_MALLOC(size); data 56 procselfmaps.cpp numBytes = Util::readAll(fd, data, size); data 69 procselfmaps.cpp if (data[i] == '\n') { data 77 procselfmaps.cpp JALLOC_HELPER_FREE(data); data 95 procselfmaps.cpp char c = data[dataIdx]; data 112 procselfmaps.cpp char c = data[dataIdx]; data 132 procselfmaps.cpp if (dataIdx >= numBytes || data[dataIdx] == 0) { data 139 procselfmaps.cpp JASSERT(data[dataIdx++] == '-'); data 144 procselfmaps.cpp JASSERT(data[dataIdx++] == ' '); data 149 procselfmaps.cpp rflag = data[dataIdx++]; data 152 procselfmaps.cpp wflag = data[dataIdx++]; data 155 procselfmaps.cpp xflag = data[dataIdx++]; data 158 procselfmaps.cpp sflag = data[dataIdx++]; data 161 procselfmaps.cpp JASSERT(data[dataIdx++] == ' '); data 164 procselfmaps.cpp JASSERT(data[dataIdx++] == ' '); data 167 procselfmaps.cpp JASSERT(data[dataIdx++] == ':'); data 170 procselfmaps.cpp JASSERT(data[dataIdx++] == ' '); data 174 procselfmaps.cpp while (data[dataIdx] == ' ') { data 179 procselfmaps.cpp if (data[dataIdx] == '/' || data[dataIdx] == '[' || data[dataIdx] == '(') { data 184 procselfmaps.cpp while (data[dataIdx] != '\n') { data 185 procselfmaps.cpp area->name[i++] = data[dataIdx++]; data 191 procselfmaps.cpp JASSERT(data[dataIdx++] == '\n'); data 47 shareddata.cpp void dmtcp_SharedData_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 40 syslogwrappers.cpp void dmtcp_Syslog_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 24 terminal.cpp void dmtcp_Terminal_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data) data 32 terminal.cpp if (data->resumeInfo.isRestart) { data 34 uniquepid.cpp void dmtcp_UniquePid_EventHook(DmtcpEvent_t event, DmtcpEventData_t *data)