Lines Matching full:ops
491 grpc_op ops[6]; in grpcwrap_call_start_unary() local
492 memset(ops, 0, sizeof(ops)); in grpcwrap_call_start_unary()
493 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_start_unary()
495 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_unary()
496 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_unary()
498 ops[0].flags = initial_metadata_flags; in grpcwrap_call_start_unary()
499 ops[0].reserved = nullptr; in grpcwrap_call_start_unary()
501 ops[1].op = GRPC_OP_SEND_MESSAGE; in grpcwrap_call_start_unary()
503 ops[1].data.send_message.send_message = ctx->send_message; in grpcwrap_call_start_unary()
504 ops[1].flags = write_flags; in grpcwrap_call_start_unary()
505 ops[1].reserved = nullptr; in grpcwrap_call_start_unary()
507 ops[2].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcwrap_call_start_unary()
508 ops[2].flags = 0; in grpcwrap_call_start_unary()
509 ops[2].reserved = nullptr; in grpcwrap_call_start_unary()
511 ops[3].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcwrap_call_start_unary()
512 ops[3].data.recv_initial_metadata.recv_initial_metadata = in grpcwrap_call_start_unary()
514 ops[3].flags = 0; in grpcwrap_call_start_unary()
515 ops[3].reserved = nullptr; in grpcwrap_call_start_unary()
517 ops[4].op = GRPC_OP_RECV_MESSAGE; in grpcwrap_call_start_unary()
518 ops[4].data.recv_message.recv_message = &(ctx->recv_message); in grpcwrap_call_start_unary()
519 ops[4].flags = 0; in grpcwrap_call_start_unary()
520 ops[4].reserved = nullptr; in grpcwrap_call_start_unary()
522 ops[5].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcwrap_call_start_unary()
523 ops[5].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_unary()
525 ops[5].data.recv_status_on_client.status = in grpcwrap_call_start_unary()
527 ops[5].data.recv_status_on_client.status_details = in grpcwrap_call_start_unary()
529 ops[5].data.recv_status_on_client.error_string = in grpcwrap_call_start_unary()
531 ops[5].flags = 0; in grpcwrap_call_start_unary()
532 ops[5].reserved = nullptr; in grpcwrap_call_start_unary()
534 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_unary()
543 grpc_op ops[4]; in grpcwrap_call_start_client_streaming() local
544 memset(ops, 0, sizeof(ops)); in grpcwrap_call_start_client_streaming()
545 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_start_client_streaming()
547 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_client_streaming()
548 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_client_streaming()
550 ops[0].flags = initial_metadata_flags; in grpcwrap_call_start_client_streaming()
551 ops[0].reserved = nullptr; in grpcwrap_call_start_client_streaming()
553 ops[1].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcwrap_call_start_client_streaming()
554 ops[1].data.recv_initial_metadata.recv_initial_metadata = in grpcwrap_call_start_client_streaming()
556 ops[1].flags = 0; in grpcwrap_call_start_client_streaming()
557 ops[1].reserved = nullptr; in grpcwrap_call_start_client_streaming()
559 ops[2].op = GRPC_OP_RECV_MESSAGE; in grpcwrap_call_start_client_streaming()
560 ops[2].data.recv_message.recv_message = &(ctx->recv_message); in grpcwrap_call_start_client_streaming()
561 ops[2].flags = 0; in grpcwrap_call_start_client_streaming()
562 ops[2].reserved = nullptr; in grpcwrap_call_start_client_streaming()
564 ops[3].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcwrap_call_start_client_streaming()
565 ops[3].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_client_streaming()
567 ops[3].data.recv_status_on_client.status = in grpcwrap_call_start_client_streaming()
569 ops[3].data.recv_status_on_client.status_details = in grpcwrap_call_start_client_streaming()
571 ops[3].data.recv_status_on_client.error_string = in grpcwrap_call_start_client_streaming()
573 ops[3].flags = 0; in grpcwrap_call_start_client_streaming()
574 ops[3].reserved = nullptr; in grpcwrap_call_start_client_streaming()
576 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_client_streaming()
585 grpc_op ops[4]; in grpcwrap_call_start_server_streaming() local
586 memset(ops, 0, sizeof(ops)); in grpcwrap_call_start_server_streaming()
587 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_start_server_streaming()
589 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_server_streaming()
590 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_server_streaming()
592 ops[0].flags = initial_metadata_flags; in grpcwrap_call_start_server_streaming()
593 ops[0].reserved = nullptr; in grpcwrap_call_start_server_streaming()
595 ops[1].op = GRPC_OP_SEND_MESSAGE; in grpcwrap_call_start_server_streaming()
597 ops[1].data.send_message.send_message = ctx->send_message; in grpcwrap_call_start_server_streaming()
598 ops[1].flags = write_flags; in grpcwrap_call_start_server_streaming()
599 ops[1].reserved = nullptr; in grpcwrap_call_start_server_streaming()
601 ops[2].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcwrap_call_start_server_streaming()
602 ops[2].flags = 0; in grpcwrap_call_start_server_streaming()
603 ops[2].reserved = nullptr; in grpcwrap_call_start_server_streaming()
605 ops[3].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcwrap_call_start_server_streaming()
606 ops[3].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_server_streaming()
608 ops[3].data.recv_status_on_client.status = in grpcwrap_call_start_server_streaming()
610 ops[3].data.recv_status_on_client.status_details = in grpcwrap_call_start_server_streaming()
612 ops[3].data.recv_status_on_client.error_string = in grpcwrap_call_start_server_streaming()
614 ops[3].flags = 0; in grpcwrap_call_start_server_streaming()
615 ops[3].reserved = nullptr; in grpcwrap_call_start_server_streaming()
617 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_server_streaming()
626 grpc_op ops[2]; in grpcwrap_call_start_duplex_streaming() local
627 memset(ops, 0, sizeof(ops)); in grpcwrap_call_start_duplex_streaming()
628 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_start_duplex_streaming()
630 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_duplex_streaming()
631 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_duplex_streaming()
633 ops[0].flags = initial_metadata_flags; in grpcwrap_call_start_duplex_streaming()
634 ops[0].reserved = nullptr; in grpcwrap_call_start_duplex_streaming()
636 ops[1].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcwrap_call_start_duplex_streaming()
637 ops[1].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_duplex_streaming()
639 ops[1].data.recv_status_on_client.status = in grpcwrap_call_start_duplex_streaming()
641 ops[1].data.recv_status_on_client.status_details = in grpcwrap_call_start_duplex_streaming()
643 ops[1].data.recv_status_on_client.error_string = in grpcwrap_call_start_duplex_streaming()
645 ops[1].flags = 0; in grpcwrap_call_start_duplex_streaming()
646 ops[1].reserved = nullptr; in grpcwrap_call_start_duplex_streaming()
648 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_duplex_streaming()
655 grpc_op ops[1]; in grpcwrap_call_recv_initial_metadata() local
656 ops[0].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcwrap_call_recv_initial_metadata()
657 ops[0].data.recv_initial_metadata.recv_initial_metadata = in grpcwrap_call_recv_initial_metadata()
659 ops[0].flags = 0; in grpcwrap_call_recv_initial_metadata()
660 ops[0].reserved = nullptr; in grpcwrap_call_recv_initial_metadata()
662 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_recv_initial_metadata()
671 grpc_op ops[2]; in grpcwrap_call_send_message() local
672 memset(ops, 0, sizeof(ops)); in grpcwrap_call_send_message()
675 ops[0].op = GRPC_OP_SEND_MESSAGE; in grpcwrap_call_send_message()
677 ops[0].data.send_message.send_message = ctx->send_message; in grpcwrap_call_send_message()
678 ops[0].flags = write_flags; in grpcwrap_call_send_message()
679 ops[0].reserved = nullptr; in grpcwrap_call_send_message()
682 ops[nops].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_send_message()
685 ops[nops].data.send_initial_metadata.count = in grpcwrap_call_send_message()
687 ops[nops].data.send_initial_metadata.metadata = in grpcwrap_call_send_message()
689 ops[nops].flags = initial_metadata_flags; in grpcwrap_call_send_message()
690 ops[nops].reserved = nullptr; in grpcwrap_call_send_message()
693 return grpc_call_start_batch(call, ops, nops, tag, nullptr); in grpcwrap_call_send_message()
699 grpc_op ops[1]; in grpcwrap_call_send_close_from_client() local
700 ops[0].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcwrap_call_send_close_from_client()
701 ops[0].flags = 0; in grpcwrap_call_send_close_from_client()
702 ops[0].reserved = nullptr; in grpcwrap_call_send_close_from_client()
704 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_send_close_from_client()
715 grpc_op ops[3]; in grpcwrap_call_send_status_from_server() local
716 memset(ops, 0, sizeof(ops)); in grpcwrap_call_send_status_from_server()
722 ops[0].op = GRPC_OP_SEND_STATUS_FROM_SERVER; in grpcwrap_call_send_status_from_server()
723 ops[0].data.send_status_from_server.status = status_code; in grpcwrap_call_send_status_from_server()
724 ops[0].data.send_status_from_server.status_details = &status_details_slice; in grpcwrap_call_send_status_from_server()
727 ops[0].data.send_status_from_server.trailing_metadata_count = in grpcwrap_call_send_status_from_server()
729 ops[0].data.send_status_from_server.trailing_metadata = in grpcwrap_call_send_status_from_server()
731 ops[0].flags = 0; in grpcwrap_call_send_status_from_server()
732 ops[0].reserved = nullptr; in grpcwrap_call_send_status_from_server()
735 ops[nops].op = GRPC_OP_SEND_MESSAGE; in grpcwrap_call_send_status_from_server()
737 ops[nops].data.send_message.send_message = ctx->send_message; in grpcwrap_call_send_status_from_server()
738 ops[nops].flags = write_flags; in grpcwrap_call_send_status_from_server()
739 ops[nops].reserved = nullptr; in grpcwrap_call_send_status_from_server()
743 ops[nops].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_send_status_from_server()
746 ops[nops].data.send_initial_metadata.count = in grpcwrap_call_send_status_from_server()
748 ops[nops].data.send_initial_metadata.metadata = in grpcwrap_call_send_status_from_server()
750 ops[nops].flags = initial_metadata_flags; in grpcwrap_call_send_status_from_server()
751 ops[nops].reserved = nullptr; in grpcwrap_call_send_status_from_server()
755 grpc_call_error ret = grpc_call_start_batch(call, ops, nops, tag, nullptr); in grpcwrap_call_send_status_from_server()
763 grpc_op ops[1]; in grpcwrap_call_recv_message() local
764 ops[0].op = GRPC_OP_RECV_MESSAGE; in grpcwrap_call_recv_message()
765 ops[0].data.recv_message.recv_message = &(ctx->recv_message); in grpcwrap_call_recv_message()
766 ops[0].flags = 0; in grpcwrap_call_recv_message()
767 ops[0].reserved = nullptr; in grpcwrap_call_recv_message()
768 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_recv_message()
775 grpc_op ops[1]; in grpcwrap_call_start_serverside() local
776 ops[0].op = GRPC_OP_RECV_CLOSE_ON_SERVER; in grpcwrap_call_start_serverside()
777 ops[0].data.recv_close_on_server.cancelled = in grpcwrap_call_start_serverside()
779 ops[0].flags = 0; in grpcwrap_call_start_serverside()
780 ops[0].reserved = nullptr; in grpcwrap_call_start_serverside()
782 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_serverside()
790 grpc_op ops[1]; in grpcwrap_call_send_initial_metadata() local
791 memset(ops, 0, sizeof(ops)); in grpcwrap_call_send_initial_metadata()
792 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_send_initial_metadata()
794 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_send_initial_metadata()
795 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_send_initial_metadata()
797 ops[0].flags = 0; in grpcwrap_call_send_initial_metadata()
798 ops[0].reserved = nullptr; in grpcwrap_call_send_initial_metadata()
800 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_send_initial_metadata()