Lines Matching full:ops
531 const grpc_op* ops,
538 const grpc_op* ops, in grpcsharp_call_start_batch_nop() argument
545 const grpc_op* ops, in grpcsharp_call_start_batch_default() argument
549 return grpc_call_start_batch(call, ops, nops, tag, reserved); in grpcsharp_call_start_batch_default()
556 const grpc_op* ops, in grpcsharp_call_start_batch() argument
559 return g_call_start_batch_func(call, ops, nops, tag, reserved); in grpcsharp_call_start_batch()
567 grpc_op ops[6]; in grpcsharp_call_start_unary() local
568 memset(ops, 0, sizeof(ops)); in grpcsharp_call_start_unary()
569 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_start_unary()
572 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_unary()
573 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_unary()
575 ops[0].flags = initial_metadata_flags; in grpcsharp_call_start_unary()
576 ops[0].reserved = NULL; in grpcsharp_call_start_unary()
578 ops[1].op = GRPC_OP_SEND_MESSAGE; in grpcsharp_call_start_unary()
580 ops[1].data.send_message.send_message = ctx->send_message; in grpcsharp_call_start_unary()
581 ops[1].flags = write_flags; in grpcsharp_call_start_unary()
582 ops[1].reserved = NULL; in grpcsharp_call_start_unary()
584 ops[2].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcsharp_call_start_unary()
585 ops[2].flags = 0; in grpcsharp_call_start_unary()
586 ops[2].reserved = NULL; in grpcsharp_call_start_unary()
588 ops[3].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcsharp_call_start_unary()
589 ops[3].data.recv_initial_metadata.recv_initial_metadata = in grpcsharp_call_start_unary()
591 ops[3].flags = 0; in grpcsharp_call_start_unary()
592 ops[3].reserved = NULL; in grpcsharp_call_start_unary()
594 ops[4].op = GRPC_OP_RECV_MESSAGE; in grpcsharp_call_start_unary()
595 ops[4].data.recv_message.recv_message = &(ctx->recv_message); in grpcsharp_call_start_unary()
596 ops[4].flags = 0; in grpcsharp_call_start_unary()
597 ops[4].reserved = NULL; in grpcsharp_call_start_unary()
599 ops[5].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcsharp_call_start_unary()
600 ops[5].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_unary()
602 ops[5].data.recv_status_on_client.status = in grpcsharp_call_start_unary()
604 ops[5].data.recv_status_on_client.status_details = in grpcsharp_call_start_unary()
606 ops[5].flags = 0; in grpcsharp_call_start_unary()
607 ops[5].reserved = NULL; in grpcsharp_call_start_unary()
609 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_unary()
617 grpc_op ops[4]; in grpcsharp_call_start_client_streaming() local
618 memset(ops, 0, sizeof(ops)); in grpcsharp_call_start_client_streaming()
619 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_start_client_streaming()
622 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_client_streaming()
623 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_client_streaming()
625 ops[0].flags = initial_metadata_flags; in grpcsharp_call_start_client_streaming()
626 ops[0].reserved = NULL; in grpcsharp_call_start_client_streaming()
628 ops[1].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcsharp_call_start_client_streaming()
629 ops[1].data.recv_initial_metadata.recv_initial_metadata = in grpcsharp_call_start_client_streaming()
631 ops[1].flags = 0; in grpcsharp_call_start_client_streaming()
632 ops[1].reserved = NULL; in grpcsharp_call_start_client_streaming()
634 ops[2].op = GRPC_OP_RECV_MESSAGE; in grpcsharp_call_start_client_streaming()
635 ops[2].data.recv_message.recv_message = &(ctx->recv_message); in grpcsharp_call_start_client_streaming()
636 ops[2].flags = 0; in grpcsharp_call_start_client_streaming()
637 ops[2].reserved = NULL; in grpcsharp_call_start_client_streaming()
639 ops[3].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcsharp_call_start_client_streaming()
640 ops[3].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_client_streaming()
642 ops[3].data.recv_status_on_client.status = in grpcsharp_call_start_client_streaming()
644 ops[3].data.recv_status_on_client.status_details = in grpcsharp_call_start_client_streaming()
646 ops[3].flags = 0; in grpcsharp_call_start_client_streaming()
647 ops[3].reserved = NULL; in grpcsharp_call_start_client_streaming()
649 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_client_streaming()
658 grpc_op ops[4]; in grpcsharp_call_start_server_streaming() local
659 memset(ops, 0, sizeof(ops)); in grpcsharp_call_start_server_streaming()
660 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_start_server_streaming()
663 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_server_streaming()
664 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_server_streaming()
666 ops[0].flags = initial_metadata_flags; in grpcsharp_call_start_server_streaming()
667 ops[0].reserved = NULL; in grpcsharp_call_start_server_streaming()
669 ops[1].op = GRPC_OP_SEND_MESSAGE; in grpcsharp_call_start_server_streaming()
671 ops[1].data.send_message.send_message = ctx->send_message; in grpcsharp_call_start_server_streaming()
672 ops[1].flags = write_flags; in grpcsharp_call_start_server_streaming()
673 ops[1].reserved = NULL; in grpcsharp_call_start_server_streaming()
675 ops[2].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcsharp_call_start_server_streaming()
676 ops[2].flags = 0; in grpcsharp_call_start_server_streaming()
677 ops[2].reserved = NULL; in grpcsharp_call_start_server_streaming()
679 ops[3].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcsharp_call_start_server_streaming()
680 ops[3].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_server_streaming()
682 ops[3].data.recv_status_on_client.status = in grpcsharp_call_start_server_streaming()
684 ops[3].data.recv_status_on_client.status_details = in grpcsharp_call_start_server_streaming()
686 ops[3].flags = 0; in grpcsharp_call_start_server_streaming()
687 ops[3].reserved = NULL; in grpcsharp_call_start_server_streaming()
689 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_server_streaming()
697 grpc_op ops[2]; in grpcsharp_call_start_duplex_streaming() local
698 memset(ops, 0, sizeof(ops)); in grpcsharp_call_start_duplex_streaming()
699 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_start_duplex_streaming()
702 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_duplex_streaming()
703 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_duplex_streaming()
705 ops[0].flags = initial_metadata_flags; in grpcsharp_call_start_duplex_streaming()
706 ops[0].reserved = NULL; in grpcsharp_call_start_duplex_streaming()
708 ops[1].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcsharp_call_start_duplex_streaming()
709 ops[1].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_duplex_streaming()
711 ops[1].data.recv_status_on_client.status = in grpcsharp_call_start_duplex_streaming()
713 ops[1].data.recv_status_on_client.status_details = in grpcsharp_call_start_duplex_streaming()
715 ops[1].flags = 0; in grpcsharp_call_start_duplex_streaming()
716 ops[1].reserved = NULL; in grpcsharp_call_start_duplex_streaming()
718 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_duplex_streaming()
725 grpc_op ops[1]; in grpcsharp_call_recv_initial_metadata() local
726 ops[0].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcsharp_call_recv_initial_metadata()
727 ops[0].data.recv_initial_metadata.recv_initial_metadata = in grpcsharp_call_recv_initial_metadata()
729 ops[0].flags = 0; in grpcsharp_call_recv_initial_metadata()
730 ops[0].reserved = NULL; in grpcsharp_call_recv_initial_metadata()
732 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_recv_initial_metadata()
741 grpc_op ops[2]; in grpcsharp_call_send_message() local
742 memset(ops, 0, sizeof(ops)); in grpcsharp_call_send_message()
744 ops[0].op = GRPC_OP_SEND_MESSAGE; in grpcsharp_call_send_message()
746 ops[0].data.send_message.send_message = ctx->send_message; in grpcsharp_call_send_message()
747 ops[0].flags = write_flags; in grpcsharp_call_send_message()
748 ops[0].reserved = NULL; in grpcsharp_call_send_message()
749 ops[1].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_send_message()
750 ops[1].flags = 0; in grpcsharp_call_send_message()
751 ops[1].reserved = NULL; in grpcsharp_call_send_message()
753 return grpcsharp_call_start_batch(call, ops, nops, ctx, NULL); in grpcsharp_call_send_message()
759 grpc_op ops[1]; in grpcsharp_call_send_close_from_client() local
760 ops[0].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcsharp_call_send_close_from_client()
761 ops[0].flags = 0; in grpcsharp_call_send_close_from_client()
762 ops[0].reserved = NULL; in grpcsharp_call_send_close_from_client()
764 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_send_close_from_client()
775 grpc_op ops[3]; in grpcsharp_call_send_status_from_server() local
776 memset(ops, 0, sizeof(ops)); in grpcsharp_call_send_status_from_server()
780 ops[0].op = GRPC_OP_SEND_STATUS_FROM_SERVER; in grpcsharp_call_send_status_from_server()
781 ops[0].data.send_status_from_server.status = status_code; in grpcsharp_call_send_status_from_server()
782 ops[0].data.send_status_from_server.status_details = &status_details_slice; in grpcsharp_call_send_status_from_server()
785 ops[0].data.send_status_from_server.trailing_metadata_count = in grpcsharp_call_send_status_from_server()
787 ops[0].data.send_status_from_server.trailing_metadata = in grpcsharp_call_send_status_from_server()
789 ops[0].flags = 0; in grpcsharp_call_send_status_from_server()
790 ops[0].reserved = NULL; in grpcsharp_call_send_status_from_server()
792 ops[nops].op = GRPC_OP_SEND_MESSAGE; in grpcsharp_call_send_status_from_server()
795 ops[nops].data.send_message.send_message = ctx->send_message; in grpcsharp_call_send_status_from_server()
796 ops[nops].flags = write_flags; in grpcsharp_call_send_status_from_server()
797 ops[nops].reserved = NULL; in grpcsharp_call_send_status_from_server()
801 ops[nops].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_send_status_from_server()
802 ops[nops].flags = 0; in grpcsharp_call_send_status_from_server()
803 ops[nops].reserved = NULL; in grpcsharp_call_send_status_from_server()
806 grpc_call_error ret = grpcsharp_call_start_batch(call, ops, nops, ctx, NULL); in grpcsharp_call_send_status_from_server()
814 grpc_op ops[1]; in grpcsharp_call_recv_message() local
815 ops[0].op = GRPC_OP_RECV_MESSAGE; in grpcsharp_call_recv_message()
816 ops[0].data.recv_message.recv_message = &(ctx->recv_message); in grpcsharp_call_recv_message()
817 ops[0].flags = 0; in grpcsharp_call_recv_message()
818 ops[0].reserved = NULL; in grpcsharp_call_recv_message()
819 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_recv_message()
826 grpc_op ops[1]; in grpcsharp_call_start_serverside() local
827 ops[0].op = GRPC_OP_RECV_CLOSE_ON_SERVER; in grpcsharp_call_start_serverside()
828 ops[0].data.recv_close_on_server.cancelled = in grpcsharp_call_start_serverside()
830 ops[0].flags = 0; in grpcsharp_call_start_serverside()
831 ops[0].reserved = NULL; in grpcsharp_call_start_serverside()
833 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_start_serverside()
841 grpc_op ops[1]; in grpcsharp_call_send_initial_metadata() local
842 memset(ops, 0, sizeof(ops)); in grpcsharp_call_send_initial_metadata()
843 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcsharp_call_send_initial_metadata()
846 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_send_initial_metadata()
847 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_send_initial_metadata()
849 ops[0].flags = 0; in grpcsharp_call_send_initial_metadata()
850 ops[0].reserved = NULL; in grpcsharp_call_send_initial_metadata()
852 return grpcsharp_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), in grpcsharp_call_send_initial_metadata()