Home
last modified time | relevance | path

Searched refs:ctrlMsg (Results 1 – 18 of 18) sorted by relevance

/dports/devel/py-py_interface/py_interface-2.3/py_interface/
H A Derl_node.py811 ctrlMsgOp = ctrlMsg[0]
817 cookie = ctrlMsg[1]
830 reason = ctrlMsg[3]
840 cookie = ctrlMsg[2]
859 reason = ctrlMsg[3]
862 cookie = ctrlMsg[1]
871 reason = ctrlMsg[4]
875 cookie = ctrlMsg[2]
889 ref = ctrlMsg[3]
894 ref = ctrlMsg[3]
[all …]
H A Derl_node_conn.py264 def SendMsg(self, ctrlMsg, msg=None): argument
276 packet = b"p" + erl_term.TermToBinary(ctrlMsg)
278 packet = b"p" + (erl_term.TermToBinary(ctrlMsg) + \
597 def SendMsg(self, ctrlMsg, msg=None): argument
609 packet = b"p" + erl_term.TermToBinary(ctrlMsg)
611 packet = b"p" + (erl_term.TermToBinary(ctrlMsg) + \
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/
H A Dconn_oob.go120 for _, ctrlMsg := range ctrlMsgs {
121 if ctrlMsg.Header.Level == unix.IPPROTO_IP {
122 switch ctrlMsg.Header.Type {
132 if len(ctrlMsg.Data) == 12 {
134 destIP = net.IP(ctrlMsg.Data[8:12])
135 } else if len(ctrlMsg.Data) == 4 {
137 destIP = net.IP(ctrlMsg.Data)
141 if ctrlMsg.Header.Level == unix.IPPROTO_IPV6 {
142 switch ctrlMsg.Header.Type {
150 if len(ctrlMsg.Data) == 20 {
[all …]
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/
H A Dconn_oob.go168 for _, ctrlMsg := range ctrlMsgs {
169 if ctrlMsg.Header.Level == unix.IPPROTO_IP {
170 switch ctrlMsg.Header.Type {
181 if len(ctrlMsg.Data) == 12 {
183 copy(ip, ctrlMsg.Data[8:12])
184 } else if len(ctrlMsg.Data) == 4 {
186 copy(ip, ctrlMsg.Data)
191 if ctrlMsg.Header.Level == unix.IPPROTO_IPV6 {
192 switch ctrlMsg.Header.Type {
200 if len(ctrlMsg.Data) == 20 {
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/
H A Dconn_oob.go168 for _, ctrlMsg := range ctrlMsgs {
169 if ctrlMsg.Header.Level == unix.IPPROTO_IP {
170 switch ctrlMsg.Header.Type {
181 if len(ctrlMsg.Data) == 12 {
183 copy(ip, ctrlMsg.Data[8:12])
184 } else if len(ctrlMsg.Data) == 4 {
186 copy(ip, ctrlMsg.Data)
191 if ctrlMsg.Header.Level == unix.IPPROTO_IPV6 {
192 switch ctrlMsg.Header.Type {
200 if len(ctrlMsg.Data) == 20 {
[all …]
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/
H A Dconn_oob.go168 for _, ctrlMsg := range ctrlMsgs {
169 if ctrlMsg.Header.Level == unix.IPPROTO_IP {
170 switch ctrlMsg.Header.Type {
181 if len(ctrlMsg.Data) == 12 {
183 copy(ip, ctrlMsg.Data[8:12])
184 } else if len(ctrlMsg.Data) == 4 {
186 copy(ip, ctrlMsg.Data)
191 if ctrlMsg.Header.Level == unix.IPPROTO_IPV6 {
192 switch ctrlMsg.Header.Type {
200 if len(ctrlMsg.Data) == 20 {
[all …]
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/
H A Dconn_oob.go168 for _, ctrlMsg := range ctrlMsgs {
169 if ctrlMsg.Header.Level == unix.IPPROTO_IP {
170 switch ctrlMsg.Header.Type {
181 if len(ctrlMsg.Data) == 12 {
183 copy(ip, ctrlMsg.Data[8:12])
184 } else if len(ctrlMsg.Data) == 4 {
186 copy(ip, ctrlMsg.Data)
191 if ctrlMsg.Header.Level == unix.IPPROTO_IPV6 {
192 switch ctrlMsg.Header.Type {
200 if len(ctrlMsg.Data) == 20 {
[all …]
/dports/net/traefik/traefik-2.6.1/vendor/github.com/lucas-clemente/quic-go/
H A Dconn_oob.go168 for _, ctrlMsg := range ctrlMsgs {
169 if ctrlMsg.Header.Level == unix.IPPROTO_IP {
170 switch ctrlMsg.Header.Type {
181 if len(ctrlMsg.Data) == 12 {
183 copy(ip, ctrlMsg.Data[8:12])
184 } else if len(ctrlMsg.Data) == 4 {
186 copy(ip, ctrlMsg.Data)
191 if ctrlMsg.Header.Level == unix.IPPROTO_IPV6 {
192 switch ctrlMsg.Header.Type {
200 if len(ctrlMsg.Data) == 20 {
[all …]
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/
H A Dconn_ecn.go96 for _, ctrlMsg := range ctrlMsgs {
97 if ctrlMsg.Header.Level == syscall.IPPROTO_IP && ctrlMsg.Header.Type == msgTypeIPTOS {
98 ecn = protocol.ECN(ctrlMsg.Data[0] & ecnMask)
101 if ctrlMsg.Header.Level == syscall.IPPROTO_IPV6 && ctrlMsg.Header.Type == syscall.IPV6_TCLASS {
102 ecn = protocol.ECN(ctrlMsg.Data[0] & ecnMask)
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/
H A Dconn_ecn.go96 for _, ctrlMsg := range ctrlMsgs {
97 if ctrlMsg.Header.Level == syscall.IPPROTO_IP && ctrlMsg.Header.Type == msgTypeIPTOS {
98 ecn = protocol.ECN(ctrlMsg.Data[0] & ecnMask)
101 if ctrlMsg.Header.Level == syscall.IPPROTO_IPV6 && ctrlMsg.Header.Type == syscall.IPV6_TCLASS {
102 ecn = protocol.ECN(ctrlMsg.Data[0] & ecnMask)
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lucas-clemente/quic-go/
H A Dconn_ecn.go96 for _, ctrlMsg := range ctrlMsgs {
97 if ctrlMsg.Header.Level == syscall.IPPROTO_IP && ctrlMsg.Header.Type == msgTypeIPTOS {
98 ecn = protocol.ECN(ctrlMsg.Data[0] & ecnMask)
101 if ctrlMsg.Header.Level == syscall.IPPROTO_IPV6 && ctrlMsg.Header.Type == syscall.IPV6_TCLASS {
102 ecn = protocol.ECN(ctrlMsg.Data[0] & ecnMask)
/dports/www/gitea/gitea-1.16.5/vendor/github.com/blevesearch/bleve/v2/index/scorch/
H A Dmerge.go44 var ctrlMsg *mergerCtrl
72 ctrlMsg = ctrlMsgDflt
74 if ctrlMsg != nil {
78 err := s.planMergeAtSnapshot(ctrlMsg.ctx, ctrlMsg.options,
87 if ctrlMsg.doneCh != nil {
88 close(ctrlMsg.doneCh)
89 ctrlMsg = nil
94 ctrlMsg = nil
103 if ctrlMsg.doneCh != nil {
104 close(ctrlMsg.doneCh)
[all …]
/dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/blevesearch/bleve/index/scorch/
H A Dmerge.go33 var ctrlMsg *mergerCtrl
62 ctrlMsg = ctrlMsgDflt
64 if ctrlMsg != nil {
68 err := s.planMergeAtSnapshot(ctrlMsg.ctx, ctrlMsg.options,
77 if ctrlMsg.doneCh != nil {
78 close(ctrlMsg.doneCh)
79 ctrlMsg = nil
84 ctrlMsg = nil
93 if ctrlMsg.doneCh != nil {
94 close(ctrlMsg.doneCh)
[all …]
/dports/net/ns3/ns-allinone-3.35/ns-3.35/src/lte/model/
H A Dlte-enb-phy.cc668 std::list<Ptr<LteControlMessage> > ctrlMsg = GetControlMessages (); in StartSubFrame() local
671 if (ctrlMsg.size () > 0) in StartSubFrame()
674 it = ctrlMsg.begin (); in StartSubFrame()
675 while (it != ctrlMsg.end ()) in StartSubFrame()
752 SendControlChannels (ctrlMsg); in StartSubFrame()
H A Dlte-ue-phy.cc1283 std::list<Ptr<LteControlMessage> > ctrlMsg = GetControlMessages (); in SubframeIndication() local
1295 m_uplinkSpectrumPhy->StartTxDataFrame (pb, ctrlMsg, UL_DATA_DURATION); in SubframeIndication()
1300 if (ctrlMsg.size () > 0) in SubframeIndication()
1311 m_uplinkSpectrumPhy->StartTxDataFrame (pb, ctrlMsg, UL_DATA_DURATION); in SubframeIndication()
/dports/news/mmail/mmail-0.52/mmail/
H A Dqwk.cc979 letter_header *ctrlMsg; in makeOffConfig() local
1005 ctrlMsg = new letter_header(mm, (attrib & ADDED) ? in makeOffConfig()
1009 enterLetter(*ctrlMsg, "", 0); in makeOffConfig()
1011 delete ctrlMsg; in makeOffConfig()
/dports/www/tikiwiki/tiki-21.2/templates/menu/
H A Dedit_option.tpl62 …{if $prefs.jquery_ui_chosen neq 'y'}{$ctrlMsg="{tr}Use Ctrl+Click to select multiple options{/tr}<…
63 …{remarksbox type="tip" title="{tr}Tip{/tr}"}{$ctrlMsg}{tr}Selecting 2 groups means that the option…
/dports/net/cjdns/cjdns-cjdns-v21.1/subnode/
H A DSubnodePathfinder.c431 static Iface_DEFUN ctrlMsg(struct Message* msg, struct SubnodePathfinder_pvt* pf) in ctrlMsg() function
506 case PFChan_Core_CTRL_MSG: return ctrlMsg(msg, pf); in incomingFromEventIf()