Home
last modified time | relevance | path

Searched refs:fd (Results 1 - 25 of 84) sorted by relevance

1234

/6.6.0/forestdb/src/
H A Dfilemgr_ops_windows.cc33 static inline HANDLE handle_to_win(int fd) in handle_to_win() argument
35 return (HANDLE)_get_osfhandle(fd); in handle_to_win()
41 int fd = _open(pathname, flags, mode); in _filemgr_win_open() local
42 if (fd < 0) { in _filemgr_win_open()
47 return fd; in _filemgr_win_open()
49 int fd; in _filemgr_win_open()
51 fd = open(pathname, flags | O_LARGEFILE, mode); in _filemgr_win_open()
52 } while (fd == -1 && errno == EINTR); in _filemgr_win_open()
54 if (fd < 0) { in _filemgr_win_open()
57 return fd; in _filemgr_win_open()
61 _filemgr_win_pwrite(int fd, void *buf, size_t count, cs_off_t offset) _filemgr_win_pwrite() argument
83 _filemgr_win_pread(int fd, void *buf, size_t count, cs_off_t offset) _filemgr_win_pread() argument
105 _filemgr_win_close(int fd) _filemgr_win_close() argument
134 _filemgr_win_goto_eof(int fd) _filemgr_win_goto_eof() argument
172 _filemgr_win_fsync(int fd) _filemgr_win_fsync() argument
188 _filemgr_win_fdatasync(int fd) _filemgr_win_fdatasync() argument
[all...]
H A Dfilemgr_ops_linux.cc34 int fd; in _filemgr_linux_open() local
36 fd = open(pathname, flags | O_LARGEFILE, mode); in _filemgr_linux_open()
37 } while (fd == -1 && errno == EINTR); in _filemgr_linux_open()
39 if (fd < 0) { in _filemgr_linux_open()
43 return fd; in _filemgr_linux_open()
46 ssize_t _filemgr_linux_pwrite(int fd, void *buf, size_t count, cs_off_t offset) in _filemgr_linux_pwrite() argument
50 rv = pwrite(fd, buf, count, offset); in _filemgr_linux_pwrite()
60 ssize_t _filemgr_linux_pread(int fd, void *buf, size_t count, cs_off_t offset) in _filemgr_linux_pread() argument
64 rv = pread(fd, buf, count, offset); in _filemgr_linux_pread()
74 int _filemgr_linux_close(int fd) in _filemgr_linux_close() argument
91 _filemgr_linux_goto_eof(int fd) _filemgr_linux_goto_eof() argument
113 _filemgr_linux_fsync(int fd) _filemgr_linux_fsync() argument
129 _filemgr_linux_fdatasync(int fd) _filemgr_linux_fdatasync() argument
[all...]
H A Dfilemgr_ops.h32 ssize_t (*pwrite)(int fd, void *buf, size_t count, cs_off_t offset);
33 ssize_t (*pread)(int fd, void *buf, size_t count, cs_off_t offset);
34 int (*close)(int fd);
35 cs_off_t (*goto_eof)(int fd);
37 int (*fdatasync)(int fd);
38 int (*fsync)(int fd);
/6.6.0/sigar/src/os/solaris/
H A Dprocfs.c22 #define my_pread(fd, ptr, type, offset) \
23 (pread(fd, ptr, sizeof(type), offset) == sizeof(type))
27 int fd, retval = SIGAR_OK; in sigar_proc_psinfo_get() local
46 if ((fd = open(buffer, O_RDONLY)) < 0) { in sigar_proc_psinfo_get()
50 if (!my_pread(fd, sigar->pinfo, psinfo_t, 0)) { in sigar_proc_psinfo_get()
54 close(fd); in sigar_proc_psinfo_get()
61 int fd, retval = SIGAR_OK; in sigar_proc_usage_get() local
66 if ((fd = open(buffer, O_RDONLY)) < 0) { in sigar_proc_usage_get()
70 if (!my_pread(fd, prusage, prusage_t, 0)) { in sigar_proc_usage_get()
74 close(fd); in sigar_proc_usage_get()
81 int fd, retval = SIGAR_OK; sigar_proc_status_get() local
[all...]
/6.6.0/godeps/src/google.golang.org/grpc/reflection/
H A Dserverreflection.go95 fd, err := decodeFileDesc(fdenc)
99 s.processFile(fd, processed)
107 func (s *serverReflectionServer) processFile(fd *dpb.FileDescriptorProto, processed map[string]struct{}) {
108 filename := fd.GetName()
114 prefix := fd.GetPackage()
116 for _, msg := range fd.MessageType {
117 s.processMessage(fd, prefix, msg)
119 for _, en := range fd.EnumType {
120 s.processEnum(fd, prefix, en)
122 for _, ext := range fd
[all...]
/6.6.0/forestdb/tests/anomaly/
H A Dfilemgr_anomalous_ops.cc75 int fd, void *buf, size_t count, cs_off_t offset) in _pwrite_cb()
77 return normal_ops->pwrite(fd, buf, count, offset); in _pwrite_cb()
81 int fd, void *buf, size_t count, cs_off_t offset) in _pread_cb()
83 return normal_ops->pread(fd, buf, count, offset); in _pread_cb()
87 int fd) in _close_cb()
89 return normal_ops->close(fd); in _close_cb()
93 int fd) in _goto_eof_cb()
95 return normal_ops->goto_eof(fd); in _goto_eof_cb()
105 int fd) in _fdatasync_cb()
107 return normal_ops->fdatasync(fd); in _fdatasync_cb()
74 _pwrite_cb(void *ctx, struct filemgr_ops *normal_ops, int fd, void *buf, size_t count, cs_off_t offset) _pwrite_cb() argument
80 _pread_cb(void *ctx, struct filemgr_ops *normal_ops, int fd, void *buf, size_t count, cs_off_t offset) _pread_cb() argument
86 _close_cb(void *ctx, struct filemgr_ops *normal_ops, int fd) _close_cb() argument
92 _goto_eof_cb(void *ctx, struct filemgr_ops *normal_ops, int fd) _goto_eof_cb() argument
104 _fdatasync_cb(void *ctx, struct filemgr_ops *normal_ops, int fd) _fdatasync_cb() argument
110 _fsync_cb(void *ctx, struct filemgr_ops *normal_ops, int fd) _fsync_cb() argument
211 _filemgr_anomalous_pwrite(int fd, void *buf, size_t count, cs_off_t offset) _filemgr_anomalous_pwrite() argument
218 _filemgr_anomalous_pread(int fd, void *buf, size_t count, cs_off_t offset) _filemgr_anomalous_pread() argument
225 _filemgr_anomalous_close(int fd) _filemgr_anomalous_close() argument
230 _filemgr_anomalous_goto_eof(int fd) _filemgr_anomalous_goto_eof() argument
240 _filemgr_anomalous_fsync(int fd) _filemgr_anomalous_fsync() argument
245 _filemgr_anomalous_fdatasync(int fd) _filemgr_anomalous_fdatasync() argument
[all...]
H A Dfilemgr_anomalous_ops.h36 int fd, void *buf, size_t count, cs_off_t offset);
38 int fd, void *buf, size_t count, cs_off_t offset);
39 int (*close_cb)(void *ctx, struct filemgr_ops *normal_ops, int fd);
40 cs_off_t (*goto_eof_cb)(void *ctx, struct filemgr_ops *normal_ops, int fd);
43 int (*fdatasync_cb)(void *ctx, struct filemgr_ops *normal_ops, int fd);
44 int (*fsync_cb)(void *ctx, struct filemgr_ops *normal_ops, int fd);
/6.6.0/couchstore/src/
H A Dos.cc73 File(int fd = -1) : fd(fd) { in File()
77 int fd; member
111 rv = ::pread(file->fd, buf, nbyte, offset); in pread()
134 rv = ::pwrite(file->fd, buf, nbyte, offset); in pwrite()
159 ssize_t got_bytes = ::pread(file->fd, read_buf, len, read_offset); in pwrite()
212 cb_assert(file->fd == -1); in open()
217 int fd; in open() local
219 fd in open()
[all...]
/6.6.0/kv_engine/engines/ep/src/
H A Dmutation_log.cc36 ssize_t pread(file_handle_t fd, void *buf, size_t nbyte, uint64_t offset) in pread() argument
43 if (!ReadFile(fd, buf, nbyte, &bytesread, &winoffs)) { in pread()
51 ssize_t pwrite(file_handle_t fd, const void *buf, size_t nbyte, in pwrite() argument
59 if (!WriteFile(fd, buf, nbyte, &byteswritten, &winoffs)) { in pwrite()
67 static inline ssize_t doWrite(file_handle_t fd, const uint8_t *buf, in doWrite() argument
70 if (!WriteFile(fd, buf, nbytes, &byteswritten, NULL)) { in doWrite()
78 static inline void doClose(file_handle_t fd) { in doClose() argument
79 if (!CloseHandle(fd)) { in doClose()
85 static inline void doFsync(file_handle_t fd) { in doFsync() argument
86 if (!FlushFileBuffers(fd)) { in doFsync()
92 SeekFile(file_handle_t fd, const std::string &fname, uint64_t offset, bool end) SeekFile() argument
116 file_handle_t fd; OpenFile() local
142 getFileSize(file_handle_t fd) getFileSize() argument
153 doWrite(file_handle_t fd, const uint8_t *buf, size_t nbytes) doWrite() argument
167 doClose(file_handle_t fd) doClose() argument
179 doFsync(file_handle_t fd) doFsync() argument
191 SeekFile(file_handle_t fd, const std::string &fname, uint64_t offset, bool end) SeekFile() argument
209 file_handle_t fd; OpenFile() local
223 getFileSize(file_handle_t fd) getFileSize() argument
235 writeFully(file_handle_t fd, const uint8_t *buf, size_t nbytes) writeFully() argument
[all...]
/6.6.0/forestdb/tests/functional/
H A Dfunctional_util.cc38 int fd = ops->open(filepath, O_CREAT| O_RDWR, 0666); in _disk_dump() local
39 if (fd < 0) { in _disk_dump()
41 return fd; in _disk_dump()
47 if (ops->pwrite(fd, buf, bytes, pos) != (int) bytes) { in _disk_dump()
50 ops->close(fd); in _disk_dump()
52 return fd; in _disk_dump()
/6.6.0/third_party/spdlog/include/spdlog/fmt/bundled/
H A Dcolors.h58 FMT_FUNC void vprint_rgb(rgb fd, string_view format, format_args args) in vprint_rgb() argument
62 internal::to_esc(fd.r, escape_fd, 7); in vprint_rgb()
63 internal::to_esc(fd.g, escape_fd, 11); in vprint_rgb()
64 internal::to_esc(fd.b, escape_fd, 15); in vprint_rgb()
71 FMT_FUNC void vprint_rgb(rgb fd, rgb bg, string_view format, format_args args) in vprint_rgb() argument
76 internal::to_esc(fd.r, escape_fd, 7); in vprint_rgb()
77 internal::to_esc(fd.g, escape_fd, 11); in vprint_rgb()
78 internal::to_esc(fd.b, escape_fd, 15); in vprint_rgb()
91 inline void print_rgb(rgb fd, string_view format_str, const Args &... args) in print_rgb() argument
93 vprint_rgb(fd, format_st in print_rgb()
98 print(rgb fd, string_view format_str, const Args &... args) print() argument
105 print(rgb fd, rgb bg, string_view format_str, const Args &... args) print() argument
[all...]
H A Dposix.h268 explicit file(int fd) in file() argument
269 : fd_(fd) in file()
297 int fd; member
302 file(Proxy p) FMT_NOEXCEPT : fd_(p.fd) {} in fd_()
314 fd_ = p.fd; in operator =()
379 FMT_API static file dup(int fd);
381 // Makes fd be the copy of this file descriptor, closing fd first if
383 FMT_API void dup2(int fd);
385 // Makes fd b
[all...]
/6.6.0/goproj/src/github.com/couchbase/nitro/
H A Dfile.go66 fd *os.File
75 f.fd, err = os.OpenFile(path, os.O_WRONLY|os.O_CREATE, 0755)
78 f.w = bufio.NewWriterSize(f.fd, DiskBlockSize)
101 return f.fd.Close()
107 fd *os.File
116 f.fd, err = os.Open(path)
119 f.r = bufio.NewReaderSize(f.fd, DiskBlockSize)
137 return f.fd.Close()
/6.6.0/third_party/HdrHistogram_c/examples/
H A Dhiccup.c36 struct pollfd fd; in record_hiccups() local
42 memset(&fd, 0, sizeof(struct pollfd)); in record_hiccups()
47 fd.fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); in record_hiccups()
48 fd.events = POLLIN|POLLPRI|POLLRDHUP; in record_hiccups()
49 fd.revents = 0; in record_hiccups()
59 timerfd_settime(fd.fd, 0, &timeout, NULL); in record_hiccups()
62 poll(&fd, 1, -1); in record_hiccups()
/6.6.0/godeps/src/google.golang.org/grpc/internal/channelz/
H A Dtypes_linux.go30 // getter function to obtain info from fd.
40 func (s *SocketOptionData) Getsockopt(fd uintptr) {
41 if v, err := unix.GetsockoptLinger(int(fd), syscall.SOL_SOCKET, syscall.SO_LINGER); err == nil {
44 if v, err := unix.GetsockoptTimeval(int(fd), syscall.SOL_SOCKET, syscall.SO_RCVTIMEO); err == nil {
47 if v, err := unix.GetsockoptTimeval(int(fd), syscall.SOL_SOCKET, syscall.SO_SNDTIMEO); err == nil {
50 if v, err := unix.GetsockoptTCPInfo(int(fd), syscall.SOL_TCP, syscall.TCP_INFO); err == nil {
/6.6.0/godeps/src/golang.org/x/tools/go/ssa/interp/
H A Dexternal_unix.go83 // func Close(fd int) (err error)
92 fd := args[0].(int)
95 return wrapError(syscall.Fchown(fd, uid, gid))
99 // func Fstat(fd int, stat *Stat_t) (err error)
100 fd := args[0].(int)
104 err := syscall.Fstat(fd, &st)
110 fd := args[0].(int)
112 return wrapError(syscall.Ftruncate(fd, length))
153 // func Open(path string, mode int, perm uint32) (fd int, err error) {
157 fd, er
[all...]
/6.6.0/godeps/src/github.com/couchbase/vellum/vendor/github.com/edsrzf/mmap-go/
H A Dmmap.go57 var fd uintptr var
59 fd = uintptr(f.Fd())
71 fd = ^uintptr(0)
73 return mmap(length, uintptr(prot), uintptr(flags), fd, offset)
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/memdb/
H A Dfile.go59 fd *os.File
68 f.fd, err = os.OpenFile(path, os.O_WRONLY|os.O_CREATE, 0755)
71 f.w = bufio.NewWriterSize(f.fd, DiskBlockSize)
94 return f.fd.Close()
100 fd *os.File
109 f.fd, err = os.Open(path)
112 f.r = bufio.NewReaderSize(f.fd, DiskBlockSize)
130 return f.fd.Close()
/6.6.0/third_party/spdlog/include/spdlog/details/
H A Dos.h149 auto fd = fileno(f); in prevent_child_fd()
150 if (fcntl(fd, F_SETFD, FD_CLOEXEC) == -1) in prevent_child_fd()
218 throw spdlog_ex("Failed getting file size. fd is null"); in filesize()
221 int fd = _fileno(f); in filesize() local
224 if (_fstat64(fd, &st) == 0) in filesize()
230 long ret = _filelength(fd); in filesize()
238 int fd = fileno(f); in filesize() local
242 if (fstat64(fd, &st) == 0) in filesize()
249 if (fstat(fd, &st) == 0) in filesize()
255 throw spdlog_ex("Failed getting file size from fd", errn in filesize()
[all...]
/6.6.0/godeps/src/github.com/shirou/gopsutil/net/
H A Dnet_linux.go370 fd uint32
374 fd uint32
509 Fd: c.fd,
538 // getProcInodes returnes fd of the pid.
542 dir := fmt.Sprintf("%s/%d/fd", root, pid)
552 for _, fd := range files {
553 inodePath := fmt.Sprintf("%s/%d/fd/%s", root, pid, fd.Name())
569 fd, err := strconv.Atoi(fd
[all...]
/6.6.0/godeps/src/github.com/aws/aws-sdk-go/example/service/dynamodb/unitTest/
H A DunitTest_test.go24 func (fd *fakeDynamoDB) GetItem(input *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error) {
27 for key, value := range fd.payload {
32 return output, fd.err
/6.6.0/kv_engine/daemon/
H A Dstats_tasks.cc30 fd = fd_; in StatsTaskConnectionStats()
45 if (c.getSocketDescriptor() == fd || fd == -1) { in execute()
/6.6.0/godeps/src/google.golang.org/grpc/internal/syscall/
H A Dsyscall_linux.go83 err = rawConn.Control(func(fd uintptr) {
84 err = syscall.SetsockoptInt(int(fd), syscall.IPPROTO_TCP, unix.TCP_USER_TIMEOUT, int(timeout/time.Millisecond))
105 err = rawConn.Control(func(fd uintptr) {
106 opt, err = syscall.GetsockoptInt(int(fd), syscall.IPPROTO_TCP, unix.TCP_USER_TIMEOUT)
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/cmd/cbindexperf/
H A Dmain.go48 fd, err := os.Create(*cpuprofile)
53 pprof.StartCPUProfile(fd)
57 fd, err := os.Create(*memprofile)
62 defer pprof.WriteHeapProfile(fd)
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/tools/n1qlperf/
H A Dmain.go46 fd, err := os.Create(*cpuprofile)
51 pprof.StartCPUProfile(fd)
55 fd, err := os.Create(*memprofile)
60 defer pprof.WriteHeapProfile(fd)

Completed in 62 milliseconds

1234