_path 132 dmtcp_restart.cpp : _path(path)
_path 134 dmtcp_restart.cpp JASSERT(jalib::Filesystem::FileExists(_path)) (_path)
_path 137 dmtcp_restart.cpp _fd = readCkptHeader(_path, &_pInfo);
_path 138 dmtcp_restart.cpp JTRACE("restore target") (_path) (_pInfo.numPeers()) (_pInfo.compGroup());
_path 309 dmtcp_restart.cpp string dirName = jalib::Filesystem::DirName(_path);
_path 348 dmtcp_restart.cpp string _path;
_path 505 plugin/ipc/file/fileconnection.cpp if (Util::strStartsWith(_path, "/proc/")) {
_path 508 plugin/ipc/file/fileconnection.cpp pid_t proc_pid = strtol(&_path[index], &rest, 0);
_path 523 plugin/ipc/file/fileconnection.cpp if (_path.compare(0, cwd.length(), cwd) == 0) {
_path 525 plugin/ipc/file/fileconnection.cpp _rel_path = _path.substr(cwd.length() + 1);
_path 551 plugin/ipc/file/fileconnection.cpp } else if (Util::strStartsWith(jalib::Filesystem::BaseName(_path), ".nfs")) {
_path 558 plugin/ipc/file/fileconnection.cpp _path = jalib::Filesystem::GetDeviceName(_fds[0]);
_path 567 plugin/ipc/file/fileconnection.cpp dmtcp_bq_should_ckpt_file(_path.c_str(), &_rmtype)) {
_path 575 plugin/ipc/file/fileconnection.cpp if (dmtcp_must_ckpt_file && dmtcp_must_ckpt_file(_path.c_str())) {
_path 583 plugin/ipc/file/fileconnection.cpp if (_isBlacklistedFile(_path)) {
_path 591 plugin/ipc/file/fileconnection.cpp (Util::strEndsWith(_path, ".swp") == 0 ||
_path 592 plugin/ipc/file/fileconnection.cpp Util::strEndsWith(_path, ".swo") == 0)) {
_path 618 plugin/ipc/file/fileconnection.cpp string savedFilePath = getSavedFilePath(_path);
_path 624 plugin/ipc/file/fileconnection.cpp JASSERT(destFd != -1) (JASSERT_ERRNO) (_path) (savedFilePath);
_path 626 plugin/ipc/file/fileconnection.cpp JTRACE("Saving checkpointed copy of the file") (_path) (savedFilePath);
_path 630 plugin/ipc/file/fileconnection.cpp int tmpfd = _real_open(_path.c_str(), O_RDONLY, 0);
_path 639 plugin/ipc/file/fileconnection.cpp JTRACE("Not checkpointing this file") (_path);
_path 649 plugin/ipc/file/fileconnection.cpp if (strstr(_path.c_str(), "infiniband/uverbs") ||
_path 650 plugin/ipc/file/fileconnection.cpp strstr(_path.c_str(), "uverbs-event")) return;
_path 653 plugin/ipc/file/fileconnection.cpp string savedFilePath = getSavedFilePath(_path);
_path 659 plugin/ipc/file/fileconnection.cpp JWARNING(false) (_path) (savedFilePath)
_path 671 plugin/ipc/file/fileconnection.cpp JASSERT(false) (_path) (savedFilePath) (errMsg);
_path 680 plugin/ipc/file/fileconnection.cpp tempfd = _real_open(_path.c_str(), _fcntlFlags | O_CREAT, 0600);
_path 681 plugin/ipc/file/fileconnection.cpp JASSERT(tempfd != -1) (_path) (JASSERT_ERRNO) .Text("open() failed");
_path 682 plugin/ipc/file/fileconnection.cpp JASSERT(truncate(_path.c_str(), _st_size) == 0)
_path 683 plugin/ipc/file/fileconnection.cpp (_path.c_str()) (_st_size) (JASSERT_ERRNO);
_path 686 plugin/ipc/file/fileconnection.cpp JASSERT(jalib::Filesystem::FileExists(_path)) (_path)
_path 689 plugin/ipc/file/fileconnection.cpp if (stat(_path.c_str() ,&statbuf) == 0 && S_ISREG(statbuf.st_mode)) {
_path 693 plugin/ipc/file/fileconnection.cpp JASSERT(truncate(_path.c_str(), _st_size) == 0)
_path 694 plugin/ipc/file/fileconnection.cpp (_path.c_str()) (_st_size) (JASSERT_ERRNO);
_path 705 plugin/ipc/file/fileconnection.cpp if (jalib::Filesystem::FileExists(_path) &&
_path 706 plugin/ipc/file/fileconnection.cpp stat(_path.c_str() ,&statbuf) == 0 && S_ISREG(statbuf.st_mode)) {
_path 709 plugin/ipc/file/fileconnection.cpp (_path) (_offset) (JASSERT_ERRNO);
_path 712 plugin/ipc/file/fileconnection.cpp JWARNING(false) (_path) (_offset) (_st_size) (statbuf.st_size)
_path 728 plugin/ipc/file/fileconnection.cpp if (jalib::Filesystem::FileExists(_path)) {
_path 729 plugin/ipc/file/fileconnection.cpp JWARNING(unlink(_path.c_str()) != -1) (_path)
_path 743 plugin/ipc/file/fileconnection.cpp JTRACE("This is Resource Manager file!") (_fds[0]) (newpath) (_path) (this);
_path 744 plugin/ipc/file/fileconnection.cpp if (newpath != _path) {
_path 746 plugin/ipc/file/fileconnection.cpp (_path) (newpath);
_path 747 plugin/ipc/file/fileconnection.cpp _path = newpath;
_path 755 plugin/ipc/file/fileconnection.cpp dmtcp_get_new_file_path(_path.c_str(), cwd.c_str(), newpath);
_path 757 plugin/ipc/file/fileconnection.cpp JASSERT(jalib::Filesystem::FileExists(newpath)) (_path) (newpath)
_path 759 plugin/ipc/file/fileconnection.cpp _path = newpath;
_path 763 plugin/ipc/file/fileconnection.cpp if (_rel_path != "*" && !jalib::Filesystem::FileExists(_path)) {
_path 766 plugin/ipc/file/fileconnection.cpp string oldPath = _path;
_path 769 plugin/ipc/file/fileconnection.cpp _path = fullPath;
_path 771 plugin/ipc/file/fileconnection.cpp (oldPath) (_path) (_rel_path);
_path 777 plugin/ipc/file/fileconnection.cpp pid_t proc_pid = strtol(&_path[index], &rest, 0);
_path 780 plugin/ipc/file/fileconnection.cpp _path = buf;
_path 793 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring File Connection") (id()) (_path);
_path 794 plugin/ipc/file/fileconnection.cpp string savedFilePath = getSavedFilePath(_path);
_path 796 plugin/ipc/file/fileconnection.cpp (savedFilePath) (_path) .Text("Unable to find checkpointed copy of file");
_path 800 plugin/ipc/file/fileconnection.cpp tempfd = dmtcp_bq_restore_file(_path.c_str(), savedFilePath.c_str(),
_path 802 plugin/ipc/file/fileconnection.cpp JTRACE("Restore Resource Manager File") (_path);
_path 805 plugin/ipc/file/fileconnection.cpp JASSERT(Util::createDirectoryTree(_path)) (_path)
_path 815 plugin/ipc/file/fileconnection.cpp int fd = _real_open(_path.c_str(), O_CREAT | O_EXCL | O_RDWR,
_path 817 plugin/ipc/file/fileconnection.cpp JASSERT(fd != -1 || errno == EEXIST) (_path) (JASSERT_ERRNO);
_path 823 plugin/ipc/file/fileconnection.cpp JASSERT(srcFd != -1) (_path) (savedFilePath) (JASSERT_ERRNO)
_path 826 plugin/ipc/file/fileconnection.cpp (savedFilePath) (_path);
_path 856 plugin/ipc/file/fileconnection.cpp JASSERT(jalib::Filesystem::FileExists(_path)) (_path)
_path 859 plugin/ipc/file/fileconnection.cpp int fd = _real_open(_path.c_str(), _fcntlFlags);
_path 860 plugin/ipc/file/fileconnection.cpp JASSERT(fd != -1) (_path) (JASSERT_ERRNO) .Text("open() failed");
_path 862 plugin/ipc/file/fileconnection.cpp JTRACE("open(_path.c_str(), _fcntlFlags)") (fd) (_path.c_str()) (_fcntlFlags);
_path 926 plugin/ipc/file/fileconnection.cpp << "/" << jalib::Filesystem::BaseName(_path) << "_" << _id.conId();
_path 934 plugin/ipc/file/fileconnection.cpp o & _path & _rel_path;
_path 936 plugin/ipc/file/fileconnection.cpp JTRACE("Serializing FileConn.") (_path) (_rel_path)
_path 949 plugin/ipc/file/fileconnection.cpp stat(_path.c_str(),&st);
_path 954 plugin/ipc/file/fileconnection.cpp ckptfd = _real_open(_path.c_str(),new_flags);
_path 978 plugin/ipc/file/fileconnection.cpp ckptfd = _real_open(_path.c_str(),new_flags);
_path 1012 plugin/ipc/file/fileconnection.cpp string oldPath = _path;
_path 1016 plugin/ipc/file/fileconnection.cpp _path = fullPath.str();
_path 1017 plugin/ipc/file/fileconnection.cpp JTRACE("Change _path based on relative path") (oldPath) (_path);
_path 1025 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring Fifo Connection") (id()) (_path);
_path 1036 plugin/ipc/file/fileconnection.cpp if (!jalib::Filesystem::FileExists(_path)) {
_path 1037 plugin/ipc/file/fileconnection.cpp JTRACE("Fifo file not present, creating new one") (_path);
_path 1038 plugin/ipc/file/fileconnection.cpp jalib::string dir = jalib::Filesystem::DirName(_path);
_path 1041 plugin/ipc/file/fileconnection.cpp mkfifo(_path.c_str(), _mode);
_path 1042 plugin/ipc/file/fileconnection.cpp JTRACE("mkfifo") (_path.c_str()) (errno);
_path 1045 plugin/ipc/file/fileconnection.cpp fd = _real_open(_path.c_str(), O_RDWR | O_NONBLOCK);
_path 1046 plugin/ipc/file/fileconnection.cpp JTRACE("Is opened") (_path.c_str()) (fd);
_path 1048 plugin/ipc/file/fileconnection.cpp JASSERT(fd != -1) (_path) (JASSERT_ERRNO);
_path 1055 plugin/ipc/file/fileconnection.cpp o & _path & _rel_path & _savedRelativePath & _mode & _in_data;
_path 1056 plugin/ipc/file/fileconnection.cpp JTRACE("Serializing FifoConn.") (_path) (_rel_path) (_savedRelativePath);
_path 129 plugin/ipc/file/fileconnection.h , _path(path)
_path 148 plugin/ipc/file/fileconnection.h virtual string str() { return _path; }
_path 149 plugin/ipc/file/fileconnection.h string filePath() { return _path; }
_path 163 plugin/ipc/file/fileconnection.h string _path;
_path 185 plugin/ipc/file/fileconnection.h , _path(path)
_path 188 plugin/ipc/file/fileconnection.h int offs = _path.find(curDir);
_path 193 plugin/ipc/file/fileconnection.h offs = _path.find('/',offs);
_path 195 plugin/ipc/file/fileconnection.h _rel_path = _path.substr(offs);
_path 197 plugin/ipc/file/fileconnection.h JTRACE("New Fifo connection created") (_path) (_rel_path);
_path 205 plugin/ipc/file/fileconnection.h virtual string str() { return _path; };
_path 212 plugin/ipc/file/fileconnection.h string _path;