/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/websocket/ |
H A D | BlowupOutputQueue.java | 73 int[] incoming = new int[2 * (N + 1)]; // 2 bytes per message in full() local 74 for (int i = 0; i < incoming.length - 2; i += 2) { in full() 76 incoming[i + 0] = 0x89; in full() 77 incoming[i + 1] = 0x00; in full() 80 incoming[incoming.length - 2] = 0x88; in full() 81 incoming[incoming.length - 1] = 0x00; in full() 85 server = Support.writingServer(incoming); in full()
|
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/net/httpclient/websocket/ |
H A D | BlowupOutputQueue.java | 73 int[] incoming = new int[2 * (N + 1)]; // 2 bytes per message in full() local 74 for (int i = 0; i < incoming.length - 2; i += 2) { in full() 76 incoming[i + 0] = 0x89; in full() 77 incoming[i + 1] = 0x00; in full() 80 incoming[incoming.length - 2] = 0x88; in full() 81 incoming[incoming.length - 1] = 0x00; in full() 85 server = Support.writingServer(incoming); in full()
|
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/net/httpclient/websocket/ |
H A D | BlowupOutputQueue.java | 73 int[] incoming = new int[2 * (N + 1)]; // 2 bytes per message in full() local 74 for (int i = 0; i < incoming.length - 2; i += 2) { in full() 76 incoming[i + 0] = 0x89; in full() 77 incoming[i + 1] = 0x00; in full() 80 incoming[incoming.length - 2] = 0x88; in full() 81 incoming[incoming.length - 1] = 0x00; in full() 85 server = Support.writingServer(incoming); in full()
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/net/httpclient/websocket/ |
H A D | BlowupOutputQueue.java | 73 int[] incoming = new int[2 * (N + 1)]; // 2 bytes per message 74 for (int i = 0; i < incoming.length - 2; i += 2) { 76 incoming[i + 0] = 0x89; 77 incoming[i + 1] = 0x00; 80 incoming[incoming.length - 2] = 0x88; 81 incoming[incoming.length - 1] = 0x00; 85 server = Support.writingServer(incoming);
|
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/net/httpclient/websocket/ |
H A D | BlowupOutputQueue.java | 73 int[] incoming = new int[2 * (N + 1)]; // 2 bytes per message in full() local 74 for (int i = 0; i < incoming.length - 2; i += 2) { in full() 76 incoming[i + 0] = 0x89; in full() 77 incoming[i + 1] = 0x00; in full() 80 incoming[incoming.length - 2] = 0x88; in full() 81 incoming[incoming.length - 1] = 0x00; in full() 85 server = Support.writingServer(incoming); in full()
|
/dports/devel/py-RPyC/rpyc-5.0.1/rpyc/core/ |
H A D | stream.py | 297 def __init__(self, incoming, outgoing): argument 299 self.incoming = incoming 326 return self.incoming is ClosedFile 329 self.incoming.close() 331 self.incoming = ClosedFile 335 return self.incoming.fileno() 378 if hasattr(incoming, "fileno"): 380 incoming = msvcrt.get_osfhandle(incoming.fileno()) 383 self.incoming = incoming 401 return self.incoming is ClosedFile [all …]
|
/dports/net/oha/oha-0.4.7/cargo-crates/warp-0.3.1/src/ |
H A D | server.rs | 69 incoming.set_nodelay(true); 70 let addr = incoming.local_addr(); 71 (addr, incoming) 79 let srv = HyperServer::builder(incoming) 143 pub async fn run_incoming<I>(self, incoming: I) in run_incoming() 154 async fn run_incoming2<I>(self, incoming: I) in run_incoming2() 160 let fut = self.serve_incoming2(incoming); in run_incoming2() 323 let incoming = incoming.map_ok(crate::transport::LiftIo); in serve_incoming() localVariable 324 self.serve_incoming2(incoming) in serve_incoming() 339 incoming: I, in serve_incoming_with_graceful_shutdown() [all …]
|
/dports/textproc/mdbook/mdBook-0.4.13/cargo-crates/warp-0.3.1/src/ |
H A D | server.rs | 69 incoming.set_nodelay(true); 70 let addr = incoming.local_addr(); 71 (addr, incoming) 79 let srv = HyperServer::builder(incoming) 143 pub async fn run_incoming<I>(self, incoming: I) in run_incoming() 154 async fn run_incoming2<I>(self, incoming: I) in run_incoming2() 160 let fut = self.serve_incoming2(incoming); in run_incoming2() 323 let incoming = incoming.map_ok(crate::transport::LiftIo); in serve_incoming() localVariable 324 self.serve_incoming2(incoming) in serve_incoming() 339 incoming: I, in serve_incoming_with_graceful_shutdown() [all …]
|
/dports/math/ltl2ba/ltl2ba-1.3/patch-from-1.1/ |
H A D | 01-ltl2ba-fix-simplify-bstates--trivial-sccs.patch | 16 + * (incoming == -1), as the acceptance condition of 22 - a->incoming >=0 && b->incoming >=0) 25 + && a->incoming >=0 /* a is not in a trivial SCC */ 26 + && b->incoming >=0) /* b is not in a trivial SCC */ 35 - if(s1->incoming == -1) 38 + if(s1->incoming == -1) { /* s1 is in a trivial SCC */ 42 + * stored in s1->incoming, because we will retarget the incoming 46 + * the incoming transitions does not change the status of s1, 59 + * If we are here, s1->incoming==1 and thus s1 forms a trivial SCC. 63 + s1->incoming = s->incoming;
|
/dports/net-im/gajim/gajim-gajim-1.3.3/test/broken/unit/ |
H A D | test_socks5.py | 26 self.incoming = [] 27 self.incoming.append(self.sockobj._get_auth_response()) 28 self.incoming.append(self.sockobj._get_request_buff(sha1, 0x00)) 37 temp = self.incoming 38 self.incoming = self.outgoing 42 return self.incoming.pop(0) 103 assert(sock.incoming == []) 117 self.assertEqual(s.recv(64), mocksock.incoming.pop(0)) 120 self.assertEqual(s.recv(64), mocksock.incoming.pop(0)) 141 self.assertEqual(s.recv(64), mocksock.incoming.pop(0)) [all …]
|
/dports/databases/py-postgresql/py-postgresql-1.1.0/postgresql/ |
H A D | notifyman.py | 51 self.incoming = None 140 if self.incoming: 143 self.incoming, self._pulled = chain(self.incoming, iter(new_seqs)), {} 145 self.incoming, self._pulled = iter(new_seqs), {} 146 elif self.incoming is None: 148 self.incoming, self._pulled = iter(()), {} 199 if self.incoming is not None: 201 return next(self.incoming) 204 self.incoming = None
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/ipfs/go-log/writer/ |
H A D | writer.go | 145 incoming: make(chan []byte, 1), 157 incoming chan []byte member 170 if bw.incoming != nil { 171 close(bw.incoming) 172 bw.incoming = nil 177 bw.incoming <- b 209 incoming := bw.incoming 214 b, ok := <-incoming 222 case b, ok := <-incoming:
|
/dports/graphics/appleseed/appleseed-2.1.0-beta/src/appleseed/foundation/math/ |
H A D | phasefunction.h | 42 virtual float evaluate(const Vector3f& outgoing, const Vector3f& incoming) const = 0; 43 virtual float sample(const Vector3f& outgoing, const Vector2f& s, Vector3f& incoming) const = 0; 59 float evaluate(const Vector3f& outgoing, const Vector3f& incoming) const override; 60 float sample(const Vector3f& outgoing, const Vector2f& s, Vector3f& incoming) const override; 75 float evaluate(const Vector3f& outgoing, const Vector3f& incoming) const override; 76 float sample(const Vector3f& outgoing, const Vector2f& s, Vector3f& incoming) const override;
|
/dports/mail/thunderbird/thunderbird-91.8.0/comm/mail/components/accountcreation/ |
H A D | ExchangeAutoDiscover.jsm | 328 config.incoming.port = 443; 351 !config.incoming.ewsURL && 435 config.incoming = server; 448 if (config.incoming.owaURL || config.incoming.ewsURL) { 449 config.incoming.oauthSettings = { 451 scope: config.incoming.owaURL || config.incoming.ewsURL, 455 scope: config.incoming.owaURL || config.incoming.ewsURL, 470 let incoming = [config.incoming, ...config.incomingAlternatives].find( 473 if (!incoming) { 629 config2.incoming.hostname = config.incoming.hostname; [all …]
|
/dports/net-im/climm/climm-0.7.1/src/ |
H A D | remote.c | 101 if (!(pak = remo->incoming)) in ScriptingDispatch() 102 remo->incoming = pak = PacketC (); in ScriptingDispatch() 110 remo->incoming = NULL; in ScriptingDispatch() 127 remo->incoming = PacketC (); in ScriptingDispatch() 128 remo->incoming->len = pak->len - (end - pak->data); in ScriptingDispatch() 129 memcpy (remo->incoming->data, end, remo->incoming->len); in ScriptingDispatch() 133 remo->incoming = NULL; in ScriptingDispatch()
|
/dports/devel/mutagen/mutagen-0.11.8/pkg/forwarding/endpoint/remote/ |
H A D | server.go | 108 var incoming net.Conn 110 if incoming, err = endpoint.Open(); err != nil { 114 incoming, err = multiplexer.Accept() 118 incoming = closewrite.Enable(incoming) 129 incoming.Close() 135 incoming.Close() 141 go forwarding.ForwardAndClose(context.Background(), incoming, outgoing)
|
/dports/mail/mailscanner/MailScanner-5.3.4/usr/sbin/ |
H A D | MSMilter | 187 if ($incoming eq '') { 375 my $incoming = MailScanner::Config::Value('inqueuedir'); 377 if ($incoming eq '') { 382 my $file = @{$incoming}[0] . '/temp-' . $id; 476 my $incoming = MailScanner::Config::Value('inqueuedir'); 478 if ($incoming eq '') { 483 my $file = @{$incoming}[0] . '/temp-' . ${$message_ref}; 522 my $incoming = MailScanner::Config::Value('inqueuedir'); 524 if ($incoming eq '') { 530 my $file2 = @{$incoming}[0] . '/' . ${$message_ref}; [all …]
|
/dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.pde.ui/ui/org.eclipse.pde.ui/src/org/eclipse/pde/internal/ui/nls/ |
H A D | ModelChangeElement.java | 38 public ModelChangeElement(ModelChange parent, Object incoming) { in ModelChangeElement() argument 40 fUnderlying = incoming; in ModelChangeElement() 41 if (incoming instanceof PluginElementNode) { in ModelChangeElement() 42 PluginElementNode elem = (PluginElementNode) incoming; in ModelChangeElement() 48 } else if (incoming instanceof PluginAttribute) { in ModelChangeElement() 49 PluginAttribute attr = (PluginAttribute) incoming; in ModelChangeElement() 54 } else if (incoming instanceof PluginExtensionPointNode) { in ModelChangeElement() 55 PluginExtensionPointNode extP = (PluginExtensionPointNode) incoming; in ModelChangeElement() 61 } else if (incoming instanceof ManifestHeader) { in ModelChangeElement() 62 ManifestHeader header = (ManifestHeader) incoming; in ModelChangeElement()
|
/dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/ipfs/go-log/ |
H A D | writer.go | 159 incoming: make(chan []byte, 1), 171 incoming chan []byte member 184 if bw.incoming != nil { 185 close(bw.incoming) 186 bw.incoming = nil 191 bw.incoming <- b 222 incoming := bw.incoming 228 case b, ok := <-incoming: 237 case b, ok := <-incoming:
|
/dports/net-im/matterbridge/matterbridge-1.22.3/vendor/layeh.com/gumble/gumble/ |
H A D | ping.go | 85 var incoming [24]byte 86 if _, err := io.ReadFull(conn, incoming[:]); err != nil { 89 id := string(incoming[4:12]) 101 Version: binary.BigEndian.Uint32(incoming[0:]), 103 ConnectedUsers: int(binary.BigEndian.Uint32(incoming[12:])), 104 MaximumUsers: int(binary.BigEndian.Uint32(incoming[16:])), 105 MaximumBitrate: int(binary.BigEndian.Uint32(incoming[20:])),
|
/dports/www/beehive/beehive-0.4.0/vendor/layeh.com/gumble/gumble/ |
H A D | ping.go | 85 var incoming [24]byte 86 if _, err := io.ReadFull(conn, incoming[:]); err != nil { 89 id := string(incoming[4:12]) 101 Version: binary.BigEndian.Uint32(incoming[0:]), 103 ConnectedUsers: int(binary.BigEndian.Uint32(incoming[12:])), 104 MaximumUsers: int(binary.BigEndian.Uint32(incoming[16:])), 105 MaximumBitrate: int(binary.BigEndian.Uint32(incoming[20:])),
|
/dports/devel/mercurial/mercurial-6.0/tests/ |
H A D | test-bundle2-multiple-changegroups.t | 71 > incoming = sh -c "printenv.py --line incoming" 122 incoming hook: HG_HOOKNAME=incoming 123 HG_HOOKTYPE=incoming 142 incoming hook: HG_HOOKNAME=incoming 249 incoming hook: HG_HOOKNAME=incoming 258 incoming hook: HG_HOOKNAME=incoming 278 incoming hook: HG_HOOKNAME=incoming 288 incoming hook: HG_HOOKNAME=incoming 298 incoming hook: HG_HOOKNAME=incoming 405 incoming hook: HG_HOOKNAME=incoming [all …]
|
/dports/net-p2p/libktorrent/libktorrent-21.12.3/src/utp/tests/ |
H A D | utppolltest.cpp | 29 incoming[num_accepted++] = new UTPSocket(conn); in accepted() 65 outgoing[i] = incoming[i] = nullptr; in initTestCase() 74 delete incoming[i]; in cleanupTestCase() 108 QVERIFY(incoming[i]->ok()); in testConnect() 142 incoming[i]->prepare(&poller, Poll::INPUT); in testPollInput() 147 if (!bs.get(i) && incoming[i]->ready(&poller, net::Poll::INPUT)) { in testPollInput() 149 QVERIFY(incoming[i]->recv(tmp, 20) == (int)strlen(test)); in testPollInput() 165 incoming[i]->prepare(&poller, Poll::OUTPUT); in testPollOutput() 170 QVERIFY(incoming[i]->ready(&poller, Poll::OUTPUT)); in testPollOutput() 180 incoming[i]->close(); in testPollClose() [all …]
|
/dports/devel/py-oslo.messaging/oslo.messaging-12.11.0/oslo_messaging/rpc/ |
H A D | dispatcher.py | 232 def _watchdog(self, event, incoming): argument 240 client_timeout = int(incoming.client_timeout) 247 incoming.client_timeout)) 254 {'method': incoming.message.get('method'), 257 incoming.heartbeat() 267 def dispatch(self, incoming): argument 274 message = incoming.message 275 ctxt = incoming.ctxt 289 args=(completion_event, incoming)) 290 if incoming.client_timeout: [all …]
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/jdk.internal.vm.compiler/share/classes/org.graalvm.compiler.replacements/src/org/graalvm/compiler/replacements/nodes/ |
H A D | ReadRegisterNode.java | 68 protected final boolean incoming; field in ReadRegisterNode 70 public ReadRegisterNode(Register register, JavaKind kind, boolean directUse, boolean incoming) { in ReadRegisterNode() argument 75 this.incoming = incoming; in ReadRegisterNode() 78 …rNode(@InjectedNodeParameter Stamp stamp, Register register, boolean directUse, boolean incoming) { in ReadRegisterNode() argument 83 this.incoming = incoming; in ReadRegisterNode() 90 if (incoming) { in generate()
|