Home
last modified time | relevance | path

Searched refs:rendezvous (Results 1 – 25 of 1430) sorted by relevance

12345678910>>...58

/dports/databases/py-pymemcache/pymemcache-3.5.0/pymemcache/test/
H A Dtest_rendezvous.py7 rendezvous = RendezvousHash()
8 assert 0 == len(rendezvous.nodes)
28 rendezvous = RendezvousHash()
29 rendezvous.add_node('1')
32 rendezvous.add_node('1')
35 rendezvous.add_node('2')
38 rendezvous.add_node('1')
47 rendezvous.remove_node('2')
56 rendezvous.remove_node('1')
59 rendezvous.remove_node('0')
[all …]
/dports/devel/py-grpcio-gcp/grpcio-gcp-0.2.2/grpc_gcp/
H A D_channel.py33 def __call__(self, rendezvous): argument
34 if rendezvous.code() is grpc.StatusCode.OK:
36 self._channel, self._key, rendezvous.result(), rendezvous)
43 def __init__(self, rendezvous): argument
45 self._rendezvous = rendezvous
244 return response, rendezvous
255 return rendezvous
283 return rendezvous
323 return response, rendezvous
340 return rendezvous
[all …]
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/test/
H A Dsingle_threaded_task_queue_unittest.cc70 rtc::Event rendezvous(true, false); in TEST() local
71 task_queue.PostTask([&rendezvous]() { in TEST()
72 ASSERT_TRUE(rendezvous.Wait(kMaxWaitTimeMs)); in TEST()
83 rendezvous.Set(); // Release the task-queue. in TEST()
128 rtc::Event rendezvous(true, false); in TEST() local
129 task_queue.PostTask([&rendezvous]() { in TEST()
264 rtc::Event rendezvous(true, false); in TEST() local
265 task_queue.PostTask([&rendezvous]() { in TEST()
281 rendezvous.Set(); in TEST()
294 rtc::Event rendezvous(true, false); in TEST() local
[all …]
/dports/www/firefox-esr/firefox-91.8.0/third_party/libwebrtc/webrtc/test/
H A Dsingle_threaded_task_queue_unittest.cc70 rtc::Event rendezvous(true, false); in TEST() local
71 task_queue.PostTask([&rendezvous]() { in TEST()
72 ASSERT_TRUE(rendezvous.Wait(kMaxWaitTimeMs)); in TEST()
83 rendezvous.Set(); // Release the task-queue. in TEST()
128 rtc::Event rendezvous(true, false); in TEST() local
129 task_queue.PostTask([&rendezvous]() { in TEST()
264 rtc::Event rendezvous(true, false); in TEST() local
265 task_queue.PostTask([&rendezvous]() { in TEST()
281 rendezvous.Set(); in TEST()
294 rtc::Event rendezvous(true, false); in TEST() local
[all …]
/dports/lang/spidermonkey78/firefox-78.9.0/media/webrtc/trunk/webrtc/test/
H A Dsingle_threaded_task_queue_unittest.cc70 rtc::Event rendezvous(true, false); in TEST() local
71 task_queue.PostTask([&rendezvous]() { in TEST()
72 ASSERT_TRUE(rendezvous.Wait(kMaxWaitTimeMs)); in TEST()
83 rendezvous.Set(); // Release the task-queue. in TEST()
128 rtc::Event rendezvous(true, false); in TEST() local
129 task_queue.PostTask([&rendezvous]() { in TEST()
264 rtc::Event rendezvous(true, false); in TEST() local
265 task_queue.PostTask([&rendezvous]() { in TEST()
281 rendezvous.Set(); in TEST()
294 rtc::Event rendezvous(true, false); in TEST() local
[all …]
/dports/devel/grpc130/grpc-1.30.2/src/python/grpcio_tests/tests/health_check/
H A D_health_servicer_test.py75 rendezvous = self._stub.Watch(request)
77 args=(rendezvous, response_queue))
84 rendezvous.cancel()
94 rendezvous = self._stub.Watch(request)
115 rendezvous.cancel()
122 rendezvous = self._stub.Watch(request)
136 rendezvous.cancel()
184 rendezvous = self._stub.Watch(request)
193 rendezvous.cancel()
211 rendezvous = self._stub.Watch(request)
[all …]
/dports/devel/grpc134/grpc-1.34.1/src/python/grpcio_tests/tests/health_check/
H A D_health_servicer_test.py75 rendezvous = self._stub.Watch(request)
77 args=(rendezvous, response_queue))
84 rendezvous.cancel()
94 rendezvous = self._stub.Watch(request)
115 rendezvous.cancel()
122 rendezvous = self._stub.Watch(request)
136 rendezvous.cancel()
184 rendezvous = self._stub.Watch(request)
193 rendezvous.cancel()
211 rendezvous = self._stub.Watch(request)
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/python/grpcio_tests/tests/health_check/
H A D_health_servicer_test.py74 rendezvous = self._stub.Watch(request)
76 target=_consume_responses, args=(rendezvous, response_queue))
83 rendezvous.cancel()
93 rendezvous = self._stub.Watch(request)
114 rendezvous.cancel()
121 rendezvous = self._stub.Watch(request)
135 rendezvous.cancel()
183 rendezvous = self._stub.Watch(request)
192 rendezvous.cancel()
210 rendezvous = self._stub.Watch(request)
[all …]
/dports/lang/scheme48/scheme48-1.9.2/scheme/cml/
H A Dpackages.scm13 (define-structures ((rendezvous rendezvous-interface)
27 (files rendezvous))
33 rendezvous make-rendezvous
43 rendezvous
55 trans-ids rendezvous make-rendezvous
65 trans-ids rendezvous make-rendezvous
/dports/devel/grpc/grpc-1.42.0/src/python/grpcio_tests/tests/health_check/
H A D_health_servicer_test.py76 rendezvous = self._stub.Watch(request)
78 args=(rendezvous, response_queue))
85 rendezvous.cancel()
95 rendezvous = self._stub.Watch(request)
116 rendezvous.cancel()
123 rendezvous = self._stub.Watch(request)
137 rendezvous.cancel()
185 rendezvous = self._stub.Watch(request)
194 rendezvous.cancel()
212 rendezvous = self._stub.Watch(request)
[all …]
/dports/editors/xvile/vile-9.8v/perl/
H A Dvileget143 our $rendezvous = "$ENV{HOME}/.vilesock";
144 $rendezvous = "$ENV{VILESOCK}" if ( defined( $ENV{VILESOCK} ) );
145 $rendezvous = $opt_s if ( defined($opt_s) );
149 if ( !connect( SOCK, sockaddr_un($rendezvous) ) ) {
177 !( connect( SOCK, sockaddr_un($rendezvous) ) ) && $tries < 5 ;
/dports/editors/vile/vile-9.8v/perl/
H A Dvileget143 our $rendezvous = "$ENV{HOME}/.vilesock";
144 $rendezvous = "$ENV{VILESOCK}" if ( defined( $ENV{VILESOCK} ) );
145 $rendezvous = $opt_s if ( defined($opt_s) );
149 if ( !connect( SOCK, sockaddr_un($rendezvous) ) ) {
177 !( connect( SOCK, sockaddr_un($rendezvous) ) ) && $tries < 5 ;
/dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/plugins/dht/impl/
H A DDHTPluginContactImpl.java150 DHTPluginContact[] rendezvous, in openTunnel() argument
160 if ( rendezvous == null || rendezvous.length == 0 ){ in openTunnel()
166 DHTTransportContact[] r = new DHTTransportContact[rendezvous.length]; in openTunnel()
170 r[0] = ((DHTPluginContactImpl)rendezvous[i]).contact; in openTunnel()
179 rendezvous[0] = new DHTPluginContactImpl( plugin, used ); in openTunnel()
/dports/devel/dfuife-curses/dfuife-curses-1.5.1.20050829/
H A Dmain.c176 char *rendezvous = NULL; in main() local
192 rendezvous = aura_strdup(optarg); in main()
208 if (rendezvous == NULL) { in main()
210 rendezvous = aura_strdup("9999"); in main()
212 rendezvous = aura_strdup("test"); in main()
264 c = dfui_connection_new(transport, rendezvous); in main()
411 if (rendezvous != NULL) in main()
412 free(rendezvous); in main()
/dports/lang/scheme48/scheme48-1.9.2/doc/src/
H A Dthread.tex528 The basic rendezvous combinators live in the \code{rendezvous}
532 \constproto{never-rv}{rendezvous}
533 \proto{always-rv}{ value}{rendezvous}
543 \proto{choose}{ rendezvous \ldots}{rendezvous}
553 \proto{wrap}{ rendezvous proc}{rendezvous}
557 When the resulting rendezvous is synchronized, \cvar{rendezvous} is
563 \proto{guard}{ thunk}{rendezvous}
573 \proto{with-nack}{ proc}{rendezvous}
586 \proto{sync}{ rendezvous}{value}
655 \code{rendezvous-placeholders}.
[all …]
/dports/games/retroarch/RetroArch-1.9.7/wiiu/include/wiiu/os/
H A Drendezvous.h14 void OSInitRendezvous(OSRendezvous *rendezvous);
15 BOOL OSWaitRendezvous(OSRendezvous *rendezvous, uint32_t coreMask);
16 BOOL OSWaitRendezvousWithTimeout(OSRendezvous *rendezvous, uint32_t coreMask, OSTime timeout);
/dports/net/freeradius3/freeradius-server-3.0.25/src/modules/rlm_smsotp/
H A Dsmsotpd.pl41 my $rendezvous = shift;
48 heap => {rendezvous => $rendezvous,},
56 unlink $heap->{rendezvous} if -e $heap->{rendezvous};
59 BindAddress => $heap->{rendezvous},
/dports/x11-toolkits/vdk/vdk-2.5.1/example/iotut/
H A Diodemo-unix.pl8 my $rendezvous = shift or die "No socket name";
14 unlink $rendezvous;
26 Local => $rendezvous,
/dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/api_lib/logging/
H A Dtailing.py40 def _HandleGrpcRendezvous(rendezvous, output_debug, output_warning): argument
57 if rendezvous.code() == grpc.StatusCode.CANCELLED:
60 output_debug(rendezvous)
62 error_messages_by_code.get(rendezvous.code(),
64 rendezvous.details()))
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/matrix-org/go-http-js-libp2p/
H A DREADME.md18 The tests will spin up a rendezvous server. For reference, you can spin one up like this:
21 npm install --global libp2p-websocket-star-rendezvous
22 rendezvous --port=9090 --host=127.0.0.1
/dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/client/lib/
H A Drendezvous.go65 var rendezvous RendezvousMethod
68 rendezvous, err = newAMPCacheRendezvous(broker, ampCache, front, createBrokerTransport())
70 rendezvous, err = newHTTPRendezvous(broker, front, createBrokerTransport())
77 Rendezvous: rendezvous,
/dports/games/pioneer/pioneer-20210723/data/modules/Combat/
H A DCombat.lua131 if ad.rendezvous then
132 …form:SetMessage(string.interp(l.MEET_ME_THERE, { rendezvous = ad.rendezvous:GetStarSystem().name }…
151 rendezvous = ad.rendezvous,
205 local rendezvous = nil
226 rendezvous = nearbysystems[Engine.rand:Integer(1, #nearbysystems)]
239 rendezvous = rendezvous and rendezvous.path,
426 if mission.rendezvous and mission.rendezvous:IsSameSystem(Game.system.path) then
462 …if not mission.rendezvous and (mission.flavour.is_multi or mission.faction == Game.system.faction.…
533 local paymentLoc = mission.rendezvous and ui.Format.SystemPath(mission.rendezvous)
/dports/devel/hyperscan/boost_1_75_0/boost/fiber/hip/
H A Dwaitfor.hpp122 detail::single_stream_rendezvous rendezvous( st); in waitfor_all() local
123 return rendezvous.wait(); in waitfor_all()
129 detail::many_streams_rendezvous rendezvous{ st0, stx ... }; in waitfor_all() local
130 return rendezvous.wait(); in waitfor_all()
/dports/devel/hyperscan/boost_1_75_0/boost/fiber/cuda/
H A Dwaitfor.hpp122 detail::single_stream_rendezvous rendezvous( st); in waitfor_all() local
123 return rendezvous.wait(); in waitfor_all()
129 detail::many_streams_rendezvous rendezvous{ st0, stx ... }; in waitfor_all() local
130 return rendezvous.wait(); in waitfor_all()
/dports/science/py-scipy/scipy-1.7.1/scipy/_lib/boost/boost/fiber/hip/
H A Dwaitfor.hpp122 detail::single_stream_rendezvous rendezvous( st); in waitfor_all() local
123 return rendezvous.wait(); in waitfor_all()
129 detail::many_streams_rendezvous rendezvous{ st0, stx ... }; in waitfor_all() local
130 return rendezvous.wait(); in waitfor_all()

12345678910>>...58