type 235 coordinatorapi.cpp JASSERT(msg.type == DMT_USER_CMD) (msg.type)
type 304 coordinatorapi.cpp msg.type = DMT_USER_CMD;
type 326 coordinatorapi.cpp JASSERT(reply.type == DMT_USER_CMD_RESULT);
type 355 coordinatorapi.cpp JASSERT(msg.type == DMT_GET_CKPT_DIR_RESULT) (msg.type);
type 500 coordinatorapi.cpp if (msg.type == DMT_KILL_PEER) {
type 504 coordinatorapi.cpp if (msg.type == DMT_REJECT_NOT_RUNNING) {
type 509 coordinatorapi.cpp } else if (msg.type == DMT_REJECT_WRONG_COMP) {
type 515 coordinatorapi.cpp JASSERT(msg.type == DMT_ACCEPT);
type 629 coordinatorapi.cpp msg.type = DMT_UNIQUE_CKPT_FILENAME;
type 631 coordinatorapi.cpp msg.type = DMT_CKPT_FILENAME;
type 649 coordinatorapi.cpp msg.type = DMT_REGISTER_NAME_SERVICE_DATA_SYNC;
type 675 coordinatorapi.cpp JASSERT(msg.type == DMT_REGISTER_NAME_SERVICE_DATA_SYNC_RESPONSE)(msg.type);
type 721 coordinatorapi.cpp JASSERT(msg.type == DMT_NAME_SERVICE_QUERY_RESPONSE &&
type 777 dmtcp_coordinator.cpp switch ( msg.type )
type 872 dmtcp_coordinator.cpp JWARNING(false) (msg.type) .Text("unexpected message from worker. Closing connection");
type 876 dmtcp_coordinator.cpp JASSERT ( false ) ( msg.from ) ( msg.type )
type 979 dmtcp_coordinator.cpp if (hello_remote.type == DMT_NAME_SERVICE_WORKER) {
type 986 dmtcp_coordinator.cpp if (hello_remote.type == DMT_NAME_SERVICE_QUERY) {
type 997 dmtcp_coordinator.cpp if (hello_remote.type == DMT_REGISTER_NAME_SERVICE_DATA) {
type 1008 dmtcp_coordinator.cpp if (hello_remote.type == DMT_REGISTER_NAME_SERVICE_DATA_SYNC) {
type 1024 dmtcp_coordinator.cpp if (hello_remote.type == DMT_USER_CMD) {
type 1036 dmtcp_coordinator.cpp msg.type = DMT_KILL_PEER;
type 1055 dmtcp_coordinator.cpp if (hello_remote.type == DMT_RESTART_WORKER) {
type 1063 dmtcp_coordinator.cpp } else if (hello_remote.type == DMT_NEW_WORKER) {
type 1074 dmtcp_coordinator.cpp JASSERT(false) (hello_remote.type)
type 1093 dmtcp_coordinator.cpp reply.type = DMT_USER_CMD_RESULT;
type 1145 dmtcp_coordinator.cpp hello_local.type = DMT_REJECT_NOT_RESTARTING;
type 1153 dmtcp_coordinator.cpp hello_local.type = DMT_REJECT_WRONG_COMP;
type 1234 dmtcp_coordinator.cpp hello_local.type = DMT_REJECT_NOT_RUNNING;
type 1245 dmtcp_coordinator.cpp hello_local.type = DMT_REJECT_WRONG_COMP;
type 1311 dmtcp_coordinator.cpp void DmtcpCoordinator::broadcastMessage(DmtcpMessageType type, int numPeers)
type 1314 dmtcp_coordinator.cpp msg.type = type;
type 1320 dmtcp_coordinator.cpp if (msg.type == DMT_KILL_PEER && clients.size() > 0) {
type 1322 dmtcp_coordinator.cpp } else if (msg.type == DMT_DO_FD_LEADER_ELECTION) {
type 1331 dmtcp_coordinator.cpp JTRACE ("sending message")( type );
type 91 dmtcp_coordinator.h void broadcastMessage(DmtcpMessageType type, int numPeers = -1);
type 141 dmtcpmessagetypes.h DmtcpMessageType type;
type 430 dmtcpworker.cpp DmtcpMessageType type)
type 433 dmtcpworker.cpp if (type == DMT_DO_SUSPEND) {
type 444 dmtcpworker.cpp if (type == DMT_DO_SUSPEND) {
type 458 dmtcpworker.cpp if (type == DMT_DO_SUSPEND) {
type 463 dmtcpworker.cpp msg.type = DMT_OK;
type 470 dmtcpworker.cpp if (type == DMT_DO_SUSPEND && exitInProgress()) {
type 476 dmtcpworker.cpp if (msg.type == DMT_KILL_PEER) {
type 481 dmtcpworker.cpp JASSERT(msg.type == type) (msg.type) (type);
type 485 dmtcpworker.cpp if (type == DMT_DO_SUSPEND) {
type 489 dmtcpworker.cpp } else if (type == DMT_DO_FD_LEADER_ELECTION) {
type 502 dmtcpworker.cpp msg.type = DMT_OK;
type 44 dmtcpworker.h DmtcpMessageType type);
type 235 miscwrappers.cpp #define SYSCALL_GET_ARG(type,arg) type arg = va_arg(ap, type)
type 376 miscwrappers.cpp SYSCALL_GET_ARGS_3(int,domain,int,type,int,protocol);
type 377 miscwrappers.cpp ret = socket(domain,type,protocol);
type 421 miscwrappers.cpp SYSCALL_GET_ARGS_4(int,d,int,type,int,protocol,int*,sv);
type 422 miscwrappers.cpp ret = socketpair(d,type,protocol,sv);
type 78 nosyscallsreal.c #define REAL_FUNC_PASSTHROUGH_TYPED(type, name) REAL_FUNC_PASSTHROUGH(name)
type 79 nosyscallsreal.c #define REAL_FUNC_PASSTHROUGH_TYPED_DLSYM(type, name) return dlsym(RTLD_NEXT, #name)
type 137 nosyscallsreal.c int _real_socket (int domain, int type, int protocol)
type 139 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (socket) (domain,type,protocol);
type 246 nosyscallsreal.c int _real_socketpair (int d, int type, int protocol, int sv[2])
type 248 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (socketpair) (d,type,protocol,sv);
type 85 plugin/ipc/connectionidentifier.h type = t;
type 92 plugin/ipc/connectionidentifier.h type = INVALID;
type 100 plugin/ipc/connectionidentifier.h JASSERT(type == t) ((int)t) ((int)type) .Text("Wrong Msg Type.");
type 107 plugin/ipc/connectionidentifier.h int32_t type;
type 239 plugin/ipc/connectionlist.cpp uint32_t type = con.conType();
type 242 plugin/ipc/connectionlist.cpp o & key & type;
type 249 plugin/ipc/connectionlist.cpp int type = -1;
type 253 plugin/ipc/connectionlist.cpp o & key & type;
type 254 plugin/ipc/connectionlist.cpp con = createDummyConnection(type);
type 81 plugin/ipc/connectionlist.h virtual Connection *createDummyConnection(int type) = 0;
type 338 plugin/ipc/event/eventconnection.cpp watch_descriptor.add_watch.type = INOTIFY_ADD_WATCH_DESCRIPTOR;
type 81 plugin/ipc/event/eventconnection.h EpollConnection(int size, int type=EPOLL_CREATE)
type 83 plugin/ipc/event/eventconnection.h _type(type),
type 33 plugin/ipc/event/eventconnlist.cpp Connection *EventConnList::createDummyConnection(int type)
type 35 plugin/ipc/event/eventconnlist.cpp switch (type) {
type 13 plugin/ipc/event/eventconnlist.h virtual Connection *createDummyConnection(int type);
type 148 plugin/ipc/event/util_descriptor.cpp int Util::Descriptor::remove_descriptor(descriptor_type_e type,
type 155 plugin/ipc/event/util_descriptor.cpp switch(type)
type 177 plugin/ipc/event/util_descriptor.cpp JTRACE("Unknown descriptor type") (type);
type 198 plugin/ipc/event/util_descriptor.cpp descriptor_type_e type,
type 203 plugin/ipc/event/util_descriptor.cpp JTRACE("get descriptor") (index) (type);
type 204 plugin/ipc/event/util_descriptor.cpp if((descrip_types_p[index])->add_watch.type == type)
type 211 plugin/ipc/event/util_descriptor.cpp JTRACE("descriptor type is different from type saved") (type) ((descrip_types_p[index])->add_watch.type);
type 250 plugin/ipc/event/util_descriptor.cpp if((descrip_types_p[i])->create_timer.type == TIMER_CREATE_DECRIPTOR)
type 257 plugin/ipc/event/util_descriptor.cpp (descrip_types_p[i])->create_timer.type = UNUSED_DESCRIPTOR;
type 285 plugin/ipc/event/util_descriptor.cpp if((descrip_types_p[i])->add_watch.type == INOTIFY_ADD_WATCH_DESCRIPTOR)
type 293 plugin/ipc/event/util_descriptor.cpp (descrip_types_p[i])->add_watch.type = UNUSED_DESCRIPTOR;
type 54 plugin/ipc/event/util_descriptor.h descriptor_type_e type;
type 63 plugin/ipc/event/util_descriptor.h descriptor_type_e type;
type 91 plugin/ipc/event/util_descriptor.h int remove_descriptor(descriptor_type_e type, void* descriptor);
type 92 plugin/ipc/event/util_descriptor.h bool get_descriptor(unsigned int index, descriptor_type_e type,
type 229 plugin/ipc/file/fileconnection.cpp int flags, mode_t mode, int type)
type 236 plugin/ipc/file/fileconnection.cpp _type = type;
type 60 plugin/ipc/file/fileconnection.h PtyConnection(int fd, const char *path, int flags, mode_t mode, int type);
type 127 plugin/ipc/file/fileconnection.h int type = FILE_REGULAR)
type 135 plugin/ipc/file/fileconnection.h _type = type;
type 488 plugin/ipc/file/fileconnlist.cpp int type = FileConnection::FILE_REGULAR;
type 491 plugin/ipc/file/fileconnlist.cpp type = FileConnection::FILE_BATCH_QUEUE;
type 493 plugin/ipc/file/fileconnlist.cpp c = new FileConnection(path, flags, mode, type);
type 505 plugin/ipc/file/fileconnlist.cpp Connection *FileConnList::createDummyConnection(int type)
type 507 plugin/ipc/file/fileconnlist.cpp switch (type) {
type 56 plugin/ipc/file/fileconnlist.h virtual Connection *createDummyConnection(int type);
type 70 plugin/ipc/socket/socketconnection.cpp SocketConnection::SocketConnection(int domain, int type, int protocol)
type 72 plugin/ipc/socket/socketconnection.cpp , _sockType(type)
type 177 plugin/ipc/socket/socketconnection.cpp TcpConnection::TcpConnection(int domain, int type, int protocol)
type 179 plugin/ipc/socket/socketconnection.cpp , SocketConnection(domain, type, protocol)
type 186 plugin/ipc/socket/socketconnection.cpp if ((type & 077) == SOCK_DGRAM) {
type 187 plugin/ipc/socket/socketconnection.cpp JWARNING(false) (type)
type 192 plugin/ipc/socket/socketconnection.cpp && (type & 077) == SOCK_STREAM)
type 193 plugin/ipc/socket/socketconnection.cpp (domain) (type) (protocol);
type 195 plugin/ipc/socket/socketconnection.cpp JTRACE("Creating TcpConnection.") (id()) (domain) (type) (protocol);
type 639 plugin/ipc/socket/socketconnection.cpp RawSocketConnection::RawSocketConnection(int domain, int type, int protocol)
type 641 plugin/ipc/socket/socketconnection.cpp , SocketConnection(domain, type, protocol)
type 643 plugin/ipc/socket/socketconnection.cpp JASSERT(type == -1 ||(type & SOCK_RAW));
type 646 plugin/ipc/socket/socketconnection.cpp JTRACE("Creating Raw socket.") (id()) (domain) (type) (protocol);
type 54 plugin/ipc/socket/socketconnection.h SocketConnection(int domain, int type, int protocol);
type 92 plugin/ipc/socket/socketconnection.h TcpConnection(int domain, int type, int protocol);
type 139 plugin/ipc/socket/socketconnection.h RawSocketConnection(int domain, int type, int protocol);
type 187 plugin/ipc/socket/socketconnlist.cpp Connection *SocketConnList::createDummyConnection(int type)
type 189 plugin/ipc/socket/socketconnlist.cpp if (type == Connection::TCP) {
type 191 plugin/ipc/socket/socketconnlist.cpp } else if (type == Connection::RAW){
type 32 plugin/ipc/socket/socketconnlist.h virtual Connection *createDummyConnection(int type);
type 53 plugin/ipc/socket/socketwrappers.cpp extern "C" int socket(int domain, int type, int protocol)
type 56 plugin/ipc/socket/socketwrappers.cpp int ret = _real_socket(domain, type, protocol);
type 59 plugin/ipc/socket/socketwrappers.cpp JTRACE("socket created") (ret) (domain) (type) (protocol);
type 60 plugin/ipc/socket/socketwrappers.cpp if ((type & 0xff) == SOCK_RAW) {
type 61 plugin/ipc/socket/socketwrappers.cpp JASSERT(domain == AF_NETLINK) (domain) (type)
type 63 plugin/ipc/socket/socketwrappers.cpp con = new RawSocketConnection(domain, type, protocol);
type 65 plugin/ipc/socket/socketwrappers.cpp con = new TcpConnection(domain, type, protocol);
type 264 plugin/ipc/socket/socketwrappers.cpp extern "C" int socketpair(int d, int type, int protocol, int sv[2])
type 269 plugin/ipc/socket/socketwrappers.cpp int rv = _real_socketpair(d,type,protocol,sv);
type 275 plugin/ipc/socket/socketwrappers.cpp a = new TcpConnection(d, type, protocol);
type 324 plugin/ipc/socket/socketwrappers.cpp socklen_t len, int type)
type 328 plugin/ipc/socket/socketwrappers.cpp struct hostent *ret = _real_gethostbyaddr(addr, len, type);
type 275 plugin/pid/pid_miscwrappers.cpp #define SYSCALL_GET_ARG(type,arg) type arg = va_arg(ap, type)
type 95 plugin/pid/pid_syscallsreal.c #define REAL_FUNC_PASSTHROUGH_TYPED(type,name) \
type 96 plugin/pid/pid_syscallsreal.c static type (*fn)() = NULL; \
type 290 plugin/svipc/dmtcp-test.h EXTERNC int dmtcp_bq_should_ckpt_file(const char *path, int *type)
type 293 plugin/svipc/dmtcp-test.h int fcntlFlags, int type)
type 228 plugin/svipc/sysvipc.cpp SysVIPC::SysVIPC(const char *str, int32_t id, int type)
type 230 plugin/svipc/sysvipc.cpp _type(type)
type 80 plugin/svipc/sysvipc.h SysVIPC(const char *str, int32_t id, int type);
type 375 shareddata.cpp int32_t SharedData::getRealIPCId(int type, int32_t virt)
type 382 shareddata.cpp switch (type) {
type 399 shareddata.cpp JASSERT(false) (type) .Text("Unknown IPC-Id type.");
type 411 shareddata.cpp void SharedData::setIPCIdMap(int type, int32_t virt, int32_t real)
type 418 shareddata.cpp switch (type) {
type 435 shareddata.cpp JASSERT(false) (type) .Text("Unknown IPC-Id type.");
type 334 syscallsreal.c #define REAL_FUNC_PASSTHROUGH_TYPED(type,name) \
type 335 syscallsreal.c static type (*fn)() = NULL; \
type 526 syscallsreal.c int _real_socket (int domain, int type, int protocol)
type 528 syscallsreal.c REAL_FUNC_PASSTHROUGH (socket) (domain,type,protocol);
type 695 syscallsreal.c int _real_socketpair (int d, int type, int protocol, int sv[2])
type 697 syscallsreal.c REAL_FUNC_PASSTHROUGH (socketpair) (d,type,protocol,sv);
type 289 syscallwrappers.h int _real_socket (int domain, int type, int protocol);
type 340 syscallwrappers.h int _real_socketpair (int d, int type, int protocol, int sv[2]);