Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 220 for unpack (0.07 sec)

  1. cmd/bucket-replication-metrics.go

    func (m *rateMeasurement) updateExponentialMovingAverage(endTime time.Time) {
    	// Calculate aggregate avg bandwidth and exp window avg
    	m.lock.Lock()
    	defer func() {
    		m.startTime = endTime
    		m.lock.Unlock()
    	}()
    
    	if m.startTime.IsZero() {
    		return
    	}
    
    	if endTime.Before(m.startTime) {
    		return
    	}
    
    	duration := endTime.Sub(m.startTime)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. cmd/metacache-server-pool.go

    				defer wg.Done()
    				err := set.listPath(listCtx, o, innerResults)
    				mu.Lock()
    				defer mu.Unlock()
    				if err == nil {
    					allAtEOF = false
    				}
    				errs[i] = err
    			}(len(errs), set)
    			errs = append(errs, nil)
    		}
    	}
    	mu.Unlock()
    
    	// Gather results to a single channel.
    	// Quorum is one since we are merging across sets.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. cmd/service.go

    	globalServiceFreezeMu.Lock()
    	// If multiple calls, first one creates channel.
    	globalServiceFreezeCnt++
    	if globalServiceFreezeCnt == 1 {
    		globalServiceFreeze.Store(make(chan struct{}))
    	}
    	globalServiceFreezeMu.Unlock()
    }
    
    // unfreezeServices will unfreeze all incoming S3 API calls.
    // For each call, unfreezeServices must be called once.
    func unfreezeServices() {
    	// We need a lock since we need the 2 atomic values to remain in sync.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  4. cmd/lock-rest-server.go

    // UnlockHandler - releases the acquired lock.
    func (l *lockRESTServer) UnlockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	resp := lockRPCUnlock.NewResponse()
    	_, err := l.ll.Unlock(context.Background(), *args)
    	// Ignore the Unlock() "reply" return value because if err == nil, "reply" is always true
    	// Consequently, if err != nil, reply is always false
    	return l.makeResp(resp, err)
    }
    
    // RLockHandler - Acquires an RLock.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            try {
              currentFuture.cancel(mayInterruptIfRunning);
            } finally {
              lock.unlock();
            }
          }
    
          @Override
          public boolean isCancelled() {
            lock.lock();
            try {
              return currentFuture.isCancelled();
            } finally {
              lock.unlock();
            }
          }
        }
    
        @Override
        final Cancellable schedule(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  6. cmd/metrics-resource.go

    	}
    	lastDriveStatsRefresh = time.Now().UTC()
    	latestDriveStatsMu.Unlock()
    }
    
    // startResourceMetricsCollection - starts the job for collecting resource metrics
    func startResourceMetricsCollection() {
    	initLatestValues()
    
    	resourceMetricsMapMu.Lock()
    	resourceMetricsMap = map[MetricSubsystem]ResourceMetrics{}
    	resourceMetricsMapMu.Unlock()
    	metricsTimer := time.NewTimer(resourceMetricsCollectionInterval)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  7. cmd/dynamic-timeouts.go

    			logCopy := [dynamicTimeoutLogSize]time.Duration{}
    			copy(logCopy[:], dt.log[:])
    
    			// reset log entries
    			atomic.StoreInt64(&dt.entries, 0)
    			dt.mutex.Unlock()
    
    			dt.adjust(logCopy)
    			return
    		}
    		dt.mutex.Unlock()
    	}
    }
    
    // adjust changes the value of the dynamic timeout based on the
    // previous results
    func (dt *dynamicTimeout) adjust(entries [dynamicTimeoutLogSize]time.Duration) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 19 23:21:05 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  8. internal/s3select/progress.go

    	// This allows another goroutine to close the reader.
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return 0, errors.New("progressReader: read after Close")
    	}
    	return pr.processedReader.Read(p)
    }
    
    func (pr *progressReader) Close() error {
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return nil
    	}
    	pr.closed = true
    	if pr.closer != nil {
    		pr.closer.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  9. cmd/batch-handlers.go

    		binary.LittleEndian.PutUint16(data[2:4], version)
    
    		buf, err := ri.MarshalMsg(data)
    		ri.mu.Unlock()
    		if err != nil {
    			return err
    		}
    		path, err := ri.getJobReportPath()
    		if err != nil {
    			batchLogIf(ctx, err)
    			return err
    		}
    		return saveConfig(ctx, api, path, buf)
    	}
    	ri.mu.Unlock()
    	return nil
    }
    
    // Note: to be used only with batch jobs that affect multiple versions through
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    						mu.Lock()
    						results[i] = info
    						mu.Unlock()
    					}
    				}()
    				// Start scanner. Blocks until done.
    				err := erObj.nsScanner(ctx, allBuckets, wantCycle, updates, healScanMode)
    				if err != nil {
    					scannerLogIf(ctx, err)
    					mu.Lock()
    					if firstErr == nil {
    						firstErr = err
    					}
    					// Cancel remaining...
    					cancel()
    					mu.Unlock()
    					return
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top