Method processFileConnection

src/plugin/ipc/file/fileconnlist.cpp:686–730

}

void
FileConnList::processFileConnection(int fd,
                                    const char *path,
                                    int flags,
                                    mode_t mode)
{
  Connection *c = NULL;

  string device;

  if (path == NULL) {
    device = jalib::Filesystem::GetDeviceName(fd);
  } else {
    device = jalib::Filesystem::ResolveSymlink(path);
    if (device == "") {
      device = path;
    }
  }

  struct stat statbuf;
  JASSERT(fstat(fd, &statbuf) == 0);

  if (strstr(device.c_str(), "infiniband/uverbs") ||
      strstr(device.c_str(), "uverbs-event")) {
    return;
  }

  path = device.c_str();
  if (S_ISREG(statbuf.st_mode) || S_ISCHR(statbuf.st_mode) ||
      S_ISDIR(statbuf.st_mode) || S_ISBLK(statbuf.st_mode)) {
    int type = FileConnection::FILE_REGULAR;
    if (dmtcp_is_bq_file && dmtcp_is_bq_file(path)) {
      // Resource manager related
      type = FileConnection::FILE_BATCH_QUEUE;
    }
    c = new FileConnection(path, flags, mode, type);
  } else if (S_ISFIFO(statbuf.st_mode)) {
    // FIFO
    c = new FifoConnection(path, flags, mode);
  } else {
    JASSERT(false) (path).Text("Unimplemented file type.");
  }

  add(fd, c);
}