Home
last modified time | relevance | path

Searched refs:inner (Results 1 - 25 of 75) sorted by relevance

123

/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/
H A Dudp_socket.rs26 pub(crate) inner: net::UdpSocket,
64 socket.inner.connect(addr)?; in connect()
71 inner: socket, in from_std()
93 self.inner.local_addr() in local_addr()
114 .try_io(|inner| inner.send_to(buf, target), &self.inner) in send_to()
133 self.state.try_io(|inner| inner.recv_from(buf), &self.inner) in recv_from()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/
H A Dudp_socket.rs66 pub(crate) inner: net::UdpSocket,
100 UdpSocket { inner: socket } in from_std()
120 self.inner.local_addr() in local_addr()
135 self.inner.set_ttl(ttl) in set_ttl()
151 self.inner.ttl() in ttl()
179 let inner = &self.inner; in send_to()
180 inner.send_to(buf, target) in send_to()
212 let inner = &self.inner; in recv_from()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dstream.rs27 pub inner: net::TcpStream,
40 TcpStream { inner: stream } in from_std()
46 inner: self.inner.try_clone()?, in try_clone()
67 self.inner.local_addr() in local_addr()
87 self.inner.peer_addr() in peer_addr()
102 self.inner.set_nodelay(nodelay) in set_nodelay()
118 self.inner.nodelay() in nodelay()
170 self.inner.set_ttl(ttl) in set_ttl()
186 self.inner in ttl()
246 let mut inner = &self.inner; read() variables
251 let mut inner = &self.inner; read_vectored() variables
258 let mut inner = &self.inner; write() variables
263 let mut inner = &self.inner; write_vectored() variables
268 let mut inner = &self.inner; flush() variables
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Dsemaphore.rs47 inner: SemaphoreInner,
81 inner: SemaphoreInner,
106 Ok(inner) => Ok(Semaphore { inner }), in new()
121 self.inner.current_permits() in current_permits()
137 self.inner.release(); in release()
161 match self.inner.try_acquire() { in try_acquire()
186 self.inner.acquire().await?;
204 self.inner.is_closed() in is_closed()
221 self.inner in close()
[all...]
H A Dwake_list.rs34 inner: UnsafeCell<Inner>,
48 inner: UnsafeCell::new(Inner { in new()
63 let mut inner = self.lock(); in remove() variables
64 inner.wake_list.remove(key) in remove()
86 let mut inner = self.lock(); in notify() variables
87 inner.notify(notify_type) in notify()
156 unsafe { &*self.waker_set.inner.get() } in deref()
162 unsafe { &mut *self.waker_set.inner.get() } in deref_mut()
188 assert_eq!((*wakelist.inner.get()).wake_list.len, 0); in ut_wakelist_new_01()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dworker.rs126 pub(crate) inner: RefCell<Box<Inner>>,
136 let mut inner = self.inner.borrow_mut(); in run() variables
137 let inner = inner.as_mut(); in run()
139 while !inner.is_cancel() { in run()
140 inner.increment_count(); in run()
141 inner.periodic_check(self); in run()
143 if let Some(task) = self.get_task(inner, worker_ctx) { in run()
144 if inner in run()
[all...]
H A Dblocking_pool.rs34 inner: Arc<Inner>,
52 inner: Arc::new(Inner { in new()
77 let mut shared = self.inner.shared.lock().unwrap(); in shutdown()
82 self.inner.condvar.notify_all(); in shutdown()
86 let shutdown_shared = self.inner.shutdown_shared.lock().unwrap(); in shutdown()
89 .inner in shutdown()
171 for _ in 0..self.inner.max_permanent_thread_num { in create_permanent_threads()
172 let mut shared = self.inner.shared.lock().unwrap(); in create_permanent_threads()
176 if let Some(stack_size) = self.inner.stack_size { in create_permanent_threads()
179 let inner in create_permanent_threads()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
H A Dstream.rs25 pub(crate) inner: net::UnixStream,
57 UnixStream { inner: stream } in from_std()
90 Ok(Self::from_std(self.inner.try_clone()?)) in try_clone()
106 self.inner.local_addr() in local_addr()
122 self.inner.peer_addr() in peer_addr()
140 self.inner.take_error() in take_error()
158 self.inner.shutdown(how) in shutdown()
164 self.inner.read(buf) in read()
168 self.inner.read_vectored(bufs) in read_vectored()
174 self.inner in read_vectored()
187 let mut inner = &self.inner; read() variables
192 let mut inner = &self.inner; read_vectored() variables
199 let mut inner = &self.inner; write() variables
204 let mut inner = &self.inner; write_vectored() variables
209 let mut inner = &self.inner; flush() variables
[all...]
H A Ddatagram.rs24 pub(crate) inner: net::UnixDatagram,
56 UnixDatagram { inner: socket } in from_std()
83 self.inner.connect(path) in connect()
115 Ok(Self::from_std(self.inner.try_clone()?)) in try_clone()
131 self.inner.local_addr() in local_addr()
147 self.inner.peer_addr() in peer_addr()
167 self.inner.recv_from(buf) in recv_from()
185 self.inner.recv(buf) in recv()
204 self.inner.send_to(buf, path) in send_to()
222 self.inner in send()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/
H A Dstream.rs30 pub(crate) inner: net::TcpStream,
55 inner: stream, in from_std()
63 inner: self.inner.try_clone()?, in try_clone()
85 self.inner.local_addr() in local_addr()
105 self.inner.peer_addr() in peer_addr()
124 self.inner.shutdown(how) in shutdown()
139 self.inner.set_nodelay(nodelay) in set_nodelay()
155 self.inner.nodelay() in nodelay()
207 self.inner in set_ttl()
[all...]
H A Dlistener.rs26 pub(crate) inner: net::TcpListener,
55 inner: listener, in from_std()
74 .try_io(|inner| inner.accept(), &self.inner) in accept()
90 self.inner.local_addr() in local_addr()
105 self.inner.ttl() in ttl()
122 self.inner.set_ttl(ttl) in set_ttl()
140 self.inner.take_error() in take_error()
160 self.inner in get_fd()
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/
H A Dpart.rs223 inner: Result<MimePart<'a>, HttpError>,
240 inner: Ok(MimePart::new()), in new()
262 self.inner = self.inner.map(move |mut inner| { in set_headers()
263 inner.set_headers(headers); in set_headers()
264 inner in set_headers()
287 self.inner = self.inner.and_then(move |mut inner| { in header()
[all...]
H A Dmulti.rs326 inner: Result<MimeMulti<'a>, HttpError>,
343 inner: Ok(MimeMulti::new()), in new()
370 self.inner = self.inner.map(move |mut inner| { in set_headers()
371 inner.set_headers(headers); in set_headers()
372 inner in set_headers()
395 self.inner = self.inner.and_then(move |mut inner| { in insert_header()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dstdio.rs34 inner: Vec<u8>,
41 inner: Vec::with_capacity(0), in new()
51 self.inner.len() - self.pos
55 &self.inner[self.pos..] in bytes()
60 if self.inner.len() < len {
61 self.inner.reserve(len - self.len());
64 self.inner.set_len(len);
70 self.inner.extend_from_slice(&buf[..n]);
79 if self.pos == self.inner.len() {
80 self.inner
165 let mut inner = self.std.take().unwrap(); poll_flush() variables
[all...]
/commonlibrary/rust/ylong_json/src/value/array/
H A Dvec.rs36 inner: Vec<JsonValue>,
49 Self { inner: Vec::new() } in new()
65 self.inner.len() in len()
81 self.inner.len() == 0 in is_empty()
97 self.inner.push(value) in push()
113 self.inner.pop() in pop()
126 self.inner.iter() in iter()
139 self.inner.iter_mut() in iter()
154 self.inner.get(index) in iter()
169 self.inner in get_mut()
[all...]
/commonlibrary/rust/ylong_json/src/value/object/
H A Dvec.rs45 inner: Vec<(String, JsonValue)>,
59 Self { inner: Vec::new() } in new()
74 self.inner.len() in len()
89 self.inner.is_empty() in is_empty()
105 self.inner.iter().any(|(k, _)| k == key) in contains_key()
120 self.inner.push((key, value)) in insert()
137 let pos = self.inner.iter().position(|(k, _)| k == key)?; in remove()
138 Some(self.inner.remove(pos).1) in remove()
151 self.inner.iter() in iter()
164 self.inner in iter()
[all...]
H A Dbtree.rs38 inner: BTreeMap<String, JsonValue>,
53 inner: BTreeMap::new(), in new()
69 self.inner.len() in len()
84 self.inner.is_empty() in is_empty()
100 self.inner.contains_key(key) in contains_key()
115 self.inner.insert(key, value); in insert()
131 self.inner.remove(key) in remove()
144 self.inner.iter() in iter()
157 self.inner.iter_mut() in iter()
173 self.inner in iter()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A Dasync_buf_reader.rs34 inner: R,
57 pub fn new(inner: R) -> AsyncBufReader<R> { in new()
58 AsyncBufReader::with_capacity(DEFAULT_BUF_SIZE, inner) in new()
74 pub fn with_capacity(capacity: usize, inner: R) -> AsyncBufReader<R> { in with_capacity()
76 inner, in with_capacity()
101 &self.inner in get_ref()
120 &mut self.inner in get_mut()
170 self.inner in into_inner()
189 return unsafe { Pin::new_unchecked(&mut this.inner).poll_read(cx, buf) }; in poll_read()
206 poll_ready!(Pin::new_unchecked(&mut this.inner)
[all...]
H A Dasync_buf_writer.rs33 inner: W,
55 pub fn new(inner: W) -> AsyncBufWriter<W> { in new()
56 AsyncBufWriter::with_capacity(DEFAULT_BUF_SIZE, inner) in new()
72 pub fn with_capacity(cap: usize, inner: W) -> AsyncBufWriter<W> { in with_capacity()
74 inner, in with_capacity()
80 /// Gets a reference to the inner writer.
96 &self.inner in get_ref()
99 /// Gets the mutable reference to the inner writer.
115 &mut self.inner in get_mut()
123 self.inner in into_inner()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/
H A Dmod.rs55 inner: Arc<Channel<C>>,
60 self.inner.tx_cnt.fetch_add(1, Relaxed); in clone()
62 inner: self.inner.clone(), in clone()
69 Tx { inner: channel } in new()
73 Arc::ptr_eq(&self.inner, &other.inner)
77 if self.inner.tx_cnt.fetch_sub(1, AcqRel) == 1 {
78 self.inner.chan.close();
87 &self.inner in deref()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
H A Dadapter.rs43 inner: Result<SslContextBuilder, ErrorStack>,
64 inner: SslContext::builder(SslMethod::tls_client()), in new()
85 self.inner = self in ca_file()
86 .inner in ca_file()
105 self.inner = self.inner.and_then(|mut builder| { in max_proto_version()
127 self.inner = self.inner.and_then(|mut builder| { in min_proto_version()
150 self.inner = self in cipher_list()
151 .inner in cipher_list()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/
H A Dsplit.rs35 inner: Arc<InnerLock<T>>,
39 inner: Arc<InnerLock<T>>,
48 inner: MutexGuard<'a, T>,
56 let inner = Arc::new(InnerLock {
62 inner: inner.clone(),
65 let wr = Writer { inner };
76 let mut guard = ready!(self.inner.get_lock(cx)); in poll_read()
87 let mut inner = ready!(self.inner in poll_write() variables
96 let mut inner = ready!(self.inner.get_lock(cx)); poll_write_vectored() variables
105 let mut inner = ready!(self.inner.get_lock(cx)); poll_flush() variables
110 let mut inner = ready!(self.inner.get_lock(cx)); poll_shutdown() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/
H A Dencoder.rs262 inner: IndexAndValue,
267 inner: IndexAndValue::new() in new()
273 fn from(inner: IndexAndValue) -> Self { in from()
274 Self { inner } in from()
278 self.inner in encode()
285 inner: NameAndValue,
290 inner: NameAndValue::new() in new()
296 fn from(inner: NameAndValue) -> Self { in from()
297 Self { inner } in from()
301 self.inner in encode()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/
H A Dsettings.rs79 pub(crate) fn inner(&self) -> &redirect::Redirect {
211 pub(crate) fn inner(&self) -> Option<Duration> {
356 inner: proxy::Proxy::all(addr), in all()
373 inner: proxy::Proxy::http(addr), in http()
390 inner: proxy::Proxy::https(addr), in https()
394 pub(crate) fn inner(self) -> proxy::Proxy {
411 inner: Result<proxy::Proxy, HttpClientError>,
426 self.inner = self.inner.map(|mut proxy| { in no_proxy()
444 self.inner in basic_auth()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dtask_handle.rs49 fn inner(&self) -> &Inner<T, S> { in inner() functions
50 unsafe { self.task.as_ref().inner() } in inner()
62 self.inner().send_result(output); in finish()
64 self.inner().turning_to_used_data(); in finish()
73 self.inner().wake_join(); in finish()
90 *out = Poll::Ready(self.inner().turning_to_get_data());
101 self.inner().turning_to_used_data();
118 let waker = self.inner().waker.get(); in set_waker_inner()
124 let waker = self.inner().waker.get(); in set_waker_inner()
135 let waker = self.inner()
[all...]

Completed in 10 milliseconds

123