MCPcopy
hub / github.com/gofiber/fiber / UnmarshalMsg

Method UnmarshalMsg

middleware/cache/manager_msgp.go:644–935  ·  view source on GitHub ↗

UnmarshalMsg implements msgp.Unmarshaler

(bts []byte)

Source from the content-addressed store, hash-verified

642
643// UnmarshalMsg implements msgp.Unmarshaler
644func (z *item) UnmarshalMsg(bts []byte) (o []byte, err error) {
645 var field []byte
646 _ = field
647 var zb0001 uint32
648 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
649 if err != nil {
650 err = msgp.WrapError(err)
651 return
652 }
653 for zb0001 > 0 {
654 zb0001--
655 field, bts, err = msgp.ReadMapKeyZC(bts)
656 if err != nil {
657 err = msgp.WrapError(err)
658 return
659 }
660 switch msgp.UnsafeString(field) {
661 case "headers":
662 var zb0002 uint32
663 zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts)
664 if err != nil {
665 err = msgp.WrapError(err, "headers")
666 return
667 }
668 if zb0002 > 1024 {
669 err = msgp.ErrLimitExceeded
670 return
671 }
672 if cap(z.headers) >= int(zb0002) {
673 z.headers = (z.headers)[:zb0002]
674 } else {
675 z.headers = make([]cachedHeader, zb0002)
676 }
677 for za0001 := range z.headers {
678 var zb0003 uint32
679 zb0003, bts, err = msgp.ReadMapHeaderBytes(bts)
680 if err != nil {
681 err = msgp.WrapError(err, "headers", za0001)
682 return
683 }
684 if zb0003 > 1024 {
685 err = msgp.ErrLimitExceeded
686 return
687 }
688 for zb0003 > 0 {
689 zb0003--
690 field, bts, err = msgp.ReadMapKeyZC(bts)
691 if err != nil {
692 err = msgp.WrapError(err, "headers", za0001)
693 return
694 }
695 switch msgp.UnsafeString(field) {
696 case "key":
697 var zb0004 uint32
698 zb0004, bts, err = msgp.ReadBytesHeader(bts)
699 if err != nil {
700 err = msgp.WrapError(err, "headers", za0001, "key")
701 return

Calls

no outgoing calls