| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/distributed/rpc/tcp/ |
| D | connection.h | 80 struct Connection { struct
108 bool IsSame(const Connection *that) { in IsSame() argument
120 void SetAllocateCallback(const MemAllocateCallback &allocate_cb) { allocate_cb_ = allocate_cb; } in SetAllocateCallback()
149 ConnectionPriority priority{ConnectionPriority::kPriorityHigh}; argument
156 ConnectionType type; argument
171 ConnectionState state{kInit}; argument
174 EventLoop *send_event_loop;
175 EventLoop *recv_event_loop;
178 SendMetrics *send_metrics;
181 MessageBase *send_message;
[all …]
|
| D | socket_operation.h | 30 class Connection; variable
|
| D | ssl_socket_operation.cc | 31 ssize_t SSLSocketOperation::ReceivePeek(Connection *, char *, uint32_t) { return 0; } in ReceivePeek() argument
|
| D | connection.cc | 128 Connection::Connection() in Connection() function in mindspore::distributed::rpc::Connection
|
| /third_party/nghttp2/src/ |
| D | shrpx_connection.h | 110 struct Connection { struct
179 TLSConnection tls; argument
203 static_assert(std::is_standard_layout<Connection>::value, argument
|
| D | shrpx_connection.cc | 54 Connection::Connection(struct ev_loop *loop, int fd, SSL *ssl, in Connection() function in shrpx::Connection
|
| /third_party/rust/rust/src/tools/rust-analyzer/lib/lsp-server/src/ |
| D | lib.rs | 30 pub struct Connection { struct
35 impl Connection { argument
48 pub fn connect<A: ToSocketAddrs>(addr: A) -> io::Result<(Connection, IoThreads)> { in connect()
58 pub fn listen<A: ToSocketAddrs>(addr: A) -> io::Result<(Connection, IoThreads)> { in listen()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/include/llvm/CodeGen/ |
| D | ScheduleDFS.h | 92 struct Connection { struct
96 Connection(unsigned tree, unsigned level): TreeID(tree), Level(level) {} in Connection() function
|
| /third_party/rust/rust/tests/ui/mir/ |
| D | issue-105809.rs | 15 struct Connection<H> { struct
19 async fn complex_future<H>(conn: &Connection<H>) { in complex_future() argument
|
| /third_party/rust/rust/tests/ui/issues/ |
| D | issue-3052.rs | 5 type Connection = Box<dyn FnMut(Vec<u8>) + 'static>; typedef
|
| /third_party/rust/rust/tests/ui/async-await/in-trait/ |
| D | implied-bounds.rs | 10 type Connection<'a>: Sized where Self: 'a; typedef
|
| /third_party/grpc/test/core/event_engine/fuzzing_event_engine/ |
| D | fuzzing_event_engine.proto | 30 message Connection { message
|
| /third_party/mesa3d/.gitlab-ci/ |
| D | report-flakes.py | 31 class Connection: class
|
| /third_party/rust/rust/src/tools/rust-analyzer/lib/lsp-server/examples/ |
| D | goto_def.rs | 77 connection: Connection, in main_loop()
|
| /third_party/grpc/test/core/event_engine/posix/ |
| D | posix_endpoint_test.cc | 70 struct Connection { struct
71 std::unique_ptr<EventEngine::Endpoint> client_endpoint;
72 std::unique_ptr<EventEngine::Endpoint> server_endpoint;
|
| /third_party/nghttp2/examples/ |
| D | client.c | 80 struct Connection { struct
81 SSL *ssl;
82 nghttp2_session *session;
89 int want_io;
|
| /third_party/rust/rust/tests/ui/impl-trait/issues/ |
| D | issue-86800.rs | 13 struct Connection { struct
|
| /third_party/mesa3d/src/vulkan/overlay-layer/ |
| D | mesa-overlay-control.py | 17 class Connection: class
|
| /third_party/mesa3d/src/vulkan/screenshot-layer/ |
| D | mesa-screenshot-control.py | 17 class Connection: class
|
| /third_party/skia/third_party/externals/microhttpd/src/testspdy/ |
| D | test_notls.c | 86 struct Connection { struct
87 spdylay_session *session;
94 int want_io;
95 int fd;
|
| D | test_request_response.c | 89 struct Connection { struct
90 SSL *ssl;
91 spdylay_session *session;
98 int want_io;
|
| D | test_new_connection.c | 107 struct Connection { struct
108 SSL *ssl;
109 spdylay_session *session;
116 int want_io;
|
| /third_party/python/Lib/multiprocessing/dummy/ |
| D | connection.py | 51 class Connection(object): class
|
| /third_party/curl/lib/vquic/ |
| D | curl_msh3.c | 252 static void MSH3_CALL msh3_conn_connected(MSH3_CONNECTION *Connection, in msh3_conn_connected()
266 static void MSH3_CALL msh3_conn_shutdown_complete(MSH3_CONNECTION *Connection, in msh3_conn_shutdown_complete()
279 static void MSH3_CALL msh3_conn_new_request(MSH3_CONNECTION *Connection, in msh3_conn_new_request()
|
| /third_party/python/Lib/test/test_sqlite3/ |
| D | test_regression.py | 226 class Connection(sqlite.Connection): class
|