| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | semaphore.rs | 200 /// sem.close();
217 /// sem.close();
220 pub fn close(&self) { in close() functions
221 self.inner.close(); in close()
316 /// sem.close();
333 /// sem.close();
336 pub fn close(&self) { in close() functions
337 self.inner.close(); in close()
353 /// UT test cases for `Semaphore::close()`.
364 sem.close(); in ut_sem_close_test()
[all...] |
| H A D | oneshot.rs | 192 /// or calls the [`close`] method.
194 /// [`close`]: Receiver::close
341 /// `close`. It will do nothing if the channel is already closed or the
354 /// rx.close();
361 /// Receive a value sent **before** calling `close`
369 /// rx.close();
375 pub fn close(&mut self) { in close() functions
385 self.close(); in drop()
506 /// UT test cases for `is_closed()` and `close` in fmt()
[all...] |
| /commonlibrary/ets_utils/platform/default/ |
| H A D | process_helper.cpp | 76 statFile.close(); in GetProcessStartRealtime()
85 statFile.close(); in GetProcessStartRealtime()
94 statFile.close(); in GetProcessStartRealtime()
|
| /commonlibrary/memory_utils/libpurgeablemem/cpp/src/ |
| H A D | purgeable_ashmem.cpp | 91 close(ashmemFd_); in ~PurgeableAshMem()
124 close(fd); in CreatePurgeableData()
133 close(ashmemFd_); in CreatePurgeableData()
204 close(ashmemFd_); in ResizeData()
227 close(ashmemFd_); in ChangeAshmemData()
|
| /commonlibrary/utils_lite/js/builtin/filekit/src/ |
| H A D | nativeapi_fs_impl.c | 236 close(fdSrc);
in CopyFileImpl()
240 close(fdSrc);
in CopyFileImpl()
248 close(fdSrc);
in CopyFileImpl()
252 close(fdSrc);
in CopyFileImpl()
253 close(fdDest);
in CopyFileImpl()
284 close(fileHandle);
in WriteTextFile()
317 close(fileHandle);
in WriteArrayFile()
322 close(fileHandle);
in WriteArrayFile()
347 close(fileHandle);
in ReadFileImpl()
351 close(fileHandl in ReadFileImpl()
[all...] |
| /commonlibrary/c_utils/base/src/ |
| H A D | ashmem.cpp | 78 close(fd); in AshmemOpenLocked()
84 close(fd); in AshmemOpenLocked()
117 close(fd); in AshmemCreate()
124 close(fd); in AshmemCreate()
132 close(fd); in AshmemCreate()
197 ::close(memoryFd_); in CloseAshmem()
|
| H A D | mapped_file.cpp | 179 if (close(fd) == -1) { in OpenFile()
180 UTILS_LOGW("%{public}s: Failed. Cannot close the file: %{public}s.", \ in OpenFile()
466 if (fd_ != -1 && close(fd_) == -1) { in Clear()
467 UTILS_LOGD("%{public}s: Failed. Cannot close the file: %{public}s.", \ in Clear()
485 if (fd_ != -1 && close(fd_) == -1) { in ~MappedFile()
486 UTILS_LOGE("%{public}s: Failed. Cannot close the file: %{public}s.", \ in ~MappedFile()
559 if (fd_ != -1 && close(fd_) == -1) { in ChangePath()
560 UTILS_LOGW("%{public}s: Failed. Cannot close the file: %{public}s.", \ in ChangePath()
|
| H A D | timer_event_handler.cpp | 42 close(GetHandle()); in ~TimerEventHandler()
|
| H A D | io_event_epoll.cpp | 50 if (close(epollFd_) != 0) { in CleanUp()
51 UTILS_LOGW("%{public}s: Failed, cannot close fd: %{public}s.", __FUNCTION__, strerror(errno)); in CleanUp()
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_file_test.cpp | 89 close(fd); in HWTEST_F()
193 close(fd); in HWTEST_F()
210 close(fd); in HWTEST_F()
227 close(fd); in HWTEST_F()
244 close(fd); in HWTEST_F()
260 close(fd); in HWTEST_F()
395 close(fd); in HWTEST_F()
401 close(fd); in HWTEST_F()
417 close(fd); in HWTEST_F()
423 close(f in HWTEST_F()
[all...] |
| H A D | utils_unique_fd_test.cpp | 45 outfile.close(); in SetUpTestCase()
55 inputfile.close(); in TearDownTestCase()
129 close(fd); in Close()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
| H A D | mod.rs | 23 fn close(&self); in close() functions
76 pub(crate) fn close(&self) {
78 self.inner.chan.close();
|
| /commonlibrary/ets_utils/js_sys_module/process/ |
| H A D | js_childprocess.cpp | 82 close(stdErrFd_[0]);
in Spawn()
83 close(stdOutFd_[0]);
in Spawn()
110 close(stdErrFd_[1]);
in Spawn()
111 close(stdOutFd_[1]);
in Spawn()
402 HILOG_ERROR("close kill SIGKILL signal failed");
in Close()
480 close(stdOutFd_[0]);
in ~ChildProcess()
481 close(stdErrFd_[0]);
in ~ChildProcess()
|
| /commonlibrary/memory_utils/libdmabufheap/src/ |
| H A D | dmabuf_alloc.c | 86 return close(fd); in DmabufHeapClose()
122 return close(buffer->fd); in DmabufHeapBufferFree()
|
| /commonlibrary/memory_utils/libmeminfo/src/ |
| H A D | meminfo.cpp | 84 in.close();
in GetPssByPid()
112 in.close();
in GetSwapPssByPid()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/quic/ |
| H A D | mod.rs | 157 self.close(false, 0x1, b"verify server cert failed")
173 self.close(false, 0x1, b"fail").ok();
|
| /commonlibrary/utils_lite/hals/file/ |
| H A D | hal_file.c | 29 return close(fd); in HalFileClose()
|
| /commonlibrary/utils_lite/js/builtin/kvstorekit/src/ |
| H A D | nativeapi_kv_impl.c | 120 close(fileHandle);
in GetValue()
149 close(fd);
in SetValue()
|
| /commonlibrary/c_utils/base/test/benchmarktest/file_benchmark_test/ |
| H A D | file_benchmark_test.cpp | 87 close(fd); in LoadString()
98 close(fd); in SaveString()
104 close(fd); in SaveString()
127 close(fd); in BENCHMARK_F()
305 close(fd); in BENCHMARK_F()
325 close(fd); in BENCHMARK_F()
523 close(fd); in BENCHMARK_F()
529 close(fd); in BENCHMARK_F()
|
| /commonlibrary/c_utils/base/test/benchmarktest/unique_fd_benchmark_test/ |
| H A D | unique_fd_benchmark_test.cpp | 48 outfile.close();
57 inputfile.close();
174 close(fd); in Close()
|
| /commonlibrary/c_utils/base/test/fuzztest/directory_fuzzer/ |
| H A D | directory_fuzzer.cpp | 40 file.close(); in DirectoryTestFunc()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | mod.rs | 128 /// dropped or calls the [`close`] method.
130 /// [`close`]: UnboundedReceiver::close
192 self.channel.close(); in drop()
359 /// `close`. It will do nothing if the channel is already closed.
370 /// rx.close();
377 /// Receive a value sent **before** calling `close`
385 /// rx.close();
391 pub fn close(&mut self) { in close() functions
392 self.channel.close(); in close()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | epoll.rs | 117 if let Err(_err) = syscall!(close(self.ep)) { in drop()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | mod.rs | 233 /// dropped or the [`close`] method gets called.
235 /// [`close`]: BoundedReceiver::close
310 self.channel.close(); in drop()
480 /// `Receiver` called `close`. It will do nothing if the channel is
493 /// rx.close();
500 /// Receives a value sent **before** calling `close`
508 /// rx.close();
514 pub fn close(&mut self) { in close() functions
515 self.channel.close(); in close()
[all...] |
| /commonlibrary/c_utils/base/include/ |
| H A D | unique_fd.h | 34 * including a static function to close FDs.
44 * @brief Default function to close an FD.
46 * Call `close()` if the input FD is valid (greater than or equal to 0).
53 close(fd); in Close()
76 * To ensure unique management on an FD, avoid the double-close issue,
122 * This function is used to close the FD and set the FD to `-1`.
|