/dports/databases/py-pymemcache/pymemcache-3.5.0/pymemcache/test/ |
H A D | test_rendezvous.py | 7 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.py | 33 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 D | single_threaded_task_queue_unittest.cc | 70 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 D | single_threaded_task_queue_unittest.cc | 70 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 D | single_threaded_task_queue_unittest.cc | 70 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.py | 75 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.py | 75 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.py | 74 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 D | packages.scm | 13 (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.py | 76 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 D | vileget | 143 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 D | vileget | 143 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 D | DHTPluginContactImpl.java | 150 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 D | main.c | 176 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 D | thread.tex | 528 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 D | rendezvous.h | 14 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 D | smsotpd.pl | 41 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 D | iodemo-unix.pl | 8 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 D | tailing.py | 40 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 D | README.md | 18 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 D | rendezvous.go | 65 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 D | Combat.lua | 131 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 D | waitfor.hpp | 122 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 D | waitfor.hpp | 122 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 D | waitfor.hpp | 122 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()
|