len 455 ckptserializer.cpp const ssize_t len = strlen(DMTCP_FILE_HEADER);
len 456 ckptserializer.cpp JASSERT(write(fd, DMTCP_FILE_HEADER, len) == len);
len 460 ckptserializer.cpp ssize_t written = len + wr.bytes();
len 374 coordinatorapi.cpp size_t len)
len 380 coordinatorapi.cpp JASSERT(len == msg.extraBytes);
len 562 coordinatorapi.cpp uint32_t len;
len 563 coordinatorapi.cpp SharedData::getCoordAddr((struct sockaddr *)&addr, &len);
len 564 coordinatorapi.cpp socklen_t addrlen = len;
len 84 coordinatorapi.h size_t len = 0);
len 487 dmtcp_coordinator.cpp socklen_t len,
len 36 dmtcp_coordinator.h socklen_t len,
len 103 dmtcp_coordinator.h socklen_t len);
len 107 dmtcp_coordinator.h socklen_t len);
len 399 dmtcp_restart.cpp const size_t len = strlen(DMTCP_FILE_HEADER);
len 403 dmtcp_restart.cpp size_t numRead = len + rdr.bytes();
len 545 dmtcp_restart.cpp const int len = strlen(DMTCP_FILE_HEADER);
len 546 dmtcp_restart.cpp JASSERT(read(fd, buf, len) == len)(path) .Text("read() failed");
len 547 dmtcp_restart.cpp if (strncmp(buf, DMTCP_FILE_HEADER, len) == 0) {
len 74 lookup_service.cpp *valLen = v->len();
len 75 lookup_service.cpp *val = new char[v->len()];
len 34 lookup_service.h KeyValue(const void *data, const size_t len) {
len 35 lookup_service.h _data = JALLOC_HELPER_MALLOC(len);
len 36 lookup_service.h _len = len;
len 37 lookup_service.h memcpy(_data, data, len);
len 47 lookup_service.h size_t len() {return _len;}
len 70 mtcp/mtcp_util.c size_t len = 0;
len 72 mtcp/mtcp_util.c len++;
len 74 mtcp/mtcp_util.c return len;
len 187 mtcp/mtcp_util.c void *mtcp_memcpy(void *dstpp, const void *srcpp, size_t len)
len 191 mtcp/mtcp_util.c while (len > 0) {
len 193 mtcp/mtcp_util.c len--;
len 225 mtcp/mtcp_util.c size_t len = mtcp_strlen(dir);
len 226 mtcp/mtcp_util.c MTCP_ASSERT(len < PATH_MAX);
len 231 mtcp/mtcp_util.c while (tmp[len - 1] == '/') {
len 232 mtcp/mtcp_util.c tmp[len - 1] = 0;
len 233 mtcp/mtcp_util.c len--;
len 236 mtcp/mtcp_util.c for(i = 1; i < len; i++) {
len 80 mtcp/mtcp_util.h mtcp_sys_memmove (void *a1, const void *a2, size_t len)
len 87 mtcp/mtcp_util.h if (dstp - srcp >= len) /* *Unsigned* compare! */
len 92 mtcp/mtcp_util.h MTCP_BYTE_COPY_FWD (dstp, srcp, len);
len 97 mtcp/mtcp_util.h srcp += len;
len 98 mtcp/mtcp_util.h dstp += len;
len 101 mtcp/mtcp_util.h MTCP_BYTE_COPY_BWD (dstp, srcp, len);
len 116 mtcp/mtcp_util.h mtcp_sys_memcpy (void *dstpp, const void *srcpp, size_t len)
len 123 mtcp/mtcp_util.h MTCP_BYTE_COPY_FWD(dstp, srcp, len);
len 134 mtcp/mtcp_util.h mtcp_sys_memcmp (s1, s2, len)
len 137 mtcp/mtcp_util.h size_t len;
len 146 mtcp/mtcp_util.h while (len != 0)
len 155 mtcp/mtcp_util.h len -= 1;
len 176 mtcp/mtcp_util.h void mtcp_strncpy(char *targ, const char* source, size_t len);
len 185 mtcp/mtcp_util.h void mtcp_sys_memcpy (void *dstpp, const void *srcpp, size_t len);
len 148 mtcp/restore_libc.c static char *memsubarray (char *array, char *subarray, size_t len)
len 234 mtcp/restore_libc.c static char *memsubarray (char *array, char *subarray, size_t len)
len 240 mtcp/restore_libc.c ASSERT (len >= sizeof(int));
len 243 mtcp/restore_libc.c for (j = 0; j < len; j++)
len 246 mtcp/restore_libc.c if (j == len)
len 175 mtcpinterface.cpp size_t len;
len 176 mtcpinterface.cpp len = (ProcessInfo::instance().argvSize() + page_size) & page_mask;
len 181 mtcpinterface.cpp for (size_t i = 0; i < len; i += page_size) {
len 191 mtcpinterface.cpp void *retAddr = mmap((void*) startAddr, len, PROT_READ | PROT_WRITE,
len 195 mtcpinterface.cpp (mtcpRestoreArgvStartAddr) (startAddr) (len) (JASSERT_ERRNO) ;
len 201 mtcpinterface.cpp if (addr + args[i].length() >= startAddr + len)
len 208 mtcpinterface.cpp JTRACE("Unable to restore /proc/self/cmdline") (startAddr) (len) (JASSERT_ERRNO) ;
len 221 mtcpinterface.cpp size_t len;
len 222 mtcpinterface.cpp len = (ProcessInfo::instance().argvSize() + page_size) & page_mask;
len 223 mtcpinterface.cpp JASSERT(_real_munmap(_mtcpRestoreArgvStartAddr, len) == 0)
len 224 mtcpinterface.cpp (_mtcpRestoreArgvStartAddr) (len)
len 557 plugin/ipc/connectionlist.cpp maps[idx].addr, maps[idx].len) != -1);
len 113 plugin/ipc/socket/connectionrewirer.cpp JASSERT(_real_connect(fd, (sockaddr*) &remoteAddr.addr, remoteAddr.len)
len 295 plugin/ipc/socket/connectionrewirer.cpp uint32_t len = sizeof(remote.addr);
len 298 plugin/ipc/socket/connectionrewirer.cpp &remote.addr, &len);
len 299 plugin/ipc/socket/connectionrewirer.cpp remote.len = len;
len 41 plugin/ipc/socket/connectionrewirer.h socklen_t len;
len 62 plugin/ipc/socket/connectionrewirer.h void registerNSData(void *addr, socklen_t len, ConnectionListT *conList);
len 38 plugin/ipc/socket/kernelbufferdrainer.cpp unsigned len = sizeof(size);
len 39 plugin/ipc/socket/kernelbufferdrainer.cpp JASSERT(getsockopt(fd, SOL_SOCKET, SO_SNDBUF, (void *)&size, &len) == 0);
len 44 plugin/ipc/socket/kernelbufferdrainer.cpp len = sizeof(newSize);
len 45 plugin/ipc/socket/kernelbufferdrainer.cpp JASSERT(_real_setsockopt(fd, SOL_SOCKET, SO_SNDBUF, (void *)&newSize, len) == 0);
len 52 plugin/ipc/socket/socketconnection.cpp static int _makeDeadSocket(const char *refillData = NULL, ssize_t len = -1)
len 61 plugin/ipc/socket/socketconnection.cpp JASSERT(Util::writeAll(sp[1], refillData, len) == len);
len 78 plugin/ipc/socket/socketconnection.cpp const char* value, int len)
len 80 plugin/ipc/socket/socketconnection.cpp _sockOptions[level][option] = jalib::JBuffer(value, len);
len 219 plugin/ipc/socket/socketconnection.cpp bool TcpConnection::isBlacklistedTcp(const sockaddr* saddr, socklen_t len)
len 222 plugin/ipc/socket/socketconnection.cpp if (len <= sizeof(saddr->sa_family)) {
len 271 plugin/ipc/socket/socketconnection.cpp void TcpConnection::onBind(const struct sockaddr* addr, socklen_t len)
len 274 plugin/ipc/socket/socketconnection.cpp JTRACE("Binding.") (id()) (len);
len 282 plugin/ipc/socket/socketconnection.cpp JASSERT(len <= sizeof _bindAddr) (len) (sizeof _bindAddr)
len 284 plugin/ipc/socket/socketconnection.cpp _bindAddrlen = len;
len 285 plugin/ipc/socket/socketconnection.cpp memcpy(&_bindAddr, addr, len);
len 321 plugin/ipc/socket/socketconnection.cpp void TcpConnection::onConnect(const struct sockaddr *addr, socklen_t len)
len 329 plugin/ipc/socket/socketconnection.cpp if (addr != NULL && isBlacklistedTcp(addr, len)) {
len 331 plugin/ipc/socket/socketconnection.cpp _connectAddrlen = len;
len 332 plugin/ipc/socket/socketconnection.cpp memcpy(&_connectAddr, addr, len);
len 55 plugin/ipc/socket/socketconnection.h void addSetsockopt(int level, int option, const char* value, int len);
len 88 plugin/ipc/socket/socketconnection.h bool isBlacklistedTcp(const sockaddr* saddr, socklen_t len);
len 93 plugin/ipc/socket/socketconnection.h void onBind(const struct sockaddr* addr, socklen_t len);
len 324 plugin/ipc/socket/socketwrappers.cpp socklen_t len, int type)
len 328 plugin/ipc/socket/socketwrappers.cpp struct hostent *ret = _real_gethostbyaddr(addr, len, type);
len 49 plugin/ipc/ssh/dmtcp_sshd.cpp socklen_t len;
len 53 plugin/ipc/ssh/dmtcp_sshd.cpp len = sizeof(addr.sun_family) + strlen(listenAddr) + 1;
len 65 plugin/ipc/ssh/dmtcp_sshd.cpp if (sendFd(sendfd, fd, &fd, sizeof(fd), addr, len) == -1) {
len 70 plugin/ipc/ssh/dmtcp_sshd.cpp if (sendFd(sendfd, fd, &fd, sizeof(fd), addr, len) == -1) {
len 75 plugin/ipc/ssh/dmtcp_sshd.cpp if (sendFd(sendfd, fd, &fd, sizeof(fd), addr, len) == -1) {
len 80 plugin/ipc/ssh/dmtcp_sshd.cpp if (sendFd(sendfd, fd, &fd, sizeof(fd), addr, len) == -1) {
len 19 plugin/ipc/ssh/util_ssh.cpp int len;
len 39 plugin/ipc/ssh/util_ssh.cpp buf->len = MAX_BUFFER_SIZE;
len 46 plugin/ipc/ssh/util_ssh.cpp buf->len = 0;
len 58 plugin/ipc/ssh/util_ssh.cpp assert(buf->buf != NULL && buf->len != 0);
len 59 plugin/ipc/ssh/util_ssh.cpp return buf->end < buf->len - 1;
len 64 plugin/ipc/ssh/util_ssh.cpp assert(buf->buf != NULL && buf->len != 0);
len 66 plugin/ipc/ssh/util_ssh.cpp if (buf->end < buf->len) {
len 67 plugin/ipc/ssh/util_ssh.cpp size_t max = buf->len - buf->end;
len 79 plugin/ipc/ssh/util_ssh.cpp assert(buf->buf != NULL && buf->len != 0);
len 85 plugin/ipc/ssh/util_ssh.cpp assert(buf->buf != NULL && buf->len != 0);
len 95 plugin/ipc/ssh/util_ssh.cpp if (buf->off > buf->len / 2) {
len 244 shareddata.cpp char *SharedData::getTmpDir(char *buf, uint32_t len)
len 248 shareddata.cpp if (len <= strlen(sharedDataHeader->tmpDir)) {
len 290 shareddata.cpp void SharedData::getCoordAddr(struct sockaddr *addr, uint32_t *len)
len 294 shareddata.cpp *len = sharedDataHeader->coordInfo.addrLen;
len 295 shareddata.cpp memcpy(addr, &sharedDataHeader->coordInfo.addr, *len);
len 490 shareddata.cpp void SharedData::createVirtualPtyName(const char* real, char *out, uint32_t len)
len 505 shareddata.cpp JASSERT(len > virt.length());
len 510 shareddata.cpp void SharedData::getRealPtyName(const char* virt, char *out, uint32_t len)
len 517 shareddata.cpp JASSERT(strlen(sharedDataHeader->ptyNameMap[i].real) < len);
len 525 shareddata.cpp void SharedData::getVirtPtyName(const char* real, char *out, uint32_t len)
len 532 shareddata.cpp JASSERT(strlen(sharedDataHeader->ptyNameMap[i].virt) < len);
len 554 shareddata.cpp socklen_t len)
len 561 shareddata.cpp memcpy(&sharedDataHeader->incomingConMap[n].addr, &receiverAddr, len);
len 562 shareddata.cpp sharedDataHeader->incomingConMap[n].len = len;
len 161 util_exec.cpp const int len = strlen(magic_elf32);
len 162 util_exec.cpp char argv_buf[len + 1];
len 169 util_exec.cpp ssize_t ret = readAll(fd, argv_buf, len);
len 171 util_exec.cpp if (ret != len) {
len 586 util_misc.cpp int len;
len 596 util_misc.cpp len = 0;
len 597 util_misc.cpp while (*tmp_env != ':' && *tmp_env != '\0' && ++len < PATH_MAX - 1)
len 602 util_misc.cpp len++;
len 604 util_misc.cpp strncat(exec_path, executable, PATH_MAX - len - 1);