| /dports/net/tunneller/tunneller-release-0.6/vendor/github.com/eclipse/paho.mqtt.golang/packets/ |
| H A D | packets.go | 102 var fh FixedHeader
140 return &ConnectPacket{FixedHeader: FixedHeader{MessageType: Connect}}
142 return &ConnackPacket{FixedHeader: FixedHeader{MessageType: Connack}}
146 return &PublishPacket{FixedHeader: FixedHeader{MessageType: Publish}}
148 return &PubackPacket{FixedHeader: FixedHeader{MessageType: Puback}}
150 return &PubrecPacket{FixedHeader: FixedHeader{MessageType: Pubrec}}
154 return &PubcompPacket{FixedHeader: FixedHeader{MessageType: Pubcomp}}
158 return &SubackPacket{FixedHeader: FixedHeader{MessageType: Suback}}
162 return &UnsubackPacket{FixedHeader: FixedHeader{MessageType: Unsuback}}
164 return &PingreqPacket{FixedHeader: FixedHeader{MessageType: Pingreq}}
[all …]
|
| H A D | subscribe.go | 12 FixedHeader
19 str := fmt.Sprintf("%s", s.FixedHeader)
34 s.FixedHeader.RemainingLength = body.Len()
35 packet := s.FixedHeader.pack()
50 payloadLength := s.FixedHeader.RemainingLength - 2
|
| H A D | unsuback.go | 11 FixedHeader
16 str := fmt.Sprintf("%s", ua.FixedHeader)
24 ua.FixedHeader.RemainingLength = 2
25 packet := ua.FixedHeader.pack()
|
| H A D | pubrel.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s", pr.FixedHeader)
24 pr.FixedHeader.RemainingLength = 2
25 packet := pr.FixedHeader.pack()
|
| H A D | puback.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s", pa.FixedHeader)
24 pa.FixedHeader.RemainingLength = 2
25 packet := pa.FixedHeader.pack()
|
| H A D | pubrec.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s", pr.FixedHeader)
24 pr.FixedHeader.RemainingLength = 2
25 packet := pr.FixedHeader.pack()
|
| H A D | pubcomp.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s", pc.FixedHeader)
24 pc.FixedHeader.RemainingLength = 2
25 packet := pc.FixedHeader.pack()
|
| H A D | publish.go | 12 FixedHeader anonMember
19 str := fmt.Sprintf("%s", p.FixedHeader)
35 p.FixedHeader.RemainingLength = body.Len() + len(p.Payload)
36 packet := p.FixedHeader.pack()
47 var payloadLength = p.FixedHeader.RemainingLength
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/eclipse/paho.mqtt.golang/packets/ |
| H A D | packets.go | 102 var fh FixedHeader
130 cp = &ConnectPacket{FixedHeader: FixedHeader{MessageType: Connect}}
132 cp = &ConnackPacket{FixedHeader: FixedHeader{MessageType: Connack}}
136 cp = &PublishPacket{FixedHeader: FixedHeader{MessageType: Publish}}
138 cp = &PubackPacket{FixedHeader: FixedHeader{MessageType: Puback}}
140 cp = &PubrecPacket{FixedHeader: FixedHeader{MessageType: Pubrec}}
144 cp = &PubcompPacket{FixedHeader: FixedHeader{MessageType: Pubcomp}}
148 cp = &SubackPacket{FixedHeader: FixedHeader{MessageType: Suback}}
152 cp = &UnsubackPacket{FixedHeader: FixedHeader{MessageType: Unsuback}}
154 cp = &PingreqPacket{FixedHeader: FixedHeader{MessageType: Pingreq}}
[all …]
|
| H A D | subscribe.go | 12 FixedHeader anonMember
19 str := fmt.Sprintf("%s", s.FixedHeader)
34 s.FixedHeader.RemainingLength = body.Len()
35 packet := s.FixedHeader.pack()
46 payloadLength := s.FixedHeader.RemainingLength - 2
|
| H A D | publish.go | 12 FixedHeader anonMember
19 str := fmt.Sprintf("%s", p.FixedHeader)
35 p.FixedHeader.RemainingLength = body.Len() + len(p.Payload)
36 packet := p.FixedHeader.pack()
47 var payloadLength = p.FixedHeader.RemainingLength
|
| H A D | unsuback.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s", ua.FixedHeader)
24 ua.FixedHeader.RemainingLength = 2
25 packet := ua.FixedHeader.pack()
|
| H A D | puback.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s", pa.FixedHeader)
24 pa.FixedHeader.RemainingLength = 2
25 packet := pa.FixedHeader.pack()
|
| H A D | pubrel.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s", pr.FixedHeader)
24 pr.FixedHeader.RemainingLength = 2
25 packet := pr.FixedHeader.pack()
|
| H A D | pubcomp.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s", pc.FixedHeader)
24 pc.FixedHeader.RemainingLength = 2
25 packet := pc.FixedHeader.pack()
|
| H A D | pubrec.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s", pr.FixedHeader)
24 pr.FixedHeader.RemainingLength = 2
25 packet := pr.FixedHeader.pack()
|
| H A D | connack.go | 12 FixedHeader anonMember
18 str := fmt.Sprintf("%s", ca.FixedHeader)
30 ca.FixedHeader.RemainingLength = 2
31 packet := ca.FixedHeader.pack()
|
| /dports/sysutils/hared/hared-hare-1.0-45-g8341d8a/vendor/github.com/eclipse/paho.mqtt.golang/packets/ |
| H A D | packets.go | 102 var fh FixedHeader
130 cp = &ConnectPacket{FixedHeader: FixedHeader{MessageType: Connect}}
132 cp = &ConnackPacket{FixedHeader: FixedHeader{MessageType: Connack}}
136 cp = &PublishPacket{FixedHeader: FixedHeader{MessageType: Publish}}
138 cp = &PubackPacket{FixedHeader: FixedHeader{MessageType: Puback}}
140 cp = &PubrecPacket{FixedHeader: FixedHeader{MessageType: Pubrec}}
144 cp = &PubcompPacket{FixedHeader: FixedHeader{MessageType: Pubcomp}}
148 cp = &SubackPacket{FixedHeader: FixedHeader{MessageType: Suback}}
152 cp = &UnsubackPacket{FixedHeader: FixedHeader{MessageType: Unsuback}}
154 cp = &PingreqPacket{FixedHeader: FixedHeader{MessageType: Pingreq}}
[all …]
|
| H A D | subscribe.go | 12 FixedHeader anonMember
19 str := fmt.Sprintf("%s", s.FixedHeader)
33 s.FixedHeader.RemainingLength = body.Len()
34 packet := s.FixedHeader.pack()
45 payloadLength := s.FixedHeader.RemainingLength - 2
|
| H A D | publish.go | 12 FixedHeader anonMember
19 str := fmt.Sprintf("%s\n", p.FixedHeader)
33 p.FixedHeader.RemainingLength = body.Len() + len(p.Payload)
34 packet := p.FixedHeader.pack()
45 var payloadLength = p.FixedHeader.RemainingLength
|
| H A D | puback.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s\n", pa.FixedHeader)
23 pa.FixedHeader.RemainingLength = 2
24 packet := pa.FixedHeader.pack()
|
| H A D | pubcomp.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s\n", pc.FixedHeader)
23 pc.FixedHeader.RemainingLength = 2
24 packet := pc.FixedHeader.pack()
|
| H A D | pubrec.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s\n", pr.FixedHeader)
23 pr.FixedHeader.RemainingLength = 2
24 packet := pr.FixedHeader.pack()
|
| H A D | pubrel.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s\n", pr.FixedHeader)
23 pr.FixedHeader.RemainingLength = 2
24 packet := pr.FixedHeader.pack()
|
| H A D | unsuback.go | 11 FixedHeader anonMember
16 str := fmt.Sprintf("%s\n", ua.FixedHeader)
23 ua.FixedHeader.RemainingLength = 2
24 packet := ua.FixedHeader.pack()
|