| /commonlibrary/memory_utils/libdmabufheap/src/ |
| D | dmabuf_alloc.c | 110 struct dma_buf_sync sync = {0}; in DmabufHeapBufferSyncStart() local
111 sync.flags = DMA_BUF_SYNC_START | syncType; in DmabufHeapBufferSyncStart()
112 return ioctl(fd, DMA_BUF_IOCTL_SYNC, &sync); in DmabufHeapBufferSyncStart()
122 struct dma_buf_sync sync = {0}; in DmabufHeapBufferSyncEnd() local
123 sync.flags = DMA_BUF_SYNC_END | syncType; in DmabufHeapBufferSyncEnd()
124 return ioctl(fd, DMA_BUF_IOCTL_SYNC, &sync); in DmabufHeapBufferSyncEnd()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/ |
| D | Cargo.toml | 15 ….20.1", features = ["io-util", "net", "rt", "rt-multi-thread", "macros", "sync", "time"], optional…
16 …penharmony-sig/commonlibrary_rust_ylong_runtime.git", features = ["net", "sync", "fs", "macros", "…
27 "sync",
33 sync = [] # Uses sync interfaces.
76 required-features = ["sync", "http1_1", "__tls"]
91 required-features = ["sync", "http1_1"]
96 required-features = ["sync", "http1_1"]
101 required-features = ["sync", "http1_1"]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/ |
| D | Cargo.toml | 17 "sync",
25 "sync",
45 fs = ["sync"]
48 sync = []
78 required-features = ["sync"]
83 required-features = ["sync"]
118 required-features = ["sync"]
123 required-features = ["sync"]
|
| D | BUILD.gn | 28 "sync",
47 "--cfg=feature=\"sync\"",
67 "--cfg=feature=\"sync\"",
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
| D | unbounded.rs | 16 use crate::sync::error::{RecvError, SendError, TryRecvError};
17 use crate::sync::mpsc::channel::{channel, Rx, Tx};
18 use crate::sync::mpsc::queue::Queue;
19 use crate::sync::mpsc::Container;
24 use crate::sync::error::RecvTimeoutError;
|
| D | bounded.rs | 16 use crate::sync::error::{RecvError, SendError, TryRecvError, TrySendError};
17 use crate::sync::mpsc::array::Array;
18 use crate::sync::mpsc::channel::{channel, Rx, Tx};
19 use crate::sync::mpsc::Container;
21 use crate::sync::error::{RecvTimeoutError, SendTimeoutError};
22 use crate::sync::mpsc::array::SendPosition;
|
| D | channel.rs | 15 use std::sync::atomic::AtomicUsize;
16 use std::sync::atomic::Ordering::{AcqRel, Relaxed};
17 use std::sync::Arc;
19 use crate::sync::mpsc::Container;
|
| D | array.rs | 18 use std::sync::atomic::AtomicUsize;
19 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release};
24 use crate::sync::atomic_waker::AtomicWaker;
25 use crate::sync::error::{RecvError, SendError, TryRecvError, TrySendError};
26 use crate::sync::mpsc::Container;
27 use crate::sync::wake_list::WakerList;
|
| D | queue.rs | 18 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release};
19 use std::sync::atomic::{AtomicBool, AtomicPtr, AtomicUsize};
24 use crate::sync::atomic_waker::AtomicWaker;
25 use crate::sync::error::{RecvError, SendError, TryRecvError};
26 use crate::sync::mpsc::Container;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | current_thread.rs | 18 use std::sync::atomic::AtomicBool;
20 use std::sync::atomic::AtomicUsize;
21 use std::sync::atomic::Ordering::{Acquire, Release};
22 use std::sync::{Arc, Mutex};
49 self.count.fetch_add(1, std::sync::atomic::Ordering::AcqRel); in schedule()
141 .fetch_add(1, std::sync::atomic::Ordering::AcqRel); in spawn()
194 use crate::sync::Waiter;
195 use std::sync::atomic::AtomicUsize;
196 use std::sync::atomic::Ordering::{Acquire, Release};
197 use std::sync::{Condvar, Mutex};
[all …]
|
| D | sleeper.rs | 14 use std::sync::atomic::AtomicUsize;
15 use std::sync::atomic::Ordering::SeqCst;
16 use std::sync::Mutex;
|
| D | parker.rs | 14 use std::sync::atomic::AtomicUsize;
15 use std::sync::atomic::Ordering::SeqCst;
16 use std::sync::{Arc, Condvar, Mutex};
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_sync_mutex_perf.rs | 16 use std::sync::Arc;
19 use ylong_runtime::sync::Mutex;
|
| D | ylong_sync_rwlock_perf.rs | 16 use std::sync::Arc;
19 use ylong_runtime::sync::rwlock::RwLock;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | driver.rs | 17 use std::sync::atomic::AtomicUsize;
18 use std::sync::{Arc, Mutex};
104 .load(std::sync::atomic::Ordering::Acquire) in get_register_count()
112 .load(std::sync::atomic::Ordering::Acquire) in get_ready_count()
265 .fetch_add(events.len(), std::sync::atomic::Ordering::AcqRel); in drive()
275 static ONCE: std::sync::Once = std::sync::Once::new(); in initialize()
335 .fetch_add(1, std::sync::atomic::Ordering::AcqRel); in register_source()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | mutex.rs | 24 use std::sync::Arc;
28 use ylong_runtime::sync::Mutex;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_mutex.rs | 91 use std::sync::Arc;
94 use tokio::sync::Mutex;
95 use ylong_runtime::sync::Mutex as YlongMutex;
|
| D | ylong_tokio_rwlock.rs | 31 use std::sync::Arc;
34 use tokio::sync::RwLock;
35 use ylong_runtime::sync::rwlock::RwLock as YlongRwlock;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | oneshot.rs | 46 use std::sync::atomic::AtomicUsize;
47 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release, SeqCst};
48 use std::sync::Arc;
465 use crate::sync::error::TryRecvError;
466 use crate::sync::oneshot;
|
| D | atomic_waker.rs | 16 use std::sync::atomic::AtomicU8;
17 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release};
|
| D | rwlock.rs | 19 use std::sync::atomic::AtomicI64;
20 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release};
22 use crate::sync::semaphore_inner::SemaphoreInner;
23 use crate::sync::LockError;
343 use std::sync::Arc;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/task_helpers/ |
| D | mod.rs | 16 use std::sync::Arc;
18 use tokio::sync::RwLock;
24 use ylong_runtime::sync::RwLock as YlongRwlock;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | mod.rs | 24 use std::sync::atomic::AtomicBool;
25 use std::sync::atomic::Ordering::Relaxed;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | pool.rs | 19 use std::sync::{Arc, Mutex};
58 use std::sync::{Arc, Mutex};
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| D | lib.rs | 59 pub(crate) use tokio::sync::{
75 pub(crate) use ylong_runtime::sync::{
|