Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 527 for channels (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top