fd 178 ckptserializer.cpp return open_ckpt_to_write(fd,pipe_fds,hbict_args);
fd 193 ckptserializer.cpp return open_ckpt_to_write(fd,pipe_fds,gzip_args);
fd 205 ckptserializer.cpp int fd = _real_open(tempCkptFilename, flags, 0600);
fd 206 ckptserializer.cpp *fdCkptFileOnDisk = fd; /* if use_compression, fd will be reset to pipe */
fd 207 ckptserializer.cpp JASSERT(fd != -1) (tempCkptFilename) (JASSERT_ERRNO)
fd 211 ckptserializer.cpp return fd;
fd 256 ckptserializer.cpp fd = open_ckpt_to_write_hbict(fd, pipe_fds, hbict_path, gzip_path);
fd 258 ckptserializer.cpp fd = open_ckpt_to_write_hbict(fd, pipe_fds, hbict_path, NULL);
fd 262 ckptserializer.cpp fd = open_ckpt_to_write_gz(fd, pipe_fds, gzip_path);
fd 272 ckptserializer.cpp return fd;
fd 333 ckptserializer.cpp fd = pipe_fds[1]; //change return value
fd 340 ckptserializer.cpp int outfd = _real_dup(fd);
fd 354 ckptserializer.cpp if (fd > STDERR_FILENO) {
fd 355 ckptserializer.cpp _real_close(fd);
fd 373 ckptserializer.cpp return fd;
fd 409 ckptserializer.cpp int fd = -1;
fd 411 ckptserializer.cpp fd = perform_open_ckpt_image_fd(tempCkptFilename.c_str(), &use_compression,
fd 414 ckptserializer.cpp JASSERT(use_compression || fd == fdCkptFileOnDisk);
fd 417 ckptserializer.cpp writeDmtcpHeader(fd);
fd 420 ckptserializer.cpp JASSERT(Util::writeAll(fd, mtcpHdr, mtcpHdrLen) == (ssize_t) mtcpHdrLen);
fd 423 ckptserializer.cpp mtcp_writememoryareas(fd);
fd 456 ckptserializer.cpp JASSERT(write(fd, DMTCP_FILE_HEADER, len) == len);
fd 458 ckptserializer.cpp jalib::JBinarySerializeWriterRaw wr("", fd);
fd 466 ckptserializer.cpp JASSERT(Util::writeAll(fd, buf, remaining) == remaining);
fd 36 ckptserializer.h void writeDmtcpHeader(int fd);
fd 1908 dmtcp_coordinator.cpp int fd = open("/dev/null", O_RDWR);
fd 1909 dmtcp_coordinator.cpp JASSERT(dup2(fd, STDIN_FILENO) == STDIN_FILENO);
fd 1910 dmtcp_coordinator.cpp JASSERT(dup2(fd, STDOUT_FILENO) == STDOUT_FILENO);
fd 1911 dmtcp_coordinator.cpp JASSERT(dup2(fd, STDERR_FILENO) == STDERR_FILENO);
fd 1913 dmtcp_coordinator.cpp if (fd > STDERR_FILENO) {
fd 1914 dmtcp_coordinator.cpp close(fd);
fd 340 dmtcp_launch.cpp for (size_t fd = PROTECTED_FD_START; fd < PROTECTED_FD_END; fd++) {
fd 341 dmtcp_launch.cpp close(fd);
fd 603 dmtcp_launch.cpp int fd;
fd 606 dmtcp_launch.cpp if ( (fd = open("/proc/meminfo", O_RDONLY)) != -1 &&
fd 607 dmtcp_launch.cpp read(fd, buf, sizeof(meminfoPrefix) + 16) == sizeof(meminfoPrefix) + 16 &&
fd 611 dmtcp_launch.cpp if (fd != -1)
fd 612 dmtcp_launch.cpp close(fd);
fd 35 dmtcp_nocheckpoint.c size_t fd;
fd 36 dmtcp_nocheckpoint.c for (fd = PROTECTED_FD_START; fd < PROTECTED_FD_END; fd++) {
fd 37 dmtcp_nocheckpoint.c close(fd);
fd 301 dmtcp_restart.cpp close(t->fd());
fd 357 dmtcp_restart.cpp sprintf(fdBuf, "%d", fd);
fd 398 dmtcp_restart.cpp int fd = openCkptFileToRead(path);
fd 401 dmtcp_restart.cpp jalib::JBinarySerializeReaderRaw rdr("", fd);
fd 409 dmtcp_restart.cpp JASSERT(Util::readAll(fd, buf, remaining) == remaining);
fd 410 dmtcp_restart.cpp return fd;
fd 415 dmtcp_restart.cpp int fd, rc;
fd 418 dmtcp_restart.cpp fd = open(filename, O_RDONLY);
fd 419 dmtcp_restart.cpp JASSERT(fd >= 0) (filename) .Text("ERROR: Cannot open filename");
fd 421 dmtcp_restart.cpp rc = read(fd, &c, 1);
fd 424 dmtcp_restart.cpp close(fd);
fd 436 dmtcp_restart.cpp int fd;
fd 459 dmtcp_restart.cpp fd = open(filename, O_RDONLY);
fd 460 dmtcp_restart.cpp JASSERT(fd>=0)(filename).Text("Failed to open file.");
fd 463 dmtcp_restart.cpp return fd;
fd 490 dmtcp_restart.cpp close(fd);
fd 516 dmtcp_restart.cpp fd = dup(dup(dup(fd)));
fd 519 dmtcp_restart.cpp JASSERT(fd != -1);
fd 520 dmtcp_restart.cpp JASSERT(dup2(fd, STDIN_FILENO) == STDIN_FILENO);
fd 521 dmtcp_restart.cpp close(fd);
fd 542 dmtcp_restart.cpp int fd = open_ckpt_to_read(path.c_str());
fd 544 dmtcp_restart.cpp JASSERT(fd >= 0) (path) .Text("Failed to open file.");
fd 546 dmtcp_restart.cpp JASSERT(read(fd, buf, len) == len)(path) .Text("read() failed");
fd 550 dmtcp_restart.cpp close(fd);
fd 551 dmtcp_restart.cpp fd = open_ckpt_to_read(path.c_str()); /* Re-open from beginning */
fd 552 dmtcp_restart.cpp JASSERT(fd >= 0) (path) .Text("Failed to open file.");
fd 554 dmtcp_restart.cpp return fd;
fd 563 dmtcp_restart.cpp int fd = mkstemp(envFile);
fd 564 dmtcp_restart.cpp JASSERT(fd != -1) (envFile) (JASSERT_ERRNO);
fd 566 dmtcp_restart.cpp JASSERT(dup2(fd, PROTECTED_ENVIRON_FD) == PROTECTED_ENVIRON_FD)
fd 568 dmtcp_restart.cpp JASSERT(close(fd) == 0);
fd 569 dmtcp_restart.cpp fd = PROTECTED_ENVIRON_FD;
fd 573 dmtcp_restart.cpp Util::writeAll(fd, *env, strlen(*env) + 1); // Also write null character
fd 576 dmtcp_restart.cpp Util::writeAll(fd, *env, 1); // Write final null character
fd 592 dmtcp_restart.cpp int fd = open(path, O_RDONLY);
fd 593 dmtcp_restart.cpp JASSERT(fd != -1) (path);
fd 594 dmtcp_restart.cpp JASSERT(dup2(fd, PROTECTED_CKPT_DIR_FD) == PROTECTED_CKPT_DIR_FD)
fd 595 dmtcp_restart.cpp (fd) (path);
fd 596 dmtcp_restart.cpp if (fd != PROTECTED_CKPT_DIR_FD) {
fd 597 dmtcp_restart.cpp close(fd);
fd 306 dmtcpplugin.cpp return DMTCP_IS_PROTECTED_FD(fd);
fd 316 dmtcpplugin.cpp JASSERT(DMTCP_IS_PROTECTED_FD(fd));
fd 317 dmtcpplugin.cpp _real_close(fd);
fd 227 dmtcpworker.cpp int fd = open(path.c_str(), O_WRONLY | O_APPEND, 0);
fd 228 dmtcpworker.cpp if (fd != -1) {
fd 229 dmtcpworker.cpp Util::writeAll(fd, o.str().c_str(), o.str().length());
fd 231 dmtcpworker.cpp _real_close(fd);
fd 252 dmtcpworker.cpp edata.serializerInfo.fd = PROTECTED_LIFEBOAT_FD;
fd 62 dmtcpworker.h static void writeCheckpointPrefix(int fd);
fd 326 execwrappers.cpp int fd = _real_mkstemp(buf);
fd 327 execwrappers.cpp JASSERT(fd != -1) (JASSERT_ERRNO);
fd 329 execwrappers.cpp Util::changeFd(fd, PROTECTED_LIFEBOAT_FD);
fd 333 execwrappers.cpp edata.serializerInfo.fd = PROTECTED_LIFEBOAT_FD;
fd 603 execwrappers.cpp snprintf (buf, sizeof (buf), "/proc/self/fd/%d", fd);
fd 605 execwrappers.cpp JTRACE("fexecve() wrapper calling execve()") (fd) (buf);
fd 81 miscwrappers.cpp if (DMTCP_IS_PROTECTED_FD(fd)) {
fd 82 miscwrappers.cpp JTRACE("blocked attempt to close protected fd") (fd);
fd 86 miscwrappers.cpp return _real_close(fd);
fd 95 miscwrappers.cpp int fd = fileno(fp);
fd 96 miscwrappers.cpp if (DMTCP_IS_PROTECTED_FD(fd)) {
fd 97 miscwrappers.cpp JTRACE("blocked attempt to fclose protected fd") (fd);
fd 106 miscwrappers.cpp int fd = dirfd(dir);
fd 107 miscwrappers.cpp if (DMTCP_IS_PROTECTED_FD(fd)) {
fd 108 miscwrappers.cpp JTRACE("blocked attempt to closedir protected fd") (fd);
fd 324 miscwrappers.cpp SYSCALL_GET_ARG(int,fd);
fd 325 miscwrappers.cpp ret = close(fd);
fd 499 miscwrappers.cpp SYSCALL_GET_ARGS_3(int,fd,sigset_t *,mask,int,flags);
fd 500 miscwrappers.cpp ret = signalfd(fd, mask, flags);
fd 507 miscwrappers.cpp SYSCALL_GET_ARGS_3(int,fd,sigset_t *,mask,int,flags);
fd 508 miscwrappers.cpp ret = signalfd(fd, mask, flags);
fd 87 mtcp/mtcp_restart.c int fd;
fd 201 mtcp/mtcp_restart.c rinfo.fd = -1;
fd 220 mtcp/mtcp_restart.c rinfo.fd = mtcp_strtol(argv[1]);
fd 234 mtcp/mtcp_restart.c if ((rinfo.fd != -1) ^ (ckptImage == NULL)) {
fd 239 mtcp/mtcp_restart.c if (rinfo.fd != -1) {
fd 240 mtcp/mtcp_restart.c mtcp_readfile(rinfo.fd, &mtcpHdr, sizeof mtcpHdr);
fd 243 mtcp/mtcp_restart.c rinfo.fd = mtcp_sys_open2(ckptImage, O_RDONLY);
fd 244 mtcp/mtcp_restart.c if (rinfo.fd == -1) {
fd 255 mtcp/mtcp_restart.c rc = mtcp_readfile(rinfo.fd, &mtcpHdr, sizeof mtcpHdr);
fd 271 mtcp/mtcp_restart.c mtcp_simulateread(rinfo.fd, &mtcpHdr);
fd 487 mtcp/mtcp_restart.c mtcp_readfile(fd, &area, sizeof area);
fd 496 mtcp/mtcp_restart.c mtcp_readfile(fd, addr, area.size);
fd 571 mtcp/mtcp_restart.c readmemoryareas (restore_info.fd);
fd 575 mtcp/mtcp_restart.c DPRINTF("close cpfd %d\n", restore_info.fd);
fd 576 mtcp/mtcp_restart.c mtcp_sys_close (restore_info.fd);
fd 779 mtcp/mtcp_restart.c if (read_one_memory_area(fd) == -1) {
fd 802 mtcp/mtcp_restart.c mtcp_readfile(fd, &area, sizeof area);
fd 899 mtcp/mtcp_restart.c mtcp_skipfile(fd, area.size);
fd 905 mtcp/mtcp_restart.c mtcp_readfile(fd, area.addr, area.size);
fd 931 mtcp/mtcp_restart.c off_t curr_size = mtcp_sys_lseek(fd, 0, SEEK_END);
fd 247 mtcp/mtcp_sys.h # define mtcp_sys_pipe(fd) mtcp_inline_syscall(pipe2,2,fd,0)
fd 275 mtcp/mtcp_sys.h (void *)mtcp_inline_syscall(mmap2,6,addr,length,prot,flags,fd,offset/4096)
fd 205 mtcp/mtcp_util.c rc = mtcp_sys_read (fd, ptr + num_read, count - num_read);
fd 264 mtcp/mtcp_util.c rc = mtcp_sys_read(fd, buf + ar, size - ar);
fd 309 mtcp/mtcp_util.c mtcp_readfile(fd, tmp_addr, size);
fd 325 mtcp/mtcp_util.c ssize_t rc = mtcp_sys_write (fd, ptr + num_written, count - num_written);
fd 348 mtcp/mtcp_util.c rc = mtcp_sys_read (fd, &c, 1);
fd 362 mtcp/mtcp_util.c c = mtcp_readchar (fd);
fd 379 mtcp/mtcp_util.c c = mtcp_readchar (fd);
fd 124 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (read) (fd,buf,count);
fd 128 nosyscallsreal.c REAL_FUNC_PASSTHROUGH_TYPED (ssize_t,write) (fd,buf,count);
fd 207 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (close) (fd);
fd 238 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (fcntl) (fd, cmd, arg);
fd 243 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (ptsname_r) (fd, buf, buflen);
fd 266 nosyscallsreal.c REAL_FUNC_PASSTHROUGH_TYPED (off_t,lseek) (fd,offset,whence);
fd 278 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (tcsetpgrp) (fd, pgrp);
fd 282 nosyscallsreal.c REAL_FUNC_PASSTHROUGH (tcgetpgrp) (fd);
fd 351 nosyscallsreal.c REAL_FUNC_PASSTHROUGH_TYPED (void*, mmap) (addr,length,prot,flags,fd,offset);
fd 33 plugin/alloc/mmapwrappers.cpp void *retval = _real_mmap(addr, length, prot, flags, fd, offset);
fd 42 plugin/alloc/mmapwrappers.cpp void *retval = _real_mmap64(addr, length, prot, flags, fd, offset);
fd 40 plugin/ipc/connection.cpp _fds.push_back(fd);
fd 47 plugin/ipc/connection.cpp JASSERT(_fds[0] == fd);
fd 51 plugin/ipc/connection.cpp if (_fds[i] == fd) {
fd 71 plugin/ipc/connection.h void addFd(int fd);
fd 72 plugin/ipc/connection.h void removeFd(int fd);
fd 103 plugin/ipc/connectionlist.cpp jalib::JBinarySerializeWriterRaw wr("", data->serializerInfo.fd);
fd 111 plugin/ipc/connectionlist.cpp jalib::JBinarySerializeReaderRaw rd("", data->serializerInfo.fd);
fd 170 plugin/ipc/connectionlist.cpp return _real_fcntl(fd, F_GETFL, 0) == -1 && errno == EBADF;
fd 297 plugin/ipc/connectionlist.cpp if (_fdToCon.find(fd) == _fdToCon.end()) {
fd 300 plugin/ipc/connectionlist.cpp return _fdToCon[fd];
fd 307 plugin/ipc/connectionlist.cpp if (_fdToCon.find(fd) != _fdToCon.end()) {
fd 315 plugin/ipc/connectionlist.cpp processCloseWork(fd);
fd 320 plugin/ipc/connectionlist.cpp c->addFd(fd);
fd 321 plugin/ipc/connectionlist.cpp _fdToCon[fd] = c;
fd 327 plugin/ipc/connectionlist.cpp Connection *con = _fdToCon[fd];
fd 328 plugin/ipc/connectionlist.cpp _fdToCon.erase(fd);
fd 329 plugin/ipc/connectionlist.cpp con->removeFd(fd);
fd 338 plugin/ipc/connectionlist.cpp if (_fdToCon.find(fd) != _fdToCon.end()) {
fd 340 plugin/ipc/connectionlist.cpp processCloseWork(fd);
fd 563 plugin/ipc/connectionlist.cpp int fd = Util::receiveFd(restoreFd, &id, sizeof(id));
fd 564 plugin/ipc/connectionlist.cpp JASSERT(fd != -1);
fd 568 plugin/ipc/connectionlist.cpp Util::dupFds(fd, con->getFds());
fd 53 plugin/ipc/connectionlist.h void add(int fd, Connection* c);
fd 57 plugin/ipc/connectionlist.h Connection *getConnection(int fd);
fd 58 plugin/ipc/connectionlist.h void processClose(int fd);
fd 86 plugin/ipc/connectionlist.h void processCloseWork(int fd);
fd 103 plugin/ipc/event/eventconnection.cpp _fdToEvent.erase(fd);
fd 107 plugin/ipc/event/eventconnection.cpp _fdToEvent[fd] = myEvent;
fd 322 plugin/ipc/event/eventconnection.cpp (wd) (fd) (pathname) (mask);
fd 335 plugin/ipc/event/eventconnection.cpp watch_descriptor.add_watch.file_descriptor = fd;
fd 98 plugin/ipc/event/eventconnection.h void onCTL(int op, int fd, struct epoll_event *event);
fd 196 plugin/ipc/event/eventconnection.h void map_inotify_fd_to_wd( int fd, int wd);
fd 197 plugin/ipc/event/eventconnection.h void add_watch_descriptors(int wd, int fd, const char *pathname,
fd 132 plugin/ipc/event/eventwrappers.cpp int ret = _real_signalfd(fd, mask, flags);
fd 134 plugin/ipc/event/eventwrappers.cpp JTRACE("signalfd created") (fd) (flags);
fd 135 plugin/ipc/event/eventwrappers.cpp EventConnList::instance().add(ret, new SignalFdConnection(fd, mask, flags));
fd 184 plugin/ipc/event/eventwrappers.cpp int ret = _real_epoll_ctl(epfd, op, fd, event);
fd 189 plugin/ipc/event/eventwrappers.cpp con->onCTL(op, fd, event);
fd 258 plugin/ipc/event/eventwrappers.cpp int fd;
fd 261 plugin/ipc/event/eventwrappers.cpp fd = _real_inotify_init();
fd 262 plugin/ipc/event/eventwrappers.cpp if (fd > 0) {
fd 269 plugin/ipc/event/eventwrappers.cpp return fd;
fd 306 plugin/ipc/event/eventwrappers.cpp int ret = _real_inotify_add_watch(fd, pathname, mask);
fd 310 plugin/ipc/event/eventwrappers.cpp (InotifyConnection*) EventConnList::instance().getConnection(fd);
fd 312 plugin/ipc/event/eventwrappers.cpp inotify_con->add_watch_descriptors(ret, fd, pathname, mask);
fd 335 plugin/ipc/event/eventwrappers.cpp int ret = _real_inotify_rm_watch(fd, wd);
fd 337 plugin/ipc/event/eventwrappers.cpp JTRACE("remove inotify mapping from dmtcp") (ret) (fd) (wd);
fd 339 plugin/ipc/event/eventwrappers.cpp (InotifyConnection*) EventConnList::instance().getConnection(fd);
fd 147 plugin/ipc/file/fileconnection.cpp FD_SET(fd, &read_fds);
fd 148 plugin/ipc/file/fileconnection.cpp select(fd + 1, &read_fds, NULL, NULL, &zeroTimeout);
fd 149 plugin/ipc/file/fileconnection.cpp return FD_ISSET(fd, &read_fds);
fd 158 plugin/ipc/file/fileconnection.cpp while (readyToRead(fd) && rc <= 0) {
fd 159 plugin/ipc/file/fileconnection.cpp rc = read(fd,(char *)buf+sizeof(hdr), maxCount-sizeof(hdr));
fd 177 plugin/ipc/file/fileconnection.cpp while ((rc = readOnePacket(fd, buf, maxCount)) > 0) {
fd 203 plugin/ipc/file/fileconnection.cpp rc = write(fd,(char *)origBuf+sizeof(hdr)+cum_count, count-cum_count);
fd 219 plugin/ipc/file/fileconnection.cpp while ((rc = writeOnePacket(fd,(char *)buf+cum_count, isPacketMode))
fd 257 plugin/ipc/file/fileconnection.cpp JASSERT(_real_ptsname_r(fd, buf, sizeof(buf)) == 0) (JASSERT_ERRNO);
fd 815 plugin/ipc/file/fileconnection.cpp int fd = _real_open(_path.c_str(), O_CREAT | O_EXCL | O_RDWR,
fd 817 plugin/ipc/file/fileconnection.cpp JASSERT(fd != -1 || errno == EEXIST) (_path) (JASSERT_ERRNO);
fd 819 plugin/ipc/file/fileconnection.cpp if (fd == -1) {
fd 827 plugin/ipc/file/fileconnection.cpp writeFileFromFd(srcFd, fd);
fd 829 plugin/ipc/file/fileconnection.cpp _real_close(fd);
fd 841 plugin/ipc/file/fileconnection.cpp if ( lseek(myfd, 0, SEEK_CUR) == lseek(fd, 0, SEEK_CUR) ) {
fd 845 plugin/ipc/file/fileconnection.cpp if ( newOffset == lseek (fd, 0, SEEK_CUR) ) {
fd 859 plugin/ipc/file/fileconnection.cpp int fd = _real_open(_path.c_str(), _fcntlFlags);
fd 860 plugin/ipc/file/fileconnection.cpp JASSERT(fd != -1) (_path) (JASSERT_ERRNO) .Text("open() failed");
fd 862 plugin/ipc/file/fileconnection.cpp JTRACE("open(_path.c_str(), _fcntlFlags)") (fd) (_path.c_str()) (_fcntlFlags);
fd 863 plugin/ipc/file/fileconnection.cpp return fd;
fd 873 plugin/ipc/file/fileconnection.cpp off_t offset1 = _real_lseek(fd, 0, SEEK_CUR);
fd 875 plugin/ipc/file/fileconnection.cpp JASSERT(_real_lseek(fd, 0, SEEK_SET) == 0) (fd) (JASSERT_ERRNO);
fd 883 plugin/ipc/file/fileconnection.cpp JASSERT(Util::readAll(fd, buf2, readBytes) == readBytes);
fd 891 plugin/ipc/file/fileconnection.cpp JASSERT(_real_lseek(fd, offset1, SEEK_SET) != -1);
fd 904 plugin/ipc/file/fileconnection.cpp fsync(fd);
fd 906 plugin/ipc/file/fileconnection.cpp off_t offset = _real_lseek(fd, 0, SEEK_CUR);
fd 907 plugin/ipc/file/fileconnection.cpp JASSERT(_real_lseek(fd, 0, SEEK_SET) == 0) (fd) (JASSERT_ERRNO);
fd 912 plugin/ipc/file/fileconnection.cpp readBytes = Util::readAll(fd, buf, bufSize);
fd 919 plugin/ipc/file/fileconnection.cpp JASSERT(_real_lseek(fd, offset, SEEK_SET) != -1);
fd 1034 plugin/ipc/file/fileconnection.cpp int fd;
fd 1045 plugin/ipc/file/fileconnection.cpp fd = _real_open(_path.c_str(), O_RDWR | O_NONBLOCK);
fd 1046 plugin/ipc/file/fileconnection.cpp JTRACE("Is opened") (_path.c_str()) (fd);
fd 1048 plugin/ipc/file/fileconnection.cpp JASSERT(fd != -1) (_path) (JASSERT_ERRNO);
fd 1049 plugin/ipc/file/fileconnection.cpp return fd;
fd 1066 plugin/ipc/file/fileconnection.cpp int fd = _fds[i];
fd 1067 plugin/ipc/file/fileconnection.cpp if (fd <= 2) {
fd 1068 plugin/ipc/file/fileconnection.cpp JTRACE("Skipping restore of STDIO, just inherit from parent") (fd);
fd 1074 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring STDIN") (fd);
fd 1078 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring STDOUT") (fd);
fd 1082 plugin/ipc/file/fileconnection.cpp JTRACE("Restoring STDERR") (fd);
fd 1089 plugin/ipc/file/fileconnection.cpp JWARNING(_real_dup2(oldFd, fd) == fd) (oldFd) (fd) (JASSERT_ERRNO);
fd 1130 plugin/ipc/file/fileconnection.cpp int fd = _real_mq_open(_name.c_str(), O_RDWR, 0, NULL);
fd 1131 plugin/ipc/file/fileconnection.cpp JASSERT(fd != -1) (_name) (JASSERT_ERRNO);
fd 1143 plugin/ipc/file/fileconnection.cpp _real_mq_close(fd);
fd 60 plugin/ipc/file/fileconnection.h PtyConnection(int fd, const char *path, int flags, mode_t mode, int type);
fd 96 plugin/ipc/file/fileconnection.h StdioConnection(int fd): Connection(STDIO + fd) {
fd 97 plugin/ipc/file/fileconnection.h JTRACE("creating stdio connection") (fd) (id());
fd 98 plugin/ipc/file/fileconnection.h JASSERT(jalib::Between(0, fd, 2)) (fd)
fd 156 plugin/ipc/file/fileconnection.h bool checkDup(int fd);
fd 257 plugin/ipc/file/fileconnlist.cpp int fd = _real_open(area.name, flags, 0);
fd 258 plugin/ipc/file/fileconnlist.cpp JASSERT(fd != -1) (JASSERT_ERRNO) (area.name);
fd 261 plugin/ipc/file/fileconnlist.cpp add(fd, fileConn);
fd 316 plugin/ipc/file/fileconnlist.cpp int fd = _real_open(area.name, O_CREAT | O_EXCL | O_RDWR,
fd 318 plugin/ipc/file/fileconnlist.cpp JASSERT(fd != -1 || errno == EEXIST) (area.name);
fd 320 plugin/ipc/file/fileconnlist.cpp if (fd == -1) {
fd 321 plugin/ipc/file/fileconnlist.cpp fd = _real_open(area.name, O_RDWR);
fd 322 plugin/ipc/file/fileconnlist.cpp JASSERT(fd != -1) (JASSERT_ERRNO);
fd 326 plugin/ipc/file/fileconnlist.cpp JASSERT(lseek(fd, area.offset, SEEK_SET) == area.offset) (JASSERT_ERRNO);
fd 328 plugin/ipc/file/fileconnlist.cpp JASSERT(Util::writeAll(fd, area.addr, area.size) == (ssize_t)area.size)
fd 330 plugin/ipc/file/fileconnlist.cpp restoreShmArea(area, fd);
fd 335 plugin/ipc/file/fileconnlist.cpp if (fd == -1) {
fd 336 plugin/ipc/file/fileconnlist.cpp fd = _real_open(area.name, Util::memProtToOpenFlags(area.prot));
fd 339 plugin/ipc/file/fileconnlist.cpp JASSERT(fd != -1) (area.name) (JASSERT_ERRNO);
fd 343 plugin/ipc/file/fileconnlist.cpp MAP_FIXED | area.flags, fd, area.offset);
fd 346 plugin/ipc/file/fileconnlist.cpp _real_close(fd);
fd 354 plugin/ipc/file/fileconnlist.cpp int fd = fileCon->getFds()[0];
fd 358 plugin/ipc/file/fileconnlist.cpp fd, area->offset);
fd 360 plugin/ipc/file/fileconnlist.cpp _real_close(fd);
fd 361 plugin/ipc/file/fileconnlist.cpp processClose(fd);
fd 375 plugin/ipc/file/fileconnlist.cpp int fd = fds[i];
fd 376 plugin/ipc/file/fileconnlist.cpp if (!Util::isValidFd(fd)) continue;
fd 377 plugin/ipc/file/fileconnlist.cpp if (dmtcp_is_protected_fd(fd)) continue;
fd 379 plugin/ipc/file/fileconnlist.cpp JASSERT(fstat(fd, &statbuf) == 0);
fd 383 plugin/ipc/file/fileconnlist.cpp string device = jalib::Filesystem::GetDeviceName(fd);
fd 385 plugin/ipc/file/fileconnlist.cpp JTRACE("scanning pre-existing device") (fd) (device);
fd 395 plugin/ipc/file/fileconnlist.cpp processDup(c->getFds()[0], fd);
fd 401 plugin/ipc/file/fileconnlist.cpp PtyConnection *con = new PtyConnection(fd, (const char*) device.c_str(),
fd 406 plugin/ipc/file/fileconnlist.cpp add(fd, (Connection*)con);
fd 410 plugin/ipc/file/fileconnlist.cpp Connection *c = findDuplication(fd, device.c_str());
fd 412 plugin/ipc/file/fileconnlist.cpp add(fd,c);
fd 416 plugin/ipc/file/fileconnlist.cpp processFileConnection(fd, device.c_str(), -1, -1);
fd 417 plugin/ipc/file/fileconnlist.cpp } else if( fd <= 2 ){
fd 418 plugin/ipc/file/fileconnlist.cpp add(fd, new StdioConnection(fd));
fd 421 plugin/ipc/file/fileconnlist.cpp Connection *c = findDuplication(fd, device.c_str());
fd 423 plugin/ipc/file/fileconnlist.cpp add(fd,c);
fd 427 plugin/ipc/file/fileconnlist.cpp processFileConnection(fd, device.c_str(), -1, -1);
fd 443 plugin/ipc/file/fileconnlist.cpp if( fcon->filePath() == npath && fcon->checkDup(fd) ){
fd 455 plugin/ipc/file/fileconnlist.cpp JASSERT(fstat(fd, &statbuf) == 0);
fd 459 plugin/ipc/file/fileconnlist.cpp device = jalib::Filesystem::GetDeviceName(fd);
fd 470 plugin/ipc/file/fileconnlist.cpp c = new PtyConnection(fd, path, flags, mode, PtyConnection::PTY_DEV_TTY);
fd 475 plugin/ipc/file/fileconnlist.cpp c = new PtyConnection(fd, path, flags, mode, PtyConnection::PTY_BSD_MASTER);
fd 478 plugin/ipc/file/fileconnlist.cpp c = new PtyConnection(fd, path, flags, mode, PtyConnection::PTY_BSD_SLAVE);
fd 482 plugin/ipc/file/fileconnlist.cpp c = new PtyConnection(fd, path, flags, mode, PtyConnection::PTY_MASTER);
fd 485 plugin/ipc/file/fileconnlist.cpp c = new PtyConnection(fd, path, flags, mode, PtyConnection::PTY_SLAVE);
fd 501 plugin/ipc/file/fileconnlist.cpp add(fd, c);
fd 58 plugin/ipc/file/fileconnlist.h Connection *findDuplication(int fd, const char *path);
fd 59 plugin/ipc/file/fileconnlist.h void processFileConnection(int fd, const char *path, int flags, mode_t mode);
fd 64 plugin/ipc/file/fileconnlist.h void restoreShmArea(const ProcMapsArea& area, int fd = -1);
fd 88 plugin/ipc/file/filewrappers.cpp if (dmtcp_is_protected_fd(fd)) {
fd 89 plugin/ipc/file/filewrappers.cpp JTRACE("blocked attempt to close protected fd") (fd);
fd 95 plugin/ipc/file/filewrappers.cpp int rv = _real_close(fd);
fd 97 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processClose(fd);
fd 105 plugin/ipc/file/filewrappers.cpp int fd = fileno(fp);
fd 106 plugin/ipc/file/filewrappers.cpp if (dmtcp_is_protected_fd(fd)) {
fd 107 plugin/ipc/file/filewrappers.cpp JTRACE("blocked attempt to fclose protected fd") (fd);
fd 115 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processClose(fd);
fd 124 plugin/ipc/file/filewrappers.cpp int fd = dirfd(dir);
fd 125 plugin/ipc/file/filewrappers.cpp if (dmtcp_is_protected_fd(fd)) {
fd 126 plugin/ipc/file/filewrappers.cpp JTRACE("blocked attempt to closedir protected fd") (fd);
fd 134 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processClose(fd);
fd 182 plugin/ipc/file/filewrappers.cpp Connection* c = FileConnList::instance().getConnection(fd);
fd 206 plugin/ipc/file/filewrappers.cpp int retVal = ptsname_r_work(fd, buf, buflen);
fd 219 plugin/ipc/file/filewrappers.cpp if (ptsname_r(fd, tmpbuf, sizeof(tmpbuf)) != 0)
fd 233 plugin/ipc/file/filewrappers.cpp int retVal = ptsname_r_work(fd, buf, buflen);
fd 244 plugin/ipc/file/filewrappers.cpp int ret = _real_ttyname_r(fd, tmpbuf, sizeof(tmpbuf));
fd 247 plugin/ipc/file/filewrappers.cpp Connection* c = FileConnList::instance().getConnection(fd);
fd 248 plugin/ipc/file/filewrappers.cpp JASSERT(c != NULL) (fd) (tmpbuf);
fd 270 plugin/ipc/file/filewrappers.cpp if (ttyname_r(fd, tmpbuf, sizeof(tmpbuf)) != 0) {
fd 278 plugin/ipc/file/filewrappers.cpp return ttyname_r(fd, buf, buflen);
fd 284 plugin/ipc/file/filewrappers.cpp int fd = _real_getpt();
fd 285 plugin/ipc/file/filewrappers.cpp if (fd >= 0 && dmtcp_is_running_state()) {
fd 286 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, "/dev/ptmx",
fd 290 plugin/ipc/file/filewrappers.cpp return fd;
fd 296 plugin/ipc/file/filewrappers.cpp int fd = _real_posix_openpt(flags);
fd 297 plugin/ipc/file/filewrappers.cpp if (fd >= 0 && dmtcp_is_running_state()) {
fd 298 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, "/dev/ptmx",
fd 302 plugin/ipc/file/filewrappers.cpp return fd;
fd 319 plugin/ipc/file/filewrappers.cpp int fd = _real_mkstemp(ttemplate);
fd 320 plugin/ipc/file/filewrappers.cpp if (fd >= 0 && dmtcp_is_running_state()) {
fd 321 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, NULL, O_RDWR, 0600);
fd 324 plugin/ipc/file/filewrappers.cpp return fd;
fd 330 plugin/ipc/file/filewrappers.cpp int fd = _real_mkostemp(ttemplate, flags);
fd 331 plugin/ipc/file/filewrappers.cpp if (fd >= 0 && dmtcp_is_running_state()) {
fd 332 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, NULL, flags, 0600);
fd 335 plugin/ipc/file/filewrappers.cpp return fd;
fd 341 plugin/ipc/file/filewrappers.cpp int fd = _real_mkstemps(ttemplate, suffixlen);
fd 342 plugin/ipc/file/filewrappers.cpp if (fd >= 0 && dmtcp_is_running_state()) {
fd 343 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, NULL, O_RDWR, 0600);
fd 346 plugin/ipc/file/filewrappers.cpp return fd;
fd 352 plugin/ipc/file/filewrappers.cpp int fd = _real_mkostemps(ttemplate, suffixlen, flags);
fd 353 plugin/ipc/file/filewrappers.cpp if (fd >= 0 && dmtcp_is_running_state()) {
fd 354 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, NULL, flags, 0600);
fd 357 plugin/ipc/file/filewrappers.cpp return fd;
fd 374 plugin/ipc/file/filewrappers.cpp int fd = (*fn) (newpath, flags, mode);
fd 376 plugin/ipc/file/filewrappers.cpp if (fd >= 0 && dmtcp_is_running_state()) {
fd 377 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, newpath, flags, mode);
fd 382 plugin/ipc/file/filewrappers.cpp return fd;
fd 509 plugin/ipc/file/filewrappers.cpp int fd = _real_openat(dirfd, path, flags, mode);
fd 510 plugin/ipc/file/filewrappers.cpp if (fd >= 0 && dmtcp_is_running_state()) {
fd 511 plugin/ipc/file/filewrappers.cpp string procpath = "/proc/self/fd/" + jalib::XToString(fd);
fd 513 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, device.c_str(),
fd 517 plugin/ipc/file/filewrappers.cpp return fd;
fd 537 plugin/ipc/file/filewrappers.cpp int fd = _real_openat64(dirfd, path, flags, mode);
fd 538 plugin/ipc/file/filewrappers.cpp if (fd >= 0 && dmtcp_is_running_state()) {
fd 539 plugin/ipc/file/filewrappers.cpp string procpath = "/proc/self/fd/" + jalib::XToString(fd);
fd 541 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processFileConnection(fd, device.c_str(),
fd 545 plugin/ipc/file/filewrappers.cpp return fd;
fd 607 plugin/ipc/file/filewrappers.cpp int retval = _real_fxstat(vers, fd, buf);
fd 615 plugin/ipc/file/filewrappers.cpp int retval = _real_fxstat64(vers, fd, buf);
fd 681 plugin/ipc/file/filewrappers.cpp int res = _real_fcntl(fd, cmd, arg);
fd 689 plugin/ipc/file/filewrappers.cpp FileConnList::instance().processDup(fd, res);
fd 62 plugin/ipc/ipc.cpp if (dmtcp_is_protected_fd(fd)) {
fd 63 plugin/ipc/ipc.cpp JTRACE("blocked attempt to close protected fd") (fd);
fd 69 plugin/ipc/ipc.cpp int rv = _real_close(fd);
fd 71 plugin/ipc/ipc.cpp process_fd_event(SYS_close, fd);
fd 79 plugin/ipc/ipc.cpp int fd = fileno(fp);
fd 80 plugin/ipc/ipc.cpp if (dmtcp_is_protected_fd(fd)) {
fd 81 plugin/ipc/ipc.cpp JTRACE("blocked attempt to fclose protected fd") (fd);
fd 89 plugin/ipc/ipc.cpp process_fd_event(SYS_close, fd);
fd 98 plugin/ipc/ipc.cpp int fd = dirfd(dir);
fd 99 plugin/ipc/ipc.cpp if (dmtcp_is_protected_fd(fd)) {
fd 100 plugin/ipc/ipc.cpp JTRACE("blocked attempt to closedir protected fd") (fd);
fd 108 plugin/ipc/ipc.cpp process_fd_event(SYS_close, fd);
fd 85 plugin/ipc/socket/connectionrewirer.cpp int fd = _real_accept(restoreSockFd, NULL, NULL);
fd 86 plugin/ipc/socket/connectionrewirer.cpp if (fd == -1 && (errno == EAGAIN || errno == EWOULDBLOCK)) {
fd 89 plugin/ipc/socket/connectionrewirer.cpp JASSERT(fd != -1) (JASSERT_ERRNO) .Text("Accept failed.");
fd 91 plugin/ipc/socket/connectionrewirer.cpp JASSERT(Util::readAll(fd, &id, sizeof id) == sizeof id);
fd 97 plugin/ipc/socket/connectionrewirer.cpp Util::dupFds(fd, (i->second)->getFds());
fd 111 plugin/ipc/socket/connectionrewirer.cpp int fd = con->getFds()[0];
fd 113 plugin/ipc/socket/connectionrewirer.cpp JASSERT(_real_connect(fd, (sockaddr*) &remoteAddr.addr, remoteAddr.len)
fd 117 plugin/ipc/socket/connectionrewirer.cpp Util::writeAll(fd, &id, sizeof id);
fd 39 plugin/ipc/socket/kernelbufferdrainer.cpp JASSERT(getsockopt(fd, SOL_SOCKET, SO_SNDBUF, (void *)&size, &len) == 0);
fd 45 plugin/ipc/socket/kernelbufferdrainer.cpp JASSERT(_real_setsockopt(fd, SOL_SOCKET, SO_SNDBUF, (void *)&newSize, len) == 0);
fd 79 plugin/ipc/socket/kernelbufferdrainer.cpp int fd;
fd 81 plugin/ipc/socket/kernelbufferdrainer.cpp fd = sock->socket().sockfd();
fd 83 plugin/ipc/socket/kernelbufferdrainer.cpp if (fd < 0) return;
fd 85 plugin/ipc/socket/kernelbufferdrainer.cpp (fd) (_reverseLookup[fd]) (JASSERT_ERRNO);
fd 86 plugin/ipc/socket/kernelbufferdrainer.cpp _disconnectedSockets[_reverseLookup[fd]] = _drainedData[fd];
fd 90 plugin/ipc/socket/kernelbufferdrainer.cpp _drainedData.erase(fd);
fd 152 plugin/ipc/socket/kernelbufferdrainer.cpp _drainedData[fd]; // create buffer
fd 155 plugin/ipc/socket/kernelbufferdrainer.cpp addWrite(new jalib::JChunkWriter(fd, theMagicDrainCookie,
fd 158 plugin/ipc/socket/kernelbufferdrainer.cpp addDataSocket(new jalib::JChunkReader(fd,512));
fd 161 plugin/ipc/socket/kernelbufferdrainer.cpp _reverseLookup[fd]=id;
fd 43 plugin/ipc/socket/kernelbufferdrainer.h void beginDrainOf(int fd , const ConnectionIdentifier& id);
fd 448 plugin/ipc/socket/socketconnection.cpp int fd;
fd 480 plugin/ipc/socket/socketconnection.cpp fd = _real_socket(_sockDomain, _sockType, _sockProtocol);
fd 481 plugin/ipc/socket/socketconnection.cpp JASSERT(fd != -1) (JASSERT_ERRNO);
fd 482 plugin/ipc/socket/socketconnection.cpp Util::dupFds(fd, _fds);
fd 565 plugin/ipc/socket/socketconnection.cpp fd = _real_socket(_sockDomain, _sockType, _sockProtocol);
fd 567 plugin/ipc/socket/socketconnection.cpp fd = _real_socket(_sockDomain == AF_INET6 ? AF_INET : _sockDomain,
fd 570 plugin/ipc/socket/socketconnection.cpp JASSERT(fd != -1) (JASSERT_ERRNO);
fd 571 plugin/ipc/socket/socketconnection.cpp Util::dupFds(fd, _fds);
fd 166 plugin/ipc/socket/socketconnlist.cpp int fd = fds[i];
fd 167 plugin/ipc/socket/socketconnlist.cpp if (!Util::isValidFd(fd)) continue;
fd 168 plugin/ipc/socket/socketconnlist.cpp if (dmtcp_is_protected_fd(fd)) continue;
fd 170 plugin/ipc/socket/socketconnlist.cpp string device = jalib::Filesystem::GetDeviceName(fd);
fd 172 plugin/ipc/socket/socketconnlist.cpp JTRACE("scanning pre-existing device") (fd) (device);
fd 175 plugin/ipc/socket/socketconnlist.cpp } else if( fd <= 2 ){
fd 179 plugin/ipc/socket/socketconnlist.cpp (fd) (device);
fd 182 plugin/ipc/socket/socketconnlist.cpp add(fd, con);
fd 38 plugin/ipc/ssh/dmtcp_ssh.cpp if (getsockname(fd, (struct sockaddr *)&addr, &addrlen) == -1) {
fd 48 plugin/ipc/ssh/dmtcp_ssh.cpp int fd = open("/dev/null", O_RDWR);
fd 49 plugin/ipc/ssh/dmtcp_ssh.cpp if (fd != STDIN_FILENO) {
fd 50 plugin/ipc/ssh/dmtcp_ssh.cpp dup2(fd, STDIN_FILENO);
fd 51 plugin/ipc/ssh/dmtcp_ssh.cpp close(fd);
fd 55 plugin/ipc/ssh/dmtcp_ssh.cpp int fd = open("/dev/null", O_RDWR);
fd 56 plugin/ipc/ssh/dmtcp_ssh.cpp if (fd != STDOUT_FILENO) {
fd 57 plugin/ipc/ssh/dmtcp_ssh.cpp dup2(fd, STDOUT_FILENO);
fd 58 plugin/ipc/ssh/dmtcp_ssh.cpp close(fd);
fd 62 plugin/ipc/ssh/dmtcp_ssh.cpp int fd = open("/dev/null", O_RDWR);
fd 63 plugin/ipc/ssh/dmtcp_ssh.cpp if (fd != STDERR_FILENO) {
fd 64 plugin/ipc/ssh/dmtcp_ssh.cpp dup2(fd, STDERR_FILENO);
fd 65 plugin/ipc/ssh/dmtcp_ssh.cpp close(fd);
fd 118 plugin/ipc/ssh/dmtcp_ssh.cpp int fd = accept(listenSock, NULL, NULL);
fd 119 plugin/ipc/ssh/dmtcp_ssh.cpp if (fd == -1) {
fd 125 plugin/ipc/ssh/dmtcp_ssh.cpp return fd;
fd 47 plugin/ipc/ssh/dmtcp_sshd.cpp int fd;
fd 64 plugin/ipc/ssh/dmtcp_sshd.cpp fd = STDIN_FILENO;
fd 65 plugin/ipc/ssh/dmtcp_sshd.cpp if (sendFd(sendfd, fd, &fd, sizeof(fd), addr, len) == -1) {
fd 69 plugin/ipc/ssh/dmtcp_sshd.cpp fd = STDOUT_FILENO;
fd 70 plugin/ipc/ssh/dmtcp_sshd.cpp if (sendFd(sendfd, fd, &fd, sizeof(fd), addr, len) == -1) {
fd 74 plugin/ipc/ssh/dmtcp_sshd.cpp fd = STDERR_FILENO;
fd 75 plugin/ipc/ssh/dmtcp_sshd.cpp if (sendFd(sendfd, fd, &fd, sizeof(fd), addr, len) == -1) {
fd 79 plugin/ipc/ssh/dmtcp_sshd.cpp fd = pipefd[1];
fd 80 plugin/ipc/ssh/dmtcp_sshd.cpp if (sendFd(sendfd, fd, &fd, sizeof(fd), addr, len) == -1) {
fd 96 plugin/ipc/ssh/ssh.cpp if (fd == SSHD_PIPE_FD) {
fd 99 plugin/ipc/ssh/ssh.cpp JASSERT(data == fd) (data) (fd);
fd 100 plugin/ipc/ssh/ssh.cpp if (fd != ret) {
fd 101 plugin/ipc/ssh/ssh.cpp _real_close(fd);
fd 102 plugin/ipc/ssh/ssh.cpp _real_dup2(ret, fd);
fd 32 plugin/ipc/ssh/sshdrainer.cpp int fd;
fd 34 plugin/ipc/ssh/sshdrainer.cpp fd = sock->socket().sockfd();
fd 36 plugin/ipc/ssh/sshdrainer.cpp if (fd < 0) return;
fd 38 plugin/ipc/ssh/sshdrainer.cpp (fd) (JASSERT_ERRNO);
fd 39 plugin/ipc/ssh/sshdrainer.cpp _drainedData.erase(fd);
fd 87 plugin/ipc/ssh/sshdrainer.cpp addWrite(new jalib::JChunkWriter(fd, theMagicDrainCookie,
fd 91 plugin/ipc/ssh/sshdrainer.cpp _drainedData[fd]; // create buffer
fd 92 plugin/ipc/ssh/sshdrainer.cpp _refillFd[fd] = refillFd;
fd 93 plugin/ipc/ssh/sshdrainer.cpp addDataSocket(new jalib::JChunkReader(fd,512));
fd 104 plugin/ipc/ssh/sshdrainer.cpp int fd = i->first;
fd 105 plugin/ipc/ssh/sshdrainer.cpp int refillFd = _refillFd[fd];
fd 17 plugin/ipc/ssh/sshdrainer.h void beginDrainOf(int fd, int refillfd = -1);
fd 68 plugin/ipc/ssh/util_ssh.cpp ssize_t rc = read(fd, &buf->buf[buf->end], max);
fd 89 plugin/ipc/ssh/util_ssh.cpp ssize_t rc = write(fd, &buf->buf[buf->off], max);
fd 105 plugin/ipc/ssh/util_ssh.cpp val = fcntl(fd, F_GETFL, 0);
fd 110 plugin/ipc/ssh/util_ssh.cpp if (fcntl(fd, F_SETFL, val) == -1) {
fd 87 plugin/pid/pid.cpp jalib::JBinarySerializeWriterRaw wr ("", data->serializerInfo.fd);
fd 94 plugin/pid/pid.cpp jalib::JBinarySerializeReaderRaw rd ("", data->serializerInfo.fd);
fd 101 plugin/pid/pid.cpp int fd;
fd 109 plugin/pid/pid.cpp if ((fd = _real_open(name.c_str(), O_EXCL|O_CREAT|O_TRUNC | flags, 0600)) >= 0) {
fd 110 plugin/pid/pid.cpp return fd;
fd 114 plugin/pid/pid.cpp JTRACE("_real_open: ")(strerror(errno))(fd)(flags);
fd 116 plugin/pid/pid.cpp if ( (fd < 0) && (errno_bkp == EEXIST) ) {
fd 118 plugin/pid/pid.cpp if ((fd = _real_open(name.c_str(), flags, 0600)) >= 0) {
fd 119 plugin/pid/pid.cpp return fd;
fd 129 plugin/pid/pid.cpp int fd;
fd 138 plugin/pid/pid.cpp fd = openSharedFile(pidMapFile, O_RDWR);
fd 139 plugin/pid/pid.cpp JASSERT (fd != -1);
fd 140 plugin/pid/pid.cpp JASSERT (dup2 (fd, PROTECTED_PIDMAP_FD) == PROTECTED_PIDMAP_FD)
fd 142 plugin/pid/pid.cpp close (fd);
fd 176 plugin/pid/pid_filewrappers.cpp int retval = _real_fxstat(vers, fd, buf);
fd 182 plugin/pid/pid_filewrappers.cpp int retval = _real_fxstat64(vers, fd, buf);
fd 139 plugin/pid/pid_syscallsreal.c REAL_FUNC_PASSTHROUGH ( tcgetsid ) ( fd );
fd 144 plugin/pid/pid_syscallsreal.c REAL_FUNC_PASSTHROUGH ( tcsetpgrp ) ( fd, pgrp );
fd 149 plugin/pid/pid_syscallsreal.c REAL_FUNC_PASSTHROUGH ( tcgetpgrp ) ( fd );
fd 354 plugin/pid/pid_syscallsreal.c REAL_FUNC_PASSTHROUGH (fcntl) (fd, cmd, arg);
fd 173 plugin/pid/pidwrappers.cpp pid_t realPid = _real_tcsetpgrp(fd, currPgrp);
fd 186 plugin/pid/pidwrappers.cpp pid_t retval = REAL_TO_VIRTUAL_PID(_real_tcgetpgrp(fd));
fd 188 plugin/pid/pidwrappers.cpp JTRACE("tcgetpgrp return value") (fd) (retval);
fd 198 plugin/pid/pidwrappers.cpp pid_t retval = REAL_TO_VIRTUAL_PID(_real_tcgetsid(fd));
fd 200 plugin/pid/pidwrappers.cpp JTRACE("tcgetsid return value") (fd) (retval);
fd 596 plugin/pid/pidwrappers.cpp int result = _real_fcntl(fd, cmd, arg);
fd 180 plugin/pid/pidwrappers.h pid_t _real_tcgetsid(int fd);
fd 181 plugin/pid/pidwrappers.h pid_t _real_tcgetpgrp(int fd);
fd 182 plugin/pid/pidwrappers.h int _real_tcsetpgrp(int fd, pid_t pgrp);
fd 212 plugin/pid/pidwrappers.h int _real_fcntl(int fd, int cmd, void *arg);
fd 90 plugin/svipc/dmtcp-test.h int fd;
fd 133 plugin/svipc/sysvipc.cpp jalib::JBinarySerializeWriterRaw wr("", data->serializerInfo.fd);
fd 142 plugin/svipc/sysvipc.cpp jalib::JBinarySerializeReaderRaw rd("", data->serializerInfo.fd);
fd 112 popen.cpp int fd = fileno(it->first);
fd 116 popen.cpp if (fd != child_std_fd) {
fd 62 processinfo.cpp jalib::JBinarySerializeWriterRaw wr("", data->serializerInfo.fd);
fd 70 processinfo.cpp jalib::JBinarySerializeReaderRaw rd("", data->serializerInfo.fd);
fd 38 procselfmaps.cpp fd = _real_open("/proc/self/maps", O_RDONLY);
fd 39 procselfmaps.cpp JASSERT(fd != -1) (JASSERT_ERRNO);
fd 44 procselfmaps.cpp numRead = Util::readAll(fd, buf, sizeof(buf));
fd 54 procselfmaps.cpp JASSERT(lseek(fd, 0, SEEK_SET) == 0);
fd 56 procselfmaps.cpp numBytes = Util::readAll(fd, data, size);
fd 66 procselfmaps.cpp _real_close(fd);
fd 78 procselfmaps.cpp fd = -1;
fd 142 shareddata.cpp int fd = _real_open(o.str().c_str(), O_RDWR | O_CREAT | O_EXCL, 0600);
fd 143 shareddata.cpp if (fd == -1 && errno == EEXIST) {
fd 144 shareddata.cpp fd = _real_open(o.str().c_str(), O_RDWR, 0600);
fd 148 shareddata.cpp JASSERT(fd != -1) (JASSERT_ERRNO);
fd 149 shareddata.cpp JASSERT(_real_dup2(fd, PROTECTED_SHM_FD) == PROTECTED_SHM_FD)
fd 151 shareddata.cpp _real_close(fd);
fd 511 syscallsreal.c REAL_FUNC_PASSTHROUGH (read) (fd,buf,count);
fd 516 syscallsreal.c REAL_FUNC_PASSTHROUGH_TYPED (ssize_t,write) (fd,buf,count);
fd 581 syscallsreal.c REAL_FUNC_PASSTHROUGH (fexecve) (fd,argv,envp);
fd 632 syscallsreal.c REAL_FUNC_PASSTHROUGH (close) (fd);
fd 668 syscallsreal.c REAL_FUNC_PASSTHROUGH (fcntl) (fd, cmd, arg);
fd 686 syscallsreal.c REAL_FUNC_PASSTHROUGH (ptsname_r) (fd, buf, buflen);
fd 691 syscallsreal.c REAL_FUNC_PASSTHROUGH (ttyname_r) (fd, buf, buflen);
fd 1069 syscallsreal.c REAL_FUNC_PASSTHROUGH_TYPED (void*, mmap) (addr,length,prot,flags,fd,offset);
fd 1075 syscallsreal.c REAL_FUNC_PASSTHROUGH_TYPED (void*,mmap64) (addr,length,prot,flags,fd,offset);
fd 303 syscallwrappers.h int _real_fexecve (int fd, char *const argv[], char *const envp[]);
fd 326 syscallwrappers.h int _real_close (int fd);
fd 333 syscallwrappers.h int _real_fcntl(int fd, int cmd, void *arg);
fd 335 syscallwrappers.h int _real_ttyname_r (int fd, char *buf, size_t buflen);
fd 336 syscallwrappers.h int _real_ptsname_r (int fd, char * buf, size_t buflen);
fd 407 syscallwrappers.h int fd, off_t offset);
fd 409 syscallwrappers.h int fd, __off64_t offset);
fd 419 syscallwrappers.h ssize_t _real_read(int fd, void *buf, size_t count);
fd 420 syscallwrappers.h ssize_t _real_write(int fd, const void *buf, size_t count);
fd 423 syscallwrappers.h off_t _real_lseek(int fd, off_t offset, int whence);
fd 78 terminal.cpp if (tcsetattr(fd, TCSANOW, termios_p) == -1) return -1;
fd 79 terminal.cpp if (tcgetattr(fd, &new_termios) == -1) return -1;
fd 165 util_exec.cpp int fd = _real_open(full_path, O_RDONLY, 0);
fd 166 util_exec.cpp if (fd == -1) {
fd 169 util_exec.cpp ssize_t ret = readAll(fd, argv_buf, len);
fd 170 util_exec.cpp close (fd);
fd 480 util_exec.cpp sprintf(buf, "%d", fd);
fd 490 util_exec.cpp JTRACE ("launching mtcp_restart --fd")(fd)(path);
fd 104 util_init.cpp int fd = open(portFile, O_CREAT|O_WRONLY|O_TRUNC, 0600);
fd 105 util_init.cpp JWARNING(fd != -1) (JASSERT_ERRNO) (portFile)
fd 110 util_init.cpp writeAll(fd, port_buf, strlen(port_buf));
fd 111 util_init.cpp fsync(fd);
fd 112 util_init.cpp close(fd);
fd 47 util_misc.cpp result = _real_fcntl(fd, F_SETLKW, &fl); /* F_GETLK, F_SETLK, F_SETLKW */
fd 76 util_misc.cpp result = _real_fcntl(fd, F_SETLK, &fl); /* set the region to unlocked */
fd 253 util_misc.cpp ssize_t rc = _real_write (fd, ptr + num_written, count - num_written);
fd 279 util_misc.cpp rc = _real_read (fd, ptr + num_read, count - num_read);
fd 300 util_misc.cpp rc = Util::readAll(fd, buf, MIN(count, sizeof(buf)));
fd 344 util_misc.cpp JASSERT(fd >= 0 && buf != NULL) (fd) ((void*)buf);
fd 347 util_misc.cpp ssize_t rc = read(fd, &c, 1);
fd 374 util_misc.cpp c = readChar (fd);
fd 392 util_misc.cpp c = readChar (fd);
fd 411 util_misc.cpp rc = _real_read (fd, &c, 1);
fd 513 util_misc.cpp int fd;
fd 519 util_misc.cpp fd = _real_open(buf, O_RDONLY, 0);
fd 520 util_misc.cpp JASSERT(fd != -1) (buf) (JASSERT_ERRNO);
fd 521 util_misc.cpp readAll(fd, buf, sizeof buf);
fd 522 util_misc.cpp _real_close(fd);
fd 542 util_misc.cpp return _real_fcntl(fd, F_GETFL, 0) != -1;
fd 220 writeckpt.cpp Util::writeAll(fd, &area, sizeof(area));
fd 253 writeckpt.cpp writememoryarea(fd, &area, stack_was_seen);
fd 265 writeckpt.cpp Util::writeAll(fd, &area, sizeof(area));
fd 268 writeckpt.cpp JASSERT(_real_close (fd) == 0);
fd 358 writeckpt.cpp Util::writeAll(fd, &a, sizeof(a));
fd 360 writeckpt.cpp Util::writeAll(fd, a.addr, a.size);
fd 415 writeckpt.cpp mtcp_write_non_rwx_and_anonymous_pages(fd, area);
fd 423 writeckpt.cpp Util::writeAll(fd, area, sizeof(*area));
fd 424 writeckpt.cpp Util::writeAll(fd, area->addr, area->size);