| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/buffer/ |
| D | window.rs | 30 pub(crate) fn size_available(&self) -> u32 { in size_available()
38 pub(crate) fn reduce_size(&mut self, size: u32) { in reduce_size()
54 pub(crate) fn send_data(&mut self, size: u32) { in send_data()
79 pub(crate) fn unreleased_size(&self) -> Option<u32> { in unreleased_size()
95 pub(crate) fn notification_available(&self) -> u32 { in notification_available()
103 pub(crate) fn reduce_actual(&mut self, size: u32) { in reduce_actual()
107 pub(crate) fn increase_actual(&mut self, size: u32) { in increase_actual()
111 pub(crate) fn reduce_notification(&mut self, size: u32) { in reduce_notification()
115 pub(crate) fn increase_notification(&mut self, size: u32) { in increase_notification()
136 pub(crate) fn recv_data(&mut self, size: u32) { in recv_data()
|
| D | settings.rs | 27 pub(crate) fn new(conn_recv_window: u32, conn_send_window: u32) -> Self { in new()
38 pub(crate) fn setup_recv_window(&mut self, size: u32) { in setup_recv_window()
58 pub(crate) fn recv_notification_size_available(&self) -> u32 { in recv_notification_size_available()
62 pub(crate) fn send_data(&mut self, size: u32) { in send_data()
66 pub(crate) fn recv_data(&mut self, size: u32) { in recv_data()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/ |
| D | http.rs | 89 pub(crate) fn set_max_frame_size(&mut self, size: u32) { in set_max_frame_size()
94 pub(crate) fn set_max_header_list_size(&mut self, size: u32) { in set_max_header_list_size()
99 pub(crate) fn set_header_table_size(&mut self, size: u32) { in set_header_table_size()
103 pub(crate) fn set_conn_window_size(&mut self, size: u32) { in set_conn_window_size()
107 pub(crate) fn set_stream_window_size(&mut self, size: u32) { in set_stream_window_size()
120 pub(crate) fn max_frame_size(&self) -> u32 { in max_frame_size()
125 pub(crate) fn max_header_list_size(&self) -> u32 { in max_header_list_size()
130 pub(crate) fn header_table_size(&self) -> u32 { in header_table_size()
138 pub(crate) fn conn_window_size(&self) -> u32 { in conn_window_size()
142 pub(crate) fn stream_window_size(&self) -> u32 { in stream_window_size()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | streams.rs | 180 recv_window_size: u32, in new()
181 send_window_size: u32, in new()
214 pub(crate) fn apply_max_concurrent_streams(&mut self, num: u32) { in apply_max_concurrent_streams()
244 pub(crate) fn apply_recv_initial_window_size(&mut self, size: u32) { in apply_recv_initial_window_size()
264 pub(crate) fn release_stream_recv_window(&mut self, id: u32, size: u32) -> Result<(), H2Error> { in release_stream_recv_window()
301 pub(crate) fn insert(&mut self, id: u32, request: RequestWrapper) { in insert()
309 pub(crate) fn push_back_pending_send(&mut self, id: u32) { in push_back_pending_send()
313 pub(crate) fn push_pending_concurrency(&mut self, id: u32) { in push_pending_concurrency()
317 pub(crate) fn next_pending_stream(&mut self) -> Option<u32> { in next_pending_stream()
360 id: u32, in reassign_stream_send_window()
[all …]
|
| D | manager.rs | 231 id: u32, in input_stream_frame()
558 id: u32, in manage_stream_error()
668 err_code: u32, in send_peer_goaway()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| D | iocp.rs | 119 pub(crate) fn new(bytes: u32, token: usize, overlapped: *mut Overlapped) -> Self { in new()
134 pub fn bytes_transferred(&self) -> u32 { in bytes_transferred()
|
| D | winapi.rs | 129 pub fn RtlNtStatusToDosError(status: NTSTATUS) -> u32; in RtlNtStatusToDosError()
164 dwIoControlCode: u32, in WSAIoctl()
166 cbInBuffer: u32, in WSAIoctl()
168 cbOutBuffer: u32, in WSAIoctl()
169 lpcbBytesReturned: *mut u32, in WSAIoctl()
|
| D | selector.rs | 447 fn set_event(&mut self, flags: u32, token_data: u64) -> bool { in set_event()
590 fn interests_to_afd_flags(interests: Interest) -> u32 { in interests_to_afd_flags()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| D | frame.rs | 477 pub fn new(error_code: u32, last_stream_id: StreamId, debug_data: Vec<u8>) -> Self { in new()
496 pub fn get_error_code(&self) -> u32 { in get_error_code()
517 pub fn get_increment(&self) -> u32 { in get_increment()
530 pub fn new(exclusive: bool, stream_dependency: u32, weight: u8) -> Self { in new()
544 pub fn get_stream_dependency(&self) -> u32 { in get_stream_dependency()
561 pub fn error_code(&self) -> u32 { in error_code()
598 pub fn new(promised_stream_id: u32, parts: Parts) -> Self { in new()
|
| D | error.rs | 105 pub fn into_code(self) -> u32 { in into_code()
|
| D | decoder.rs | 773 promised_stream_id: u32, in push_promise_framing()
837 fn get_stream_id(token: &[u8]) -> u32 { in get_stream_id()
844 fn get_code_value(token: &[u8]) -> u32 { in get_code_value()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| D | udp_socket.rs | 150 pub fn ttl(&self) -> io::Result<u32> { in ttl()
347 pub fn multicast_ttl_v4(&self) -> io::Result<u32> { in multicast_ttl_v4()
499 pub fn ttl(&self) -> io::Result<u32> { in ttl()
672 pub fn multicast_ttl_v4(&self) -> io::Result<u32> { in multicast_ttl_v4()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| D | udp_socket.rs | 220 pub fn ttl(&self) -> io::Result<u32> { in ttl()
259 pub fn multicast_ttl_v4(&self) -> io::Result<u32> { in multicast_ttl_v4()
409 pub fn ttl(&self) -> io::Result<u32> { in ttl()
552 pub fn multicast_ttl_v4(&self) -> io::Result<u32> { in multicast_ttl_v4()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| D | ylong_runtime_signal.rs | 21 pub fn GenerateConsoleCtrlEvent(dwCtrlEvent: u32, dwProcessGroupId: u32) -> i32; in GenerateConsoleCtrlEvent()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 398 id: u32, in new()
432 fn generate_id(&self) -> u32 { in generate_id()
455 last_stream_id: u32, in get_unsent_streams()
456 ) -> Result<Vec<u32>, H2Error> { in get_unsent_streams()
469 stream_id: u32, in send_message_to_stream()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | listener.rs | 144 pub fn ttl(&self) -> io::Result<u32> { in ttl()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| D | listener.rs | 120 pub fn ttl(&self) -> io::Result<u32> { in ttl()
|
| D | stream.rs | 185 pub fn ttl(&self) -> io::Result<u32> { in ttl()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| D | listener.rs | 104 pub fn ttl(&self) -> io::Result<u32> { in ttl()
|
| D | stream.rs | 222 pub fn ttl(&self) -> io::Result<u32> { in ttl()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | udp.rs | 670 pub fn ttl(&self) -> io::Result<u32> { in ttl()
713 pub fn multicast_ttl_v4(&self) -> io::Result<u32> { in multicast_ttl_v4()
923 pub fn ttl(&self) -> io::Result<u32> { in ttl()
1359 pub fn multicast_ttl_v4(&self) -> io::Result<u32> { in multicast_ttl_v4()
|
| /commonlibrary/rust/ylong_json/src/ |
| D | serializer_compact.rs | 196 _variant_index: u32, in serialize_unit_variant()
217 _variant_index: u32, in serialize_newtype_variant()
263 _variant_index: u32, in serialize_tuple_variant()
295 _variant_index: u32, in serialize_struct_variant()
|
| D | states.rs | 490 fn utf8_first_byte(byte: u8, width: u32) -> u32 { in read_error_char()
495 fn utf8_acc_cont_byte(ch: u32, byte: u8) -> u32 { in read_error_char()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| D | child.rs | 41 pub(crate) fn id(&self) -> u32 { in id()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| D | bit.rs | 91 pub const fn new(width: u32, shift: u32) -> Self { in new()
|