- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 6,372 for callB (0.09 sec)
-
docs/features/events.md
} @Override public void callStart(Call call) { printEvent("callStart"); } @Override public void callEnd(Call call) { printEvent("callEnd"); } @Override public void dnsStart(Call call, String domainName) { printEvent("dnsStart"); } @Override public void dnsEnd(Call call, String domainName, List<InetAddress> inetAddressList) { printEvent("dnsEnd");
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 7.7K bytes - Viewed (0) -
pilot/pkg/networking/core/serviceentry_simulation_test.go
cases := []simulationTest{ { name: "service entries with reused hosts should have auto allocated the same IP address", config: serviceEntriesWithDuplicatedHosts, calls: []simulation.Expect{ { Name: "HTTP call", Call: simulation.Call{ Address: "240.240.91.120", Port: 80, HostHeader: "istio.io", Protocol: simulation.HTTP, }, Result: simulation.Result{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 21:06:06 UTC 2024 - 4.9K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway_simulation_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 18:27:40 UTC 2024 - 46.5K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
} { calls = append(calls, simulation.Expect{ Name: fmt.Sprintf("%s-%d", call.call.Protocol, call.call.Port), Call: call.call, Result: simulation.Result{ ClusterMatched: fmt.Sprintf("outbound|%d||%s.default.svc.cluster.local", call.call.Port, call.expected), }, }) } service := `apiVersion: v1 kind: Service metadata: name: alias namespace: default spec:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
src/sync/oncefunc_test.go
func TestOnceFunc(t *testing.T) { calls := 0 f := sync.OnceFunc(func() { calls++ }) allocs := testing.AllocsPerRun(10, f) if calls != 1 { t.Errorf("want calls==1, got %d", calls) } if allocs != 0 { t.Errorf("want 0 allocations per call, got %v", allocs) } } func TestOnceValue(t *testing.T) { calls := 0 f := sync.OnceValue(func() int { calls++ return calls })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 17:31:33 UTC 2023 - 6.9K bytes - Viewed (0) -
src/net/rpc/client.go
} else { err = io.ErrUnexpectedEOF } } for _, call := range client.pending { call.Error = err call.done() } client.mutex.Unlock() client.reqMutex.Unlock() if debugLog && err != io.EOF && !closing { log.Println("rpc: client protocol error:", err) } } func (call *Call) done() { select { case call.Done <- call: // ok default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9K bytes - Viewed (0) -
src/log/slog/logger.go
// Before [SetDefault] is called, slog top-level logging functions call the default [log.Logger]. // In that mode, SetLogLoggerLevel sets the minimum level for those calls. // By default, the minimum level is Info, so calls to [Debug] // (as well as top-level logging calls at lower levels) // will not be passed to the log.Logger. After calling // // slog.SetLogLoggerLevel(slog.LevelDebug) // // calls to [Debug] will be passed to the log.Logger. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 08 18:26:18 UTC 2024 - 10.2K bytes - Viewed (0) -
src/sync/once.go
// arguments to a function to be invoked by Do: // // config.once.Do(func() { config.init(filename) }) // // Because no call to Do returns until the one call to f returns, if f causes // Do to be called, it will deadlock. // // If f panics, Do considers it to have returned; future calls of Do return // without calling f. func (o *Once) Do(f func()) { // Note: Here is an incorrect implementation of Do: //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 2.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
return copy(writeTimeoutMillis = checkDuration("writeTimeout", timeout.toLong(), unit)) } override fun call(): Call = call override fun request(): Request = request @Throws(IOException::class) override fun proceed(request: Request): Response { check(index < interceptors.size) calls++ if (exchange != null) { check(exchange.finder.routePlanner.sameHostAndPort(request.url)) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingExecutor.kt
} fun finishJob(url: String) { val i = calls.iterator() while (i.hasNext()) { val call = i.next() if (call.request.url.toString() == url) { i.remove() dispatcherTest.dispatcher.finishedAccessor(call) return } } throw AssertionError("No such job: $url") } override fun shutdown() { shutdown = true } override fun shutdownNow(): List<Runnable> {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0)