Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 220 for unpack (0.06 sec)

  1. cmd/test-utils_test.go

    	globalObjLayerMutex.Lock()
    	globalObjectAPI = nil
    	globalObjLayerMutex.Unlock()
    }
    
    // reset the value of the Global server config.
    // set it to `nil`.
    func resetGlobalConfig() {
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	// Save the loaded config globally.
    	globalServerConfig = nil
    	globalServerConfigMu.Unlock()
    }
    
    func resetGlobalEndpoints() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

      internal val lock: ReentrantLock = ReentrantLock()
    
      private val hpackBuffer: Buffer = Buffer()
      private var maxFrameSize: Int = INITIAL_MAX_FRAME_SIZE
      private var closed: Boolean = false
      val hpackWriter: Hpack.Writer = Hpack.Writer(out = hpackBuffer)
    
      @Throws(IOException::class)
      fun connectionPreface() {
        this.withLock {
          if (closed) throw IOException("closed")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		}
    	}
    	globalProfilerMu.Unlock()
    
    	timer := time.NewTimer(duration)
    	defer timer.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Stop remote profiles
    			go globalNotificationSys.DownloadProfilingData(GlobalContext, io.Discard)
    
    			// Stop local
    			globalProfilerMu.Lock()
    			defer globalProfilerMu.Unlock()
    			for k, v := range globalProfiler {
    				v.Stop()
    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. cmd/object_api_suite_test.go

    	globalCompressConfig.Enabled = true
    	globalCompressConfig.MimeTypes = mimeTypes
    	globalCompressConfig.Extensions = extensions
    	globalCompressConfig.AllowEncrypted = encrypt
    	globalCompressConfigMu.Unlock()
    	if encrypt {
    		globalAutoEncryption = encrypt
    		KMS, err := kms.ParseSecretKey("my-minio-key:5lF+0pJM0OWwlQrvK2S/I7W9mO4a6rJJI7wzj7v09cw=")
    		if err != nil {
    			t.Fatal(err)
    		}
    		GlobalKMS = KMS
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    	}
    
    	if !dstOpts.NoLock {
    		lk := er.NewNSLock(dstBucket, dstObject)
    		lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return oi, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    	// Read metadata associated with the object from all disks.
    	storageDisks := er.getDisks()
    
    	var metaArr []FileInfo
    	var errs []error
    
    	// Read metadata associated with the object from all disks.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  6. compat/maven-model-builder/src/test/resources/poms/validation/empty-plugin-version.xml

    under the License.
    -->
    
    <project>
      <modelVersion>4.0.0</modelVersion>
      <artifactId>foo</artifactId>
      <groupId>bar</groupId>
      <version>1.0</version>
      <packaging>pack</packaging>
      <build>
        <plugins>
          <plugin>
            <artifactId>maven-it-plugin</artifactId>
            <version></version>
          </plugin>
        </plugins>
      </build>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  7. cmd/metrics-v3-types.go

    		ch <- metric
    	}
    }
    
    // LockAndSetBuckets - locks the buckets and sets the given buckets. It returns
    // a function to unlock the buckets.
    func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() {
    	mg.bucketsLock.Lock()
    	mg.buckets = buckets
    	return func() {
    		mg.bucketsLock.Unlock()
    	}
    }
    
    // MetricFQN - returns the fully qualified name for the given metric name.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 30 22:28:46 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. cmd/consolelogger.go

    	}
    	atomic.AddInt64(&sys.totalMessages, 1)
    
    	sys.pubsub.Publish(lg)
    	sys.Lock()
    	// add log to ring buffer
    	sys.logBuf.Value = lg
    	sys.logBuf = sys.logBuf.Next()
    	sys.Unlock()
    	err := sys.console.Send(entry)
    	if err != nil {
    		atomic.AddInt64(&sys.failedMessages, 1)
    	}
    	return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/Verify.java

     *
     * <pre>{@code
     * Bill bill = remoteService.getLastUnpaidBill();
     *
     * // In case bug 12345 happens again we'd rather just die
     * Verify.verify(bill.status() == Status.UNPAID,
     *     "Unexpected bill status: %s", bill.status());
     * }</pre>
     *
     * <h3>Comparison to alternatives</h3>
     *
     * <p><b>Note:</b> In some cases the differences explained below can be subtle. When it's unclear
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon May 17 14:07:47 UTC 2021
    - 18.5K bytes
    - Viewed (0)
  10. cmd/metrics-v3-cache.go

    						v.ioStats[d] = getDriveIOStatMetrics(getDiffStats(ps, cs), duration)
    					}
    				}
    			}
    		}
    
    		prevDriveIOStats = currentStats
    		prevDriveIOStatsRefreshedAt = now
    		prevDriveIOStatsMu.Unlock()
    
    		return
    	}
    
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadDriveMetrics)
    }
    
    func newCPUMetricsCache() *cachevalue.Cache[madmin.CPUMetrics] {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
Back to top