Lines Matching full:ops
475 grpc_op ops[6]; in grpcwrap_call_start_unary() local
476 memset(ops, 0, sizeof(ops)); in grpcwrap_call_start_unary()
477 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_start_unary()
479 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_unary()
480 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_unary()
482 ops[0].flags = initial_metadata_flags; in grpcwrap_call_start_unary()
483 ops[0].reserved = nullptr; in grpcwrap_call_start_unary()
485 ops[1].op = GRPC_OP_SEND_MESSAGE; in grpcwrap_call_start_unary()
487 ops[1].data.send_message.send_message = ctx->send_message; in grpcwrap_call_start_unary()
488 ops[1].flags = write_flags; in grpcwrap_call_start_unary()
489 ops[1].reserved = nullptr; in grpcwrap_call_start_unary()
491 ops[2].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcwrap_call_start_unary()
492 ops[2].flags = 0; in grpcwrap_call_start_unary()
493 ops[2].reserved = nullptr; in grpcwrap_call_start_unary()
495 ops[3].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcwrap_call_start_unary()
496 ops[3].data.recv_initial_metadata.recv_initial_metadata = in grpcwrap_call_start_unary()
498 ops[3].flags = 0; in grpcwrap_call_start_unary()
499 ops[3].reserved = nullptr; in grpcwrap_call_start_unary()
501 ops[4].op = GRPC_OP_RECV_MESSAGE; in grpcwrap_call_start_unary()
502 ops[4].data.recv_message.recv_message = &(ctx->recv_message); in grpcwrap_call_start_unary()
503 ops[4].flags = 0; in grpcwrap_call_start_unary()
504 ops[4].reserved = nullptr; in grpcwrap_call_start_unary()
506 ops[5].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcwrap_call_start_unary()
507 ops[5].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_unary()
509 ops[5].data.recv_status_on_client.status = in grpcwrap_call_start_unary()
511 ops[5].data.recv_status_on_client.status_details = in grpcwrap_call_start_unary()
513 ops[5].flags = 0; in grpcwrap_call_start_unary()
514 ops[5].reserved = nullptr; in grpcwrap_call_start_unary()
516 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_unary()
525 grpc_op ops[4]; in grpcwrap_call_start_client_streaming() local
526 memset(ops, 0, sizeof(ops)); in grpcwrap_call_start_client_streaming()
527 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_start_client_streaming()
529 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_client_streaming()
530 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_client_streaming()
532 ops[0].flags = initial_metadata_flags; in grpcwrap_call_start_client_streaming()
533 ops[0].reserved = nullptr; in grpcwrap_call_start_client_streaming()
535 ops[1].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcwrap_call_start_client_streaming()
536 ops[1].data.recv_initial_metadata.recv_initial_metadata = in grpcwrap_call_start_client_streaming()
538 ops[1].flags = 0; in grpcwrap_call_start_client_streaming()
539 ops[1].reserved = nullptr; in grpcwrap_call_start_client_streaming()
541 ops[2].op = GRPC_OP_RECV_MESSAGE; in grpcwrap_call_start_client_streaming()
542 ops[2].data.recv_message.recv_message = &(ctx->recv_message); in grpcwrap_call_start_client_streaming()
543 ops[2].flags = 0; in grpcwrap_call_start_client_streaming()
544 ops[2].reserved = nullptr; in grpcwrap_call_start_client_streaming()
546 ops[3].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcwrap_call_start_client_streaming()
547 ops[3].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_client_streaming()
549 ops[3].data.recv_status_on_client.status = in grpcwrap_call_start_client_streaming()
551 ops[3].data.recv_status_on_client.status_details = in grpcwrap_call_start_client_streaming()
553 ops[3].flags = 0; in grpcwrap_call_start_client_streaming()
554 ops[3].reserved = nullptr; in grpcwrap_call_start_client_streaming()
556 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_client_streaming()
565 grpc_op ops[4]; in grpcwrap_call_start_server_streaming() local
566 memset(ops, 0, sizeof(ops)); in grpcwrap_call_start_server_streaming()
567 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_start_server_streaming()
569 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_server_streaming()
570 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_server_streaming()
572 ops[0].flags = initial_metadata_flags; in grpcwrap_call_start_server_streaming()
573 ops[0].reserved = nullptr; in grpcwrap_call_start_server_streaming()
575 ops[1].op = GRPC_OP_SEND_MESSAGE; in grpcwrap_call_start_server_streaming()
577 ops[1].data.send_message.send_message = ctx->send_message; in grpcwrap_call_start_server_streaming()
578 ops[1].flags = write_flags; in grpcwrap_call_start_server_streaming()
579 ops[1].reserved = nullptr; in grpcwrap_call_start_server_streaming()
581 ops[2].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcwrap_call_start_server_streaming()
582 ops[2].flags = 0; in grpcwrap_call_start_server_streaming()
583 ops[2].reserved = nullptr; in grpcwrap_call_start_server_streaming()
585 ops[3].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcwrap_call_start_server_streaming()
586 ops[3].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_server_streaming()
588 ops[3].data.recv_status_on_client.status = in grpcwrap_call_start_server_streaming()
590 ops[3].data.recv_status_on_client.status_details = in grpcwrap_call_start_server_streaming()
592 ops[3].flags = 0; in grpcwrap_call_start_server_streaming()
593 ops[3].reserved = nullptr; in grpcwrap_call_start_server_streaming()
595 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_server_streaming()
604 grpc_op ops[2]; in grpcwrap_call_start_duplex_streaming() local
605 memset(ops, 0, sizeof(ops)); in grpcwrap_call_start_duplex_streaming()
606 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_start_duplex_streaming()
608 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_duplex_streaming()
609 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_duplex_streaming()
611 ops[0].flags = initial_metadata_flags; in grpcwrap_call_start_duplex_streaming()
612 ops[0].reserved = nullptr; in grpcwrap_call_start_duplex_streaming()
614 ops[1].op = GRPC_OP_RECV_STATUS_ON_CLIENT; in grpcwrap_call_start_duplex_streaming()
615 ops[1].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_duplex_streaming()
617 ops[1].data.recv_status_on_client.status = in grpcwrap_call_start_duplex_streaming()
619 ops[1].data.recv_status_on_client.status_details = in grpcwrap_call_start_duplex_streaming()
621 ops[1].flags = 0; in grpcwrap_call_start_duplex_streaming()
622 ops[1].reserved = nullptr; in grpcwrap_call_start_duplex_streaming()
624 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_duplex_streaming()
631 grpc_op ops[1]; in grpcwrap_call_recv_initial_metadata() local
632 ops[0].op = GRPC_OP_RECV_INITIAL_METADATA; in grpcwrap_call_recv_initial_metadata()
633 ops[0].data.recv_initial_metadata.recv_initial_metadata = in grpcwrap_call_recv_initial_metadata()
635 ops[0].flags = 0; in grpcwrap_call_recv_initial_metadata()
636 ops[0].reserved = nullptr; in grpcwrap_call_recv_initial_metadata()
638 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_recv_initial_metadata()
646 grpc_op ops[2]; in grpcwrap_call_send_message() local
647 memset(ops, 0, sizeof(ops)); in grpcwrap_call_send_message()
649 ops[0].op = GRPC_OP_SEND_MESSAGE; in grpcwrap_call_send_message()
651 ops[0].data.send_message.send_message = ctx->send_message; in grpcwrap_call_send_message()
652 ops[0].flags = write_flags; in grpcwrap_call_send_message()
653 ops[0].reserved = nullptr; in grpcwrap_call_send_message()
654 ops[1].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_send_message()
655 ops[1].flags = 0; in grpcwrap_call_send_message()
656 ops[1].reserved = nullptr; in grpcwrap_call_send_message()
658 return grpc_call_start_batch(call, ops, nops, tag, nullptr); in grpcwrap_call_send_message()
664 grpc_op ops[1]; in grpcwrap_call_send_close_from_client() local
665 ops[0].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; in grpcwrap_call_send_close_from_client()
666 ops[0].flags = 0; in grpcwrap_call_send_close_from_client()
667 ops[0].reserved = nullptr; in grpcwrap_call_send_close_from_client()
669 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_send_close_from_client()
679 grpc_op ops[3]; in grpcwrap_call_send_status_from_server() local
680 memset(ops, 0, sizeof(ops)); in grpcwrap_call_send_status_from_server()
684 ops[0].op = GRPC_OP_SEND_STATUS_FROM_SERVER; in grpcwrap_call_send_status_from_server()
685 ops[0].data.send_status_from_server.status = status_code; in grpcwrap_call_send_status_from_server()
686 ops[0].data.send_status_from_server.status_details = &status_details_slice; in grpcwrap_call_send_status_from_server()
689 ops[0].data.send_status_from_server.trailing_metadata_count = in grpcwrap_call_send_status_from_server()
691 ops[0].data.send_status_from_server.trailing_metadata = in grpcwrap_call_send_status_from_server()
693 ops[0].flags = 0; in grpcwrap_call_send_status_from_server()
694 ops[0].reserved = nullptr; in grpcwrap_call_send_status_from_server()
696 ops[nops].op = GRPC_OP_SEND_MESSAGE; in grpcwrap_call_send_status_from_server()
698 ops[nops].data.send_message.send_message = ctx->send_message; in grpcwrap_call_send_status_from_server()
699 ops[nops].flags = write_flags; in grpcwrap_call_send_status_from_server()
700 ops[nops].reserved = nullptr; in grpcwrap_call_send_status_from_server()
704 ops[nops].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_send_status_from_server()
705 ops[nops].flags = 0; in grpcwrap_call_send_status_from_server()
706 ops[nops].reserved = nullptr; in grpcwrap_call_send_status_from_server()
709 grpc_call_error ret = grpc_call_start_batch(call, ops, nops, tag, nullptr); in grpcwrap_call_send_status_from_server()
717 grpc_op ops[1]; in grpcwrap_call_recv_message() local
718 ops[0].op = GRPC_OP_RECV_MESSAGE; in grpcwrap_call_recv_message()
719 ops[0].data.recv_message.recv_message = &(ctx->recv_message); in grpcwrap_call_recv_message()
720 ops[0].flags = 0; in grpcwrap_call_recv_message()
721 ops[0].reserved = nullptr; in grpcwrap_call_recv_message()
722 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_recv_message()
729 grpc_op ops[1]; in grpcwrap_call_start_serverside() local
730 ops[0].op = GRPC_OP_RECV_CLOSE_ON_SERVER; in grpcwrap_call_start_serverside()
731 ops[0].data.recv_close_on_server.cancelled = in grpcwrap_call_start_serverside()
733 ops[0].flags = 0; in grpcwrap_call_start_serverside()
734 ops[0].reserved = nullptr; in grpcwrap_call_start_serverside()
736 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_start_serverside()
744 grpc_op ops[1]; in grpcwrap_call_send_initial_metadata() local
745 memset(ops, 0, sizeof(ops)); in grpcwrap_call_send_initial_metadata()
746 ops[0].op = GRPC_OP_SEND_INITIAL_METADATA; in grpcwrap_call_send_initial_metadata()
748 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_send_initial_metadata()
749 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_send_initial_metadata()
751 ops[0].flags = 0; in grpcwrap_call_send_initial_metadata()
752 ops[0].reserved = nullptr; in grpcwrap_call_send_initial_metadata()
754 return grpc_call_start_batch(call, ops, sizeof(ops) / sizeof(ops[0]), tag, in grpcwrap_call_send_initial_metadata()