size 515 dmtcp_coordinator.cpp JASSERT(_virtualPidToClientMap.size() < MAX_VIRTUAL_PID/1000)
size 570 dmtcp_coordinator.cpp for (size_t i = 0; i < clients.size(); i++) {
size 588 dmtcp_coordinator.cpp for (size_t i = 0; i < clients.size(); i++) {
size 907 dmtcp_coordinator.cpp for (size_t i = 0; i < clients.size(); i++) {
size 1044 dmtcp_coordinator.cpp if (clients.size() == 0) {
size 1084 dmtcp_coordinator.cpp JTRACE("END") (clients.size());
size 1320 dmtcp_coordinator.cpp if (msg.type == DMT_KILL_PEER && clients.size() > 0) {
size 1328 dmtcp_coordinator.cpp for (size_t i = 0; i < clients.size(); i++) {
size 1343 dmtcp_coordinator.cpp for (size_t i = 0; i < clients.size(); i++) {
size 1380 dmtcp_coordinator.cpp const bool isSingleHost = (_restartFilenames.size() == 1);
size 1429 dmtcp_coordinator.cpp _restartFilenames.size(), getStatus().numPeers );
size 760 dmtcp_restart.cpp JASSERT(independentProcessTreeRoots.size() > 0)
size 189 dmtcpworker.cpp for (size_t i = 0; i < args.size(); i++) {
size 384 execwrappers.cpp for (size_t i = 0; i < pluginLibraries.size(); i++) {
size 420 execwrappers.cpp for (size_t i = 0; i < s.size(); i++) {
size 452 execwrappers.cpp for (size_t i = 0; i < env.size(); i++) {
size 453 miscwrappers.cpp SYSCALL_GET_ARGS_3(key_t,key,size_t,size,int,shmflg);
size 454 miscwrappers.cpp ret = shmget(key, size, shmflg);
size 485 miscwrappers.cpp SYSCALL_GET_ARG(int,size);
size 486 miscwrappers.cpp ret = epoll_create(size);
size 122 mtcp/mtcp_restart.c static int hasOverlappingMapping(VA addr, size_t size);
size 123 mtcp/mtcp_restart.c static void getTextAddr(VA *textAddr, size_t *size);
size 488 mtcp/mtcp_restart.c if (area.size == -1) break;
size 490 mtcp/mtcp_restart.c void *addr = mtcp_sys_mmap(0, area.size, PROT_WRITE | PROT_READ,
size 496 mtcp/mtcp_restart.c mtcp_readfile(fd, addr, area.size);
size 497 mtcp/mtcp_restart.c if (mtcp_sys_munmap(addr, area.size) == -1) {
size 506 mtcp/mtcp_restart.c area.addr, area.addr + area.size,
size 626 mtcp/mtcp_restart.c } else if (area.size > 0 ) {
size 628 mtcp/mtcp_restart.c if (mtcp_sys_munmap(area.addr, area.size) == -1) {
size 630 mtcp/mtcp_restart.c area.name, area.flags, area.addr, area.size,
size 803 mtcp/mtcp_restart.c if (area.size == -1) return -1;
size 806 mtcp/mtcp_restart.c && mtcp_sys_brk(NULL) != area.addr + area.size) {
size 808 mtcp/mtcp_restart.c mtcp_sys_brk(NULL), area.addr + area.size);
size 824 mtcp/mtcp_restart.c area.size, area.addr);
size 825 mtcp/mtcp_restart.c mmappedat = mtcp_sys_mmap (area.addr, area.size,
size 831 mtcp/mtcp_restart.c mtcp_sys_errno, area.size, area.addr);
size 858 mtcp/mtcp_restart.c area.size, area.addr);
size 862 mtcp/mtcp_restart.c area.size, area.addr, area.name, area.offset);
size 871 mtcp/mtcp_restart.c mmappedat = mtcp_sys_mmap (area.addr, area.size, area.prot | PROT_WRITE,
size 876 mtcp/mtcp_restart.c mtcp_sys_errno, area.size, area.addr);
size 899 mtcp/mtcp_restart.c mtcp_skipfile(fd, area.size);
size 905 mtcp/mtcp_restart.c mtcp_readfile(fd, area.addr, area.size);
size 907 mtcp/mtcp_restart.c if (mtcp_sys_mprotect (area.addr, area.size, area.prot) < 0) {
size 909 mtcp/mtcp_restart.c mtcp_sys_errno, area.size, area.addr);
size 933 mtcp/mtcp_restart.c if (area->offset + area->size > curr_size) {
size 934 mtcp/mtcp_restart.c size_t diff_in_size = (area->offset + area->size) - curr_size;
size 937 mtcp/mtcp_restart.c VA anon_start_addr = area->addr + (area->size - anon_area_size);
size 941 mtcp/mtcp_restart.c area->name, curr_size, area->size);
size 1023 mtcp/mtcp_restart.c static int hasOverlappingMapping(VA addr, size_t size)
size 1035 mtcp/mtcp_restart.c if (doAreasOverlap(addr, size, area.addr, area.size)) {
size 1045 mtcp/mtcp_restart.c static void getTextAddr(VA *text_addr, size_t *size)
size 1068 mtcp/mtcp_restart.c (area.addr < this_fn && (area.addr + area.size) > this_fn)) {
size 1070 mtcp/mtcp_restart.c *size = area.size;
size 246 mtcp/mtcp_util.c int mtcp_readfile(int fd, void *buf, size_t size)
size 263 mtcp/mtcp_util.c while(ar != size) {
size 264 mtcp/mtcp_util.c rc = mtcp_sys_read(fd, buf + ar, size - ar);
size 276 mtcp/mtcp_util.c (unsigned)ar, (unsigned)size);
size 300 mtcp/mtcp_util.c void mtcp_skipfile(int fd, size_t size)
size 303 mtcp/mtcp_util.c VA tmp_addr = mtcp_sys_mmap(0, size, PROT_WRITE | PROT_READ,
size 309 mtcp/mtcp_util.c mtcp_readfile(fd, tmp_addr, size);
size 310 mtcp/mtcp_util.c if (mtcp_sys_munmap(tmp_addr, size) == -1) {
size 463 mtcp/mtcp_util.c area -> size = endaddr - startaddr;
size 526 mtcp/mtcp_util.c VA end_addr = area.addr + area.size;
size 546 mtcp/mtcp_util.c MTCP_ASSERT(mtcp_sys_mmap(start_addr, area.size, PROT_READ,
size 627 mtcp/mtcp_util.c static void rwrite (char const *buff, int size) {
size 628 mtcp/mtcp_util.c mtcp_write_all(2, buff, size);
size 167 mtcp/mtcp_util.h int mtcp_readfile(int fd, void *buf, size_t size);
size 168 mtcp/mtcp_util.h void mtcp_skipfile(int fd, size_t size);
size 200 mtcpinterface.cpp for ( size_t i=0; i< args.size(); ++i ) {
size 420 nosyscallsreal.c int _real_shmget (key_t key, size_t size, int shmflg) {
size 421 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (shmget) (key, size, shmflg);
size 29 plugin/alloc/alloc.h extern "C" void *__libc_memalign(size_t boundary, size_t size);
size 29 plugin/alloc/mallocwrappers.cpp extern "C" void *calloc(size_t nmemb, size_t size)
size 32 plugin/alloc/mallocwrappers.cpp void *retval = _real_calloc ( nmemb, size );
size 37 plugin/alloc/mallocwrappers.cpp extern "C" void *malloc(size_t size)
size 40 plugin/alloc/mallocwrappers.cpp void *retval = _real_malloc ( size );
size 45 plugin/alloc/mallocwrappers.cpp extern "C" void *memalign(size_t boundary, size_t size)
size 48 plugin/alloc/mallocwrappers.cpp void *retval = _real_memalign(boundary, size);
size 53 plugin/alloc/mallocwrappers.cpp extern "C" int posix_memalign(void **memptr, size_t alignment, size_t size)
size 56 plugin/alloc/mallocwrappers.cpp int retval = _real_posix_memalign(memptr, alignment, size);
size 61 plugin/alloc/mallocwrappers.cpp extern "C" void *valloc(size_t size)
size 64 plugin/alloc/mallocwrappers.cpp void *retval = _real_valloc(size);
size 76 plugin/alloc/mallocwrappers.cpp extern "C" void *realloc(void *ptr, size_t size)
size 79 plugin/alloc/mallocwrappers.cpp void *retval = _real_realloc ( ptr, size );
size 45 plugin/ipc/connection.cpp JASSERT(_fds.size() > 0);
size 46 plugin/ipc/connection.cpp if (_fds.size() == 1) {
size 50 plugin/ipc/connection.cpp for (size_t i = 0; i < _fds.size(); i++) {
size 73 plugin/ipc/connection.h uint32_t numFds() const { return _fds.size(); }
size 86 plugin/ipc/connectionidentifier.h size = sizeof(ConnMsg);
size 98 plugin/ipc/connectionidentifier.h JASSERT(size == sizeof(ConnMsg)) (size) (sizeof(ConnMsg))
size 108 plugin/ipc/connectionidentifier.h int32_t size;
size 200 plugin/ipc/connectionlist.cpp if (staleFds.size() > 0) {
size 204 plugin/ipc/connectionlist.cpp for (size_t i = 0; i < staleFds.size(); ++i) {
size 218 plugin/ipc/connectionlist.cpp for (size_t i = 0; i < staleFds.size(); ++i) {
size 232 plugin/ipc/connectionlist.cpp uint32_t numCons = _connections.size();
size 259 plugin/ipc/connectionlist.cpp for (size_t i = 0; i < fds.size(); i++) {
size 275 plugin/ipc/connectionlist.cpp for (size_t j = 0; j<fds.size(); j++) {
size 277 plugin/ipc/connectionlist.cpp if (j < fds.size() - 1)
size 511 plugin/ipc/connectionlist.cpp numIncomingCons = incomingCons.size();
size 536 plugin/ipc/connectionlist.cpp size_t numOutgoingCons = outgoingCons.size();
size 539 plugin/ipc/connectionlist.cpp if (outgoingCons.size() > 0) {
size 53 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 58 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 74 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size()>0);
size 117 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 126 plugin/ipc/event/eventconnection.cpp ssize_t size;
size 131 plugin/ipc/event/eventconnection.cpp size = read(evtfd, &u, sizeof(uint64_t));
size 132 plugin/ipc/event/eventconnection.cpp if (-1 != size) {
size 157 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 171 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 194 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 204 plugin/ipc/event/eventconnection.cpp ssize_t size;
size 208 plugin/ipc/event/eventconnection.cpp size = read(signlfd, &_fdsi, sizeof(struct signalfd_siginfo));
size 209 plugin/ipc/event/eventconnection.cpp if (-1 != size) {
size 223 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 232 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 255 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 260 plugin/ipc/event/eventconnection.cpp JASSERT(_fds.size() > 0);
size 81 plugin/ipc/event/eventconnection.h EpollConnection(int size, int type=EPOLL_CREATE)
size 84 plugin/ipc/event/eventconnection.h _size(size)
size 157 plugin/ipc/event/eventwrappers.cpp extern "C" int epoll_create(int size)
size 160 plugin/ipc/event/eventwrappers.cpp int ret = _real_epoll_create(size);
size 162 plugin/ipc/event/eventwrappers.cpp JTRACE("epoll fd created") (ret) (size);
size 163 plugin/ipc/event/eventwrappers.cpp EventConnList::instance().add(ret, new EpollConnection(size));
size 52 plugin/ipc/file/fileconnection.cpp static bool areFilesEqual(int fd, int destFd, size_t size);
size 371 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
size 534 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
size 568 plugin/ipc/file/fileconnection.cpp JTRACE("Pre-checkpoint Torque files") (_fds.size());
size 569 plugin/ipc/file/fileconnection.cpp for (unsigned int i=0; i< _fds.size(); i++)
size 789 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
size 866 plugin/ipc/file/fileconnection.cpp static bool areFilesEqual(int fd, int savedFd, size_t size)
size 879 plugin/ipc/file/fileconnection.cpp while (size > 0) {
size 880 plugin/ipc/file/fileconnection.cpp readBytes = Util::readAll(savedFd, buf1, MIN(bufSize, size));
size 887 plugin/ipc/file/fileconnection.cpp size -= readBytes;
size 893 plugin/ipc/file/fileconnection.cpp return size == 0;
size 947 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
size 960 plugin/ipc/file/fileconnection.cpp int size;
size 963 plugin/ipc/file/fileconnection.cpp size = read(ckptfd,buf,bufsize);
size 964 plugin/ipc/file/fileconnection.cpp if (size < 0) {
size 967 plugin/ipc/file/fileconnection.cpp for (int i=0;i<size;i++) {
size 972 plugin/ipc/file/fileconnection.cpp JTRACE("Checkpointing fifo: end.") (_fds[0]) (_in_data.size());
size 985 plugin/ipc/file/fileconnection.cpp for (size_t i=0;i<(_in_data.size()/bufsize);i++) { // refill fifo
size 992 plugin/ipc/file/fileconnection.cpp int start =(_in_data.size()/bufsize)*bufsize;
size 993 plugin/ipc/file/fileconnection.cpp for (j=0; j<_in_data.size()%bufsize; j++) {
size 1024 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
size 1065 plugin/ipc/file/fileconnection.cpp for (size_t i=0; i<_fds.size(); ++i) {
size 1113 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
size 1150 plugin/ipc/file/fileconnection.cpp _msgInQueue[i].size(), _msgInQueuePrio[i]) != -1);
size 1158 plugin/ipc/file/fileconnection.cpp JASSERT(_fds.size() > 0);
size 192 plugin/ipc/file/fileconnection.h offs += curDir.size();
size 137 plugin/ipc/file/fileconnlist.cpp if (inodeConnIdMaps.size() > 0) {
size 166 plugin/ipc/file/fileconnlist.cpp for (size_t i = 0; i < unlinkedShmAreas.size(); i++) {
size 195 plugin/ipc/file/fileconnlist.cpp for (size_t i = 0; i < missingUnlinkedShmFiles.size(); i++) {
size 210 plugin/ipc/file/fileconnlist.cpp for (size_t i = 0; i < missingUnlinkedShmFiles.size(); i++) {
size 250 plugin/ipc/file/fileconnlist.cpp JWARNING(msync(area.addr, area.size, MS_INVALIDATE) == 0)
size 251 plugin/ipc/file/fileconnlist.cpp (area.addr) (area.size) (area.name) (area.offset) (JASSERT_ERRNO);
size 275 plugin/ipc/file/fileconnlist.cpp JASSERT(_real_mmap(area.addr, area.size, PROT_NONE,
size 328 plugin/ipc/file/fileconnlist.cpp JASSERT(Util::writeAll(fd, area.addr, area.size) == (ssize_t)area.size)
size 342 plugin/ipc/file/fileconnlist.cpp void *addr = _real_mmap(area.addr, area.size, area.prot,
size 351 plugin/ipc/file/fileconnlist.cpp for (size_t i = 0; i < shmAreas.size(); i++) {
size 356 plugin/ipc/file/fileconnlist.cpp void *addr = _real_mmap(area->addr, area->size, area->prot,
size 374 plugin/ipc/file/fileconnlist.cpp for (size_t i = 0; i < fds.size(); ++i) {
size 84 plugin/ipc/socket/connectionrewirer.cpp while (conList->size() > 0) {
size 129 plugin/ipc/socket/connectionrewirer.cpp if (_pendingIP4Incoming.size() > 0) {
size 136 plugin/ipc/socket/connectionrewirer.cpp if (_pendingIP6Incoming.size() > 0) {
size 143 plugin/ipc/socket/connectionrewirer.cpp if (_pendingUDSIncoming.size() > 0) {
size 319 plugin/ipc/socket/connectionrewirer.cpp o << i->first << " numFds=" << con->getFds().size()
size 325 plugin/ipc/socket/connectionrewirer.cpp o << i->first << " numFds=" << con->getFds().size()
size 37 plugin/ipc/socket/kernelbufferdrainer.cpp int size;
size 38 plugin/ipc/socket/kernelbufferdrainer.cpp unsigned len = sizeof(size);
size 39 plugin/ipc/socket/kernelbufferdrainer.cpp JASSERT(getsockopt(fd, SOL_SOCKET, SO_SNDBUF, (void *)&size, &len) == 0);
size 43 plugin/ipc/socket/kernelbufferdrainer.cpp int newSize = static_cast<int>(size * factor / 2);
size 70 plugin/ipc/socket/kernelbufferdrainer.cpp buffer.resize(buffer.size() + sock->bytesRead());
size 71 plugin/ipc/socket/kernelbufferdrainer.cpp int startIdx = buffer.size() - sock->bytesRead();
size 96 plugin/ipc/socket/kernelbufferdrainer.cpp for (size_t i = 0; i < _dataSockets.size();++i)
size 100 plugin/ipc/socket/kernelbufferdrainer.cpp if (buffer.size() >= sizeof(theMagicDrainCookie)
size 101 plugin/ipc/socket/kernelbufferdrainer.cpp && memcmp(&buffer[buffer.size() - sizeof(theMagicDrainCookie)],
size 104 plugin/ipc/socket/kernelbufferdrainer.cpp buffer.resize(buffer.size() - sizeof(theMagicDrainCookie));
size 106 plugin/ipc/socket/kernelbufferdrainer.cpp (buffer.size()) ((_dataSockets.size()));
size 122 plugin/ipc/socket/kernelbufferdrainer.cpp for (size_t i = 0; i < _dataSockets.size();++i){
size 125 plugin/ipc/socket/kernelbufferdrainer.cpp (buffer.size()) (WARN_INTERVAL_SEC)
size 167 plugin/ipc/socket/kernelbufferdrainer.cpp JTRACE("refilling socket buffers") (_drainedData.size());
size 172 plugin/ipc/socket/kernelbufferdrainer.cpp int size = i->second.size();
size 173 plugin/ipc/socket/kernelbufferdrainer.cpp JWARNING(size>=0) (size).Text("a failed drain is in our table???");
size 174 plugin/ipc/socket/kernelbufferdrainer.cpp if (size<0) size=0;
size 178 plugin/ipc/socket/kernelbufferdrainer.cpp msg.extraBytes = size;
size 180 plugin/ipc/socket/kernelbufferdrainer.cpp if (size > 0) {
size 181 plugin/ipc/socket/kernelbufferdrainer.cpp JTRACE("requesting repeat buffer...") (sock.sockfd()) (size);
size 184 plugin/ipc/socket/kernelbufferdrainer.cpp if (size>0) sock.writeAll(&i->second[0],size);
size 198 plugin/ipc/socket/kernelbufferdrainer.cpp int size = msg.extraBytes;
size 199 plugin/ipc/socket/kernelbufferdrainer.cpp JTRACE("repeating buffer back to peer") (size);
size 200 plugin/ipc/socket/kernelbufferdrainer.cpp if (size > 0) {
size 202 plugin/ipc/socket/kernelbufferdrainer.cpp jalib::JBuffer tmp(size);
size 203 plugin/ipc/socket/kernelbufferdrainer.cpp sock.readAll(tmp,size);
size 204 plugin/ipc/socket/kernelbufferdrainer.cpp sock.writeAll(tmp,size);
size 93 plugin/ipc/socket/socketconnection.cpp (fds[0]) (opt->first) (opt->second.size());
size 96 plugin/ipc/socket/socketconnection.cpp opt->second.size());
size 98 plugin/ipc/socket/socketconnection.cpp (lvl->first) (opt->first) (opt->second.size())
size 110 plugin/ipc/socket/socketconnection.cpp uint64_t numSockOpts = _sockOptions.size();
size 117 plugin/ipc/socket/socketconnection.cpp uint64_t numLvl = _sockOptions.size();
size 123 plugin/ipc/socket/socketconnection.cpp uint64_t numOpts = lvl->second.size();
size 133 plugin/ipc/socket/socketconnection.cpp int64_t bufLen = buffer.size();
size 360 plugin/ipc/socket/socketconnection.cpp JTRACE("Creating dead socket.") (_fds[0]) (_fds.size());
size 363 plugin/ipc/socket/socketconnection.cpp Util::dupFds(_makeDeadSocket(&buffer[0], buffer.size()), _fds);
size 368 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0) (id());
size 449 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0);
size 454 plugin/ipc/socket/socketconnection.cpp JTRACE("Creating dead socket.") (_fds[0]) (_fds.size());
size 463 plugin/ipc/socket/socketconnection.cpp Util::dupFds(_makeDeadSocket(&buffer[0], buffer.size()), _fds);
size 522 plugin/ipc/socket/socketconnection.cpp (_fds[0]) (opt->first) (opt->second.size());
size 526 plugin/ipc/socket/socketconnection.cpp opt->second.size());
size 528 plugin/ipc/socket/socketconnection.cpp (opt->first) (opt->second.buffer()) (opt->second.size())
size 651 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0) (id());
size 675 plugin/ipc/socket/socketconnection.cpp JASSERT(_fds.size() > 0);
size 165 plugin/ipc/socket/socketconnlist.cpp for (size_t i = 0; i < fds.size(); ++i) {
size 310 plugin/ipc/ssh/ssh.cpp for(size_t i = 0; i < dmtcp_args.size(); i++){
size 23 plugin/ipc/ssh/sshdrainer.cpp buffer.resize(buffer.size() + sock->bytesRead());
size 24 plugin/ipc/ssh/sshdrainer.cpp int startIdx = buffer.size() - sock->bytesRead();
size 46 plugin/ipc/ssh/sshdrainer.cpp for (size_t i = 0; i < _dataSockets.size();++i)
size 50 plugin/ipc/ssh/sshdrainer.cpp if (buffer.size() >= sizeof(theMagicDrainCookie)
size 51 plugin/ipc/ssh/sshdrainer.cpp && memcmp(&buffer[buffer.size() - sizeof(theMagicDrainCookie)],
size 54 plugin/ipc/ssh/sshdrainer.cpp buffer.resize(buffer.size() - sizeof(theMagicDrainCookie));
size 56 plugin/ipc/ssh/sshdrainer.cpp (buffer.size()) ((_dataSockets.size()));
size 72 plugin/ipc/ssh/sshdrainer.cpp for (size_t i = 0; i < _dataSockets.size();++i){
size 75 plugin/ipc/ssh/sshdrainer.cpp (buffer.size()) (WARN_INTERVAL_SEC)
size 99 plugin/ipc/ssh/sshdrainer.cpp JTRACE("refilling socket buffers") (_drainedData.size());
size 107 plugin/ipc/ssh/sshdrainer.cpp int size = i->second.size();
size 108 plugin/ipc/ssh/sshdrainer.cpp JWARNING(size>=0) (size).Text("a failed drain is in our table???");
size 109 plugin/ipc/ssh/sshdrainer.cpp if (size<0) size=0;
size 111 plugin/ipc/ssh/sshdrainer.cpp Util::writeAll(refillFd, &i->second[0], size);
size 438 plugin/pid/pid_miscwrappers.cpp SYSCALL_GET_ARGS_3(key_t,key,size_t,size,int,shmflg);
size 439 plugin/pid/pid_miscwrappers.cpp ret = shmget(key, size, shmflg);
size 295 plugin/pid/pid_syscallsreal.c int _real_shmget (key_t key, size_t size, int shmflg) {
size 296 plugin/pid/pid_syscallsreal.c REAL_FUNC_PASSTHROUGH ( shmget ) (key, size, shmflg);
size 165 plugin/pid/pidwrappers.h int _real_shmget(key_t key, size_t size, int shmflg);
size 94 plugin/pid/virtualpidtable.cpp (_idMapTable.size()) .Text("Exceeded maximum number of threads allowed");
size 171 plugin/svipc/sysvipc.cpp static void huge_memcpy(char *dest, char *src, size_t size)
size 173 plugin/svipc/sysvipc.cpp if (size < 100 * 1024 * 1024) {
size 174 plugin/svipc/sysvipc.cpp memcpy(dest, src, size);
size 182 plugin/svipc/sysvipc.cpp size_t n = size / chunkSize;
size 190 plugin/svipc/sysvipc.cpp size -= chunkSize;
size 192 plugin/svipc/sysvipc.cpp memcpy(dest, src, size);
size 248 plugin/svipc/sysvipc.cpp for (size_t j = 0; j < staleIds.size(); ++j) {
size 340 plugin/svipc/sysvipc.cpp JASSERT(_virtIdTable.getNewVirtualId(&id)) (_virtIdTable.size())
size 359 plugin/svipc/sysvipc.cpp void SysVShm::on_shmget(int shmid, key_t key, size_t size, int shmflg)
size 368 plugin/svipc/sysvipc.cpp _map[virtId] = new ShmSegment(virtId, shmid, key, size, shmflg);
size 532 plugin/svipc/sysvipc.cpp ShmSegment::ShmSegment(int shmid, int realShmid, key_t key, size_t size,
size 536 plugin/svipc/sysvipc.cpp _size = size;
size 537 plugin/svipc/sysvipc.cpp if (key == -1 || size == 0) {
size 603 plugin/svipc/sysvipc.cpp if (_shmaddrToFlag.size() == 0) {
size 880 plugin/svipc/sysvipc.cpp size_t size = buf.__msg_cbytes;
size 881 plugin/svipc/sysvipc.cpp void *msgBuf = JALLOC_HELPER_MALLOC(size);
size 885 plugin/svipc/sysvipc.cpp ssize_t numBytes = _real_msgrcv(_realId, msgBuf, size, 0, 0);
size 890 plugin/svipc/sysvipc.cpp JASSERT(_msgInQueue.size() == _qnum) (_qnum);
size 892 plugin/svipc/sysvipc.cpp while (_real_msgrcv(_realId, msgBuf, size, 0, IPC_NOWAIT) != -1);
size 904 plugin/svipc/sysvipc.cpp JASSERT(_msgInQueue.size() == _qnum) (_msgInQueue.size()) (_qnum);
size 915 plugin/svipc/sysvipc.cpp size_t size = buf.__msg_cbytes;
size 916 plugin/svipc/sysvipc.cpp void *msgBuf = JALLOC_HELPER_MALLOC(size);
size 917 plugin/svipc/sysvipc.cpp while (_real_msgrcv(_realId, msgBuf, size, 0, IPC_NOWAIT) != -1);
size 926 plugin/svipc/sysvipc.cpp _msgInQueue[i].size(), IPC_NOWAIT) == 0);
size 95 plugin/svipc/sysvipc.h virtual void on_shmget(int shmid, key_t key, size_t size, int shmflg) {}
size 127 plugin/svipc/sysvipc.h virtual void on_shmget(int shmid, key_t key, size_t size, int shmflg);
size 208 plugin/svipc/sysvipc.h ShmSegment(int shmid, int realShmid, key_t key, size_t size, int shmflg);
size 47 plugin/svipc/sysvipcwrappers.cpp int shmget(key_t key, size_t size, int shmflg)
size 52 plugin/svipc/sysvipcwrappers.cpp realId = _real_shmget(key, size, shmflg);
size 54 plugin/svipc/sysvipcwrappers.cpp SysVShm::instance().on_shmget(realId, key, size, shmflg);
size 57 plugin/svipc/sysvipcwrappers.cpp (key) (size) (shmflg) (realId) (virtId);
size 89 plugin/timer/timerlist.cpp for (size_t i = 0; i < staleClockIds.size(); i++) {
size 106 plugin/timer/timerlist.cpp for (size_t i = 0; i < staleClockIds.size(); i++) {
size 249 plugin/timer/timerlist.cpp if (_clockVirtIdTable.size() > 800) {
size 264 plugin/timer/timerlist.cpp if (_clockVirtIdTable.size() > 800) {
size 180 processinfo.cpp JTRACE("Original stack area") ((void*)area.addr) (area.size);
size 195 processinfo.cpp int ret = mprotect(area.addr + area.size, 0x1000,
size 207 processinfo.cpp allocSize = stackSize - stackArea.size - 4095;
size 218 processinfo.cpp JTRACE("New stack size") ((void*)area.addr) (area.size);
size 565 processinfo.cpp JTRACE("Serializing ChildPid Table") (_childTable.size()) (o.filename());
size 86 processinfo.h void argvSize(int size) { _argvSize = size; }
size 88 processinfo.h void envSize(int size) { _envSize = size; }
size 52 procselfmaps.cpp size_t size = numBytes + 4096; // Add a one page buffer.
size 53 procselfmaps.cpp data = (char*) JALLOC_HELPER_MALLOC(size);
size 56 procselfmaps.cpp numBytes = Util::readAll(fd, data, size);
size 61 procselfmaps.cpp JASSERT(numBytes < size) (numBytes) (size);
size 147 procselfmaps.cpp area->size = area->endAddr - area->addr;
size 75 shareddata.cpp off_t size = CEIL(SHM_MAX_SIZE , Util::pageSize());
size 76 shareddata.cpp JASSERT(lseek(PROTECTED_SHM_FD, size, SEEK_SET) == size)
size 79 shareddata.cpp memset(sharedDataHeader, 0, size);
size 154 shareddata.cpp size_t size = CEIL(SHM_MAX_SIZE , Util::pageSize());
size 155 shareddata.cpp void *addr = _real_mmap(prevSharedDataHeaderAddr, size,
size 209 shareddata.cpp size_t size = CEIL(SHM_MAX_SIZE, Util::pageSize());
size 210 shareddata.cpp JASSERT(_real_munmap(sharedDataHeader, size) == 0) (JASSERT_ERRNO);
size 558 shareddata.cpp for (size_t i = 0; i < ids.size(); i++) {
size 579 shareddata.cpp sharedDataHeader->numInodeConnIdMaps += maps.size();
size 582 shareddata.cpp for (size_t i = 0; i < maps.size(); i++) {
size 949 syscallsreal.c int _real_shmget (int key, size_t size, int shmflg) {
size 950 syscallsreal.c REAL_FUNC_PASSTHROUGH (shmget) (key, size, shmflg);
size 401 syscallwrappers.h void *_real_calloc(size_t nmemb, size_t size);
size 402 syscallwrappers.h void *_real_malloc(size_t size);
size 404 syscallwrappers.h void *_real_realloc(void *ptr, size_t size);
size 405 syscallwrappers.h void *_real_libc_memalign(size_t boundary, size_t size);
size 449 syscallwrappers.h int _real_shmget (int key, size_t size, int shmflg);
size 102 util_exec.cpp size_t size)
size 106 util_exec.cpp strncpy(outpath, inpath, size);
size 109 util_exec.cpp snprintf(outpath, size, "%s%s", getenv("HOME"), &inpath[1]);
size 112 util_exec.cpp snprintf(outpath, size, "/home/%s", &inpath[1]);
size 115 util_exec.cpp snprintf(outpath, size, "%s/%s", jalib::Filesystem::GetCWD().c_str(),
size 136 util_exec.cpp JASSERT(size > strlen(outpath) + strlen(inpath) + 1)
size 137 util_exec.cpp (size) (outpath) (strlen(outpath)) (inpath) (strlen(inpath))
size 206 util_init.cpp for (i = 0; i < args.size(); i++) {
size 122 util_misc.cpp if (v.size() > 0) {
size 124 util_misc.cpp for (size_t i = 1; i < v.size(); i++) {
size 196 util_misc.cpp if (n.isSome() && tokens.size() == n.get() - 1) {
size 322 util_misc.cpp for (size_t i = 1; i < newfds.size(); i++) {
size 474 util_misc.cpp area -> size = endaddr - startaddr;
size 137 writeckpt.cpp JASSERT(area.size == ProcessInfo::instance().restoreBufLen())
size 138 writeckpt.cpp ((void*) area.addr) (area.size) (ProcessInfo::instance().restoreBufLen());
size 264 writeckpt.cpp area.size = -1; // End of data
size 273 writeckpt.cpp for (size_t i = 0; i < areas.size(); i++) {
size 274 writeckpt.cpp JASSERT(munmap(areas[i].addr, areas[i].size) == 0) (JASSERT_ERRNO)
size 276 writeckpt.cpp JASSERT(mmap(areas[i].addr, areas[i].size, areas[i].prot,
size 288 writeckpt.cpp static void mtcp_get_next_page_range(Area *area, size_t *size, int *is_zero)
size 294 writeckpt.cpp if (area->size < one_MB) {
size 295 writeckpt.cpp *size = area->size;
size 299 writeckpt.cpp *size = one_MB;
size 303 writeckpt.cpp pg < area->addr + area->size;
size 305 writeckpt.cpp size_t minsize = MIN(one_MB, (size_t)(area->addr + area->size - pg));
size 309 writeckpt.cpp *size += minsize;
size 311 writeckpt.cpp if (madvise(prevAddr, area->addr + *size - prevAddr,
size 314 writeckpt.cpp (JASSERT_ERRNO) ((void*)area->addr) ((int)*size);
size 338 writeckpt.cpp JASSERT(mprotect(orig_area->addr, orig_area->size,
size 340 writeckpt.cpp (JASSERT_ERRNO) (orig_area->size) (orig_area->addr)
size 344 writeckpt.cpp while (area.size > 0) {
size 345 writeckpt.cpp size_t size;
size 349 writeckpt.cpp size = area.size;
size 352 writeckpt.cpp mtcp_get_next_page_range(&a, &size, &is_zero);
size 356 writeckpt.cpp a.size = size;
size 360 writeckpt.cpp Util::writeAll(fd, a.addr, a.size);
size 362 writeckpt.cpp if (madvise(a.addr, a.size, MADV_DONTNEED) == -1) {
size 364 writeckpt.cpp (JASSERT_ERRNO) (a.addr) ((int)a.size);
size 367 writeckpt.cpp area.addr += size;
size 368 writeckpt.cpp area.size -= size;
size 374 writeckpt.cpp JASSERT(mprotect(orig_area->addr, orig_area->size, orig_area->prot) == 0)
size 375 writeckpt.cpp (JASSERT_ERRNO) (orig_area->addr) (orig_area->size)
size 385 writeckpt.cpp JTRACE("save region") (addr) (area->size) (area->name) (area->offset);
size 387 writeckpt.cpp JTRACE("save anonymous") (addr) (area->size);
size 389 writeckpt.cpp JTRACE("save anonymous") (addr) (area->size) (area->name) (area->offset);
size 393 writeckpt.cpp if (brk > area -> addr && brk <= area -> addr + area -> size)
size 397 writeckpt.cpp if (area->size == 0) {
size 400 writeckpt.cpp (addr) (area->size);
size 406 writeckpt.cpp (area->name) (addr) (area->size);
size 424 writeckpt.cpp Util::writeAll(fd, area->addr, area->size);