(md metadata.MD)
| 1679 | } |
| 1680 | |
| 1681 | func (ss *serverStream) SendHeader(md metadata.MD) error { |
| 1682 | err := imetadata.Validate(md) |
| 1683 | if err != nil { |
| 1684 | return status.Error(codes.Internal, err.Error()) |
| 1685 | } |
| 1686 | |
| 1687 | err = ss.s.SendHeader(md) |
| 1688 | if len(ss.binlogs) != 0 && !ss.serverHeaderBinlogged { |
| 1689 | h, _ := ss.s.Header() |
| 1690 | sh := &binarylog.ServerHeader{ |
| 1691 | Header: h, |
| 1692 | } |
| 1693 | ss.serverHeaderBinlogged = true |
| 1694 | for _, binlog := range ss.binlogs { |
| 1695 | binlog.Log(ss.ctx, sh) |
| 1696 | } |
| 1697 | } |
| 1698 | return err |
| 1699 | } |
| 1700 | |
| 1701 | func (ss *serverStream) SetTrailer(md metadata.MD) { |
| 1702 | if md.Len() == 0 { |
nothing calls this directly
no test coverage detected