- Sort Score
- Result 10 results
- Languages All
Results 401 - 410 of 527 for channels (0.11 sec)
-
src/main/java/jcifs/smb/SIDCacheImpl.java
* to resolve SIDs using a cache and cache the results of any SIDs that * required resolving with the authority. SID cache entries are currently not * expired because under normal circumstances SID information never changes. * * @param authorityServerName * The hostname of the server that should be queried. For maximum efficiency this should be the hostname
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 12.6K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/Cache.java
* <p>Iterators from the returned map are at least <i>weakly consistent</i>: they are safe for * concurrent use, but if the cache is modified (including by eviction) after the iterator is * created, it is undefined which of the changes (if any) will be reflected in that iterator. * * <p><b>Warning to users of Java 8+:</b> do not call any of the new <i>default methods</i> that
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sun Aug 07 02:38:22 UTC 2022 - 8.3K bytes - Viewed (0) -
cmd/admin-handlers.go
return } setEventStreamHeaders(w) // Trace Publisher and peer-trace-client uses nonblocking send and hence does not wait for slow receivers. // Keep 100k buffered channel. // If receiver cannot keep up with that we drop events. traceCh := make(chan []byte, 100000) peers, _ := newPeerRestClients(globalEndpoints)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/PluginDescriptor.java
if (getMojos() == null) { return null; // no mojo in this POM } // TODO could we use a map? Maybe if the parent did that for components too, as this is too vulnerable to // changes above not being propagated to the map for (MojoDescriptor desc : getMojos()) { if (goal.equals(desc.getGoal())) { return desc; } } return null;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 16.2K bytes - Viewed (0) -
docs/fr/docs/tutorial/first-steps.md
### Étape 5 : retourner le contenu ```Python hl_lines="8" {!../../docs_src/first_steps/tutorial001.py!} ``` Vous pouvez retourner un dictionnaire (`dict`), une liste (`list`), des valeurs seules comme des chaines de caractères (`str`) et des entiers (`int`), etc. Vous pouvez aussi retourner des models **Pydantic** (qui seront détaillés plus tard).
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 10.3K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
log := repairLog.WithLabels("pod", pod.Namespace+"/"+pod.Name) key := types.NamespacedName{Name: pod.Name, Namespace: pod.Namespace} // We will get an event every time the pod changes. The repair is not instantaneous, though -- it will only recover // once the pod restarts (in CrashLoopBackoff), which can take some time.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
internal/rest/client.go
c.dumpHTTP(req, resp) } if resp.StatusCode != http.StatusOK { // If server returns 412 pre-condition failed, it would // mean that authentication succeeded, but another // side-channel check has failed, we shall take // the client offline in such situations. // generally all implementations should simply return // 403, but in situations where there is a dependency
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 14.7K bytes - Viewed (0) -
internal/s3select/jstream/decoder.go
// containing those values is emitted. func (d *Decoder) Recursive() *Decoder { d.emitRecursive = true return d } // Stream begins decoding from the underlying reader and returns a // streaming MetaValue channel for JSON values at the configured emitDepth. func (d *Decoder) Stream() chan *MetaValue { go d.decode() return d.metaCh } // Pos returns the number of bytes consumed from the underlying reader
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 13.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NameServiceClient.java
} void tryClose() { synchronized( LOCK ) { /* Yes, there is the potential to drop packets * because we might close the socket during a * request. However the chances are slim and the * retry code should ensure the overall request * is serviced. The alternative complicates things * more than I think is worth it. */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 17.4K bytes - Viewed (0) -
internal/grid/manager.go
"github.com/minio/minio/internal/pubsub" "github.com/minio/mux" ) const ( // apiVersion is a major version of the entire api. // Bumping this should only be done when overall, // incompatible changes are made, not when adding a new handler // or changing an existing handler. apiVersion = "v1" // RoutePath is the remote path to connect to. RoutePath = "/minio/grid/" + apiVersion
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 10.6K bytes - Viewed (0)