Home
last modified time | relevance | path

Searched refs:pair (Results 1 - 25 of 29) sorted by relevance

12

/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dmessage_queue.cpp73 std::pair<uint32_t, MessageDataType> MarkedMessageQueue::Front() in Front()
89 std::pair<uint32_t, MessageDataType> pair = queue_.front(); in Clear() local
90 napi_delete_serialization_data(env, pair.second); in Clear()
H A Dmessage_queue.h46 std::pair<uint32_t, MessageDataType> Front();
57 std::queue<std::pair<uint32_t, MessageDataType>> queue_;
H A Dworker.cpp1507 std::pair<uint32_t, MessageDataType> pair = hostGlobalCallQueue_.Front(); in HostOnGlobalCallInner() local
1509 if (pair.first == globalCallId_) { in HostOnGlobalCallInner()
1510 currentCallId = pair.first; in HostOnGlobalCallInner()
1511 data = pair.second; in HostOnGlobalCallInner()
1514 napi_delete_serialization_data(hostEnv_, pair.second); in HostOnGlobalCallInner()
1619 std::pair<int32_t, napi_value> pair = globalCallErrors_.front(); in HandleGlobalCallError() local
1621 int32_t errCode = pair.first; in HandleGlobalCallError()
1629 std::pair<int32_ in ClearGlobalCallError() local
[all...]
H A Dworker.h591 std::queue<std::pair<int32_t, napi_value>> globalCallErrors_ {};
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Duds_test.rs27 /// 1. Creates a server and a client with `pair()`.
34 let (server, client) = UnixStream::pair().unwrap(); in sdv_uds_stream_try_test()
69 /// 1. Creates a server and a client with `pair()`.
76 let (server, client) = UnixDatagram::pair().unwrap(); in sdv_uds_datagram_try_test()
111 /// 1. Create a std UnixStream with `pair()`.
116 let (stream, _) = std::os::unix::net::UnixStream::pair().unwrap(); in sdv_uds_stream_baisc_test()
133 /// 1. Create a std UnixDatagram with `pair()`.
138 let (datagram, _) = std::os::unix::net::UnixDatagram::pair().unwrap(); in sdv_uds_datagram_baisc_test()
/commonlibrary/c_utils/base/include/
H A Dsafe_map.h96 * @param key Indicates the key of the key-value (KV) pair to insert.
97 * @param value Indicates the value of the KV pair to insert.
98 * @return Returns <b>true</b> if the KV pair is inserted; returns
104 auto ret = map_.insert(std::pair<K, V>(key, value)); in Insert()
111 * @param key Indicates the key of the KV pair to insert.
112 * @param value Indicates the value of the KV pair to insert.
114 * the KV pair to ensure that the value is inserted.
119 auto ret = map_.insert(std::pair<K, V>(key, value)); in EnsureInsert()
123 map_.insert(std::pair<K, V>(key, value)); in EnsureInsert()
133 * @param value Indicates the value of the KV pair t
[all...]
H A Dio_event_reactor.h91 void HandleAll(const std::vector<std::pair<int, EventId>>&);
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Ddatagram.rs241 /// Creates an unnamed pair of connected sockets.
248 /// let (datagram1, datagram2) = UnixDatagram::pair().unwrap();
250 pub fn pair() -> Result<(UnixDatagram, UnixDatagram)> { in pair() functions
251 let (datagram1, datagram2) = ylong_io::UnixDatagram::pair()?; in pair()
465 /// 1. Create a std UnixDatagram with `pair()`.
470 let (datagram, _) = std::os::unix::net::UnixDatagram::pair().unwrap(); in ut_uds_datagram_baisc_test()
497 let (server, client) = UnixDatagram::pair().unwrap(); in ut_uds_datagram_read_write_test()
521 /// 1. Creates a server and a client with `pair()`.
528 let (server, client) = UnixDatagram::pair().unwrap(); in ut_uds_datagram_try_test()
H A Dstream.rs96 /// Creates an unnamed pair of connected sockets.
103 /// let (stream1, stream2) = match UnixStream::pair() {
106 /// println!("Couldn't create a pair of sockets: {err:?}");
111 pub fn pair() -> Result<(UnixStream, UnixStream)> { in pair() functions
112 let (stream1, stream2) = ylong_io::UnixStream::pair()?; in pair()
406 /// 1. Create a std UnixStream with `pair()`.
411 let (stream, _) = std::os::unix::net::UnixStream::pair().unwrap(); in ut_uds_stream_baisc_test()
429 /// 1. Creates a server and a client with `pair()`.
434 let (mut server, mut client) = UnixStream::pair().unwrap(); in ut_uds_stream_pair_test()
453 /// 1. Creates a server and a client with `pair()`
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
H A Dsocket.rs70 pair(libc::SOCK_STREAM)
74 pair(libc::SOCK_DGRAM)
77 fn pair<T: FromRawFd>(socket_type: libc::c_int) -> io::Result<(T, T)> { in pair() functions
H A Ddatagram.rs86 /// Creates an unnamed pair of connected sockets.
93 /// if let Ok((sock1, sock2)) = UnixDatagram::pair() {
94 /// println!("unix datagram pair creates successfully");
97 pub fn pair() -> io::Result<(UnixDatagram, UnixDatagram)> { in pair() functions
306 /// UT for `UnixDatagram::pair`
309 /// 1. Create a pair of UnixDatagram
315 let (sender, receiver) = UnixDatagram::pair().unwrap(); in ut_uds_datagram_pair()
H A Dstream.rs60 /// Creates an unnamed pair of connected sockets.
67 /// if let Ok((stream1, stream2)) = UnixStream::pair() {
68 /// println!("unix socket pair created successfully");
71 pub fn pair() -> io::Result<(UnixStream, UnixStream)> { in pair() functions
258 /// UT for `UnixStream::pair`
261 /// 1. Create a pair of UnixStream
267 let (sender, receiver) = UnixStream::pair().unwrap(); in ut_uds_stream_pair()
/commonlibrary/c_utils/base/src/
H A Dio_event_epoll.h47 virtual ErrCode Polling(int timeout, std::vector<std::pair<int, REventId>>&);
H A Dio_event_reactor.cpp262 void IOEventReactor::HandleAll(const std::vector<std::pair<int, EventId>>& events) in HandleAll()
279 std::vector<std::pair<int, EventId>> gotEvents; in Run()
H A Dio_event_epoll.cpp106 ErrCode IOEventEpoll::Polling(int timeout /* ms */, std::vector<std::pair<int, REventId>>& res) in Polling()
/commonlibrary/rust/ylong_http/ylong_http/src/
H A Dheaders.rs168 fn try_from(pair: (N, V)) -> Result<Self, Self::Error> { in try_from()
170 HeaderName::try_from(pair.0).map_err(Into::into)?, in try_from()
171 HeaderValue::try_from(pair.1).map_err(Into::into)?, in try_from()
826 /// // Operate on each `HeaderName` and `HeaderValue` pair.
845 /// // Operate on each `HeaderName` and `HeaderValue` pair. in iter()
858 /// and `HeaderValue` pair out of the `Headers` in arbitrary order. The in iter()
870 /// // Operate on each `HeaderName` and `HeaderValue` pair. in iter()
911 /// // Operate on each `HeaderName` and `HeaderValue` pair.
931 /// // Operate on each `HeaderName` and `HeaderValue` pair.
951 /// // Operate on each `HeaderName` and `HeaderValue` pair
[all...]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_manager.h66 std::pair<uint64_t, Priority> DequeueTaskId();
118 std::pair<uint64_t, Priority> DequeuePendingTaskInfo(uint64_t taskId);
175 std::pair<uint64_t, Priority> GetTaskByPriority(const std::unique_ptr<ExecuteQueue>& taskQueue, Priority priority);
196 std::unordered_map<uint64_t, std::pair<uint64_t, uint64_t>> taskDurationInfos_ {};
H A Dtask_manager.cpp765 std::pair<uint64_t, Priority> TaskManager::DequeueTaskId() in DequeueTaskId()
809 std::pair<uint64_t, Priority> TaskManager::GetTaskByPriority(const std::unique_ptr<ExecuteQueue>& taskQueue, in GetTaskByPriority()
1160 std::pair<uint64_t, Priority> TaskManager::DequeuePendingTaskInfo(uint64_t taskId) in DequeuePendingTaskInfo()
1166 std::pair<uint64_t, Priority> result; in DequeuePendingTaskInfo()
1233 std::pair<uint64_t, uint64_t> durationData = std::make_pair(totalDuration, cpuDuration); in StoreTaskDuration()
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Duds_test.rs31 /// 1. Create a pair of UnixStream.
133 /// 1. Create a pair of UnixDatagram.
139 let (sender, _) = UnixDatagram::pair().unwrap(); in sdv_uds_send_recv()
153 let (sender, receiver) = UnixDatagram::pair().unwrap(); in sdv_uds_send_recv()
/commonlibrary/ets_utils/js_util_module/util/
H A Djs_textdecoder.cpp79 std::pair<char *, bool> TextDecoder::ConvertToChar(UChar *uchar, size_t length, char *tempCharArray) in ConvertToChar()
168 std::pair<char *, bool> tempPair = ConvertToChar(arrDat, length, tempCharArray); in GetResultStr()
176 std::pair<char *, bool> tempPair = ConvertToChar(arrDat, length, nullptr); in GetResultStr()
H A Djs_textdecoder.h135 std::pair<char *, bool> ConvertToChar(UChar* uchar, size_t length, char* tempCharArray);
/commonlibrary/ets_utils/js_concurrent_module/utils/locks/
H A Dasync_lock.cpp220 auto *data = new std::pair<AsyncLock *, napi_async_work>(); in AsyncDestroy()
236 auto *lockAndWork = reinterpret_cast<std::pair<AsyncLock *, napi_async_work> *>(data); in AsyncDestroyCallback()
/commonlibrary/memory_utils/libmeminfo/src/
H A Dmeminfo.cpp125 const std::vector<std::pair<MemoryTrackerType, std::string>> MEMORY_TRACKER_TYPES = { in GetGraphicsMemory()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dasync_pool.rs567 let pair = self.inner.shutdown_handle.clone(); in release_wait()
569 let (lock, cvar) = &*pair; in release_wait()
/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_refbase_test.cpp265 objects1_.insert(std::pair<string, wptr<IRemoteObject>>(to_string(handle), remoteObject)); in FindOrNewObject()

Completed in 17 milliseconds

12