endpoint.cc
Go to the documentation of this file.
1 /*
2  *
3  * Copyright 2015 gRPC authors.
4  *
5  * Licensed under the Apache License, Version 2.0 (the "License");
6  * you may not use this file except in compliance with the License.
7  * You may obtain a copy of the License at
8  *
9  * http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  *
17  */
18 
20 
22 
24 
26  grpc_closure* cb, bool urgent, int min_progress_size) {
27  ep->vtable->read(ep, slices, cb, urgent, min_progress_size);
28 }
29 
31  grpc_closure* cb, void* arg, int max_frame_size) {
32  ep->vtable->write(ep, slices, cb, arg, max_frame_size);
33 }
34 
36  ep->vtable->add_to_pollset(ep, pollset);
37 }
38 
40  grpc_pollset_set* pollset_set) {
41  ep->vtable->add_to_pollset_set(ep, pollset_set);
42 }
43 
45  grpc_pollset_set* pollset_set) {
46  ep->vtable->delete_from_pollset_set(ep, pollset_set);
47 }
48 
50  ep->vtable->shutdown(ep, why);
51 }
52 
54 
56  return ep->vtable->get_peer(ep);
57 }
58 
60  return ep->vtable->get_local_address(ep);
61 }
62 
63 int grpc_endpoint_get_fd(grpc_endpoint* ep) { return ep->vtable->get_fd(ep); }
64 
66  return ep->vtable->can_track_err(ep);
67 }
grpc_pollset_set
struct grpc_pollset_set grpc_pollset_set
Definition: iomgr_fwd.h:23
absl::string_view
Definition: abseil-cpp/absl/strings/string_view.h:167
grpc_endpoint_read
void grpc_endpoint_read(grpc_endpoint *ep, grpc_slice_buffer *slices, grpc_closure *cb, bool urgent, int min_progress_size)
Definition: endpoint.cc:25
grpc_endpoint::vtable
const grpc_endpoint_vtable * vtable
Definition: endpoint.h:106
grpc_endpoint_get_peer
absl::string_view grpc_endpoint_get_peer(grpc_endpoint *ep)
Definition: endpoint.cc:55
grpc_endpoint_delete_from_pollset_set
void grpc_endpoint_delete_from_pollset_set(grpc_endpoint *ep, grpc_pollset_set *pollset_set)
Definition: endpoint.cc:44
grpc_endpoint_vtable::delete_from_pollset_set
void(* delete_from_pollset_set)(grpc_endpoint *ep, grpc_pollset_set *pollset)
Definition: endpoint.h:46
grpc_endpoint_vtable::destroy
void(* destroy)(grpc_endpoint *ep)
Definition: endpoint.h:48
grpc_tcp_trace
grpc_core::TraceFlag grpc_tcp_trace(false, "tcp")
grpc_endpoint_vtable::get_peer
absl::string_view(* get_peer)(grpc_endpoint *ep)
Definition: endpoint.h:49
grpc_endpoint_vtable::write
void(* write)(grpc_endpoint *ep, grpc_slice_buffer *slices, grpc_closure *cb, void *arg, int max_frame_size)
Definition: endpoint.h:42
arg
Definition: cmdline.cc:40
grpc_endpoint_shutdown
void grpc_endpoint_shutdown(grpc_endpoint *ep, grpc_error_handle why)
Definition: endpoint.cc:49
grpc_endpoint_destroy
void grpc_endpoint_destroy(grpc_endpoint *ep)
Definition: endpoint.cc:53
grpc_endpoint_vtable::add_to_pollset
void(* add_to_pollset)(grpc_endpoint *ep, grpc_pollset *pollset)
Definition: endpoint.h:44
grpc_core::TraceFlag
Definition: debug/trace.h:63
grpc_endpoint_get_fd
int grpc_endpoint_get_fd(grpc_endpoint *ep)
Definition: endpoint.cc:63
grpc_endpoint_vtable::add_to_pollset_set
void(* add_to_pollset_set)(grpc_endpoint *ep, grpc_pollset_set *pollset)
Definition: endpoint.h:45
grpc_endpoint_vtable::shutdown
void(* shutdown)(grpc_endpoint *ep, grpc_error_handle why)
Definition: endpoint.h:47
grpc_endpoint_add_to_pollset_set
void grpc_endpoint_add_to_pollset_set(grpc_endpoint *ep, grpc_pollset_set *pollset_set)
Definition: endpoint.cc:39
grpc_endpoint_can_track_err
bool grpc_endpoint_can_track_err(grpc_endpoint *ep)
Definition: endpoint.cc:65
slices
SliceBuffer * slices
Definition: retry_filter.cc:631
grpc_endpoint_vtable::can_track_err
bool(* can_track_err)(grpc_endpoint *ep)
Definition: endpoint.h:52
grpc_endpoint_write
void grpc_endpoint_write(grpc_endpoint *ep, grpc_slice_buffer *slices, grpc_closure *cb, void *arg, int max_frame_size)
Definition: endpoint.cc:30
grpc_endpoint_vtable::get_fd
int(* get_fd)(grpc_endpoint *ep)
Definition: endpoint.h:51
grpc_slice_buffer
Definition: include/grpc/impl/codegen/slice.h:83
grpc_endpoint_get_local_address
absl::string_view grpc_endpoint_get_local_address(grpc_endpoint *ep)
Definition: endpoint.cc:59
endpoint.h
grpc_error
Definition: error_internal.h:42
grpc_endpoint_vtable::read
void(* read)(grpc_endpoint *ep, grpc_slice_buffer *slices, grpc_closure *cb, bool urgent, int min_progress_size)
Definition: endpoint.h:40
grpc_endpoint_add_to_pollset
void grpc_endpoint_add_to_pollset(grpc_endpoint *ep, grpc_pollset *pollset)
Definition: endpoint.cc:35
grpc_pollset
Definition: bm_cq_multiple_threads.cc:37
grpc_closure
Definition: closure.h:56
grpc_endpoint_vtable::get_local_address
absl::string_view(* get_local_address)(grpc_endpoint *ep)
Definition: endpoint.h:50
grpc_endpoint
Definition: endpoint.h:105
cb
OPENSSL_EXPORT pem_password_cb * cb
Definition: pem.h:351
port_platform.h


grpc
Author(s):
autogenerated on Fri May 16 2025 02:58:19