MCPcopy Create free account

hub / github.com/HFQR/xitca-web / functions

Functions3,753 in github.com/HFQR/xitca-web

↓ 4 callersFunctionquery_iter_with_pool
( iter: impl Iterator<Item = StatementQuery<'_, P>> + Send, pool: &Pool, )
postgres/src/pool/execute.rs:238
↓ 4 callersFunctionquery_iter_with_pool_owned
( iter: impl Iterator<Item = StatementQuery<'_, P>> + Send, pool: &PoolOwned, )
postgres/src/pool/execute.rs:500
↓ 4 callersMethodread
(mut self, io: &impl AsyncBufRead)
http/src/h1/io.rs:20
↓ 4 callersMethodremaining
(&self)
unsafe_collection/src/bytes/buf_list.rs:52
↓ 4 callersMethodremove
(&mut self, cookie: C)
web/src/handler/types/cookie.rs:123
↓ 4 callersFunctionremove_file
Removes a File This function will return an error in the following situations, but is not limited to just these cases: `path` doesn't exist. [`io::E
tokio-uring/src/fs/file.rs:896
↓ 4 callersFunctionreset_stream
(send: &mut SendStream, recv: &mut RecvStream, code: u64)
http/src/h3/proto/dispatcher_v2.rs:960
↓ 4 callersMethodresize
(&mut self, size: usize)
http/src/h2/proto/hpack/table.rs:342
↓ 4 callersFunctionrun
( io: Io, addr: SocketAddr, read_buf: BytesMut, mut ka: Pin<&mut KeepAlive>, service: &S,
http/src/h2/dispatcher.rs:416
↓ 4 callersFunctionrun_no_ops
(opts: Options)
tokio-uring/benches/lai/no_op.rs:32
↓ 4 callersMethodset_init
(&mut self, pos: usize)
tokio-uring/tests/driver.rs:33
↓ 4 callersFunctionshould_connect_tls
(io: &mut Io, ssl_mode: SslMode, ssl_negotiation: SslNegotiation)
postgres/src/driver.rs:99
↓ 4 callersMethodshutdown
Shuts down the read, write, or both halves of this connection. This function causes all pending and future I/O on the specified portions to return im
tokio-uring/src/net/udp.rs:360
↓ 4 callersMethodsize
Compute the number of bytes needed to encode this value
http/src/h3/proto/varint.rs:49
↓ 4 callersMethodsize_hint
(&self)
client/src/h1/body.rs:79
↓ 4 callersFunctionsmoke_test
(s: &str)
postgres/tests/runtime.rs:18
↓ 4 callersMethodsocket_addr
(&self)
http/src/http.rs:253
↓ 4 callersMethodstart
Starts an `io_uring` enabled Tokio runtime.
tokio-uring/src/lib.rs:157
↓ 4 callersMethodsync_all
Attempts to sync all OS-internal metadata to disk. This function will attempt to ensure that all in-memory data reaches the filesystem before complet
tokio-uring/src/fs/file.rs:752
↓ 4 callersMethodtake_body_ref
(&self)
web/src/context.rs:145
↓ 4 callersMethodtake_owned
(self)
http-encoding/src/writer.rs:17
↓ 4 callersFunctiontempfile
()
tokio-uring/tests/fixed_buf.rs:175
↓ 4 callersMethodtry_apply_config
(&self, stream: impl Into<SockRef<'s>>)
http/src/util/middleware/socket_config.rs:161
↓ 4 callersMethodtry_remove
(&mut self)
http/src/h2/proto/stream.rs:235
↓ 4 callersMethodtry_start_continue
(&mut self)
http-ws/src/codec.rs:228
↓ 4 callersFunctiontry_value
(name: N, value: V)
http/src/h3/proto/headers.rs:358
↓ 4 callersFunctionunspecified_socket_addr
()
http/src/lib.rs:81
↓ 4 callersMethodupdate
(self: Pin<&mut Self>, deadline: Instant)
http/src/util/timer.rs:66
↓ 4 callersFunctionuring_builder
Creates and returns an io_uring::Builder that can then be modified through its implementation methods.
tokio-uring/src/lib.rs:120
↓ 4 callersMethoduring_builder
Replaces the default [`io_uring::Builder`], which controls the settings for the inner `io_uring` API.
tokio-uring/src/lib.rs:151
↓ 4 callersMethodvalue_slice
(&self)
http/src/h2/proto/hpack/header.rs:127
↓ 4 callersMethodwait
(&self)
postgres/src/driver/generic.rs:111
↓ 4 callersFunctionwith_worker_name_str
(func: F)
server/src/worker/mod.rs:76
↓ 4 callersMethodwrite
(&mut self, _buf: &[u8])
client/src/http_tunnel.rs:220
↓ 4 callersFunctionwrite_bits
Write bits from `value` to the `out` slice Write the least significant `pos.count` bits from `value` to the position specified by `(pos.byte, pos.bit
http/src/h3/proto/qpack/prefix_string/encode.rs:86
↓ 4 callersFunctionwrite_cstr
(s: &str, buf: &mut BytesMut)
postgres/src/protocol.rs:116
↓ 4 callersMethodwrite_fixed_at
Like [`write_at`], but using a pre-mapped buffer registered with [`FixedBufRegistry`]. [`write_at`]: Self::write_at [`FixedBufRegistry`]: crate::buf:
tokio-uring/src/fs/file.rs:655
↓ 3 callersFunctionT
(e,n,t)
examples/file/static/client.626570da.js:1
↓ 3 callersMethodacquire
(&self, key: impl Into<K>)
client/src/pool/shared.rs:52
↓ 3 callersFunctionapply_mask_fallback
(buf: &mut [u8], mask: [u8; 4])
http-ws/src/mask.rs:11
↓ 3 callersMethodas_frame_size
(self)
http/src/h2/proto/window.rs:144
↓ 3 callersMethodas_header_value
(&self)
http-encoding/src/coding.rs:29
↓ 3 callersMethodas_raw_fd
(&self)
tokio-uring/src/net/udp.rs:372
↓ 3 callersMethodas_raw_fd
(&self)
tokio-uring/src/net/unix/stream.rs:250
↓ 3 callersMethodas_slice
SAFETY: caller must make sure the variant is properly intialized.
unsafe_collection/src/small_str.rs:51
↓ 3 callersMethodas_socket
(&self)
io/src/net/tcp.rs:83
↓ 3 callersMethodas_str
(&self)
unsafe_collection/src/bytes/byte_str.rs:45
↓ 3 callersMethodassert_thread_id
(&self)
unsafe_collection/src/fake.rs:73
↓ 3 callersMethodborrow_cli_ref
(&self)
postgres/src/transaction/builder.rs:196
↓ 3 callersMethodcall
(&self, req: &'r mut Connect<'c>)
client/src/resolver.rs:19
↓ 3 callersMethodcall
( &self, (name, listeners): (&'a str, &'a [(String, ListenerDyn)]), )
server/src/server/service.rs:36
↓ 3 callersMethodcall
(&self, res: Result<S, E>)
web/src/middleware/limit.rs:56
↓ 3 callersMethodcancel_token
Constructs a cancellation token that can later be used to request cancellation of a query running on the connection associated with this client.
postgres/src/client.rs:196
↓ 3 callersMethodcheck
Allow a single cell through the rate limiter. If the rate limit is reached, `check` returns information about the earliest time that a cell might be
http-rate/src/state/direct.rs:67
↓ 3 callersMethodcheck_not_idle
(&self, id: StreamId)
http/src/h2/proto/flow.rs:121
↓ 3 callersMethodchunk
Returns a shared reference to the initialized portion of the buffer.
tokio-uring/src/buf/bounded.rs:78
↓ 3 callersMethodclone
(&self)
http/src/util/middleware/extension.rs:47
↓ 3 callersMethodclose
(&mut self)
http/src/h2/proto/flow.rs:804
↓ 3 callersMethodclosed
a lossy hint of running state of io driver. an io driver shutdown can happen at the same time this api is called.
postgres/src/client.rs:201
↓ 3 callersMethodcolumns
(&self)
postgres/src/row/types.rs:81
↓ 3 callersMethodconn
(&self)
postgres/src/pool/connection.rs:159
↓ 3 callersMethodconnect
logic where a new connection is created
postgres/examples/pooling.rs:26
↓ 3 callersMethodconsume
(self, buf: &mut Cursor<&mut BytesMut>)
http/src/h2/proto/hpack/decoder.rs:432
↓ 3 callersMethodcopy_to_bytes
(&mut self, len: usize)
unsafe_collection/src/bytes/limit.rs:90
↓ 3 callersMethodcreate
Opens a file in write-only mode. This function will create a file if it does not exist, and will truncate it if it does. See the [`OpenOptions::open
tokio-uring/src/fs/file.rs:113
↓ 3 callersMethoddbname
Sets the name of the database to connect to. Defaults to the user.
postgres/src/config.rs:117
↓ 3 callersMethoddecode
(&mut self, src: &mut BytesMut)
http-ws/src/codec.rs:178
↓ 3 callersMethoddecode_literal
(&mut self, buf: &mut Cursor<&mut BytesMut>, index: bool)
http/src/h2/proto/hpack/decoder.rs:249
↓ 3 callersFunctiondecoded_header_size
(name: usize, value: usize)
http/src/h2/proto/frame/headers.rs:728
↓ 3 callersFunctiondefault_pat_ident
generate a default PatIdent
codegen/src/service.rs:381
↓ 3 callersMethoddeferrable
Sets the deferrability of the transaction. If the transaction is also serializable and read only, creation of the transaction may block, but when it
postgres/src/transaction/builder.rs:76
↓ 3 callersFunctionderef
(buf: &impl IoBuf)
tokio-uring/src/buf/mod.rs:22
↓ 3 callersMethodderef
(&self)
http-ws/src/lib.rs:151
↓ 3 callersMethoddestroy_on_drop
(&mut self)
client/src/body.rs:63
↓ 3 callersMethoddispatch_completions
(&mut self)
tokio-uring/src/runtime/driver/mod.rs:81
↓ 3 callersFunctionencode
(size: u8, flags: u8, value: &[u8], buf: &mut B)
http/src/h3/proto/qpack/prefix_string.rs:62
↓ 3 callersFunctionencode_bind
( stmt_name: &str, types: &[Type], params: P, portal_name: &str, buf: &mut BytesMut, )
postgres/src/driver/codec/encode.rs:235
↓ 3 callersFunctionencode_size_update
(val: usize, dst: &mut BytesMut)
http/src/h2/proto/hpack/encoder.rs:172
↓ 3 callersFunctionencode_stateless
(block: &mut W, fields: T)
http/src/h3/proto/qpack/encoder.rs:200
↓ 3 callersMethodentries
Collects all entries as `(path, &value)` pairs.
router/src/tree.rs:792
↓ 3 callersFunctionestablish
( client: &Client, connect: &mut Connect<'_>, version: Version, allow_h2c_downgrade: bool, )
client/src/pool/service.rs:153
↓ 3 callersMethodexecute
(self, cli: &'c GenericPoolConnection<P>)
postgres/src/pool/connection.rs:266
↓ 3 callersMethodfile_name
Attach a filename (sets the `filename` parameter in `Content-Disposition`).
http-multipart/src/form.rs:128
↓ 3 callersMethodfinish
Finish the builder and construct [Client] instance.
client/src/builder.rs:467
↓ 3 callersMethodfor_each
Iterates over the tree and calls the given visitor function with fully resolved path and its value.
router/src/tree.rs:749
↓ 3 callersMethodfront
(&self)
unsafe_collection/src/bound_queue/heap.rs:45
↓ 3 callersMethodfront_idx
(&self)
unsafe_collection/src/bound_queue/mod.rs:157
↓ 3 callersMethodget_password
Gets the password to authenticate with, if one has been configured with the `password` method.
postgres/src/config.rs:110
↓ 3 callersMethodget_ports
Gets the ports that have been added to the configuration with `port`.
postgres/src/config.rs:216
↓ 3 callersMethodgo_away
(&mut self, err: Error)
http/src/h2/proto/flow.rs:465
↓ 3 callersFunctionhandler
( method: &Method, addr: &SocketAddr, uri: &Uri, headers: &HeaderMap,
http/src/util/service/handler.rs:354
↓ 3 callersFunctionhandshake
(stream: S)
client/src/h2/proto/dispatcher.rs:167
↓ 3 callersMethodhead
(&self)
http/src/h2/proto/frame/data.rs:95
↓ 3 callersMethodheaders
(block: T)
http/src/h3/proto/frame.rs:227
↓ 3 callersFunctionhuff_encode
(src: &[u8])
http/src/h2/proto/hpack/decoder.rs:833
↓ 3 callersMethodindex
(&self, index: usize)
http/src/h3/proto/qpack/vas.rs:128
↓ 3 callersMethodinit
(&mut self, settings: Settings)
http/src/h2/proto/flow.rs:712
↓ 3 callersMethodinit_from
(self, slice: I)
unsafe_collection/src/uninit.rs:29
↓ 3 callersMethodinitial_window_size
(&self)
http/src/h2/proto/frame/settings.rs:77
↓ 3 callersMethodinline_remove_stream
(&mut self, id: StreamId)
http/src/h2/proto/flow.rs:189
← previousnext →501–600 of 3,753, ranked by callers