- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 148 for __callback (0.19 sec)
-
src/runtime/syscall_windows.go
cbsLock() // Check if this callback is already registered. if n, ok := cbs.index[key]; ok { cbsUnlock() return callbackasmAddr(n) } // Register the callback. if cbs.index == nil { cbs.index = make(map[winCallbackKey]int) } n := cbs.n if n >= len(cbs.ctxt) { cbsUnlock() throw("too many callback functions") } c := winCallback{key.fn, retPop, abiMap}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:12:46 UTC 2024 - 16.6K bytes - Viewed (0) -
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
import kotlinx.coroutines.withContext import kotlinx.coroutines.withTimeout import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import mockwebserver3.SocketPolicy.DisconnectAfterRequest import okhttp3.Callback import okhttp3.FailingCall import okhttp3.HttpUrl.Companion.toHttpUrl import okhttp3.OkHttpClientTestRule import okhttp3.Protocol import okhttp3.Request import okhttp3.Response import okhttp3.ResponseBody
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
tests := []struct { name string opCallback func(asw ActualStateOfWorld, volumeOpts operationexecutor.MarkVolumeOpts) error verifyCallback func(asw ActualStateOfWorld, volumeOpts operationexecutor.MarkVolumeOpts) error }{ { name: "marking volume mounted should remove volume from found during reconstruction", opCallback: func(asw ActualStateOfWorld, volumeOpts operationexecutor.MarkVolumeOpts) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor.cc
return base; } // Wrapper that allows passing std::function across C API. struct HostCallbackContext { absl::AnyInvocable<absl::Status() &&> callback; }; // This wrapper allows calling `HostCallbackContext::callback` across C API. // This function matches `SE_StatusCallbackFn` signature and will be passed as // `callback_fn` to `host_callback` in `SP_StreamExecutor`.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 27.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
responseCallback.onResponse(this@RealCall, response) } catch (e: IOException) { if (signalledCallback) { // Do not signal the callback twice! Platform.get().log("Callback failure for ${toLoggableString()}", Platform.INFO, e) } else { responseCallback.onFailure(this@RealCall, e) } } catch (t: Throwable) { cancel()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/waiting_pods_map.go
defer m.mu.RUnlock() return m.pods[uid] } // iterate acquires a read lock and iterates over the WaitingPods map. func (m *waitingPodsMap) iterate(callback func(framework.WaitingPod)) { m.mu.RLock() defer m.mu.RUnlock() for _, v := range m.pods { callback(v) } } // waitingPod represents a pod waiting in the permit phase. type waitingPod struct { pod *v1.Pod pendingPlugins map[string]*time.Timer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 4.5K bytes - Viewed (0) -
src/runtime/coro_test.go
checkCoroTestProgOutput(t, runTestProg(t, "testprog", test)) }) } } func TestCoroCgoCallback(t *testing.T) { testenv.MustHaveCGO(t) if runtime.GOOS == "windows" { t.Skip("coro cgo callback tests not supported on Windows") } for _, test := range []string{ "CoroCgoIterCallback", "CoroCgoIterCallbackYield", "CoroCgoCallback", "CoroCgoCallbackIterNested", "CoroCgoCallbackIterCallback",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 21:36:37 UTC 2024 - 1.9K bytes - Viewed (0) -
src/testing/newcover.go
if mode == "" { return } cover2.mode = mode cover2.tearDown = tearDown cover2.snapshotcov = snapcov } // coverReport2 invokes a callback in _testmain.go that will // emit coverage data at the point where test execution is complete, // for "go test -cover" runs. func coverReport2() { if !goexperiment.CoverageRedesign { panic("unexpected") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 09:58:07 UTC 2024 - 1.6K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/test/groovy/org/gradle/api/internal/provider/DefaultValueSourceProviderFactoryTest.groovy
} when: "value is obtained for the 1st time" provider.get() then: "beforeValueObtained callback is notified" 1 * computationListener.beforeValueObtained() then: "afterValueObtained callback is notified" 1 * computationListener.afterValueObtained() then: "valueObtained is notified" obtainedValues.size() == 1
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 08:26:25 UTC 2024 - 10.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filterlatency/filterlatency_test.go
if handlerCallCount != 1 { t.Errorf("expected the given handler to be invoked once, but was actually invoked %d times", handlerCallCount) } if actionCallCount != 1 { t.Errorf("expected the action callback to be invoked once, but was actually invoked %d times", actionCallCount) } if filterRecordGot == nil { t.Fatal("expected a filter record in the request context, but got nil") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 7.1K bytes - Viewed (0)