Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 408 for chain (0.04 sec)

  1. cmd/sftp-server-driver.go

    		defer cancel()
    
    		if prefix == "" {
    			// if all objects are not deleted yet this call may fail.
    			return clnt.RemoveBucket(cctx, bucket)
    		}
    
    		objectsCh := make(chan minio.ObjectInfo)
    
    		// Send object names that are needed to be removed to objectsCh
    		go func() {
    			defer xioutil.SafeClose(objectsCh)
    			opts := minio.ListObjectsOptions{
    				Prefix:    prefix,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java

         * We overload this method from ServerMessageBlock because
         * we want writeAndXWireFormat to write the parameterWords
         * and bytes. This is so we can write batched smbs because
         * all but the first smb of the chaain do not have a header
         * and therefore we do not want to writeHeaderWireFormat. We
         * just recursivly call writeAndXWireFormat.
         */
    
        @Override
        public int encode ( byte[] dst, int dstIndex ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Nov 28 10:56:27 UTC 2022
    - 14.3K bytes
    - Viewed (0)
  3. docs/fr/docs/python-types.md

    <img src="/img/python-types/image04.png">
    
    Maintenant que vous avez connaissance du problème, convertissez `age` en <abbr title="string">chaîne de caractères</abbr> grâce à `str(age)` :
    
    {*../../docs_src/python_types/tutorial004.py hl[2] *}
    
    ## Déclarer des types
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:21:34 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableList.java

    import jsinterop.annotations.JsMethod;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * GWT emulated version of {@link com.google.common.collect.ImmutableList}. TODO(cpovirk): more doc
     *
     * @author Hayward Chan
     */
    @SuppressWarnings("serial") // we're overriding default serialization
    @ElementTypesAreNonnullByDefault
    public abstract class ImmutableList<E> extends ImmutableCollection<E>
        implements List<E>, RandomAccess {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 22:14:46 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_test.go

    		rng.Shuffle(len(vers), func(i, j int) {
    			vers[i], vers[j] = vers[j], vers[i]
    		})
    		var entries []chan metaCacheEntry
    		for _, v := range vers {
    			v.cached = nil
    			ch := make(chan metaCacheEntry, 1)
    			ch <- v
    			close(ch)
    			entries = append(entries, ch)
    		}
    		out := make(chan metaCacheEntry, 1)
    		err := mergeEntryChannels(context.Background(), entries, out, 1)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  6. cni/pkg/repair/repaircontroller.go

    		controllers.WithReconciler(c.Reconcile),
    		controllers.WithMaxAttempts(5))
    	c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject))
    
    	return c, nil
    }
    
    func (c *Controller) Run(stop <-chan struct{}) {
    	kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced)
    	c.queue.Run(stop)
    	c.pods.ShutdownHandlers()
    }
    
    func (c *Controller) Reconcile(key types.NamespacedName) error {
    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. cmd/metacache-entries.go

    // The entry not chosen will be discarded.
    // If the context is canceled the function will return the error,
    // otherwise the function will return nil.
    func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error {
    	defer xioutil.SafeClose(out)
    	top := make([]*metaCacheEntry, len(in))
    	nDone := 0
    	ctxDone := ctx.Done()
    
    	// Use simpler forwarder.
    	if len(in) == 1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/collect/testing/google/SetGenerators.java

    import java.util.Set;
    import java.util.SortedSet;
    
    /**
     * Generators of different types of sets and derived collections from sets.
     *
     * @author Kevin Bourrillion
     * @author Jared Levy
     * @author Hayward Chan
     */
    @GwtCompatible(emulated = true)
    @ElementTypesAreNonnullByDefault
    public class SetGenerators {
    
      public static class ImmutableSetCopyOfGenerator extends TestStringSetGenerator {
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/google/SetGenerators.java

    import java.util.Set;
    import java.util.SortedSet;
    
    /**
     * Generators of different types of sets and derived collections from sets.
     *
     * @author Kevin Bourrillion
     * @author Jared Levy
     * @author Hayward Chan
     */
    @GwtCompatible(emulated = true)
    @ElementTypesAreNonnullByDefault
    public class SetGenerators {
    
      public static class ImmutableSetCopyOfGenerator extends TestStringSetGenerator {
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  10. internal/grid/manager.go

    	Hosts        []string      // All hosts, including local in the grid.
    	Incoming     func(n int64) // Record incoming bytes.
    	Outgoing     func(n int64) // Record outgoing bytes.
    	BlockConnect chan struct{} // If set, incoming and outgoing connections will be blocked until closed.
    	RoutePath    string
    	TraceTo      *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]
    	Dialer       ConnDialer
    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