Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 547 for sock (0.04 sec)

  1. internal/bucket/lifecycle/lifecycle_test.go

    	"github.com/google/uuid"
    	"github.com/minio/minio/internal/bucket/object/lock"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestParseAndValidateLifecycleConfig(t *testing.T) {
    	testCases := []struct {
    		inputConfig           string
    		expectedParsingErr    error
    		expectedValidationErr error
    		lr                    lock.Retention
    	}{
    		{ // Valid lifecycle config
    			inputConfig: `<LifecycleConfiguration>
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  2. cmd/iam-etcd-store.go

    	}
    }
    
    func (ies *IAMEtcdStore) rlock() *iamCache {
    	ies.RLock()
    	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)
  3. internal/config/storageclass/storage-class.go

    			Value:         "",
    			HiddenIfEmpty: true,
    		},
    	}
    )
    
    // StorageClass - holds storage class information
    type StorageClass struct {
    	Parity int
    }
    
    // ConfigLock is a global lock for storage-class config
    var ConfigLock sync.RWMutex
    
    // Config storage class configuration
    type Config struct {
    	Standard    StorageClass `json:"standard"`
    	RRS         StorageClass `json:"rrs"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    }
    
    // sets globalObjectAPI to `nil`.
    func resetGlobalObjectAPI() {
    	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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/AbstractRepositoryMetadata.java

            if (metadataFile.length() == 0) {
                if (!metadataFile.delete()) {
                    // sleep for 10ms just in case this is windows holding a file lock
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        // ignore
                    }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7K bytes
    - Viewed (0)
  6. CONTRIBUTING.md

    ## Making your change
    
    ### Code change guidelines
    
    All code contributions should contain the following:
    
    * Create unit tests using [Spock](https://spockframework.org/spock/docs/2.0/index.html) for new classes or methods that you introduce.
    * Create integration tests that exercise a Gradle build for the bug/feature. 
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Nov 05 15:15:33 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. mockwebserver/README.md

      server.shutdown();
    }
    ```
    
    Your unit tests might move the `server` into a field so you can shut it down
    from your test's `tearDown()`.
    
    ### API
    
    #### MockResponse
    
    Mock responses default to an empty response body and a `200` status code.
    You can set a custom body with a string, input stream or byte array. Also
    add headers with a fluent builder API.
    
    ```java
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 17 15:34:10 UTC 2023
    - 5K bytes
    - Viewed (0)
  8. internal/config/heal/heal.go

    func (opts Config) GetWorkers() int {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.DriveWorkers
    }
    
    // Update updates opts with nopts
    func (opts *Config) Update(nopts Config) {
    	configMutex.Lock()
    	defer configMutex.Unlock()
    
    	opts.Bitrot = nopts.Bitrot
    	opts.IOCount = nopts.IOCount
    	opts.Sleep = nopts.Sleep
    	opts.DriveWorkers = nopts.DriveWorkers
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  9. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt

          when (code) {
            in 100..199 -> "Informational"
            in 200..299 -> "OK"
            in 300..399 -> "Redirection"
            in 400..499 -> "Client Error"
            in 500..599 -> "Server Error"
            else -> "Mock Response"
          }
        return apply { status = "HTTP/1.1 $code $reason" }
      }
    
      fun clearHeaders() =
        apply {
          headersBuilder = Headers.Builder()
        }
    
      fun addHeader(header: String) =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      protected void shutDown() throws Exception {}
    
      /**
       * Invoked to request the service to stop.
       *
       * <p>By default this method does nothing.
       *
       * <p>Currently, this method is invoked while holding a lock. If an implementation of this method
       * blocks, it can prevent this service from changing state. If you need to performing a blocking
       * operation in order to trigger shutdown, consider instead registering a listener and
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top