legacy-libs/grpc/deps/grpc/src/core/lib/iomgr/tcp_custom.h

   1 /*
   2  *
   3  * Copyright 2018 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
  19 #ifndef GRPC_CORE_LIB_IOMGR_TCP_CUSTOM_H
  20 #define GRPC_CORE_LIB_IOMGR_TCP_CUSTOM_H
  21
  22 #include <grpc/support/port_platform.h>
  23
  24 #include "src/core/lib/iomgr/endpoint.h"
  25 #include "src/core/lib/iomgr/sockaddr.h"
  26
  27 typedef struct grpc_tcp_listener grpc_tcp_listener;
  28 typedef struct grpc_custom_tcp_connect grpc_custom_tcp_connect;
  29
  30 typedef struct grpc_custom_socket {
  31   // Implementation defined
  32   void* impl;
  33   grpc_endpoint* endpoint;
  34   grpc_tcp_listener* listener;
  35   grpc_custom_tcp_connect* connector;
  36   int refs;
  37 } grpc_custom_socket;
  38
  39 typedef void (*grpc_custom_connect_callback)(grpc_custom_socket* socket,
  40                                              grpc_error* error);
  41 typedef void (*grpc_custom_write_callback)(grpc_custom_socket* socket,
  42                                            grpc_error* error);
  43 typedef void (*grpc_custom_read_callback)(grpc_custom_socket* socket,
  44                                           size_t nread, grpc_error* error);
  45 typedef void (*grpc_custom_accept_callback)(grpc_custom_socket* socket,
  46                                             grpc_custom_socket* client,
  47                                             grpc_error* error);
  48 typedef void (*grpc_custom_close_callback)(grpc_custom_socket* socket);
  49
  50 typedef struct grpc_socket_vtable {
  51   grpc_error* (*init)(grpc_custom_socket* socket, int domain);
  52   void (*connect)(grpc_custom_socket* socket, const grpc_sockaddr* addr,
  53                   size_t len, grpc_custom_connect_callback cb);
  54   void (*destroy)(grpc_custom_socket* socket);
  55   void (*shutdown)(grpc_custom_socket* socket);
  56   void (*close)(grpc_custom_socket* socket, grpc_custom_close_callback cb);
  57   void (*write)(grpc_custom_socket* socket, grpc_slice_buffer* slices,
  58                 grpc_custom_write_callback cb);
  59   void (*read)(grpc_custom_socket* socket, char* buffer, size_t length,
  60                grpc_custom_read_callback cb);
  61   grpc_error* (*getpeername)(grpc_custom_socket* socket,
  62                              const grpc_sockaddr* addr, int* len);
  63   grpc_error* (*getsockname)(grpc_custom_socket* socket,
  64                              const grpc_sockaddr* addr, int* len);
  65   grpc_error* (*bind)(grpc_custom_socket* socket, const grpc_sockaddr* addr,
  66                       size_t len, int flags);
  67   grpc_error* (*listen)(grpc_custom_socket* socket);
  68   void (*accept)(grpc_custom_socket* socket, grpc_custom_socket* client,
  69                  grpc_custom_accept_callback cb);
  70 } grpc_socket_vtable;
  71
  72 /* Internal APIs */
  73 void grpc_custom_endpoint_init(grpc_socket_vtable* impl);
  74
  75 void grpc_custom_close_server_callback(grpc_tcp_listener* listener);
  76
  77 grpc_endpoint* custom_tcp_endpoint_create(grpc_custom_socket* socket,
  78                                           grpc_resource_quota* resource_quota,
  79                                           char* peer_string);
  80
  81 #endif /* GRPC_CORE_LIB_IOMGR_TCP_CUSTOM_H */