/dports/devel/py-py_interface/py_interface-2.3/py_interface/ |
H A D | erl_node.py | 811 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 D | erl_node_conn.py | 264 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 D | conn_oob.go | 120 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 D | conn_oob.go | 168 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 D | conn_oob.go | 168 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 D | conn_oob.go | 168 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 D | conn_oob.go | 168 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 D | conn_oob.go | 168 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 D | conn_ecn.go | 96 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 D | conn_ecn.go | 96 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 D | conn_ecn.go | 96 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 D | merge.go | 44 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 D | merge.go | 33 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 D | lte-enb-phy.cc | 668 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 D | lte-ue-phy.cc | 1283 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 D | qwk.cc | 979 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 D | edit_option.tpl | 62 …{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 D | SubnodePathfinder.c | 431 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()
|