Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 227 for unpack (0.09 sec)

  1. internal/config/browser/browser.go

    	ReferrerPolicy        string `json:"referrer_policy"`
    }
    
    // Update Updates browser with new config
    func (browseCfg *Config) Update(newCfg Config) {
    	configLock.Lock()
    	defer configLock.Unlock()
    	browseCfg.CSPPolicy = newCfg.CSPPolicy
    	browseCfg.HSTSSeconds = newCfg.HSTSSeconds
    	browseCfg.HSTSIncludeSubdomains = newCfg.HSTSIncludeSubdomains
    	browseCfg.HSTSPreload = newCfg.HSTSPreload
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. cmd/bucket-lifecycle.go

    }
    
    func (es *expiryState) ResizeWorkers(n int) {
    	if n == 0 {
    		n = 100
    	}
    
    	// Lock to avoid multiple resizes to happen at the same time.
    	es.mu.Lock()
    	defer es.mu.Unlock()
    	var workers []chan expiryOp
    	if v := es.workers.Load(); v != nil {
    		// Copy to new array.
    		workers = append(workers, *v...)
    	}
    
    	if n == len(workers) || n < 1 {
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  5. 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)
  6. doc/go_mem.html

    call <i>n</i> of <code>l.Unlock()</code> is synchronized before call <i>m</i> of <code>l.Lock()</code> returns.
    </p>
    
    <p>
    This program:
    </p>
    
    <pre>
    var l sync.Mutex
    var a string
    
    func f() {
    	a = "hello, world"
    	l.Unlock()
    }
    
    func main() {
    	l.Lock()
    	go f()
    	l.Lock()
    	print(a)
    }
    </pre>
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  7. cni/pkg/log/uds.go

    		if !ok {
    			continue
    		}
    		messages = append(messages, msg)
    	}
    	// Lock log message printing to prevent log messages from different CNI
    	// processes interleave.
    	l.mu.Lock()
    	defer l.mu.Unlock()
    	for _, m := range messages {
    		logger := pluginLog
    		// For any k/v pairs, add them back
    		for k, v := range m.Arbitrary {
    			logger = logger.WithLabels(k, v)
    		}
    		// There is no fatal log from CNI plugin
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. 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)
  9. cmd/iam-etcd-store.go

    	return ies.iamCache
    }
    
    func (ies *IAMEtcdStore) runlock() {
    	ies.RUnlock()
    }
    
    func (ies *IAMEtcdStore) lock() *iamCache {
    	ies.Lock()
    	return ies.iamCache
    }
    
    func (ies *IAMEtcdStore) unlock() {
    	ies.Unlock()
    }
    
    func (ies *IAMEtcdStore) getUsersSysType() UsersSysType {
    	return ies.usersSysType
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  10. 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)
Back to top