Home
last modified time | relevance | path

Searched refs:grpc_custom_socket (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_custom.h30 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 …]
Dtcp_uv.cc58 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 …]
Dtcp_client_custom.cc39 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()
Dtcp_server_custom.cc47 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 …]
Dtcp_custom.cc59 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/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dgrpc_gevent.pxd.pxi57 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 …]
Dgrpc_gevent.pyx.pxi87 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 …]