Home
last modified time | relevance | path

Searched refs:emfd (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc/test/core/iomgr/
Dudp_server_test.cc63 TestGrpcUdpHandler(grpc_fd* emfd, void* user_data) in TestGrpcUdpHandler() argument
64 : GrpcUdpHandler(emfd, user_data), emfd_(emfd) { in TestGrpcUdpHandler()
76 recv(grpc_fd_wrapped_fd(emfd()), read_buffer, sizeof(read_buffer), 0); in Read()
101 grpc_fd_wrapped_fd(emfd())); in OnFdAboutToOrphan()
106 grpc_fd* emfd() { return emfd_; } in emfd() function in TestGrpcUdpHandler
114 GrpcUdpHandler* CreateUdpHandler(grpc_fd* emfd, void* user_data) override { in CreateUdpHandler() argument
115 gpr_log(GPR_INFO, "create udp handler for fd %d", grpc_fd_wrapped_fd(emfd)); in CreateUdpHandler()
116 return grpc_core::New<TestGrpcUdpHandler>(emfd, user_data); in CreateUdpHandler()
/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_server_posix.cc152 grpc_fd_orphan(sp->emfd, &sp->destroyed_closure, nullptr, in deactivated_all_ports()
173 sp->emfd, GRPC_ERROR_CREATE_FROM_STATIC_STRING("Server destroyed")); in tcp_server_destroy()
205 grpc_fd_notify_on_read(sp->emfd, &sp->read_closure); in on_read()
365 sp->emfd = grpc_fd_create(fd, name, true); in clone_port()
370 GPR_ASSERT(sp->emfd); in clone_port()
494 grpc_pollset_add_fd(pollsets[i], sp->emfd); in tcp_server_start()
497 grpc_fd_notify_on_read(sp->emfd, &sp->read_closure); in tcp_server_start()
503 grpc_pollset_add_fd(pollsets[i], sp->emfd); in tcp_server_start()
507 grpc_fd_notify_on_read(sp->emfd, &sp->read_closure); in tcp_server_start()
545 grpc_fd_shutdown(sp->emfd, in tcp_server_shutdown_listeners()
Dudp_server.h42 GrpcUdpHandler(grpc_fd* emfd, void* user_data) {} in GrpcUdpHandler() argument
70 virtual GrpcUdpHandler* CreateUdpHandler(grpc_fd* emfd,
Dtcp_server_utils_posix_common.cc108 sp->emfd = grpc_fd_create(fd, name, true); in add_socket_to_server()
115 GPR_ASSERT(sp->emfd); in add_socket_to_server()
Dtcp_server_utils_posix.h32 grpc_fd* emfd; member
Dudp_server.cc99 grpc_fd* emfd() const { return emfd_; } in emfd() function in GrpcUdpListener