/dports/sysutils/helmfile/helmfile-0.138.7/vendor/github.com/hashicorp/vault/vendor/github.com/apple/foundationdb/bindings/go/src/fdb/ |
H A D | futures.go | 75 type future struct { struct 76 ptr *C.FDBFuture 103 func (f future) BlockUntilReady() { 107 func (f future) IsReady() bool { 111 func (f future) Cancel() { 135 *future anonMember 190 *future anonMember 241 *future anonMember 260 *future anonMember 316 *future anonMember [all …]
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/hashicorp/vault/vendor/github.com/apple/foundationdb/bindings/go/src/fdb/ |
H A D | futures.go | 75 type future struct { struct 76 ptr *C.FDBFuture 103 func (f future) BlockUntilReady() { 107 func (f future) IsReady() bool { 111 func (f future) Cancel() { 135 *future anonMember 190 *future anonMember 241 *future anonMember 260 *future anonMember 316 *future anonMember [all …]
|
/dports/sysutils/gomplate/vault-sdk-v0.1.13/vendor/github.com/apple/foundationdb/bindings/go/src/fdb/ |
H A D | futures.go | 75 type future struct { struct 76 ptr *C.FDBFuture 103 func (f future) BlockUntilReady() { 107 func (f future) IsReady() bool { 111 func (f future) Cancel() { 135 *future anonMember 190 *future anonMember 241 *future anonMember 260 *future anonMember 316 *future anonMember [all …]
|
/dports/devel/gitlab-runner/vault-sdk-v0.1.13/vendor/github.com/apple/foundationdb/bindings/go/src/fdb/ |
H A D | futures.go | 75 type future struct { struct 76 ptr *C.FDBFuture 103 func (f future) BlockUntilReady() { 107 func (f future) IsReady() bool { 111 func (f future) Cancel() { 135 *future anonMember 190 *future anonMember 241 *future anonMember 260 *future anonMember 316 *future anonMember [all …]
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/hashicorp/vault/vault-api-v1.0.4/vendor/github.com/apple/foundationdb/bindings/go/src/fdb/ |
H A D | futures.go | 75 type future struct { struct 76 ptr *C.FDBFuture 103 func (f future) BlockUntilReady() { 107 func (f future) IsReady() bool { 111 func (f future) Cancel() { 135 *future anonMember 190 *future anonMember 241 *future anonMember 260 *future anonMember 316 *future anonMember [all …]
|
/dports/sysutils/istio/vault-sdk-v0.1.12/vendor/github.com/apple/foundationdb/bindings/go/src/fdb/ |
H A D | futures.go | 75 type future struct { struct 76 ptr *C.FDBFuture 103 func (f future) BlockUntilReady() { 107 func (f future) IsReady() bool { 111 func (f future) Cancel() { 135 *future anonMember 190 *future anonMember 241 *future anonMember 260 *future anonMember 316 *future anonMember [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/bindings/go/src/fdb/ |
H A D | futures.go | 75 type future struct { struct 76 ptr *C.FDBFuture 103 func (f future) BlockUntilReady() { 107 func (f future) IsReady() bool { 111 func (f future) Cancel() { 135 *future anonMember 190 *future anonMember 241 *future anonMember 260 *future anonMember 316 *future anonMember [all …]
|
/dports/www/cpr/cpr-1.7.0/test/ |
H A D | callback_tests.cpp | 43 auto future = cpr::GetCallback( in TEST() local 57 auto future = cpr::GetCallback( in TEST() local 71 auto future = cpr::GetCallback( in TEST() local 85 auto future = cpr::GetCallback( in TEST() local 235 auto future = cpr::HeadCallback( in TEST() local 249 auto future = cpr::HeadCallback( in TEST() local 263 auto future = cpr::HeadCallback( in TEST() local 436 auto future = cpr::PutCallback( in TEST() local 451 auto future = cpr::PutCallback( in TEST() local 466 auto future = cpr::PutCallback( in TEST() local [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/ |
H A D | AsyncLoggerSet.java | 257 ListenableFuture<Void> future = in sendEdits() local 270 ListenableFuture<RemoteEditLogManifest> future = in getEditLogManifest() local 283 ListenableFuture<PrepareRecoveryResponseProto> future = in prepareRecovery() local 295 ListenableFuture<Void> future = in acceptRecovery() local 306 ListenableFuture<Void> future = in format() local 326 ListenableFuture<Void> future = in doPreUpgrade() local 337 ListenableFuture<Void> future = in doUpgrade() local 348 ListenableFuture<Void> future = in doFinalize() local 360 ListenableFuture<Boolean> future = in canRollBack() local 371 ListenableFuture<Void> future = in doRollback() local [all …]
|
/dports/lang/racket/racket-8.3/src/bc/src/ |
H A D | jit_ts_future_glue.c | 5 future_t *future; in scheme_rtcall_siS_s() local 32 future_t *future; in scheme_rtcall_iSs_s() local 59 future_t *future; in scheme_rtcall_s_s() local 84 future_t *future; in scheme_rtcall_n_s() local 109 future_t *future; in scheme_rtcall__s() local 134 future_t *future; in scheme_rtcall_ss_s() local 160 future_t *future; in scheme_rtcall_ssi_s() local 187 future_t *future; in scheme_rtcall_tt_s() local 213 future_t *future; in scheme_rtcall_ss_m() local 239 future_t *future; in scheme_rtcall_Sl_s() local [all …]
|
/dports/lang/racket-minimal/racket-8.3/src/bc/src/ |
H A D | jit_ts_future_glue.c | 5 future_t *future; in scheme_rtcall_siS_s() local 32 future_t *future; in scheme_rtcall_iSs_s() local 59 future_t *future; in scheme_rtcall_s_s() local 84 future_t *future; in scheme_rtcall_n_s() local 109 future_t *future; in scheme_rtcall__s() local 134 future_t *future; in scheme_rtcall_ss_s() local 160 future_t *future; in scheme_rtcall_ssi_s() local 187 future_t *future; in scheme_rtcall_tt_s() local 213 future_t *future; in scheme_rtcall_ss_m() local 239 future_t *future; in scheme_rtcall_Sl_s() local [all …]
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/catalog/ |
H A D | dist_lock_catalog_impl_test.cpp | 122 auto future = launchAsync([this] { in TEST_F() local 174 auto future = launchAsync([this] { in TEST_F() local 192 auto future = launchAsync([this] { in TEST_F() local 210 auto future = launchAsync([this] { in TEST_F() local 231 auto future = launchAsync([this] { in TEST_F() local 253 auto future = launchAsync([this] { in TEST_F() local 267 auto future = launchAsync([this] { in TEST_F() local 310 auto future = launchAsync([this] { in TEST_F() local 374 auto future = launchAsync([this] { in TEST_F() local 426 auto future = launchAsync([this] { in TEST_F() local [all …]
|
H A D | sharding_catalog_drop_coll_test.cpp | 184 auto future = launchAsync([this] { in TEST_F() local 213 auto future = launchAsync([this] { in TEST_F() local 267 auto future = launchAsync([this] { in TEST_F() local 282 auto future = launchAsync([this] { in TEST_F() local 298 auto future = launchAsync([this] { in TEST_F() local 319 auto future = launchAsync([this] { in TEST_F() local 347 auto future = launchAsync([this] { in TEST_F() local 365 auto future = launchAsync([this] { in TEST_F() local 388 auto future = launchAsync([this] { in TEST_F() local 410 auto future = launchAsync([this] { in TEST_F() local [all …]
|
/dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/examples/callbacks/ |
H A D | callbacks.c | 66 void print_error(CassFuture* future) { in print_error() 81 CassFuture* future = cass_session_connect(session, cluster); in connect_session() local 88 CassFuture* future = cass_session_execute(session, statement); in execute_query() local 94 void on_session_connect(CassFuture* future, void* data) { in on_session_connect() 110 void on_create_keyspace(CassFuture* future, void* data) { in on_create_keyspace() 119 void on_set_keyspace(CassFuture* future, void* data) { in on_set_keyspace() 131 void on_create_table(CassFuture* future, void* data) { in on_create_table() 157 void on_insert(CassFuture* future, void* data) { in on_insert() 174 void on_select(CassFuture* future, void* data) { in on_select()
|
/dports/net/py-mpi4py/mpi4py-3.1.3/src/mpi4py/futures/ |
H A D | aplus.py | 30 def then(future, on_success=None, on_failure=None): argument 65 def catch(future, on_failure=None): argument 80 def _chain_log(new_future, future): argument 100 def _chain_future(new_future, future): argument 117 def _done_cb(new_future, future, on_success=None, on_failure=None): argument
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/ |
H A D | MessageQueue.java | 113 CompletableFuture<T> future) in addText() 128 CompletableFuture<? super T> future) in add() 163 CompletableFuture<? super T> future) in addBinary() 173 CompletableFuture<? super T> future) in addPing() 183 CompletableFuture<? super T> future) in addPong() 193 CompletableFuture<? super T> future) in addPong() 204 CompletableFuture<? super T> future) in addClose() 318 CompletableFuture<? super T> future) throws E; in onText() 329 CompletableFuture<? super T> future) throws E; in onPing() 334 CompletableFuture<? super T> future) throws E; in onPong() [all …]
|
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/ |
H A D | MessageQueue.java | 113 CompletableFuture<T> future) in addText() 128 CompletableFuture<? super T> future) in add() 163 CompletableFuture<? super T> future) in addBinary() 173 CompletableFuture<? super T> future) in addPing() 183 CompletableFuture<? super T> future) in addPong() 193 CompletableFuture<? super T> future) in addPong() 204 CompletableFuture<? super T> future) in addClose() 318 CompletableFuture<? super T> future) throws E; in onText() 329 CompletableFuture<? super T> future) throws E; in onPing() 334 CompletableFuture<? super T> future) throws E; in onPong() [all …]
|
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/ |
H A D | MessageQueue.java | 113 CompletableFuture<T> future) in addText() 128 CompletableFuture<? super T> future) in add() 163 CompletableFuture<? super T> future) in addBinary() 173 CompletableFuture<? super T> future) in addPing() 183 CompletableFuture<? super T> future) in addPong() 193 CompletableFuture<? super T> future) in addPong() 204 CompletableFuture<? super T> future) in addClose() 318 CompletableFuture<? super T> future) throws E; in onText() 329 CompletableFuture<? super T> future) throws E; in onPing() 334 CompletableFuture<? super T> future) throws E; in onPong() [all …]
|
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/ |
H A D | MessageQueue.java | 113 CompletableFuture<T> future) in addText() 128 CompletableFuture<? super T> future) in add() 163 CompletableFuture<? super T> future) in addBinary() 173 CompletableFuture<? super T> future) in addPing() 183 CompletableFuture<? super T> future) in addPong() 193 CompletableFuture<? super T> future) in addPong() 204 CompletableFuture<? super T> future) in addClose() 318 CompletableFuture<? super T> future) throws E; in onText() 329 CompletableFuture<? super T> future) throws E; in onPing() 334 CompletableFuture<? super T> future) throws E; in onPong() [all …]
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/ |
H A D | MessageQueue.java | 113 CompletableFuture<T> future) in addText() 128 CompletableFuture<? super T> future) in add() 163 CompletableFuture<? super T> future) in addBinary() 173 CompletableFuture<? super T> future) in addPing() 183 CompletableFuture<? super T> future) in addPong() 193 CompletableFuture<? super T> future) in addPong() 204 CompletableFuture<? super T> future) in addClose() 318 CompletableFuture<? super T> future) throws E; in onText() 329 CompletableFuture<? super T> future) throws E; in onPing() 334 CompletableFuture<? super T> future) throws E; in onPong() [all …]
|
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.net.http/share/classes/jdk/internal/net/http/websocket/ |
H A D | MessageQueue.java | 113 CompletableFuture<T> future) in addText() 128 CompletableFuture<? super T> future) in add() 163 CompletableFuture<? super T> future) in addBinary() 173 CompletableFuture<? super T> future) in addPing() 183 CompletableFuture<? super T> future) in addPong() 193 CompletableFuture<? super T> future) in addPong() 204 CompletableFuture<? super T> future) in addClose() 318 CompletableFuture<? super T> future) throws E; in onText() 329 CompletableFuture<? super T> future) throws E; in onPing() 334 CompletableFuture<? super T> future) throws E; in onPong() [all …]
|
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/ |
H A D | MessageQueue.java | 113 CompletableFuture<T> future) in addText() 128 CompletableFuture<? super T> future) in add() 163 CompletableFuture<? super T> future) in addBinary() 173 CompletableFuture<? super T> future) in addPing() 183 CompletableFuture<? super T> future) in addPong() 193 CompletableFuture<? super T> future) in addPong() 204 CompletableFuture<? super T> future) in addClose() 318 CompletableFuture<? super T> future) throws E; in onText() 329 CompletableFuture<? super T> future) throws E; in onPing() 334 CompletableFuture<? super T> future) throws E; in onPong() [all …]
|
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/ |
H A D | MessageQueue.java | 113 CompletableFuture<T> future) in addText() 128 CompletableFuture<? super T> future) in add() 163 CompletableFuture<? super T> future) in addBinary() 173 CompletableFuture<? super T> future) in addPing() 183 CompletableFuture<? super T> future) in addPong() 193 CompletableFuture<? super T> future) in addPong() 204 CompletableFuture<? super T> future) in addClose() 318 CompletableFuture<? super T> future) throws E; in onText() 329 CompletableFuture<? super T> future) throws E; in onPing() 334 CompletableFuture<? super T> future) throws E; in onPong() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/nearby/src/cpp/platform/public/ |
H A D | future_test.cc | 52 Future<int> future; in TEST() local 59 Future<int> future; in TEST() local 65 Future<TestEnum> future; in TEST() local 72 Future<ScopedTestEnum> future; in TEST() local 81 Future<BigSizedStruct> future; in TEST() local 96 Future<int> future; in TEST() local 102 Future<int> future; in TEST() local
|
/dports/java/springframework31/spring-framework-3.1.4.RELEASE/projects/org.springframework.context/src/test/java/org/springframework/scheduling/concurrent/ |
H A D | ThreadPoolTaskSchedulerTests.java | 88 Future<?> future = scheduler.submit(task); in submitRunnable() local 97 Future<?> future = scheduler.submit(task); in submitFailingRunnableWithoutErrorHandler() local 112 Future<?> future = scheduler.submit(task); in submitFailingRunnableWithErrorHandler() local 122 Future<String> future = scheduler.submit(task); in submitCallable() local 130 Future<String> future = scheduler.submit(task); in submitFailingCallableWithoutErrorHandler() local 140 Future<String> future = scheduler.submit(task); in submitFailingCallableWithErrorHandler() local 150 Future<?> future = scheduler.schedule(task, new Date()); in scheduleOneTimeTask() local 160 Future<?> future = scheduler.schedule(task, new Date()); in scheduleOneTimeFailingTaskWithoutErrorHandler() local 175 Future<?> future = scheduler.schedule(task, new Date()); in scheduleOneTimeFailingTaskWithErrorHandler() local 185 Future<?> future = scheduler.schedule(task, new TestTrigger(3)); in scheduleTriggerTask() local
|