Home
last modified time | relevance | path

Searched refs:incoming (Results 201 – 225 of 25036) sorted by relevance

12345678910>>...1002

/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/websocket/
H A DBlowupOutputQueue.java73 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 DBlowupOutputQueue.java73 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 DBlowupOutputQueue.java73 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 DBlowupOutputQueue.java73 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 DBlowupOutputQueue.java73 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 Dstream.py297 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 Dserver.rs69 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 Dserver.rs69 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 D01-ltl2ba-fix-simplify-bstates--trivial-sccs.patch16 + * (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 Dtest_socks5.py26 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 Dnotifyman.py51 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 Dwriter.go145 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 Dphasefunction.h42 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 DExchangeAutoDiscover.jsm328 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 Dremote.c101 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 Dserver.go108 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 DMSMilter187 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 DModelChangeElement.java38 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 Dwriter.go159 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 Dping.go85 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 Dping.go85 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 Dtest-bundle2-multiple-changegroups.t71 > 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 Dutppolltest.cpp29 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 Ddispatcher.py232 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 DReadRegisterNode.java68 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()

12345678910>>...1002