- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 3,854 for Sall (0.17 sec)
-
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* we must return it in the following next() call even if it was in the process of being removed * when hasNext() was called. */ private @Nullable E nextItem; /** * Index of element returned by most recent call to next. Reset to -1 if this element is deleted * by a call to remove. */ private int lastRet; Itr() { lastRet = -1;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 22.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* {@link MoreExecutors#directExecutor}. Normally, when the first future completes, all the other * tasks would be called recursively. Here, we detect that the delegate executor is executing * inline, and maintain a queue to dispatch tasks iteratively. There is one instance of this class * per call to submit() or submitAsync(), and each instance supports only one call to execute(). *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0) -
doc/go_mem.html
and the matching call to <code>l.RUnlock</code> is synchronized before the return from call <i>n</i>+1 to <code>l.Lock</code>. </p> <p class="rule"> A successful call to <code>l.TryLock</code> (or <code>l.TryRLock</code>) is equivalent to a call to <code>l.Lock</code> (or <code>l.RLock</code>). An unsuccessful call has no synchronizing effect at all. As far as the memory model is concerned,
HTML - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Mar 04 15:54:42 GMT 2024 - 26.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt
server.requestClientAuth() server.enqueue( MockResponse.Builder() .body("abc") .build(), ) val call = client.newCall(Request.Builder().url(server.url("/")).build()) val response = call.execute() assertThat(response.handshake!!.peerPrincipal) .isEqualTo(X500Principal("CN=Local Host")) assertThat(response.handshake!!.localPrincipal)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
err error ) if options.XdsViaAgents { responses, err = queryDebugSynczViaAgents(all, dr, istioNamespace, kubeClient, centralOpts, options) } else { // Self-administered case. Find all Istiods in revision using K8s, port-forward and call each in turn responses, err = queryEachShard(all, dr, istioNamespace, kubeClient, centralOpts) } if err != nil { if _, ok := err.(ControlPlaneNotFoundError); ok {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
common/config/.golangci.yml
# with golangci-lint call it on a directory with the changed file. check-exported: false gci: sections: - standard # Captures all standard packages if they do not match another section. - default # Contains all imports that could not be matched to another section type. - prefix(istio.io/) # Groups all imports with the specified Prefix.
Others - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 19:22:39 GMT 2024 - 11K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/utils/InlineFunctionAnalyzer.kt
super.visitExpression(expression) val bindingContext = analysisContext.analyze(expression) val call = bindingContext.get(BindingContext.CALL, expression) ?: return val resolvedCall = bindingContext.get(BindingContext.RESOLVED_CALL, call) collector.checkResolveCall(resolvedCall) }
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Aug 29 23:55:31 GMT 2023 - 5.1K bytes - Viewed (0) -
cmd/service.go
argv0, err := exec.LookPath(os.Args[0]) if err != nil { return err } // Invokes the execve system call. // Re-uses the same pid. This preserves the pid over multiple server-respawns. return syscall.Exec(argv0, os.Args, os.Environ()) } // freezeServices will freeze all incoming S3 API calls. // For each call, unfreezeServices must be called once. func freezeServices() {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/grid/README.md
// The typed instance is also used for calls conn := manager.Connection("host") resp, err := instance.Call(ctx, conn, grid.NewMSSWith(map[string]string{"myfield": "myvalue"})) if err == nil { fmt.Println("Got response with field", resp["result"]) } ``` The wrapper will handle all serialization and de-seralization of the request and response,
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
guava/src/com/google/common/cache/Cache.java
* value. Otherwise, a call that passes one {@code loader} may return the result of another call * with a differently behaving {@code loader}. For example, a call that requests a short timeout * for an RPC may wait for a similar call that requests a long timeout, or a call by an * unprivileged user may return a resource accessible only to a privileged user making a similar
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sun Aug 07 02:38:22 GMT 2022 - 7.9K bytes - Viewed (0)