@ -34,14 +34,14 @@
# include "src/core/lib/support/string.h"
# include <grpc/byte_buffer_reader.h>
# include <grpc/support/port_platform.h>
# include <grpc/grpc.h>
# include <grpc/grpc_security.h>
# include <grpc/slice.h>
# include <grpc/support/alloc.h>
# include <grpc/support/log.h>
# include <grpc/slice .h>
# include <grpc/support/port_platform .h>
# include <grpc/support/string_util.h>
# include <grpc/support/thd.h>
# include <grpc/grpc.h>
# include <grpc/grpc_security.h>
# include <string.h>
@ -84,7 +84,8 @@ typedef struct grpcsharp_batch_context {
int recv_close_on_server_cancelled ;
} grpcsharp_batch_context ;
GPR_EXPORT grpcsharp_batch_context * GPR_CALLTYPE grpcsharp_batch_context_create ( ) {
GPR_EXPORT grpcsharp_batch_context * GPR_CALLTYPE
grpcsharp_batch_context_create ( ) {
grpcsharp_batch_context * ctx = gpr_malloc ( sizeof ( grpcsharp_batch_context ) ) ;
memset ( ctx , 0 , sizeof ( grpcsharp_batch_context ) ) ;
return ctx ;
@ -96,8 +97,10 @@ typedef struct {
grpc_metadata_array request_metadata ;
} grpcsharp_request_call_context ;
GPR_EXPORT grpcsharp_request_call_context * GPR_CALLTYPE grpcsharp_request_call_context_create ( ) {
grpcsharp_request_call_context * ctx = gpr_malloc ( sizeof ( grpcsharp_request_call_context ) ) ;
GPR_EXPORT grpcsharp_request_call_context * GPR_CALLTYPE
grpcsharp_request_call_context_create ( ) {
grpcsharp_request_call_context * ctx =
gpr_malloc ( sizeof ( grpcsharp_request_call_context ) ) ;
memset ( ctx , 0 , sizeof ( grpcsharp_request_call_context ) ) ;
return ctx ;
}
@ -175,15 +178,15 @@ grpcsharp_metadata_array_count(grpc_metadata_array *array) {
return ( intptr_t ) array - > count ;
}
GPR_EXPORT const char * GPR_CALLTYPE
grpcsharp_metadata_array_get_key ( grpc_metadata_array * array , size_t index , size_t * key_length ) {
GPR_EXPORT const char * GPR_CALLTYPE grpcsharp_metadata_array_get_key (
grpc_metadata_array * array , size_t index , size_t * key_length ) {
GPR_ASSERT ( index < array - > count ) ;
* key_length = GRPC_SLICE_LENGTH ( array - > metadata [ index ] . key ) ;
return ( char * ) GRPC_SLICE_START_PTR ( array - > metadata [ index ] . key ) ;
}
GPR_EXPORT const char * GPR_CALLTYPE
grpcsharp_metadata_array_get_value ( grpc_metadata_array * array , size_t index , size_t * value_length ) {
GPR_EXPORT const char * GPR_CALLTYPE grpcsharp_metadata_array_get_value (
grpc_metadata_array * array , size_t index , size_t * value_length ) {
GPR_ASSERT ( index < array - > count ) ;
* value_length = GRPC_SLICE_LENGTH ( array - > metadata [ index ] . value ) ;
return ( char * ) GRPC_SLICE_START_PTR ( array - > metadata [ index ] . value ) ;
@ -208,7 +211,8 @@ void grpcsharp_metadata_array_move(grpc_metadata_array *dest,
src - > metadata = NULL ;
}
GPR_EXPORT void GPR_CALLTYPE grpcsharp_batch_context_destroy ( grpcsharp_batch_context * ctx ) {
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_batch_context_destroy ( grpcsharp_batch_context * ctx ) {
if ( ! ctx ) {
return ;
}
@ -231,7 +235,8 @@ GPR_EXPORT void GPR_CALLTYPE grpcsharp_batch_context_destroy(grpcsharp_batch_con
gpr_free ( ctx ) ;
}
GPR_EXPORT void GPR_CALLTYPE grpcsharp_request_call_context_destroy ( grpcsharp_request_call_context * ctx ) {
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_request_call_context_destroy ( grpcsharp_request_call_context * ctx ) {
if ( ! ctx ) {
return ;
}
@ -240,8 +245,7 @@ GPR_EXPORT void GPR_CALLTYPE grpcsharp_request_call_context_destroy(grpcsharp_re
to take its ownership . */
grpc_call_details_destroy ( & ( ctx - > call_details ) ) ;
grpcsharp_metadata_array_destroy_metadata_only (
& ( ctx - > request_metadata ) ) ;
grpcsharp_metadata_array_destroy_metadata_only ( & ( ctx - > request_metadata ) ) ;
gpr_free ( ctx ) ;
}
@ -299,8 +303,10 @@ grpcsharp_batch_context_recv_status_on_client_status(
GPR_EXPORT const char * GPR_CALLTYPE
grpcsharp_batch_context_recv_status_on_client_details (
const grpcsharp_batch_context * ctx , size_t * details_length ) {
* details_length = GRPC_SLICE_LENGTH ( ctx - > recv_status_on_client . status_details ) ;
return ( char * ) GRPC_SLICE_START_PTR ( ctx - > recv_status_on_client . status_details ) ;
* details_length =
GRPC_SLICE_LENGTH ( ctx - > recv_status_on_client . status_details ) ;
return ( char * ) GRPC_SLICE_START_PTR (
ctx - > recv_status_on_client . status_details ) ;
}
GPR_EXPORT const grpc_metadata_array * GPR_CALLTYPE
@ -309,13 +315,12 @@ grpcsharp_batch_context_recv_status_on_client_trailing_metadata(
return & ( ctx - > recv_status_on_client . trailing_metadata ) ;
}
GPR_EXPORT grpc_call * GPR_CALLTYPE grpcsharp_request_call_context_call (
const grpcsharp_request_call_context * ctx ) {
GPR_EXPORT grpc_call * GPR_CALLTYPE
grpcsharp_request_call_context_call ( const grpcsharp_request_call_context * ctx ) {
return ctx - > call ;
}
GPR_EXPORT const char * GPR_CALLTYPE
grpcsharp_request_call_context_method (
GPR_EXPORT const char * GPR_CALLTYPE grpcsharp_request_call_context_method (
const grpcsharp_request_call_context * ctx , size_t * method_length ) {
* method_length = GRPC_SLICE_LENGTH ( ctx - > call_details . method ) ;
return ( char * ) GRPC_SLICE_START_PTR ( ctx - > call_details . method ) ;
@ -327,8 +332,7 @@ GPR_EXPORT const char *GPR_CALLTYPE grpcsharp_request_call_context_host(
return ( char * ) GRPC_SLICE_START_PTR ( ctx - > call_details . host ) ;
}
GPR_EXPORT gpr_timespec GPR_CALLTYPE
grpcsharp_request_call_context_deadline (
GPR_EXPORT gpr_timespec GPR_CALLTYPE grpcsharp_request_call_context_deadline (
const grpcsharp_request_call_context * ctx ) {
return ctx - > call_details . deadline ;
}
@ -342,7 +346,7 @@ grpcsharp_request_call_context_request_metadata(
GPR_EXPORT int32_t GPR_CALLTYPE
grpcsharp_batch_context_recv_close_on_server_cancelled (
const grpcsharp_batch_context * ctx ) {
return ( int32_t ) ctx - > recv_close_on_server_cancelled ;
return ( int32_t ) ctx - > recv_close_on_server_cancelled ;
}
/* Init & shutdown */
@ -389,7 +393,8 @@ grpcsharp_completion_queue_pluck(grpc_completion_queue *cq, void *tag) {
GPR_EXPORT grpc_channel * GPR_CALLTYPE
grpcsharp_insecure_channel_create ( const char * target , const grpc_channel_args * args ) {
grpcsharp_insecure_channel_create ( const char * target ,
const grpc_channel_args * args ) {
return grpc_insecure_channel_create ( target , args , NULL ) ;
}
@ -397,12 +402,10 @@ GPR_EXPORT void GPR_CALLTYPE grpcsharp_channel_destroy(grpc_channel *channel) {
grpc_channel_destroy ( channel ) ;
}
GPR_EXPORT grpc_call * GPR_CALLTYPE
grpcsharp_channel_create_call ( grpc_channel * channel , grpc_call * parent_call ,
uint32_t propagation_mask ,
grpc_completion_queue * cq ,
const char * method , const char * host ,
gpr_timespec deadline ) {
GPR_EXPORT grpc_call * GPR_CALLTYPE grpcsharp_channel_create_call (
grpc_channel * channel , grpc_call * parent_call , uint32_t propagation_mask ,
grpc_completion_queue * cq , const char * method , const char * host ,
gpr_timespec deadline ) {
grpc_slice method_slice = grpc_slice_from_copied_string ( method ) ;
grpc_slice * host_slice_ptr = NULL ;
grpc_slice host_slice ;
@ -415,18 +418,21 @@ grpcsharp_channel_create_call(grpc_channel *channel, grpc_call *parent_call,
}
GPR_EXPORT grpc_connectivity_state GPR_CALLTYPE
grpcsharp_channel_check_connectivity_state ( grpc_channel * channel , int32_t try_to_connect ) {
grpcsharp_channel_check_connectivity_state ( grpc_channel * channel ,
int32_t try_to_connect ) {
return grpc_channel_check_connectivity_state ( channel , try_to_connect ) ;
}
GPR_EXPORT void GPR_CALLTYPE grpcsharp_channel_watch_connectivity_state (
grpc_channel * channel , grpc_connectivity_state last_observed_state ,
gpr_timespec deadline , grpc_completion_queue * cq , grpcsharp_batch_context * ctx ) {
grpc_channel_watch_connectivity_state ( channel , last_observed_state ,
deadline , cq , ctx ) ;
gpr_timespec deadline , grpc_completion_queue * cq ,
grpcsharp_batch_context * ctx ) {
grpc_channel_watch_connectivity_state ( channel , last_observed_state , deadline ,
cq , ctx ) ;
}
GPR_EXPORT char * GPR_CALLTYPE grpcsharp_channel_get_target ( grpc_channel * channel ) {
GPR_EXPORT char * GPR_CALLTYPE
grpcsharp_channel_get_target ( grpc_channel * channel ) {
return grpc_channel_get_target ( channel ) ;
}
@ -444,9 +450,8 @@ grpcsharp_channel_args_create(size_t num_args) {
return args ;
}
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_channel_args_set_string ( grpc_channel_args * args , size_t index ,
const char * key , const char * value ) {
GPR_EXPORT void GPR_CALLTYPE grpcsharp_channel_args_set_string (
grpc_channel_args * args , size_t index , const char * key , const char * value ) {
GPR_ASSERT ( args ) ;
GPR_ASSERT ( index < args - > num_args ) ;
args - > args [ index ] . type = GRPC_ARG_STRING ;
@ -454,9 +459,8 @@ grpcsharp_channel_args_set_string(grpc_channel_args *args, size_t index,
args - > args [ index ] . value . string = gpr_strdup ( value ) ;
}
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_channel_args_set_integer ( grpc_channel_args * args , size_t index ,
const char * key , int value ) {
GPR_EXPORT void GPR_CALLTYPE grpcsharp_channel_args_set_integer (
grpc_channel_args * args , size_t index , const char * key , int value ) {
GPR_ASSERT ( args ) ;
GPR_ASSERT ( index < args - > num_args ) ;
args - > args [ index ] . type = GRPC_ARG_INTEGER ;
@ -485,15 +489,18 @@ GPR_EXPORT gpr_timespec GPR_CALLTYPE gprsharp_now(gpr_clock_type clock_type) {
return gpr_now ( clock_type ) ;
}
GPR_EXPORT gpr_timespec GPR_CALLTYPE gprsharp_inf_future ( gpr_clock_type clock_type ) {
GPR_EXPORT gpr_timespec GPR_CALLTYPE
gprsharp_inf_future ( gpr_clock_type clock_type ) {
return gpr_inf_future ( clock_type ) ;
}
GPR_EXPORT gpr_timespec GPR_CALLTYPE gprsharp_inf_past ( gpr_clock_type clock_type ) {
GPR_EXPORT gpr_timespec GPR_CALLTYPE
gprsharp_inf_past ( gpr_clock_type clock_type ) {
return gpr_inf_past ( clock_type ) ;
}
GPR_EXPORT gpr_timespec GPR_CALLTYPE gprsharp_convert_clock_type ( gpr_timespec t , gpr_clock_type target_clock ) {
GPR_EXPORT gpr_timespec GPR_CALLTYPE
gprsharp_convert_clock_type ( gpr_timespec t , gpr_clock_type target_clock ) {
return gpr_convert_clock_type ( t , target_clock ) ;
}
@ -507,9 +514,8 @@ GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_cancel(grpc_call *call) {
return grpc_call_cancel ( call , NULL ) ;
}
GPR_EXPORT grpc_call_error GPR_CALLTYPE
grpcsharp_call_cancel_with_status ( grpc_call * call , grpc_status_code status ,
const char * description ) {
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_cancel_with_status (
grpc_call * call , grpc_status_code status , const char * description ) {
return grpc_call_cancel_with_status ( call , status , description , NULL ) ;
}
@ -517,18 +523,16 @@ GPR_EXPORT char *GPR_CALLTYPE grpcsharp_call_get_peer(grpc_call *call) {
return grpc_call_get_peer ( call ) ;
}
GPR_EXPORT void GPR_CALLTYPE gprsharp_free ( void * p ) {
gpr_free ( p ) ;
}
GPR_EXPORT void GPR_CALLTYPE gprsharp_free ( void * p ) { gpr_free ( p ) ; }
GPR_EXPORT void GPR_CALLTYPE grpcsharp_call_destroy ( grpc_call * call ) {
grpc_call_destroy ( call ) ;
grpc_call_unref ( call ) ;
}
GPR_EXPORT grpc_call_error GPR_CALLTYPE
grpcsharp_call_start_unary ( grpc_call * call , grpcsharp_batch_context * ctx ,
const char * send_buffer , size_t send_buffer_len , uint32_t write_flags ,
grpc_metadata_array * initial_metadata , uint32_t initial_metadata_flags ) {
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_start_unary (
grpc_call * call , grpcsharp_batch_context * ctx , const char * send_buffer ,
size_t send_buffer_len , uint32_t write_flags ,
grpc_metadata_array * initial_metadata , uint32_t initial_metadata_flags ) {
/* TODO: don't use magic number */
grpc_op ops [ 6 ] ;
memset ( ops , 0 , sizeof ( ops ) ) ;
@ -576,11 +580,9 @@ grpcsharp_call_start_unary(grpc_call *call, grpcsharp_batch_context *ctx,
NULL ) ;
}
GPR_EXPORT grpc_call_error GPR_CALLTYPE
grpcsharp_call_start_client_streaming ( grpc_call * call ,
grpcsharp_batch_context * ctx ,
grpc_metadata_array * initial_metadata ,
uint32_t initial_metadata_flags ) {
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_start_client_streaming (
grpc_call * call , grpcsharp_batch_context * ctx ,
grpc_metadata_array * initial_metadata , uint32_t initial_metadata_flags ) {
/* TODO: don't use magic number */
grpc_op ops [ 4 ] ;
memset ( ops , 0 , sizeof ( ops ) ) ;
@ -658,11 +660,9 @@ GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_start_server_streaming(
NULL ) ;
}
GPR_EXPORT grpc_call_error GPR_CALLTYPE
grpcsharp_call_start_duplex_streaming ( grpc_call * call ,
grpcsharp_batch_context * ctx ,
grpc_metadata_array * initial_metadata ,
uint32_t initial_metadata_flags ) {
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_start_duplex_streaming (
grpc_call * call , grpcsharp_batch_context * ctx ,
grpc_metadata_array * initial_metadata , uint32_t initial_metadata_flags ) {
/* TODO: don't use magic number */
grpc_op ops [ 2 ] ;
memset ( ops , 0 , sizeof ( ops ) ) ;
@ -690,7 +690,7 @@ grpcsharp_call_start_duplex_streaming(grpc_call *call,
}
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_recv_initial_metadata (
grpc_call * call , grpcsharp_batch_context * ctx ) {
grpc_call * call , grpcsharp_batch_context * ctx ) {
/* TODO: don't use magic number */
grpc_op ops [ 1 ] ;
ops [ 0 ] . op = GRPC_OP_RECV_INITIAL_METADATA ;
@ -700,14 +700,13 @@ GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_recv_initial_metadata(
ops [ 0 ] . reserved = NULL ;
return grpc_call_start_batch ( call , ops , sizeof ( ops ) / sizeof ( ops [ 0 ] ) , ctx ,
NULL ) ;
NULL ) ;
}
GPR_EXPORT grpc_call_error GPR_CALLTYPE
grpcsharp_call_send_message ( grpc_call * call , grpcsharp_batch_context * ctx ,
const char * send_buffer , size_t send_buffer_len ,
uint32_t write_flags ,
int32_t send_empty_initial_metadata ) {
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_send_message (
grpc_call * call , grpcsharp_batch_context * ctx , const char * send_buffer ,
size_t send_buffer_len , uint32_t write_flags ,
int32_t send_empty_initial_metadata ) {
/* TODO: don't use magic number */
grpc_op ops [ 2 ] ;
memset ( ops , 0 , sizeof ( ops ) ) ;
@ -724,9 +723,8 @@ grpcsharp_call_send_message(grpc_call *call, grpcsharp_batch_context *ctx,
return grpc_call_start_batch ( call , ops , nops , ctx , NULL ) ;
}
GPR_EXPORT grpc_call_error GPR_CALLTYPE
grpcsharp_call_send_close_from_client ( grpc_call * call ,
grpcsharp_batch_context * ctx ) {
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_send_close_from_client (
grpc_call * call , grpcsharp_batch_context * ctx ) {
/* TODO: don't use magic number */
grpc_op ops [ 1 ] ;
ops [ 0 ] . op = GRPC_OP_SEND_CLOSE_FROM_CLIENT ;
@ -740,14 +738,15 @@ grpcsharp_call_send_close_from_client(grpc_call *call,
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_send_status_from_server (
grpc_call * call , grpcsharp_batch_context * ctx , grpc_status_code status_code ,
const char * status_details , size_t status_details_len ,
grpc_metadata_array * trailing_metadata ,
int32_t send_empty_initial_metadata , const char * optional_send_buffer ,
size_t optional_send_buffer_len , uint32_t write_flags ) {
grpc_metadata_array * trailing_metadata , int32_t send_empty_initial_metadata ,
const char * optional_send_buffer , size_t optional_send_buffer_len ,
uint32_t write_flags ) {
/* TODO: don't use magic number */
grpc_op ops [ 3 ] ;
memset ( ops , 0 , sizeof ( ops ) ) ;
size_t nops = 1 ;
grpc_slice status_details_slice = grpc_slice_from_copied_buffer ( status_details , status_details_len ) ;
grpc_slice status_details_slice =
grpc_slice_from_copied_buffer ( status_details , status_details_len ) ;
ops [ 0 ] . op = GRPC_OP_SEND_STATUS_FROM_SERVER ;
ops [ 0 ] . data . send_status_from_server . status = status_code ;
ops [ 0 ] . data . send_status_from_server . status_details = & status_details_slice ;
@ -761,8 +760,8 @@ GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_send_status_from_server(
ops [ 0 ] . reserved = NULL ;
if ( optional_send_buffer ) {
ops [ nops ] . op = GRPC_OP_SEND_MESSAGE ;
ctx - > send_message = string_to_byte_buffer ( optional_send_buffer ,
optional_send_buffer_len ) ;
ctx - > send_message =
string_to_byte_buffer ( optional_send_buffer , optional_send_buffer_len ) ;
ops [ nops ] . data . send_message . send_message = ctx - > send_message ;
ops [ nops ] . flags = write_flags ;
ops [ nops ] . reserved = NULL ;
@ -803,10 +802,9 @@ grpcsharp_call_start_serverside(grpc_call *call, grpcsharp_batch_context *ctx) {
NULL ) ;
}
GPR_EXPORT grpc_call_error GPR_CALLTYPE
grpcsharp_call_send_initial_metadata ( grpc_call * call ,
grpcsharp_batch_context * ctx ,
grpc_metadata_array * initial_metadata ) {
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_send_initial_metadata (
grpc_call * call , grpcsharp_batch_context * ctx ,
grpc_metadata_array * initial_metadata ) {
/* TODO: don't use magic number */
grpc_op ops [ 1 ] ;
memset ( ops , 0 , sizeof ( ops ) ) ;
@ -823,9 +821,8 @@ grpcsharp_call_send_initial_metadata(grpc_call *call,
NULL ) ;
}
GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_set_credentials (
grpc_call * call ,
grpc_call_credentials * creds ) {
GPR_EXPORT grpc_call_error GPR_CALLTYPE
grpcsharp_call_set_credentials ( grpc_call * call , grpc_call_credentials * creds ) {
return grpc_call_set_credentials ( call , creds ) ;
}
@ -836,14 +833,13 @@ grpcsharp_server_create(const grpc_channel_args *args) {
return grpc_server_create ( args , NULL ) ;
}
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_server_register_completion_queue ( grpc_server * server ,
grpc_completion_queue * cq ) {
GPR_EXPORT void GPR_CALLTYPE grpcsharp_server_register_completion_queue (
grpc_server * server , grpc_completion_queue * cq ) {
grpc_server_register_completion_queue ( server , cq , NULL ) ;
}
GPR_EXPORT int32_t GPR_CALLTYPE
grpcsharp_server_add_insecure_http2_port ( grpc_server * server , const char * addr ) {
GPR_EXPORT int32_t GPR_CALLTYPE grpcsharp_server_add_insecure_http2_port (
grpc_server * server , const char * addr ) {
return grpc_server_add_insecure_http2_port ( server , addr ) ;
}
@ -851,14 +847,14 @@ GPR_EXPORT void GPR_CALLTYPE grpcsharp_server_start(grpc_server *server) {
grpc_server_start ( server ) ;
}
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_server_shutdown_and_notify_callback ( grpc_server * server ,
grpc_completion_queue * cq ,
grpcsharp_batch_context * ctx ) {
GPR_EXPORT void GPR_CALLTYPE grpcsharp_server_shutdown_and_notify_callback (
grpc_server * server , grpc_completion_queue * cq ,
grpcsharp_batch_context * ctx ) {
grpc_server_shutdown_and_notify ( server , cq , ctx ) ;
}
GPR_EXPORT void GPR_CALLTYPE grpcsharp_server_cancel_all_calls ( grpc_server * server ) {
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_server_cancel_all_calls ( grpc_server * server ) {
grpc_server_cancel_all_calls ( server ) ;
}
@ -869,9 +865,8 @@ GPR_EXPORT void GPR_CALLTYPE grpcsharp_server_destroy(grpc_server *server) {
GPR_EXPORT grpc_call_error GPR_CALLTYPE
grpcsharp_server_request_call ( grpc_server * server , grpc_completion_queue * cq ,
grpcsharp_request_call_context * ctx ) {
return grpc_server_request_call (
server , & ( ctx - > call ) , & ( ctx - > call_details ) ,
& ( ctx - > request_metadata ) , cq , cq , ctx ) ;
return grpc_server_request_call ( server , & ( ctx - > call ) , & ( ctx - > call_details ) ,
& ( ctx - > request_metadata ) , cq , cq , ctx ) ;
}
/* Security */
@ -888,8 +883,8 @@ static grpc_ssl_roots_override_result override_ssl_roots_handler(
return GRPC_SSL_ROOTS_OVERRIDE_OK ;
}
GPR_EXPORT void GPR_CALLTYPE grpcsharp_override_default_ssl_roots (
const char * pem_root_certs ) {
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_override_default_ssl_roots ( const char * pem_root_certs ) {
/*
* This currently wastes ~ 300 kB of memory by keeping a copy of roots
* in a static variable , but for desktop / server use , the overhead
@ -916,20 +911,19 @@ grpcsharp_ssl_credentials_create(const char *pem_root_certs,
}
}
GPR_EXPORT void GPR_CALLTYPE grpcsharp_channel_credentials_release (
grpc_channel_credentials * creds ) {
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_channel_credentials_release ( grpc_channel_credentials * creds ) {
grpc_channel_credentials_release ( creds ) ;
}
GPR_EXPORT void GPR_CALLTYPE grpcsharp_call_credentials_release (
grpc_call_credentials * creds ) {
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_call_credentials_release ( grpc_call_credentials * creds ) {
grpc_call_credentials_release ( creds ) ;
}
GPR_EXPORT grpc_channel * GPR_CALLTYPE
grpcsharp_secure_channel_create ( grpc_channel_credentials * creds ,
const char * target ,
const grpc_channel_args * args ) {
GPR_EXPORT grpc_channel * GPR_CALLTYPE grpcsharp_secure_channel_create (
grpc_channel_credentials * creds , const char * target ,
const grpc_channel_args * args ) {
return grpc_secure_channel_create ( creds , target , args , NULL ) ;
}
@ -962,36 +956,36 @@ grpcsharp_ssl_server_credentials_create(
return creds ;
}
GPR_EXPORT void GPR_CALLTYPE grpcsharp_server_credentials_release (
grpc_server_credentials * creds ) {
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_server_credentials_release ( grpc_server_credentials * creds ) {
grpc_server_credentials_release ( creds ) ;
}
GPR_EXPORT int32_t GPR_CALLTYPE
grpcsharp_server_add_secure_http2_port ( grpc_server * server , const char * addr ,
grpc_server_credentials * creds ) {
GPR_EXPORT int32_t GPR_CALLTYPE grpcsharp_server_add_secure_http2_port (
grpc_server * server , const char * addr , grpc_server_credentials * creds ) {
return grpc_server_add_secure_http2_port ( server , addr , creds ) ;
}
GPR_EXPORT grpc_channel_credentials * GPR_CALLTYPE grpcsharp_composite_channel_credentials_create (
grpc_channel_credentials * channel_creds ,
grpc_call_credentials * call_creds ) {
return grpc_composite_channel_credentials_create ( channel_creds , call_creds , NULL ) ;
GPR_EXPORT grpc_channel_credentials * GPR_CALLTYPE
grpcsharp_composite_channel_credentials_create (
grpc_channel_credentials * channel_creds ,
grpc_call_credentials * call_creds ) {
return grpc_composite_channel_credentials_create ( channel_creds , call_creds ,
NULL ) ;
}
GPR_EXPORT grpc_call_credentials * GPR_CALLTYPE grpcsharp_composite_call_credentials_create (
grpc_call_credentials * creds1 ,
grpc_call_credentials * creds2 ) {
GPR_EXPORT grpc_call_credentials * GPR_CALLTYPE
grpcsharp_composite_call_credentials_create ( grpc_call_credentials * creds1 ,
grpc_call_credentials * creds2 ) {
return grpc_composite_call_credentials_create ( creds1 , creds2 , NULL ) ;
}
/* Metadata credentials plugin */
GPR_EXPORT void GPR_CALLTYPE grpcsharp_metadata_credentials_notify_from_plugin (
grpc_credentials_plugin_metadata_cb cb ,
void * user_data , grpc_metadata_array * metadata ,
grpc_status_code status , const char * error_details ) {
grpc_credentials_plugin_metadata_cb cb , void * user_data ,
grpc_metadata_array * metadata , grpc_status_code status ,
const char * error_details ) {
if ( metadata ) {
cb ( user_data , metadata - > metadata , metadata - > count , status , error_details ) ;
} else {
@ -1000,16 +994,17 @@ GPR_EXPORT void GPR_CALLTYPE grpcsharp_metadata_credentials_notify_from_plugin(
}
typedef void ( GPR_CALLTYPE * grpcsharp_metadata_interceptor_func ) (
void * state , const char * service_url , const char * method_name ,
grpc_credentials_plugin_metadata_cb cb ,
void * user_data , int32_t is_destroy ) ;
void * state , const char * service_url , const char * method_name ,
grpc_credentials_plugin_metadata_cb cb , void * user_data ,
int32_t is_destroy ) ;
static void grpcsharp_get_metadata_handler (
void * state , grpc_auth_metadata_context context ,
grpc_credentials_plugin_metadata_cb cb , void * user_data ) {
grpcsharp_metadata_interceptor_func interceptor =
( grpcsharp_metadata_interceptor_func ) ( intptr_t ) state ;
interceptor ( state , context . service_url , context . method_name , cb , user_data , 0 ) ;
interceptor ( state , context . service_url , context . method_name , cb , user_data ,
0 ) ;
}
static void grpcsharp_metadata_credentials_destroy_handler ( void * state ) {
@ -1018,23 +1013,26 @@ static void grpcsharp_metadata_credentials_destroy_handler(void *state) {
interceptor ( state , NULL , NULL , NULL , NULL , 1 ) ;
}
GPR_EXPORT grpc_call_credentials * GPR_CALLTYPE grpcsharp_metadata_credentials_create_from_plugin (
grpcsharp_metadata_interceptor_func metadata_interceptor ) {
GPR_EXPORT grpc_call_credentials * GPR_CALLTYPE
grpcsharp_metadata_credentials_create_from_plugin (
grpcsharp_metadata_interceptor_func metadata_interceptor ) {
grpc_metadata_credentials_plugin plugin ;
plugin . get_metadata = grpcsharp_get_metadata_handler ;
plugin . destroy = grpcsharp_metadata_credentials_destroy_handler ;
plugin . state = ( void * ) ( intptr_t ) metadata_interceptor ;
plugin . state = ( void * ) ( intptr_t ) metadata_interceptor ;
plugin . type = " " ;
return grpc_metadata_credentials_create_from_plugin ( plugin , NULL ) ;
}
/* Auth context */
GPR_EXPORT grpc_auth_context * GPR_CALLTYPE grpcsharp_call_auth_context ( grpc_call * call ) {
GPR_EXPORT grpc_auth_context * GPR_CALLTYPE
grpcsharp_call_auth_context ( grpc_call * call ) {
return grpc_call_auth_context ( call ) ;
}
GPR_EXPORT const char * GPR_CALLTYPE grpcsharp_auth_context_peer_identity_property_name (
GPR_EXPORT const char * GPR_CALLTYPE
grpcsharp_auth_context_peer_identity_property_name (
const grpc_auth_context * ctx ) {
return grpc_auth_context_peer_identity_property_name ( ctx ) ;
}
@ -1044,12 +1042,13 @@ grpcsharp_auth_context_property_iterator(const grpc_auth_context *ctx) {
return grpc_auth_context_property_iterator ( ctx ) ;
}
GPR_EXPORT const grpc_auth_property * GPR_CALLTYPE grpcsharp_auth_property_iterator_next (
grpc_auth_property_iterator * it ) {
GPR_EXPORT const grpc_auth_property * GPR_CALLTYPE
grpcsharp_auth_property_iterator_next ( grpc_auth_property_iterator * it ) {
return grpc_auth_property_iterator_next ( it ) ;
}
GPR_EXPORT void GPR_CALLTYPE grpcsharp_auth_context_release ( grpc_auth_context * ctx ) {
GPR_EXPORT void GPR_CALLTYPE
grpcsharp_auth_context_release ( grpc_auth_context * ctx ) {
grpc_auth_context_release ( ctx ) ;
}
ncteisen
8 years ago