Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 45 for recycle (0.06 sec)

  1. cmd/peer-s3-client.go

    	}
    	buckets := make([]BucketInfo, 0, len(bi.Value()))
    	for _, b := range bi.Value() {
    		if b != nil {
    			buckets = append(buckets, *b)
    		}
    	}
    	bi.Recycle() // BucketInfo has no internal pointers, so it's safe to recycle.
    	return buckets, nil
    }
    
    func (client *remotePeerS3Client) HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error) {
    	conn := client.gridConn()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  2. cmd/data-scanner-metric.go

    	p.cycleInfoMu.Lock()
    	defer p.cycleInfoMu.Unlock()
    	if p.cycleInfo == nil {
    		return nil
    	}
    	c := p.cycleInfo.clone()
    	return &c
    }
    
    func (p *scannerMetrics) report() madmin.ScannerMetrics {
    	var m madmin.ScannerMetrics
    	cycle := p.getCycle()
    	if cycle != nil {
    		m.CurrentCycle = cycle.current
    		m.CyclesCompletedAt = cycle.cycleCompleted
    		m.CurrentStarted = cycle.started
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/SmbFile.java

            sid = resp.sid;
            req = new Trans2FindNext2(sid, resp.resumeKey, resp.lastName);
    
            /* The only difference between first2 and next2 responses is subCommand
             * so let's recycle the response object.
             */
            resp.subCommand = SmbComTransaction.TRANS2_FIND_NEXT2;
    
            for (;;) {
                for (int i = 0; i < resp.numEntries; i++) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 112.2K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    	minSleep time.Duration
    
    	// cycle will be closed
    	cycle chan struct{}
    
    	// isScanner should be set when this is used by the scanner
    	// to record metrics.
    	isScanner bool
    }
    
    // newDynamicSleeper
    func newDynamicSleeper(factor float64, maxWait time.Duration, isScanner bool) *dynamicSleeper {
    	return &dynamicSleeper{
    		factor:    factor,
    		cycle:     make(chan struct{}),
    		maxSleep:  maxWait,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/IteratorsTest.java

        cycle.remove();
        assertEquals(singletonList("b"), iterable);
        assertTrue(cycle.hasNext());
        assertEquals("b", cycle.next());
        assertTrue(cycle.hasNext());
        assertEquals("b", cycle.next());
        cycle.remove();
        assertEquals(emptyList(), iterable);
        assertFalse(cycle.hasNext());
      }
    
      public void testCycleRemoveWithoutNext() {
        Iterator<String> cycle = Iterators.cycle("a", "b");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 54.4K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/smb1/SmbComWrite.java

            this.fid = fid;
            this.offset = (int) (offset & 0xFFFFFFFFL);
            this.remaining = remaining;
            this.b = b;
            this.off = off;
            count = len;
            digest = null; /* otherwise recycled commands
                            * like writeandx will choke if session
                            * closes in between */
        }
    
        @Override
        int writeParameterWordsWireFormat(final byte[] dst, int dstIndex) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/SmbComWriteAndX.java

            this.fid = fid;
            this.offset = offset;
            this.remaining = remaining;
            this.b = b;
            this.off = off;
            dataLength = len;
            digest = null; /* otherwise recycled commands
                            * like writeandx will choke if session
                            * closes in between */
        }
    
        @Override
        int getBatchLimit(final byte command) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb1/com/SmbComWrite.java

            this.remaining = remaining;
            this.b = b;
            this.off = off;
            this.count = len;
            this.digest = null; /*
                                 * otherwise recycled commands
                                 * like writeandx will choke if session
                                 * closes in between
                                 */
        }
    
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/collect/IteratorsTest.java

        cycle.remove();
        assertEquals(singletonList("b"), iterable);
        assertTrue(cycle.hasNext());
        assertEquals("b", cycle.next());
        assertTrue(cycle.hasNext());
        assertEquals("b", cycle.next());
        cycle.remove();
        assertEquals(emptyList(), iterable);
        assertFalse(cycle.hasNext());
      }
    
      public void testCycleRemoveWithoutNext() {
        Iterator<String> cycle = Iterators.cycle("a", "b");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 54.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/graph/Graphs.java

      // Graph query methods
    
      /**
       * Returns true if {@code graph} has at least one cycle. A cycle is defined as a non-empty subset
       * of edges in a graph arranged to form a path (a sequence of adjacent outgoing edges) starting
       * and ending with the same node.
       *
       * <p>This method will detect any non-empty cycle, including self-loops (a cycle of length 1).
       */
      public static <N> boolean hasCycle(Graph<N> graph) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Aug 01 00:26:14 UTC 2025
    - 22.7K bytes
    - Viewed (0)
Back to top