| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_custom.h | 30 typedef struct grpc_custom_socket { struct
37 } grpc_custom_socket; argument
39 typedef void (*grpc_custom_connect_callback)(grpc_custom_socket* socket,
41 typedef void (*grpc_custom_write_callback)(grpc_custom_socket* socket,
43 typedef void (*grpc_custom_read_callback)(grpc_custom_socket* socket,
45 typedef void (*grpc_custom_accept_callback)(grpc_custom_socket* socket,
46 grpc_custom_socket* client,
48 typedef void (*grpc_custom_close_callback)(grpc_custom_socket* socket);
51 grpc_error* (*init)(grpc_custom_socket* socket, int domain);
52 void (*connect)(grpc_custom_socket* socket, const grpc_sockaddr* addr,
[all …]
|
| D | tcp_uv.cc | 58 grpc_custom_socket* accept_socket;
82 static void uv_socket_destroy(grpc_custom_socket* socket) { in uv_socket_destroy()
91 (uv_socket_t*)((grpc_custom_socket*)handle->data)->impl; in alloc_uv_buf()
111 grpc_custom_socket* socket = (grpc_custom_socket*)stream->data; in uv_read_callback()
117 grpc_custom_socket* socket = (grpc_custom_socket*)handle->data; in uv_close_callback()
126 static void uv_socket_read(grpc_custom_socket* socket, char* buffer, in uv_socket_read()
145 grpc_custom_socket* socket = (grpc_custom_socket*)req->data; in uv_write_callback()
151 void uv_socket_write(grpc_custom_socket* socket, in uv_socket_write()
175 static void uv_socket_shutdown(grpc_custom_socket* socket) { in uv_socket_shutdown()
181 static void uv_socket_close(grpc_custom_socket* socket, in uv_socket_close()
[all …]
|
| D | tcp_client_custom.cc | 39 grpc_custom_socket* socket;
50 grpc_custom_socket* socket = connect->socket; in custom_tcp_connect_cleanup()
61 static void custom_close_callback(grpc_custom_socket* socket) {} in custom_close_callback()
65 grpc_custom_socket* socket = (grpc_custom_socket*)acp; in on_alarm()
84 static void custom_connect_callback(grpc_custom_socket* socket, in custom_connect_callback()
122 grpc_custom_socket* socket = in tcp_connect()
123 (grpc_custom_socket*)gpr_malloc(sizeof(grpc_custom_socket)); in tcp_connect()
|
| D | tcp_server_custom.cc | 47 grpc_custom_socket* socket;
140 static void custom_close_callback(grpc_custom_socket* socket) { in custom_close_callback()
167 grpc_custom_socket* socket = sp->socket; in close_listener()
204 static void finish_accept(grpc_tcp_listener* sp, grpc_custom_socket* socket) { in finish_accept()
240 static void custom_accept_callback(grpc_custom_socket* socket,
241 grpc_custom_socket* client,
244 static void custom_accept_callback(grpc_custom_socket* socket, in custom_accept_callback()
245 grpc_custom_socket* client, in custom_accept_callback()
259 grpc_custom_socket* new_socket = in custom_accept_callback()
260 (grpc_custom_socket*)gpr_malloc(sizeof(grpc_custom_socket)); in custom_accept_callback()
[all …]
|
| D | tcp_custom.cc | 59 grpc_custom_socket* socket;
75 static void tcp_free(grpc_custom_socket* s) { in tcp_free()
147 static void custom_read_callback(grpc_custom_socket* socket, size_t nread, in custom_read_callback()
209 static void custom_write_callback(grpc_custom_socket* socket, in custom_write_callback()
299 static void custom_close_callback(grpc_custom_socket* socket) { in custom_close_callback()
340 grpc_endpoint* custom_tcp_endpoint_create(grpc_custom_socket* socket, in custom_tcp_endpoint_create()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_custom.h | 33 typedef struct grpc_custom_socket { struct
40 } grpc_custom_socket; argument
42 typedef void (*grpc_custom_connect_callback)(grpc_custom_socket* socket,
44 typedef void (*grpc_custom_write_callback)(grpc_custom_socket* socket,
46 typedef void (*grpc_custom_read_callback)(grpc_custom_socket* socket,
48 typedef void (*grpc_custom_accept_callback)(grpc_custom_socket* socket,
49 grpc_custom_socket* client,
51 typedef void (*grpc_custom_close_callback)(grpc_custom_socket* socket);
54 grpc_error* (*init)(grpc_custom_socket* socket, int domain);
55 void (*connect)(grpc_custom_socket* socket, const grpc_sockaddr* addr,
[all …]
|
| D | tcp_uv.cc | 57 grpc_custom_socket* accept_socket;
81 static void uv_socket_destroy(grpc_custom_socket* socket) { in uv_socket_destroy()
90 (uv_socket_t*)((grpc_custom_socket*)handle->data)->impl; in alloc_uv_buf()
110 grpc_custom_socket* socket = (grpc_custom_socket*)stream->data; in uv_read_callback()
116 grpc_custom_socket* socket = (grpc_custom_socket*)handle->data; in uv_close_callback()
125 static void uv_socket_read(grpc_custom_socket* socket, char* buffer, in uv_socket_read()
144 grpc_custom_socket* socket = (grpc_custom_socket*)req->data; in uv_write_callback()
150 void uv_socket_write(grpc_custom_socket* socket, in uv_socket_write()
174 static void uv_socket_shutdown(grpc_custom_socket* socket) { in uv_socket_shutdown()
180 static void uv_socket_close(grpc_custom_socket* socket, in uv_socket_close()
[all …]
|
| D | tcp_client_custom.cc | 39 grpc_custom_socket* socket;
50 grpc_custom_socket* socket = connect->socket; in custom_tcp_connect_cleanup()
60 static void custom_close_callback(grpc_custom_socket* /*socket*/) {} in custom_close_callback() argument
64 grpc_custom_socket* socket = static_cast<grpc_custom_socket*>(acp); in on_alarm()
83 static void custom_connect_callback_internal(grpc_custom_socket* socket, in custom_connect_callback_internal()
101 static void custom_connect_callback(grpc_custom_socket* socket, in custom_connect_callback()
133 grpc_custom_socket* socket = in tcp_connect()
134 static_cast<grpc_custom_socket*>(gpr_malloc(sizeof(grpc_custom_socket))); in tcp_connect()
|
| D | tcp_server_custom.cc | 50 grpc_custom_socket* socket;
151 static void custom_close_callback(grpc_custom_socket* socket) { in custom_close_callback()
178 grpc_custom_socket* socket = sp->socket; in close_listener()
215 static void finish_accept(grpc_tcp_listener* sp, grpc_custom_socket* socket) { in finish_accept()
247 static void custom_accept_callback(grpc_custom_socket* socket,
248 grpc_custom_socket* client,
251 static void custom_accept_callback(grpc_custom_socket* socket, in custom_accept_callback()
252 grpc_custom_socket* client, in custom_accept_callback()
267 grpc_custom_socket* new_socket = static_cast<grpc_custom_socket*>( in custom_accept_callback()
268 gpr_malloc(sizeof(grpc_custom_socket))); in custom_accept_callback()
[all …]
|
| D | tcp_custom.cc | 59 grpc_custom_socket* socket;
75 static void tcp_free(grpc_custom_socket* s) { in tcp_free()
148 static void custom_read_callback(grpc_custom_socket* socket, size_t nread, in custom_read_callback()
215 static void custom_write_callback(grpc_custom_socket* socket, in custom_write_callback()
308 static void custom_close_callback(grpc_custom_socket* socket) { in custom_close_callback()
359 grpc_endpoint* custom_tcp_endpoint_create(grpc_custom_socket* socket, in custom_tcp_endpoint_create()
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | grpc_gevent.pxd.pxi | 57 struct grpc_custom_socket:
60 ctypedef void (*grpc_custom_connect_callback)(grpc_custom_socket* socket,
62 ctypedef void (*grpc_custom_write_callback)(grpc_custom_socket* socket,
64 ctypedef void (*grpc_custom_read_callback)(grpc_custom_socket* socket,
66 ctypedef void (*grpc_custom_accept_callback)(grpc_custom_socket* socket,
67 grpc_custom_socket* client,
69 ctypedef void (*grpc_custom_close_callback)(grpc_custom_socket* socket)
72 grpc_error* (*init)(grpc_custom_socket* socket, int domain);
73 void (*connect)(grpc_custom_socket* socket, const grpc_sockaddr* addr,
75 void (*destroy)(grpc_custom_socket* socket);
[all …]
|
| D | grpc_gevent.pyx.pxi | 87 cdef grpc_error* socket_init(grpc_custom_socket* socket, int domain) with gil:
103 socket_wrapper.connect_cb(<grpc_custom_socket*>socket_wrapper.c_socket,
106 socket_wrapper.connect_cb(<grpc_custom_socket*>socket_wrapper.c_socket,
113 cdef void socket_connect(grpc_custom_socket* socket, const grpc_sockaddr* addr,
128 cdef void socket_destroy(grpc_custom_socket* socket) with gil:
131 cdef void socket_shutdown(grpc_custom_socket* socket) with gil:
138 cdef void socket_close(grpc_custom_socket* socket,
168 socket_wrapper.write_cb(<grpc_custom_socket*>socket_wrapper.c_socket,
171 socket_wrapper.write_cb(<grpc_custom_socket*>socket_wrapper.c_socket,
178 cdef void socket_write(grpc_custom_socket* socket, grpc_slice_buffer* buffer,
[all …]
|