()
| 684 | } |
| 685 | |
| 686 | func (ed *expectedData) toServerLogEntries() []*binlogpb.GrpcLogEntry { |
| 687 | var ( |
| 688 | ret []*binlogpb.GrpcLogEntry |
| 689 | idInRPC uint64 = 1 |
| 690 | ) |
| 691 | ret = append(ret, ed.newClientHeaderEntry(false, globalRPCID, idInRPC)) |
| 692 | idInRPC++ |
| 693 | |
| 694 | switch ed.cc.callType { |
| 695 | case unaryRPC: |
| 696 | ret = append(ret, ed.newClientMessageEntry(false, globalRPCID, idInRPC, ed.requests[0])) |
| 697 | idInRPC++ |
| 698 | ret = append(ret, ed.newServerHeaderEntry(false, globalRPCID, idInRPC)) |
| 699 | idInRPC++ |
| 700 | if ed.cc.success { |
| 701 | ret = append(ret, ed.newServerMessageEntry(false, globalRPCID, idInRPC, ed.responses[0])) |
| 702 | idInRPC++ |
| 703 | } |
| 704 | case fullDuplexStreamRPC: |
| 705 | ret = append(ret, ed.newServerHeaderEntry(false, globalRPCID, idInRPC)) |
| 706 | idInRPC++ |
| 707 | for i := 0; i < len(ed.requests); i++ { |
| 708 | ret = append(ret, ed.newClientMessageEntry(false, globalRPCID, idInRPC, ed.requests[i])) |
| 709 | idInRPC++ |
| 710 | if !ed.cc.success { |
| 711 | // There is no response in the RPC error case. |
| 712 | continue |
| 713 | } |
| 714 | ret = append(ret, ed.newServerMessageEntry(false, globalRPCID, idInRPC, ed.responses[i])) |
| 715 | idInRPC++ |
| 716 | } |
| 717 | |
| 718 | if ed.cc.success && ed.cc.callType == fullDuplexStreamRPC { |
| 719 | ret = append(ret, ed.newHalfCloseEntry(false, globalRPCID, idInRPC)) |
| 720 | idInRPC++ |
| 721 | } |
| 722 | case clientStreamRPC: |
| 723 | ret = append(ret, ed.newServerHeaderEntry(false, globalRPCID, idInRPC)) |
| 724 | idInRPC++ |
| 725 | for i := 0; i < len(ed.requests); i++ { |
| 726 | ret = append(ret, ed.newClientMessageEntry(false, globalRPCID, idInRPC, ed.requests[i])) |
| 727 | idInRPC++ |
| 728 | } |
| 729 | if ed.cc.success { |
| 730 | ret = append(ret, ed.newHalfCloseEntry(false, globalRPCID, idInRPC)) |
| 731 | idInRPC++ |
| 732 | ret = append(ret, ed.newServerMessageEntry(false, globalRPCID, idInRPC, ed.responses[0])) |
| 733 | idInRPC++ |
| 734 | } |
| 735 | case serverStreamRPC: |
| 736 | ret = append(ret, ed.newClientMessageEntry(false, globalRPCID, idInRPC, ed.requests[0])) |
| 737 | idInRPC++ |
| 738 | ret = append(ret, ed.newServerHeaderEntry(false, globalRPCID, idInRPC)) |
| 739 | idInRPC++ |
| 740 | for i := 0; i < len(ed.responses); i++ { |
| 741 | ret = append(ret, ed.newServerMessageEntry(false, globalRPCID, idInRPC, ed.responses[0])) |
| 742 | idInRPC++ |
| 743 | } |
no test coverage detected