Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 206 for blocker (0.19 sec)

  1. cmd/bucket-metadata-sys.go

    	g := errgroup.WithNErrs(len(buckets))
    	bucketMetas := make([]BucketMetadata, len(buckets))
    	for index := range buckets {
    		index := index
    		g.Go(func() error {
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    			time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond))))
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. javadoc-stylesheet.css

    }
    h1.hidden {
        visibility:hidden;
        overflow:hidden;
        font-size:.9em;
    }
    .block {
        display:block;
        margin:3px 0 0 0;
    }
    .strong {
        font-weight:bold;
    }
    
    /*
     Fixes for a number of issues with the default stylesheet.
     */
    
    /* Fixes huge font size in <pre>{@code} blocks. */
    pre code {
        font-size:inherit;
    }
    
    /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 17 21:01:06 UTC 2013
    - 11.2K bytes
    - Viewed (0)
  3. cmd/local-locker_test.go

    	}
    	// A UID is added for every resource.
    	// We removed Add Rlocked entries
    	if len(l.lockUID) != len(wResources)*m {
    		t.Fatalf("lockUID len, got %d, want %d + %d", len(l.lockUID), 0, len(wResources)*m)
    	}
    
    	// Remove write locked
    	for i, names := range wResources {
    		arg := dsync.LockArgs{
    			UID:       wUIDs[i],
    			Resources: names[:],
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.6.md

        * Leaked File descriptors ([#275](https://github.com/docker/containerd/issues/275))
        * Additional memory overhead per container ([#21737](https://github.com/docker/docker/issues/21737))
      * Docker 1.10.3 contains [backports provided by RedHat](https://github.com/docker/docker/compare/v1.10.3...runcom:docker-1.10.3-stable) for known issues
      * Support for Docker version 1.9.x has been removed
    * rkt version 1.23.0+
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 304K bytes
    - Viewed (0)
  6. internal/disk/stat_linux.go

    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := s.Bfree - s.Bavail
    	info = Info{
    		Total: uint64(s.Frsize) * (s.Blocks - reservedBlocks),
    		Free:  uint64(s.Frsize) * s.Bavail,
    		Files: s.Files,
    		Ffree: s.Ffree,
    		//nolint:unconvert
    		FSType: getFSType(int64(s.Type)),
    	}
    
    	st := syscall.Stat_t{}
    	err = syscall.Stat(path, &st)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  7. internal/kms/config.go

    			b, err := os.ReadFile(env.Get(EnvKMSSecretKeyFile, ""))
    			if err != nil && !os.IsNotExist(err) {
    				return nil, err
    			}
    			if os.IsNotExist(err) {
    				// Relative path where "/run/secrets" is the default docker path for secrets
    				b, err = os.ReadFile(filepath.Join("/run/secrets", env.Get(EnvKMSSecretKeyFile, "")))
    			}
    			if err != nil {
    				return nil, err
    			}
    			s = string(b)
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  8. src/archive/tar/reader.go

    	return paxHdrs, nil
    }
    
    // readHeader reads the next block header and assumes that the underlying reader
    // is already aligned to a block boundary. It returns the raw block of the
    // header in case further processing is required.
    //
    // The err will be set to io.EOF only when one of the following occurs:
    //   - Exactly 0 bytes are read and EOF is hit.
    //   - Exactly 1 block of zeros is read and EOF is hit.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  9. internal/grid/muxclient.go

    		}
    		m.addResponse(Response{Err: ErrIncorrectSequence})
    		return false
    	}
    	m.RecvSeq++
    	return true
    }
    
    // response will send handleIncoming response to client.
    // may never block.
    // Should return whether the next call would block.
    func (m *muxClient) response(seq uint32, r Response) {
    	if debugReqs {
    		fmt.Println(m.MuxID, m.parent.String(), "RESP")
    	}
    	if debugPrint {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  10. cmd/metacache-set.go

    	return pathJoin(bucketMetaPrefix, bucket, metacachePrefix, id)
    }
    
    // objectPath returns the object path of the cache.
    func (o *listPathOptions) objectPath(block int) string {
    	return pathJoin(metacachePrefixForID(o.Bucket, o.ID), "block-"+strconv.Itoa(block)+".s2")
    }
    
    func (o *listPathOptions) SetFilter() {
    	switch {
    	case metacacheSharePrefix:
    		return
    	case o.Prefix == o.BaseDir:
    		// No additional prefix
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
Back to top