(bytes []byte, veifyfn verifyFunc)
| 521 | } |
| 522 | |
| 523 | func decodeBytes(bytes []byte, veifyfn verifyFunc) (pa *Package, ptr ptypes.DynamicAny, err error) { |
| 524 | pa = &Package{} |
| 525 | //TestPoint |
| 526 | //bytes = []byte{} |
| 527 | if err = proto.Unmarshal(bytes, pa); err != nil { |
| 528 | err = errors.Errorf("Unmarshal: %w", err) |
| 529 | return |
| 530 | } |
| 531 | if veifyfn != nil { |
| 532 | if err = veifyfn(pa.GetAnything().Value, pa.GetSignature()); err != nil { |
| 533 | err = errors.Errorf("veifyfn: %w", err) |
| 534 | return |
| 535 | } |
| 536 | } |
| 537 | if err = ptypes.UnmarshalAny(pa.GetAnything(), &ptr); err != nil { |
| 538 | err = errors.Errorf("UnmarshalAny: %w", err) |
| 539 | } |
| 540 | return |
| 541 | } |
| 542 | |
| 543 | func writeTo(bytes []byte, conn net.Conn) (err error) { |
| 544 | prefix := make([]byte, headerSize) |
no test coverage detected