Home
Sort by
last modified time
|
relevance
|
path
Repository(s)
applications
arkcompiler
base
build
commonlibrary
developtools
device
docs
domains
drivers
foundation
ide
interface
kernel
napi_generator
productdefine
test
third_party
vendor
select all
invert selection
clear
Full Search
Search through all text tokens(words,strings,identifiers,numbers) in index.
Definition
Only finds symbol definitions(where e.g a variable(function,...) is defined).
Symbol
Only finds symbol(e.g. methods classes,function,variables).
File Path
Path of the source file(use "/").If you want just exact path,enclose it in "".Source files end with: .jar/.bz2/.a/.h/.java...
History
History log comments.
Type
Any
Bzip(2)
C
Clojure
C#
C++
ELF
Erlang
Image file
Fortran
Golang
GZIP
Haskell
Jar
Java
Java class
JavaScript
Lisp
Lua
Pascal
Perl
PHP
Plain Text
PL/SQL
Python
Rust
Scala
Shell script
SQL
Tar
Tcl
Troff
UUEncoded
Visual Basic
XML
Zip
Type of analyzer used to filter file types include with selected(e.g. just C sources).
Help
Searched
refs:connection
(Results
1 - 4
of
4
) sorted by relevance
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
H
A
D
ylong_io_tcp_server.rs
45
println!("Accept
connection
addr: {stream:?} {addr:?}");
in main()
52
Some(
connection
) => {
in main()
55
match
connection
.write(b"Hello client_from writable") {
in main()
58
poll.deregister(
connection
)?;
in main()
59
poll.register(
connection
, event.token(), Interest::READABLE)?;
in main()
64
poll.deregister(
connection
)?;
in main()
65
poll.register(
connection
, event.token(), Interest::READABLE)?;
in main()
72
match
connection
.read(&mut msg_buf) {
in main()
74
poll.deregister(
connection
)?;
in main()
84
poll.deregister(
connection
)
in main()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H
A
D
uds_test.rs
90
Some(
connection
) => {
in server()
92
match
connection
.write(b"Hello client") {
in server()
94
poll.deregister(
connection
)?;
in server()
95
poll.register(
connection
, event.token(), Interest::READABLE)?;
in server()
99
poll.deregister(
connection
)?;
in server()
100
poll.register(
connection
, event.token(), Interest::READABLE)?;
in server()
106
match
connection
.read(&mut msg_buf) {
in server()
107
Ok(0) => poll.deregister(
connection
)?,
in server()
116
poll.deregister(
connection
)?;
in server()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H
A
D
manager.rs
332
let mut
connection
= self.settings.lock().unwrap();
in recv_settings_frame()
variables
334
if let SettingsState::Acknowledging(ref acknowledged) =
connection
.settings {
in recv_settings_frame()
343
connection
.settings = SettingsState::Synced;
in recv_settings_frame()
403
// Prevents the current
connection
from generating a new stream.
in recv_go_away_frame()
634
// ensure that the
connection
is in the closing state.
in poll_deal_with_go_away()
H
A
D
output.rs
169
// TODO Whether to continue processing the remaining frames after
connection
in poll_iterator_frames()
241
let
connection
= self.settings.lock().unwrap();
in update_decoder_settings()
242
match &
connection
.settings {
in update_decoder_settings()
Completed in 3 milliseconds