c_str 381 ckptserializer.cpp JASSERT(mkdir(ckptDir.c_str(), S_IRWXU) == 0 || errno == EEXIST) c_str 385 ckptserializer.cpp JASSERT(0 == access(ckptDir.c_str(), X_OK|W_OK)) (ckptDir) c_str 411 ckptserializer.cpp fd = perform_open_ckpt_image_fd(tempCkptFilename.c_str(), &use_compression, c_str 442 ckptserializer.cpp JASSERT(rename(tempCkptFilename.c_str(), ckptFilename.c_str()) == 0); c_str 127 coordinatorapi.cpp instance()._coordinatorSocket.writeAll(progname.c_str(), c_str 438 coordinatorapi.cpp (char*)coordinator.c_str(), c_str 494 coordinatorapi.cpp _coordinatorSocket.writeAll(hostname.c_str(), hostname.length() + 1); c_str 495 coordinatorapi.cpp _coordinatorSocket.writeAll(progname.c_str(), progname.length() + 1); c_str 635 coordinatorapi.cpp _coordinatorSocket.writeAll(ckptFilename.c_str(), ckptFilename.length() + 1); c_str 636 coordinatorapi.cpp _coordinatorSocket.writeAll(hostname.c_str(), hostname.length() + 1); c_str 135 dmtcp_command.cpp char *cmd = (char *)request.c_str(); c_str 141 dmtcp_command.cpp setenv(ENV_VAR_CKPT_INTR, interval.c_str(), 1); c_str 143 dmtcp_command.cpp printf("Interval changed to %s\n", interval.c_str()); c_str 653 dmtcp_coordinator.cpp printf("%s", o.str().c_str()); c_str 813 dmtcp_coordinator.cpp client->sock().writeAll(ckptDir.c_str(), reply.extraBytes); c_str 820 dmtcp_coordinator.cpp if (strcmp(ckptDir.c_str(), extraData) != 0) { c_str 890 dmtcp_coordinator.cpp unlink(o.str().c_str()); c_str 897 dmtcp_coordinator.cpp unlink(thePortFile.c_str()); c_str 1391 dmtcp_coordinator.cpp FILE* fp = fopen ( uniqueFilename.c_str(),"w" ); c_str 1425 dmtcp_coordinator.cpp jalib::Filesystem::GetProgramDir().c_str()); c_str 1439 dmtcp_coordinator.cpp fprintf ( fp, "given_ckpt_files=\"%s\"\n\n", o.str().c_str()); c_str 1454 dmtcp_coordinator.cpp fprintf ( fp, "\n :: %s :bg:", host->first.c_str() ); c_str 1456 dmtcp_coordinator.cpp fprintf ( fp," %s", file->c_str() ); c_str 1549 dmtcp_coordinator.cpp int dirfd = open(dirname.c_str(), O_DIRECTORY | O_RDONLY); c_str 1554 dmtcp_coordinator.cpp JASSERT(stat(uniqueFilename.c_str(), &buf) == 0); c_str 1555 dmtcp_coordinator.cpp JASSERT(chmod(uniqueFilename.c_str(), buf.st_mode | S_IXUSR) == 0); c_str 1558 dmtcp_coordinator.cpp unlink(filename.c_str()); c_str 1562 dmtcp_coordinator.cpp JWARNING(symlinkat(uniqueFilename.c_str(), dirfd, filename.c_str()) == 0); c_str 1871 dmtcp_coordinator.cpp Util::writeCoordPortToFile(thePort, thePortFile.c_str()); c_str 1898 dmtcp_coordinator.cpp coordHostname.c_str(), inet_ntoa(localhostIPAddr), thePort); c_str 432 dmtcp_launch.cpp ckptDir = _buf.c_str(); c_str 501 dmtcp_launch.cpp Util::writeCoordPortToFile(port, thePortFile.c_str()); c_str 512 dmtcp_launch.cpp char *str = const_cast<char*>(installDir.c_str()); c_str 524 dmtcp_launch.cpp SharedData::initialize(tmpDir.c_str(), c_str 525 dmtcp_launch.cpp installDir.c_str(), c_str 722 dmtcp_launch.cpp setenv(ENV_VAR_HIJACK_LIBS, preloadLibs.c_str(), 1); c_str 724 dmtcp_launch.cpp setenv(ENV_VAR_HIJACK_LIBS_M32, preloadLibs32.c_str(), 1); c_str 737 dmtcp_launch.cpp setenv("LD_PRELOAD", preloadLibs.c_str(), 1); c_str 747 dmtcp_launch.cpp setenv("LD_PRELOAD", preloadLibs.c_str(), 1); c_str 218 dmtcp_restart.cpp Util::writeCoordPortToFile(port, thePortFile.c_str()); c_str 229 dmtcp_restart.cpp char *str = const_cast<char*>(installDir.c_str()); c_str 241 dmtcp_restart.cpp SharedData::initialize(tmpDir.c_str(), c_str 242 dmtcp_restart.cpp installDir.c_str(), c_str 310 dmtcp_restart.cpp int dirfd = open(dirName.c_str(), O_RDONLY); c_str 383 dmtcp_restart.cpp (char*) mtcprestart.c_str(), c_str 542 dmtcp_restart.cpp int fd = open_ckpt_to_read(path.c_str()); c_str 551 dmtcp_restart.cpp fd = open_ckpt_to_read(path.c_str()); /* Re-open from beginning */ c_str 562 dmtcp_restart.cpp sprintf(envFile, "%s/envFile.XXXXXX", tmpDir.c_str()); c_str 710 dmtcp_restart.cpp int rc = stat(restorename.c_str(), &buf); c_str 720 dmtcp_restart.cpp sprintf(error_msg, "\ndmtcp_restart: ckpt image %s", restorename.c_str()); c_str 730 dmtcp_restart.cpp getuid(), buf.st_uid, restorename.c_str(), __FILE__, __LINE__ - 7); c_str 66 dmtcpnohijackstubs.cpp return uniquepid_str.c_str(); c_str 183 dmtcpplugin.cpp return tmpdir.c_str(); c_str 197 dmtcpplugin.cpp return dir.c_str(); c_str 216 dmtcpplugin.cpp return filename.c_str(); c_str 223 dmtcpplugin.cpp return tmpdir.c_str(); c_str 233 dmtcpplugin.cpp return ProcessInfo::instance().procSelfExe().c_str(); c_str 241 dmtcpplugin.cpp return uniquepid_str->c_str(); c_str 261 dmtcpplugin.cpp return compid_str->c_str(); c_str 227 dmtcpworker.cpp int fd = open(path.c_str(), O_WRONLY | O_APPEND, 0); c_str 229 dmtcpworker.cpp Util::writeAll(fd, o.str().c_str(), o.str().length()); c_str 436 dmtcpworker.cpp unlink(shmFile.c_str()); c_str 243 execwrappers.cpp output = _real_popen(command.c_str(), "r"); c_str 325 execwrappers.cpp strcpy(buf, os.str().c_str()); c_str 421 execwrappers.cpp result.push_back(s[i].c_str()); c_str 487 execwrappers.cpp ldPreloadStr += getUpdatedLdPreload(filename, userPreloadStr.c_str()); c_str 557 execwrappers.cpp setenv("LD_PRELOAD", getUpdatedLdPreload(filename, NULL).c_str(), 1); c_str 203 mtcpinterface.cpp strcpy(addr, args[i].c_str()); c_str 270 plugin/ipc/file/fileconnection.cpp SharedData::createVirtualPtyName(_ptsName.c_str(), buf, sizeof(buf)); c_str 328 plugin/ipc/file/fileconnection.cpp SharedData::getRealPtyName(_virtPtsName.c_str(), buf, sizeof(buf)); c_str 339 plugin/ipc/file/fileconnection.cpp int tempfd = _real_open(_ptsName.c_str(), _flags | extraFlags); c_str 397 plugin/ipc/file/fileconnection.cpp _real_access(controllingTty.c_str(), R_OK | W_OK) == 0) { c_str 398 plugin/ipc/file/fileconnection.cpp tempfd = _real_open(controllingTty.c_str(), _fcntlFlags); c_str 430 plugin/ipc/file/fileconnection.cpp SharedData::insertPtyNameMap(_virtPtsName.c_str(), _ptsName.c_str()); c_str 448 plugin/ipc/file/fileconnection.cpp SharedData::insertPtyNameMap(_virtPtsName.c_str(), _ptsName.c_str()); c_str 464 plugin/ipc/file/fileconnection.cpp tempfd = _real_open(_masterName.c_str(), _flags | extraFlags); c_str 567 plugin/ipc/file/fileconnection.cpp dmtcp_bq_should_ckpt_file(_path.c_str(), &_rmtype)) { c_str 575 plugin/ipc/file/fileconnection.cpp if (dmtcp_must_ckpt_file && dmtcp_must_ckpt_file(_path.c_str())) { c_str 622 plugin/ipc/file/fileconnection.cpp int destFd = _real_open(savedFilePath.c_str(), O_CREAT | O_WRONLY | O_TRUNC, c_str 630 plugin/ipc/file/fileconnection.cpp int tmpfd = _real_open(_path.c_str(), O_RDONLY, 0); c_str 649 plugin/ipc/file/fileconnection.cpp if (strstr(_path.c_str(), "infiniband/uverbs") || c_str 650 plugin/ipc/file/fileconnection.cpp strstr(_path.c_str(), "uverbs-event")) return; c_str 654 plugin/ipc/file/fileconnection.cpp int savedFd = _real_open(savedFilePath.c_str(), O_RDONLY, 0); c_str 680 plugin/ipc/file/fileconnection.cpp tempfd = _real_open(_path.c_str(), _fcntlFlags | O_CREAT, 0600); c_str 682 plugin/ipc/file/fileconnection.cpp JASSERT(truncate(_path.c_str(), _st_size) == 0) c_str 683 plugin/ipc/file/fileconnection.cpp (_path.c_str()) (_st_size) (JASSERT_ERRNO); c_str 689 plugin/ipc/file/fileconnection.cpp if (stat(_path.c_str() ,&statbuf) == 0 && S_ISREG(statbuf.st_mode)) { c_str 693 plugin/ipc/file/fileconnection.cpp JASSERT(truncate(_path.c_str(), _st_size) == 0) c_str 694 plugin/ipc/file/fileconnection.cpp (_path.c_str()) (_st_size) (JASSERT_ERRNO); c_str 706 plugin/ipc/file/fileconnection.cpp stat(_path.c_str() ,&statbuf) == 0 && S_ISREG(statbuf.st_mode)) { c_str 729 plugin/ipc/file/fileconnection.cpp JWARNING(unlink(_path.c_str()) != -1) (_path) c_str 755 plugin/ipc/file/fileconnection.cpp dmtcp_get_new_file_path(_path.c_str(), cwd.c_str(), newpath); c_str 800 plugin/ipc/file/fileconnection.cpp tempfd = dmtcp_bq_restore_file(_path.c_str(), savedFilePath.c_str(), c_str 815 plugin/ipc/file/fileconnection.cpp int fd = _real_open(_path.c_str(), O_CREAT | O_EXCL | O_RDWR, c_str 822 plugin/ipc/file/fileconnection.cpp int srcFd = _real_open(savedFilePath.c_str(), O_RDONLY, 0); c_str 859 plugin/ipc/file/fileconnection.cpp int fd = _real_open(_path.c_str(), _fcntlFlags); c_str 862 plugin/ipc/file/fileconnection.cpp JTRACE("open(_path.c_str(), _fcntlFlags)") (fd) (_path.c_str()) (_fcntlFlags); c_str 949 plugin/ipc/file/fileconnection.cpp stat(_path.c_str(),&st); c_str 954 plugin/ipc/file/fileconnection.cpp ckptfd = _real_open(_path.c_str(),new_flags); c_str 978 plugin/ipc/file/fileconnection.cpp ckptfd = _real_open(_path.c_str(),new_flags); c_str 1041 plugin/ipc/file/fileconnection.cpp mkfifo(_path.c_str(), _mode); c_str 1042 plugin/ipc/file/fileconnection.cpp JTRACE("mkfifo") (_path.c_str()) (errno); c_str 1045 plugin/ipc/file/fileconnection.cpp fd = _real_open(_path.c_str(), O_RDWR | O_NONBLOCK); c_str 1046 plugin/ipc/file/fileconnection.cpp JTRACE("Is opened") (_path.c_str()) (fd); c_str 1130 plugin/ipc/file/fileconnection.cpp int fd = _real_mq_open(_name.c_str(), O_RDWR, 0, NULL); c_str 1162 plugin/ipc/file/fileconnection.cpp mq_unlink(_name.c_str()); c_str 1165 plugin/ipc/file/fileconnection.cpp int tempfd = _real_mq_open(_name.c_str(), _oflag, _mode, &_attr); c_str 401 plugin/ipc/file/fileconnlist.cpp PtyConnection *con = new PtyConnection(fd, (const char*) device.c_str(), c_str 408 plugin/ipc/file/fileconnlist.cpp } else if(dmtcp_is_bq_file && dmtcp_is_bq_file(device.c_str())) { c_str 410 plugin/ipc/file/fileconnlist.cpp Connection *c = findDuplication(fd, device.c_str()); c_str 416 plugin/ipc/file/fileconnlist.cpp processFileConnection(fd, device.c_str(), -1, -1); c_str 421 plugin/ipc/file/fileconnlist.cpp Connection *c = findDuplication(fd, device.c_str()); c_str 427 plugin/ipc/file/fileconnlist.cpp processFileConnection(fd, device.c_str(), -1, -1); c_str 467 plugin/ipc/file/fileconnlist.cpp path = device.c_str(); c_str 197 plugin/ipc/file/filewrappers.cpp strcpy(buf, virtPtsName.c_str()); c_str 258 plugin/ipc/file/filewrappers.cpp strncpy(buf, virtPtsName.c_str(), buflen); c_str 513 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, device.c_str(), c_str 541 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, device.c_str(), c_str 209 plugin/ipc/socket/connectionrewirer.cpp strncpy(&_udsRestoreAddr.sun_path[1], str.c_str(), str.length()); c_str 258 plugin/ipc/socket/socketconnection.cpp if (Util::strStartsWith(uaddr->sun_path, blacklist[i].c_str()) || c_str 259 plugin/ipc/socket/socketconnection.cpp Util::strStartsWith(&uaddr->sun_path[1], blacklist[i].c_str())) { c_str 174 plugin/ipc/socket/socketconnlist.cpp } else if(dmtcp_is_bq_file && dmtcp_is_bq_file(device.c_str())) { c_str 180 plugin/ipc/ssh/ssh.cpp argv[idx++] = (char*) dmtcp_nocheckpoint_path.c_str(); c_str 187 plugin/ipc/ssh/ssh.cpp argv[idx++] = (char*) dmtcp_sshd_path.c_str(); c_str 345 plugin/ipc/ssh/ssh.cpp new_argv[idx++] = (char*) dmtcp_ssh_path.c_str(); c_str 349 plugin/ipc/ssh/ssh.cpp new_argv[idx++] = (char*) dmtcp_nocheckpoint_path.c_str(); c_str 359 plugin/ipc/ssh/ssh.cpp new_argv[idx++] = (char*) cmd.c_str(); c_str 109 plugin/pid/pid.cpp if ((fd = _real_open(name.c_str(), O_EXCL|O_CREAT|O_TRUNC | flags, 0600)) >= 0) { c_str 118 plugin/pid/pid.cpp if ((fd = _real_open(name.c_str(), flags, 0600)) >= 0) { c_str 170 plugin/pid/pid.cpp unlink(pidMapFile.c_str()); c_str 350 processinfo.cpp if (Util::strStartsWith(_ckptCWD.c_str(), _launchCWD.c_str()) && c_str 354 processinfo.cpp if (chdir(rpath.c_str()) == 0) { c_str 357 processinfo.cpp JWARNING(chdir(_ckptCWD.c_str()) == 0) (_ckptCWD) (_launchCWD) c_str 97 procname.cpp if (prctl(PR_SET_NAME, prgName.c_str()) != -1) { c_str 142 shareddata.cpp int fd = _real_open(o.str().c_str(), O_RDWR | O_CREAT | O_EXCL, 0600); c_str 144 shareddata.cpp fd = _real_open(o.str().c_str(), O_RDWR, 0600); c_str 504 shareddata.cpp strcpy(sharedDataHeader->ptyNameMap[n].virt, virt.c_str()); c_str 506 shareddata.cpp strcpy(out, virt.c_str()); c_str 83 syslogwrappers.cpp openlog ( ( _identIsNotNULL ? _ident().c_str() : NULL), c_str 97 util_exec.cpp setenv("LD_PRELOAD", dmtcphjk.c_str(), 1); c_str 115 util_exec.cpp snprintf(outpath, size, "%s/%s", jalib::Filesystem::GetCWD().c_str(), c_str 130 util_exec.cpp strcpy(outpath, jalib::Filesystem::GetCWD().c_str()); c_str 214 util_exec.cpp if (isElf && safeSystem(cmd.c_str())) { c_str 242 util_exec.cpp setenv("SCREENDIR", Util::getScreenDir().c_str(), 1); c_str 257 util_exec.cpp safeMkdir(tmpdir.c_str(), 0700); c_str 306 util_exec.cpp jalib::Filesystem::BaseName(realFilename).c_str()); c_str 435 util_exec.cpp fp = popen(cmd1.c_str(), "r"); c_str 444 util_exec.cpp fp = popen(cmd2.c_str(), "r"); c_str 453 util_exec.cpp fp = popen(cmd2.c_str(), "r"); c_str 483 util_exec.cpp (char*) mtcprestart.c_str(), c_str 45 util_init.cpp *host = SharedData::coordHost().c_str(); c_str 163 util_init.cpp JASSERT(mkdir(tmpDir.c_str(), S_IRWXU) == 0 || errno == EEXIST) c_str 168 util_init.cpp JASSERT(0 == access(tmpDir.c_str(), X_OK|W_OK)) (tmpDir) c_str 216 util_init.cpp JLOG(a.str().c_str()); c_str 111 util_misc.cpp return strStartsWith(str.c_str(), pattern); c_str 116 util_misc.cpp return strEndsWith(str.c_str(), pattern); c_str 134 util_misc.cpp if (strEndsWith(s, suffix.c_str())) { c_str 220 util_misc.cpp int res = mkdir(dirName.c_str(), S_IRWXU | S_IRWXG | S_IROTH | S_IXOTH); c_str 225 util_misc.cpp int ret = stat(dirName.c_str(), &buff);