Home
last modified time | relevance | path

Searched refs:id (Results 1 - 25 of 43) sorted by relevance

12

/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dstreams.rs233 for id in self.pending_stream_window.iter() {
234 self.pending_send.push_back(*id);
271 id: StreamId,
274 if let Some(stream) = self.stream_map.get_mut(&id) {
276 return Err(H2Error::StreamError(id, ErrorCode::FlowControlError));
280 self.window_updating_streams.push_back(id);
306 pub(crate) fn stream_state(&self, id: StreamId) -> Option<H2StreamState> {
307 self.stream_map.get(&id).map(|stream| stream.state)
310 pub(crate) fn insert(&mut self, id: StreamId, headers: Frame, data: BodyDataRef) {
314 self.stream_map.insert(id, strea
[all...]
H A Dmanager.rs180 let id = match self.controller.streams.generate_id() { in poll_recv_request()
181 Ok(id) => id, in poll_recv_request()
187 let headers = Frame::new(id, message.request.flag, message.request.payload); in poll_recv_request()
191 self.controller.streams.push_pending_concurrency(id) in poll_recv_request()
194 self.controller.streams.push_back_pending_send(id) in poll_recv_request()
196 self.controller.senders.insert(id, message.sender); in poll_recv_request()
199 .insert(id, headers, message.request.data); in poll_recv_request()
213 Some(id) => {
214 self.input_stream_frame(cx, id)
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A Dstreams.rs52 pub(crate) fn from(id: u64) -> Self {
53 match id % 4 {
166 let id =
172 .insert(id, BidirectionalStream::new(rx, header, data));
174 self.push_back_pending_concurrency(id);
176 self.push_back_pending_send(id);
185 id: u64,
188 if let Some(stream) = self.bidirectional_stream.get_mut(&id) {
230 self.stream_pend_channel(id);
241 id
[all...]
H A Dstream_manager.rs137 id: u64, in transmit_error()
140 self.streams.send_error(cx, id, error) in transmit_error()
149 if let Some(id) = self.streams.next_stream() {
150 self.input_stream_frame(cx, id)?;
161 id: u64, in input_stream_frame()
163 if let Some(header) = self.streams.get_header(id)? { in input_stream_frame()
164 self.poll_send_header(id, header)?; in input_stream_frame()
169 if self.streams.encoding(id)? { in input_stream_frame()
170 if let Err(e) = self.poll_send_frame(id, None) { in input_stream_frame()
176 if self.streams.encoding(id) in input_stream_frame()
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Ddecoder.rs124 pub fn finish_stream(&mut self, id: u64) -> Result<(), H3Error> { in finish_stream()
125 if is_bidirectional(id) { in finish_stream()
127 .finish_stream(id) in finish_stream()
130 self.streams.remove(&id); in finish_stream()
146 pub fn decode(&mut self, id: u64, src: &[u8]) -> Result<StreamMessage, H3Error> { in decode()
147 let mut stream = if let Some(stream) = self.streams.remove(&id) { in decode()
150 DecodedH3Stream::new(id) in decode()
158 self.streams.insert(id, stream); in decode()
164 self.streams.insert(id, stream); in decode()
173 self.streams.insert(id, strea in decode()
[all...]
H A Dframe.rs114 id: u64,
228 pub fn new(id: u64) -> Self { in new()
229 CancelPush { push_id: id } in new()
232 /// Gets push id of CancelPush payload.
270 /// Gets push id of PushPromise payload.
287 pub fn new(id: u64) -> Self { in new()
288 GoAway { id } in new()
291 /// Gets go away stream id.
293 &self.id in get_id()
303 /// Gets allowed max push stream id
[all...]
H A Dmod.rs40 pub(crate) fn is_bidirectional(id: u64) -> bool {
41 (id & 0x02) == 0
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dslab.rs463 id: AtomicUsize,
470 id: AtomicUsize::new(0), in default()
482 id: AtomicUsize,
489 id: AtomicUsize::new(0), in default()
528 // Modify the current `id` in ut_slab_for_each()
529 foo1.id.store(1, SeqCst); in ut_slab_for_each()
533 foo2.id.store(2, SeqCst); in ut_slab_for_each()
537 foo3.id.store(3, SeqCst); in ut_slab_for_each()
542 assert_eq!(temp.pop().unwrap(), value.id.load(SeqCst)); in ut_slab_for_each()
580 foo.id in ut_slab_compact()
[all...]
/commonlibrary/ets_utils/js_concurrent_module/utils/locks/
H A Dasync_lock_manager.cpp81 for (auto [id, lock] : anonymousLockMap) { in CollectLockDependencies()
82 std::string lockName = "anonymous #" + std::to_string(id); in CollectLockDependencies()
220 auto it = anonymousLockMap.find(identity->id); in Destructor()
243 AsyncLockIdentity *id; in LockAsync() local
244 NAPI_CALL(env, napi_unwrap_sendable(env, thisVar, reinterpret_cast<void **>(&id))); in LockAsync()
249 asyncLock = FindAsyncLockUnsafe(id); in LockAsync()
258 if (id->isAnonymous) { in LockAsync()
259 strTrace += "lockId: " + std::to_string(id->id); in LockAsync()
261 strTrace += "lockName: " + id in LockAsync()
406 Request(uint32_t id) Request() argument
428 FindAsyncLockUnsafe(AsyncLockIdentity *id) FindAsyncLockUnsafe() argument
[all...]
H A Dasync_lock_manager.h30 uint32_t id; member
65 static void Request(uint32_t id);
67 static AsyncLock *FindAsyncLockUnsafe(AsyncLockIdentity *id);
/commonlibrary/c_utils/base/test/fuzztest/timer_fuzzer/
H A Dtimer_fuzzer.cpp55 size_t id = dataProvider->ConsumeIntegralInRange<size_t>(0, val.size() - 1);
56 timer.Unregister(val[id]);
57 FUZZ_LOGI("Unregister, timerId = %{public}d", val[id]);
58 for (size_t i = id; i < val.size() - 1; i++) {
/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dchunk.rs806 id: usize,
815 fn set_id(&mut self, id: usize) { in set_id()
816 self.id = id; in set_id()
823 /// Get the id of chunk-data.
824 pub fn id(&self) -> usize { in id() functions
825 self.id in id()
944 /// chunk.id(),
1154 id: 0, in sized_chunk()
1620 id in ut_chunk_body_decode_0()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/
H A Dcommand.rs409 /// fn pty(id: u32) {
411 /// let gid = cmd.uid(id);
414 pub fn uid(&mut self, id: u32) -> &mut PtyCommand { in uid()
415 self.command.uid(id); in uid()
427 /// fn pty(id: u32) {
429 /// let gid = cmd.gid(id);
432 pub fn gid(&mut self, id: u32) -> &mut PtyCommand { in gid()
433 self.command.gid(id); in gid()
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dmessage_queue.cpp61 void MarkedMessageQueue::Push(uint32_t id, MessageDataType data) in Push() argument
64 queue_.push({id, data}); in Push()
H A Dmessage_queue.h44 void Push(uint32_t id, MessageDataType data);
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/buffer/
H A Dwindow.rs119 pub(crate) fn check_window_update(&mut self, id: StreamId) -> Option<Frame> {
123 let frame = Frame::new(id, FrameFlags::new(0), Payload::WindowUpdate(window_update));
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Dframe.rs56 id: StreamId,
206 self.id in stream_id()
211 pub fn new(id: StreamId, flags: FrameFlags, payload: Payload) -> Self { in new()
212 Frame { id, flags, payload } in new()
568 pub fn error(&self, id: u32) -> Result<H2Error, H2Error> { in error()
570 id, in error()
/commonlibrary/c_utils/base/src/
H A Dtimer.cpp244 uint32_t id = (*itor)->timerId; in EraseUnusedTimerId() local
245 if (std::find(unusedIds.begin(), unusedIds.end(), id) == unusedIds.end()) { in EraseUnusedTimerId()
253 timerToEntries_.erase(id); in EraseUnusedTimerId()
H A Drwlock.cpp86 writeThreadID_ = std::thread::id(); in UnLockWrite()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/
H A Dcommand.rs525 pub fn uid(&mut self, id: u32) -> &mut Command { in uid()
526 self.std.uid(id); in uid()
534 pub fn gid(&mut self, id: u32) -> &mut Command { in gid()
535 self.std.gid(id); in gid()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/
H A Depoll.rs28 // selector id
29 id: usize,
48 id: NEXT_ID.fetch_add(1, Ordering::Relaxed), in new()
125 write!(fmt, "epoll fd: {}, Select id: {}", self.ep, self.id) in fmt()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_tokio_mem.rs21 let pid = process::id(); in get_memory_info()
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_memory.rs34 let pid = process::id(); in get_memory_info()
/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/
H A Ddecoder.rs94 pub(crate) fn finish_stream(&mut self, id: u64) -> Result<(), QpackError> {
95 if self.blocked.contains_key(&id) {
98 self.streams.remove(&id);
157 .filter_map(|(id, required)| {
159 Some(*id)
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp406 uint64_t id = mediumTaskQueue->DequeueTaskId(); in GetTaskByPriority() local
407 while (id != 0) { in GetTaskByPriority()
408 id = mediumTaskQueue->DequeueTaskId(); in GetTaskByPriority()
482 uint64_t id = task->taskId_ + MAX_TIMEOUT_TIME; in NotifyDependencyTaskInfo() local
483 std::set<uint64_t> set{ task->taskId_, id }; in NotifyDependencyTaskInfo()
486 std::set<uint64_t> set1{ task->taskId_, id }; in NotifyDependencyTaskInfo()
489 taskManager.EnqueuePendingTaskInfo(id, Priority::DEFAULT); in NotifyDependencyTaskInfo()
492 std::set<uint64_t> set2{ task->taskId_, id }; in NotifyDependencyTaskInfo()
540 uint64_t id = task->taskId_ + MAX_TIMEOUT_TIME; in RemoveTaskDependency() local
545 std::set<uint64_t> set{ id }; in RemoveTaskDependency()
812 uint64_t id = mediumTaskQueue->DequeueTaskId(); PerformTask() local
873 uint64_t id = task->taskId_ + MAX_TIMEOUT_TIME; TaskResultCallback() local
[all...]

Completed in 15 milliseconds

12