Home
last modified time | relevance | path

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

123

/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_unique_fd_test.cpp61 int fd = open("NOTHISFILE", O_RDWR, 0666); in HWTEST_F() local
63 UniqueFd ufd2(fd); in HWTEST_F()
76 int fd = open(testfilename, O_RDWR, 0666); in HWTEST_F() local
77 UniqueFd ufd2(fd); in HWTEST_F()
78 ASSERT_EQ(fd, ufd2); in HWTEST_F()
79 ASSERT_EQ(ufd2, fd); in HWTEST_F()
84 int fd = open(testfilename, O_RDWR, 0666); in HWTEST_F() local
85 UniqueFd ufd2(fd); in HWTEST_F()
92 int fd = open(testfilename, O_RDWR, 0666); in HWTEST_F() local
93 UniqueFd ufd2(fd); in HWTEST_F()
100 int fd = open(testfilename, O_RDWR, 0666); HWTEST_F() local
108 int fd = open(testfilename, O_RDWR, 0666); HWTEST_F() local
116 int fd = open(testfilename, O_RDWR, 0666); HWTEST_F() local
125 Close(int fd) Close() argument
137 int fd = open(testfilename, O_RDWR); HWTEST_F() local
151 int fd = open(testfilename, O_RDWR); HWTEST_F() local
164 int fd = open(testfilename, O_RDWR); HWTEST_F() local
[all...]
H A Dutils_file_test.cpp87 int fd = open(filename.c_str(), O_RDONLY); in HWTEST_F() local
88 EXPECT_TRUE(LoadStringFromFd(fd, str2)); in HWTEST_F()
89 close(fd); in HWTEST_F()
172 * @tc.desc: Test loading a file by a invalid fd -1
183 * @tc.desc: Test loading a newly created file without contents by its fd
191 int fd = open(filename.c_str(), O_RDONLY); in HWTEST_F() local
192 EXPECT_TRUE(LoadStringFromFd(fd, result)); in HWTEST_F()
193 close(fd); in HWTEST_F()
200 * @tc.desc: Test loading a newly created file with contents by its fd
208 int fd in HWTEST_F() local
225 int fd = open(filename.c_str(), O_RDONLY); HWTEST_F() local
242 int fd = open(filename.c_str(), O_RDONLY); HWTEST_F() local
259 int fd = open(filename.c_str(), O_RDONLY); HWTEST_F() local
393 int fd = open(filename.c_str(), O_RDWR | O_CREAT | O_TRUNC, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); HWTEST_F() local
415 int fd = open(filename.c_str(), O_RDWR | O_CREAT | O_TRUNC, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); HWTEST_F() local
437 int fd = open(filename.c_str(), O_RDONLY | O_CREAT | O_TRUNC, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); HWTEST_F() local
[all...]
H A Dutils_event_test.cpp65 TimerFdHandler(int fd, const TimerEventCallback& cb);
87 // 2. Set fd in HWTEST_F()
88 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); in HWTEST_F() local
89 ASSERT_NE(fd, -1); in HWTEST_F()
90 handler->SetFd(fd); in HWTEST_F()
91 EXPECT_EQ(handler->GetFd(), fd); in HWTEST_F()
130 // 2. Set fd in HWTEST_F()
131 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); in HWTEST_F() local
132 ASSERT_NE(fd, -1); in HWTEST_F()
133 handler->SetFd(fd); in HWTEST_F()
173 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); HWTEST_F() local
232 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); HWTEST_F() local
251 TimerFdHandler(int fd, const TimerEventCallback& cb) TimerFdHandler() argument
334 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); HWTEST_F() local
368 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); HWTEST_F() local
407 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); HWTEST_F() local
441 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); HWTEST_F() local
478 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); HWTEST_F() local
515 int fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK | TFD_CLOEXEC); HWTEST_F() local
[all...]
/commonlibrary/c_utils/base/src/
H A Dashmem.cpp46 int fd = AshmemCreate(name, size); in CreateAshmemStd() local
47 if (fd < 0) { in CreateAshmemStd()
48 UTILS_LOGE("%{public}s: Failed to exec AshmemCreate, fd= %{public}d", __func__, size); in CreateAshmemStd()
52 return std::make_shared<Ashmem>(fd, size); in CreateAshmemStd()
68 int fd = TEMP_FAILURE_RETRY(open("/dev/ashmem", O_RDWR | O_CLOEXEC)); in AshmemOpenLocked() local
69 if (fd < 0) { in AshmemOpenLocked()
70 UTILS_LOGE("%{public}s: fd is invalid, fd = %{public}d, errno = %{public}d", __func__, fd, errno); in AshmemOpenLocked()
71 return fd; in AshmemOpenLocked()
93 int fd = AshmemOpenLocked(); AshmemOpen() local
106 int fd = AshmemOpen(); AshmemCreate() local
138 AshmemSetProt(int fd, int prot) AshmemSetProt() argument
143 AshmemGetSize(int fd) AshmemGetSize() argument
148 Ashmem(int fd, int32_t size) Ashmem() argument
165 int fd = AshmemCreate(name, size); CreateAshmem() local
[all...]
H A Dio_event_reactor.cpp54 void IOEventReactor::InsertNodeFront(int fd, IOEventHandler* target) in InsertNodeFront() argument
56 IOEventHandler* h = ioHandlers_[fd].head.get(); in InsertNodeFront()
84 UTILS_LOGE("%{public}s: Failed, Bad fd.", __FUNCTION__); in AddHandler()
93 int fd = target->fd_; in AddHandler() local
94 if (static_cast<size_t>(fd) > ioHandlers_.size() - 1u) { in AddHandler()
95 UTILS_LOGD("%{public}s: Resize when fd: %{public}d", __FUNCTION__, fd); in AddHandler()
96 ioHandlers_.resize(fd * EXPANSION_COEFF); in AddHandler()
99 InsertNodeFront(fd, target); in AddHandler()
101 if ((ioHandlers_[fd] in AddHandler()
203 UpdateToDemultiplexer(int fd) UpdateToDemultiplexer() argument
233 HandleEvents(int fd, EventId event) HandleEvents() argument
265 int fd = events[idx].first; HandleAll() local
312 DoClean(int fd) DoClean() argument
346 Clean(int fd) Clean() argument
[all...]
H A Dio_event_epoll.cpp51 UTILS_LOGW("%{public}s: Failed, cannot close fd: %{public}s.", __FUNCTION__, strerror(errno)); in CleanUp()
57 bool IOEventEpoll::OperateEpoll(int op, int fd, EPEventId epollEvents) in OperateEpoll() argument
62 event.data.fd = fd; in OperateEpoll()
64 if (epoll_ctl(epollFd_, op, fd, &event) != 0) { in OperateEpoll()
66 target fd: %{public}d", __FUNCTION__, strerror(errno), epollFd_, op, fd); in OperateEpoll()
72 interestFds_.insert(fd); in OperateEpoll()
75 interestFds_.erase(fd); in OperateEpoll()
83 ErrCode IOEventEpoll::ModifyEvents(int fd, REventI argument
[all...]
H A Dfile_ex.cpp47 bool RustLoadStringFromFd(int fd, rust::String& content) in RustLoadStringFromFd() argument
50 if (LoadStringFromFd(fd, tmpContent)) { in RustLoadStringFromFd()
82 bool RustSaveStringToFd(int fd, const rust::String& content) in RustSaveStringToFd() argument
85 return SaveStringToFd(fd, tmpContent); in RustSaveStringToFd()
131 string GetFileNameByFd(const int fd) in GetFileNameByFd() argument
133 if (fd <= 0) { in GetFileNameByFd()
137 string fdPath = "/proc/self/fd/" + std::to_string(fd); in GetFileNameByFd()
149 bool LoadStringFromFdToFile(int fd, string& content) in LoadStringFromFdToFile() argument
151 string fileName = GetFileNameByFd(fd); in LoadStringFromFdToFile()
164 LoadStringFromFd(int fd, string& content) LoadStringFromFd() argument
231 SaveStringToFd(int fd, const std::string& content) SaveStringToFd() argument
[all...]
H A Devent_handler.h34 EventHandler(int fd, EventReactor* r);
42 void SetHandle(int fd) { fd_ = fd; } in SetHandle() argument
/commonlibrary/utils_lite/hals/file/
H A Dhal_file.c27 int HalFileClose(int fd) in HalFileClose() argument
29 return close(fd); in HalFileClose()
32 int HalFileRead(int fd, char *buf, unsigned int len) in HalFileRead() argument
34 return read(fd, buf, len); in HalFileRead()
37 int HalFileWrite(int fd, const char *buf, unsigned int len) in HalFileWrite() argument
39 return write(fd, buf, len); in HalFileWrite()
58 int HalFileSeek(int fd, int offset, unsigned int whence) in HalFileSeek() argument
60 return lseek(fd, offset, whence); in HalFileSeek()
H A Dhal_file.h27 int HalFileClose(int fd);
29 int HalFileRead(int fd, char* buf, unsigned int len);
31 int HalFileWrite(int fd, const char* buf, unsigned int len);
37 int HalFileSeek(int fd, int offset, unsigned int whence);
/commonlibrary/c_utils/base/test/benchmarktest/unique_fd_benchmark_test/
H A Dunique_fd_benchmark_test.cpp75 int fd = open("NOTHISFILE", O_RDWR, FILE_PERMISSION_READ_WRITE); in BENCHMARK_F() local
77 UniqueFd ufd2(fd); in BENCHMARK_F()
98 int fd = open(TEST_FILE_NAME, O_RDWR, FILE_PERMISSION_READ_WRITE); in BENCHMARK_F() local
99 UniqueFd ufd2(fd); in BENCHMARK_F()
100 AssertEqual(fd, ufd2, "fd did not equal ufd2 as expected.", state); in BENCHMARK_F()
101 AssertEqual(ufd2, fd, "ufd2 did not equal fd as expected.", state); in BENCHMARK_F()
110 int fd = open(TEST_FILE_NAME, O_RDWR, FILE_PERMISSION_READ_WRITE); in BENCHMARK_F() local
111 UniqueFd ufd2(fd); in BENCHMARK_F()
122 int fd = open(TEST_FILE_NAME, O_RDWR, FILE_PERMISSION_READ_WRITE); BENCHMARK_F() local
134 int fd = open(TEST_FILE_NAME, O_RDWR, FILE_PERMISSION_READ_WRITE); BENCHMARK_F() local
146 int fd = open(TEST_FILE_NAME, O_RDWR, FILE_PERMISSION_READ_WRITE); BENCHMARK_F() local
158 int fd = open(TEST_FILE_NAME, O_RDWR, FILE_PERMISSION_READ_WRITE); BENCHMARK_F() local
169 Close(int fd) Close() argument
188 int fd = open(TEST_FILE_NAME, O_RDWR); BENCHMARK_F() local
208 int fd = open(TEST_FILE_NAME, O_RDWR); BENCHMARK_F() local
229 int fd = ufd.Release(); BENCHMARK_F() local
244 int fd = ufd; BENCHMARK_F() local
258 int fd = ufd.Get(); BENCHMARK_F() local
[all...]
/commonlibrary/memory_utils/libdmabufheap/src/
H A Ddmabuf_alloc.c76 int fd = open(heapPath, O_RDONLY | O_CLOEXEC); in DmabufHeapOpen() local
77 long newFd = fd; in DmabufHeapOpen()
79 return fd; in DmabufHeapOpen()
82 int DmabufHeapClose(unsigned int fd) in DmabufHeapClose() argument
84 long newFd = fd; in DmabufHeapClose()
86 return close(fd); in DmabufHeapClose()
111 buffer->fd = data.fd; in DmabufHeapBufferAlloc()
122 return close(buffer->fd); in DmabufHeapBufferFree()
125 int DmabufHeapBufferSyncStart(unsigned int fd, DmabufHeapBufferSyncTyp argument
137 DmabufHeapBufferSyncEnd(unsigned int fd, DmabufHeapBufferSyncType syncType) DmabufHeapBufferSyncEnd() argument
[all...]
/commonlibrary/memory_utils/libdmabufheap/test/unittest/libdmabufheap/
H A Ddmabuf_alloc_test.cpp95 void *ptr = mmap(NULL, BUFFER_SIZE, PROT_READ | PROT_WRITE, MAP_SHARED, buffer.fd, 0); in HWTEST_F()
98 ASSERT_EQ(0, DmabufHeapBufferSyncStart(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_RW)); in HWTEST_F()
102 ASSERT_EQ(0, DmabufHeapBufferSyncEnd(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_RW)); in HWTEST_F()
123 void *ptr = mmap(NULL, BUFFER_SIZE, PROT_READ | PROT_WRITE, MAP_SHARED, buffer.fd, 0); in HWTEST_F()
126 ASSERT_EQ(0, DmabufHeapBufferSyncStart(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_RW)); in HWTEST_F()
130 ASSERT_EQ(0, DmabufHeapBufferSyncEnd(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_RW)); in HWTEST_F()
136 ptr = mmap(NULL, BUFFER_SIZE, PROT_READ | PROT_WRITE, MAP_SHARED, buffer.fd, 0); in HWTEST_F()
139 ASSERT_EQ(0, DmabufHeapBufferSyncStart(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_RW)); in HWTEST_F()
145 ASSERT_EQ(0, DmabufHeapBufferSyncEnd(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_RW)); in HWTEST_F()
156 ASSERT_EQ(0, DmabufHeapBufferSyncStart(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_R in HWTEST_F()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/
H A Dwaker.rs47 fd: File,
52 let fd = unsafe { libc::eventfd(0, libc::EFD_CLOEXEC | libc::EFD_NONBLOCK) };
53 let file = unsafe { File::from_raw_fd(fd) };
54 if fd == -1 {
59 .register(fd, token, Interest::READABLE)
60 .map(|()| WakerInner { fd: file })
66 match (&self.fd).write(&buf) {
70 match (&self.fd).read(&mut buf) {
H A Depoll.rs30 // epoll fd
75 /// Registers the fd with specific interested events
76 pub fn register(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in register()
82 match syscall!(epoll_ctl(self.ep, libc::EPOLL_CTL_ADD, fd, &mut sys_event)) { in register()
88 /// Re-registers the fd with specific interested events
89 pub fn reregister(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in reregister()
95 match syscall!(epoll_ctl(self.ep, libc::EPOLL_CTL_MOD, fd, &mut sys_event)) { in reregister()
101 /// De-registers the fd.
102 pub fn deregister(&self, fd: i32) -> io::Result<()> { in deregister()
106 fd, in deregister()
[all...]
/commonlibrary/utils_lite/file/src/file_impl_hal/
H A Dfile.c31 int UtilsFileClose(int fd) in UtilsFileClose() argument
33 return HalFileClose(fd); in UtilsFileClose()
36 int UtilsFileRead(int fd, char* buf, unsigned int len) in UtilsFileRead() argument
38 return HalFileRead(fd, buf, len); in UtilsFileRead()
41 int UtilsFileWrite(int fd, const char* buf, unsigned int len) in UtilsFileWrite() argument
43 return HalFileWrite(fd, buf, len); in UtilsFileWrite()
56 int UtilsFileSeek(int fd, int offset, unsigned int whence) in UtilsFileSeek() argument
58 return HalFileSeek(fd, offset, whence); in UtilsFileSeek()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/
H A Dpipe.rs24 pub(crate) fd: File,
29 let fd = unsafe { File::from_raw_fd(value.into_raw_fd()) }; in from()
30 Self { fd } in from()
36 (&self.fd).read(buf) in read()
42 (&self.fd).write(buf) in write()
46 (&self.fd).write_vectored(bufs) in write_vectored()
50 (&self.fd).flush() in write_vectored()
56 self.fd.as_raw_fd() in as_raw_fd()
62 unsafe { BorrowedFd::borrow_raw(self.fd.as_raw_fd()) } in as_fd()
81 self.fd in get_fd()
[all...]
/commonlibrary/memory_utils/libpurgeablemem/test/
H A Dpurgeableashmem_test.cpp170 int fd = AshmemCreate("Purgeable Ashmem", size); in HWTEST_F() local
171 ASSERT_GT(fd, 0); in HWTEST_F()
172 if (AshmemSetProt(fd, PROT_READ | PROT_WRITE) < 0) { in HWTEST_F()
173 close(fd); in HWTEST_F()
176 void *dataPtr = mmap(nullptr, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); in HWTEST_F()
179 close(fd); in HWTEST_F()
188 EXPECT_EQ(ioctl(fd, ASHMEM_GET_PURGEABLE), -1); in HWTEST_F()
189 EXPECT_EQ(ioctl(fd, ASHMEM_SET_PURGEABLE), 0); in HWTEST_F()
190 EXPECT_EQ(ioctl(fd, ASHMEM_GET_PURGEABLE), 1); in HWTEST_F()
191 EXPECT_EQ(ioctl(fd, ASHMEM_GET_PIN_STATU in HWTEST_F()
606 int fd = 5; HWTEST_F() local
[all...]
/commonlibrary/utils_lite/include/
H A Dutils_file.h167 * @param fd Indicates the file descriptor of the file to close.
172 int UtilsFileClose(int fd);
178 * @param fd Indicates the file descriptor of the file to read.
185 int UtilsFileRead(int fd, char* buf, unsigned int len);
190 * @param fd Indicates the file descriptor of the file where to write the data.
197 int UtilsFileWrite(int fd, const char* buf, unsigned int len);
225 * @param fd Indicates the file descriptor of the file where the read and write position offset needs adjustment.
241 int UtilsFileSeek(int fd, int offset, unsigned int whence);
/commonlibrary/c_utils/base/include/
H A Dio_event_reactor.h50 ErrCode Clean(int fd);
88 void InsertNodeFront(int fd, IOEventHandler* target);
94 ErrCode HandleEvents(int fd, EventId events);
95 bool UpdateToDemultiplexer(int fd);
97 bool DoClean(int fd);
H A Dfile_ex.h42 bool RustLoadStringFromFd(int fd, rust::String& content);
46 bool RustSaveStringToFd(int fd, const rust::String& content);
80 * @param fd Indicates the FD of the file to read.
86 bool LoadStringFromFd(int fd, std::string& content);
92 * @param fd Indicates the FD of the file to write.
97 bool SaveStringToFd(int fd, const std::string& content);
/commonlibrary/memory_utils/libpurgeablemem/cpp/src/
H A Dpurgeable_ashmem.cpp119 int fd = AshmemCreate("PurgeableAshmem", size); in CreatePurgeableData() local
120 if (fd < 0) { in CreatePurgeableData()
123 if (AshmemSetProt(fd, PROT_READ | PROT_WRITE) < 0) { in CreatePurgeableData()
124 close(fd); in CreatePurgeableData()
127 ashmemFd_ = fd; in CreatePurgeableData()
151 PM_HILOG_DEBUG(LOG_CORE, "%{public}s: fd:%{public}d PURGEABLE_GET_PIN_STATE: %{public}d", in Pin()
167 PM_HILOG_DEBUG(LOG_CORE, "%{public}s: fd:%{public}d PURGEABLE_GET_PIN_STATE: %{public}d", in Unpin()
215 bool PurgeableAshMem::ChangeAshmemData(size_t size, int fd, void *data) in ChangeAshmemData() argument
232 ashmemFd_ = fd; in ChangeAshmemData()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dsocket.rs97 unsafe fn from_raw_fd(fd: RawFd) -> TcpSocket { in from_raw_fd()
98 TcpSocket { socket: fd } in from_raw_fd()
102 pub(crate) fn get_sock_linger(fd: Fd) -> io::Result<Option<Duration>> {
107 fd as c_int,
119 pub(crate) fn set_sock_linger(fd: Fd, duration: Option<Duration>) -> io::Result<()> {
122 fd as c_int,
155 use std::os::fd::{AsRawFd, FromRawFd};
/commonlibrary/rust/ylong_runtime/ylong_ffrt/src/
H A Dsys_event.rs28 fn ffrt_sys_event_create(ty: c_int, fd: usize, filter: usize) -> FfrtSysEventHandleT; in ffrt_sys_event_create()
32 /// Registers the fd to ffrt's epoll. Callback will be called when io events
35 fd: c_int, in ffrt_poller_register()
41 /// Deregisters the fd from ffrt's epoll.
42 pub fn ffrt_poller_deregister(fd: c_int) -> c_int; in ffrt_poller_deregister()
/commonlibrary/c_utils/base/test/unittest/rust/
H A Drust_utils_file_test.rs56 let fd: RawFd = file.as_raw_fd(); in test_load_string_from_file_001()
57 assert!(file_ex::ffi::RustLoadStringFromFd(fd, &mut str2)); in test_load_string_from_file_001()
132 let fd: RawFd = file.as_raw_fd(); in test_load_string_from_fd_002()
133 assert!(file_ex::ffi::RustLoadStringFromFd(fd, &mut result)); in test_load_string_from_fd_002()
145 let fd: RawFd = file.as_raw_fd(); in test_load_string_from_fd_003()
146 assert!(file_ex::ffi::RustLoadStringFromFd(fd, &mut result)); in test_load_string_from_fd_003()
158 let fd: RawFd = file.as_raw_fd(); in test_load_string_from_fd_004()
159 assert!(file_ex::ffi::RustLoadStringFromFd(fd, &mut result)); in test_load_string_from_fd_004()
171 let fd: RawFd = file.as_raw_fd(); in test_load_string_from_fd_005()
172 assert!(!file_ex::ffi::RustLoadStringFromFd(fd, in test_load_string_from_fd_005()
290 let mut fd: RawFd = file.as_raw_fd(); test_save_string_to_fd_002() variables
308 let mut fd: RawFd = file.as_raw_fd(); test_save_string_to_fd_003() variables
327 let mut fd: RawFd = file.as_raw_fd(); test_save_string_to_fd_004() variables
[all...]

Completed in 10 milliseconds

123