Lines Matching refs:ops
566 const grpc_op* ops,
573 const grpc_op* ops, in grpcsharp_call_start_batch_nop() argument
577 (void)ops; in grpcsharp_call_start_batch_nop()
585 const grpc_op* ops, in grpcsharp_call_start_batch_default() argument
589 return grpc_call_start_batch(call, ops, nops, tag, reserved); in grpcsharp_call_start_batch_default()
596 const grpc_op* ops, in grpcsharp_call_start_batch() argument
599 return g_call_start_batch_func(call, ops, nops, tag, reserved); in grpcsharp_call_start_batch()
607 grpc_op ops[6]; in grpcsharp_call_start_unary() local
608 memset(ops, 0, sizeof(ops)); in grpcsharp_call_start_unary()
609 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_start_unary()
612 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_unary()
613 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_unary()
615 ops[0].flags = initial_metadata_flags; in grpcsharp_call_start_unary()
616 ops[0].reserved = NULL; in grpcsharp_call_start_unary()
618 ops[1].op = GRPC_OP_SEND_MESSAGE; in grpcsharp_call_start_unary()
621 ops[1].data.send_message.send_message = ctx->send_message; in grpcsharp_call_start_unary()
622 ops[1].flags = write_flags; in grpcsharp_call_start_unary()
623 ops[1].reserved = NULL; in grpcsharp_call_start_unary()
625 ops[2].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcsharp_call_start_unary()
626 ops[2].flags = 0; in grpcsharp_call_start_unary()
627 ops[2].reserved = NULL; in grpcsharp_call_start_unary()
629 ops[3].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcsharp_call_start_unary()
630 ops[3].data.recv_initial_metadata.recv_initial_metadata = in grpcsharp_call_start_unary()
632 ops[3].flags = 0; in grpcsharp_call_start_unary()
633 ops[3].reserved = NULL; in grpcsharp_call_start_unary()
635 ops[4].op = GRPC_OP_RECV_MESSAGE; in grpcsharp_call_start_unary()
636 ops[4].data.recv_message.recv_message = &(ctx->recv_message); in grpcsharp_call_start_unary()
637 ops[4].flags = 0; in grpcsharp_call_start_unary()
638 ops[4].reserved = NULL; in grpcsharp_call_start_unary()
640 ops[5].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcsharp_call_start_unary()
641 ops[5].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_unary()
643 ops[5].data.recv_status_on_client.status = in grpcsharp_call_start_unary()
645 ops[5].data.recv_status_on_client.status_details = in grpcsharp_call_start_unary()
647 ops[5].data.recv_status_on_client.error_string = in grpcsharp_call_start_unary()
649 ops[5].flags = 0; in grpcsharp_call_start_unary()
650 ops[5].reserved = NULL; in grpcsharp_call_start_unary()
652 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_unary()
684 grpc_op ops[4]; in grpcsharp_call_start_client_streaming() local
685 memset(ops, 0, sizeof(ops)); in grpcsharp_call_start_client_streaming()
686 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_start_client_streaming()
689 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_client_streaming()
690 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_client_streaming()
692 ops[0].flags = initial_metadata_flags; in grpcsharp_call_start_client_streaming()
693 ops[0].reserved = NULL; in grpcsharp_call_start_client_streaming()
695 ops[1].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcsharp_call_start_client_streaming()
696 ops[1].data.recv_initial_metadata.recv_initial_metadata = in grpcsharp_call_start_client_streaming()
698 ops[1].flags = 0; in grpcsharp_call_start_client_streaming()
699 ops[1].reserved = NULL; in grpcsharp_call_start_client_streaming()
701 ops[2].op = GRPC_OP_RECV_MESSAGE; in grpcsharp_call_start_client_streaming()
702 ops[2].data.recv_message.recv_message = &(ctx->recv_message); in grpcsharp_call_start_client_streaming()
703 ops[2].flags = 0; in grpcsharp_call_start_client_streaming()
704 ops[2].reserved = NULL; in grpcsharp_call_start_client_streaming()
706 ops[3].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcsharp_call_start_client_streaming()
707 ops[3].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_client_streaming()
709 ops[3].data.recv_status_on_client.status = in grpcsharp_call_start_client_streaming()
711 ops[3].data.recv_status_on_client.status_details = in grpcsharp_call_start_client_streaming()
713 ops[3].data.recv_status_on_client.error_string = in grpcsharp_call_start_client_streaming()
715 ops[3].flags = 0; in grpcsharp_call_start_client_streaming()
716 ops[3].reserved = NULL; in grpcsharp_call_start_client_streaming()
718 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_client_streaming()
727 grpc_op ops[4]; in grpcsharp_call_start_server_streaming() local
728 memset(ops, 0, sizeof(ops)); in grpcsharp_call_start_server_streaming()
729 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_start_server_streaming()
732 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_server_streaming()
733 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_server_streaming()
735 ops[0].flags = initial_metadata_flags; in grpcsharp_call_start_server_streaming()
736 ops[0].reserved = NULL; in grpcsharp_call_start_server_streaming()
738 ops[1].op = GRPC_OP_SEND_MESSAGE; in grpcsharp_call_start_server_streaming()
741 ops[1].data.send_message.send_message = ctx->send_message; in grpcsharp_call_start_server_streaming()
742 ops[1].flags = write_flags; in grpcsharp_call_start_server_streaming()
743 ops[1].reserved = NULL; in grpcsharp_call_start_server_streaming()
745 ops[2].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcsharp_call_start_server_streaming()
746 ops[2].flags = 0; in grpcsharp_call_start_server_streaming()
747 ops[2].reserved = NULL; in grpcsharp_call_start_server_streaming()
749 ops[3].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcsharp_call_start_server_streaming()
750 ops[3].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_server_streaming()
752 ops[3].data.recv_status_on_client.status = in grpcsharp_call_start_server_streaming()
754 ops[3].data.recv_status_on_client.status_details = in grpcsharp_call_start_server_streaming()
756 ops[3].data.recv_status_on_client.error_string = in grpcsharp_call_start_server_streaming()
758 ops[3].flags = 0; in grpcsharp_call_start_server_streaming()
759 ops[3].reserved = NULL; in grpcsharp_call_start_server_streaming()
761 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_server_streaming()
769 grpc_op ops[2]; in grpcsharp_call_start_duplex_streaming() local
770 memset(ops, 0, sizeof(ops)); in grpcsharp_call_start_duplex_streaming()
771 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_start_duplex_streaming()
774 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_duplex_streaming()
775 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_duplex_streaming()
777 ops[0].flags = initial_metadata_flags; in grpcsharp_call_start_duplex_streaming()
778 ops[0].reserved = NULL; in grpcsharp_call_start_duplex_streaming()
780 ops[1].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcsharp_call_start_duplex_streaming()
781 ops[1].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_duplex_streaming()
783 ops[1].data.recv_status_on_client.status = in grpcsharp_call_start_duplex_streaming()
785 ops[1].data.recv_status_on_client.status_details = in grpcsharp_call_start_duplex_streaming()
787 ops[1].data.recv_status_on_client.error_string = in grpcsharp_call_start_duplex_streaming()
789 ops[1].flags = 0; in grpcsharp_call_start_duplex_streaming()
790 ops[1].reserved = NULL; in grpcsharp_call_start_duplex_streaming()
792 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_duplex_streaming()
799 grpc_op ops[1]; in grpcsharp_call_recv_initial_metadata() local
800 ops[0].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcsharp_call_recv_initial_metadata()
801 ops[0].data.recv_initial_metadata.recv_initial_metadata = in grpcsharp_call_recv_initial_metadata()
803 ops[0].flags = 0; in grpcsharp_call_recv_initial_metadata()
804 ops[0].reserved = NULL; in grpcsharp_call_recv_initial_metadata()
806 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_recv_initial_metadata()
815 grpc_op ops[2]; in grpcsharp_call_send_message() local
816 memset(ops, 0, sizeof(ops)); in grpcsharp_call_send_message()
818 ops[0].op = GRPC_OP_SEND_MESSAGE; in grpcsharp_call_send_message()
821 ops[0].data.send_message.send_message = ctx->send_message; in grpcsharp_call_send_message()
822 ops[0].flags = write_flags; in grpcsharp_call_send_message()
823 ops[0].reserved = NULL; in grpcsharp_call_send_message()
824 ops[1].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_send_message()
825 ops[1].flags = 0; in grpcsharp_call_send_message()
826 ops[1].reserved = NULL; in grpcsharp_call_send_message()
828 return grpcsharp_call_start_batch(call, ops, nops, ctx, NULL); in grpcsharp_call_send_message()
834 grpc_op ops[1]; in grpcsharp_call_send_close_from_client() local
835 ops[0].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcsharp_call_send_close_from_client()
836 ops[0].flags = 0; in grpcsharp_call_send_close_from_client()
837 ops[0].reserved = NULL; in grpcsharp_call_send_close_from_client()
839 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_send_close_from_client()
849 grpc_op ops[3]; in grpcsharp_call_send_status_from_server() local
850 memset(ops, 0, sizeof(ops)); in grpcsharp_call_send_status_from_server()
854 ops[0].op = GRPC_OP_SEND_STATUS_FROM_SERVER; in grpcsharp_call_send_status_from_server()
855 ops[0].data.send_status_from_server.status = status_code; in grpcsharp_call_send_status_from_server()
856 ops[0].data.send_status_from_server.status_details = &status_details_slice; in grpcsharp_call_send_status_from_server()
859 ops[0].data.send_status_from_server.trailing_metadata_count = in grpcsharp_call_send_status_from_server()
861 ops[0].data.send_status_from_server.trailing_metadata = in grpcsharp_call_send_status_from_server()
863 ops[0].flags = 0; in grpcsharp_call_send_status_from_server()
864 ops[0].reserved = NULL; in grpcsharp_call_send_status_from_server()
866 ops[nops].op = GRPC_OP_SEND_MESSAGE; in grpcsharp_call_send_status_from_server()
869 ops[nops].data.send_message.send_message = ctx->send_message; in grpcsharp_call_send_status_from_server()
870 ops[nops].flags = write_flags; in grpcsharp_call_send_status_from_server()
871 ops[nops].reserved = NULL; in grpcsharp_call_send_status_from_server()
875 ops[nops].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_send_status_from_server()
876 ops[nops].flags = 0; in grpcsharp_call_send_status_from_server()
877 ops[nops].reserved = NULL; in grpcsharp_call_send_status_from_server()
880 grpc_call_error ret = grpcsharp_call_start_batch(call, ops, nops, ctx, NULL); in grpcsharp_call_send_status_from_server()
888 grpc_op ops[1]; in grpcsharp_call_recv_message() local
889 ops[0].op = GRPC_OP_RECV_MESSAGE; in grpcsharp_call_recv_message()
890 ops[0].data.recv_message.recv_message = &(ctx->recv_message); in grpcsharp_call_recv_message()
891 ops[0].flags = 0; in grpcsharp_call_recv_message()
892 ops[0].reserved = NULL; in grpcsharp_call_recv_message()
893 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_recv_message()
900 grpc_op ops[1]; in grpcsharp_call_start_serverside() local
901 ops[0].op = GRPC_OP_RECV_CLOSE_ON_SERVER; in grpcsharp_call_start_serverside()
902 ops[0].data.recv_close_on_server.cancelled = in grpcsharp_call_start_serverside()
904 ops[0].flags = 0; in grpcsharp_call_start_serverside()
905 ops[0].reserved = NULL; in grpcsharp_call_start_serverside()
907 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_serverside()
915 grpc_op ops[1]; in grpcsharp_call_send_initial_metadata() local
916 memset(ops, 0, sizeof(ops)); in grpcsharp_call_send_initial_metadata()
917 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_send_initial_metadata()
920 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_send_initial_metadata()
921 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_send_initial_metadata()
923 ops[0].flags = 0; in grpcsharp_call_send_initial_metadata()
924 ops[0].reserved = NULL; in grpcsharp_call_send_initial_metadata()
926 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_send_initial_metadata()