|
|
@ -389,9 +389,16 @@ static char *win_get_peer(grpc_endpoint *ep) { |
|
|
|
return gpr_strdup(tcp->peer_string); |
|
|
|
return gpr_strdup(tcp->peer_string); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static grpc_endpoint_vtable vtable = { |
|
|
|
static grpc_workqueue *win_get_workqueue(grpc_endpoint *ep) { return NULL; } |
|
|
|
win_read, win_write, win_add_to_pollset, win_add_to_pollset_set, |
|
|
|
|
|
|
|
win_shutdown, win_destroy, win_get_peer}; |
|
|
|
static grpc_endpoint_vtable vtable = {win_read, |
|
|
|
|
|
|
|
win_write, |
|
|
|
|
|
|
|
win_get_workqueue, |
|
|
|
|
|
|
|
win_add_to_pollset, |
|
|
|
|
|
|
|
win_add_to_pollset_set, |
|
|
|
|
|
|
|
win_shutdown, |
|
|
|
|
|
|
|
win_destroy, |
|
|
|
|
|
|
|
win_get_peer}; |
|
|
|
|
|
|
|
|
|
|
|
grpc_endpoint *grpc_tcp_create(grpc_winsocket *socket, char *peer_string) { |
|
|
|
grpc_endpoint *grpc_tcp_create(grpc_winsocket *socket, char *peer_string) { |
|
|
|
grpc_tcp *tcp = (grpc_tcp *)gpr_malloc(sizeof(grpc_tcp)); |
|
|
|
grpc_tcp *tcp = (grpc_tcp *)gpr_malloc(sizeof(grpc_tcp)); |
|
|
|