Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 690 for OK (0.02 sec)

  1. cmd/erasure-server-pool-rebalance.go

    func (z *erasureServerPools) updateRebalanceStats(ctx context.Context) error {
    	var ok bool
    	for i := range z.serverPools {
    		if z.findIndex(i) == -1 {
    			// Also ensure to initialize rebalanceStats to indicate
    			// its a new pool that can receive rebalanced data.
    			z.rebalMeta.PoolStats = append(z.rebalMeta.PoolStats, &rebalanceStats{})
    			ok = true
    		}
    	}
    	if ok {
    		return z.rebalMeta.save(ctx, z.serverPools[0])
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/helper/RoleQueryHelperTest.java

            Set<String> roleSet;
    
            try {
                roleSet = buildByHeader(roleQueryHelperImpl, getMockRequest());
                fail();
            } catch (final NullPointerException e) {
                //ok
            }
    
            roleQueryHelperImpl.headerKey = "fess1";
    
            getMockRequest().addHeader("aaa", "bbb");
            roleSet = buildByHeader(roleQueryHelperImpl, getMockRequest());
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  3. cmd/signature-v4-parser.go

    	v4PresignQueryParams := []string{xhttp.AmzAlgorithm, xhttp.AmzCredential, xhttp.AmzSignature, xhttp.AmzDate, xhttp.AmzSignedHeaders, xhttp.AmzExpires}
    	for _, v4PresignQueryParam := range v4PresignQueryParams {
    		if _, ok := query[v4PresignQueryParam]; !ok {
    			return ErrInvalidQueryParams
    		}
    	}
    	return ErrNone
    }
    
    // Parses all the presigned signature values into separate elements.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. cmd/data-scanner_test.go

    	var wg sync.WaitGroup
    	wg.Add(1)
    	expired := make([]ObjectToDelete, 0, 5)
    	go func() {
    		defer wg.Done()
    		workers := globalExpiryState.workers.Load()
    		for t := range (*workers)[0] {
    			if t, ok := t.(newerNoncurrentTask); ok {
    				expired = append(expired, t.versions...)
    			}
    		}
    	}()
    	lc := lifecycle.Lifecycle{
    		Rules: []lifecycle.Rule{
    			{
    				ID:     "max-versions",
    				Status: "Enabled",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. cmd/mrf.go

    // corresponding erasure set
    func (m *mrfState) healRoutine(z *erasureServerPools) {
    	for {
    		select {
    		case <-GlobalContext.Done():
    			return
    		case u, ok := <-m.opCh:
    			if !ok {
    				return
    			}
    
    			// We might land at .metacache, .trash, .multipart
    			// no need to heal them skip, only when bucket
    			// is '.minio.sys'
    			if u.Bucket == minioMetaBucket {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  6. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

    import okhttp3.internal.http2.Settings
    import okio.Buffer
    
    /** A scripted response to be replayed by the mock web server. */
    @ExperimentalOkHttpApi
    class MockResponse {
      /** Returns the HTTP response line, such as "HTTP/1.1 200 OK". */
      val status: String
    
      val code: Int
        get() {
          val statusParts = status.split(' ', limit = 3)
          require(statusParts.size >= 2) { "Unexpected status: $status" }
          return statusParts[1].toInt()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. cmd/bucket-replication-utils_test.go

    			t.Errorf("Test%d (%s): Invalid number of entries in targetsMap  got %d , want %d", i+1, test.name, len(dsc.targetsMap), len(test.expDsc.targetsMap))
    		}
    		for arn, tdsc := range dsc.targetsMap {
    			expDsc, ok := test.expDsc.targetsMap[arn]
    			if !ok || expDsc != tdsc {
    				t.Errorf("Test%d (%s): Invalid  target replicate decision: got %+v, want %+v", i+1, test.name, tdsc, expDsc)
    			}
    		}
    	}
    }
    
    var replicationStateTest = []struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 08 20:27:40 UTC 2023
    - 9.3K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2.go

    	}
    	fi.DataDir = uuid.UUID(j.DataDir).String()
    
    	if st, ok := j.MetaSys[metaTierStatus]; ok {
    		fi.TransitionStatus = string(st)
    	}
    	if o, ok := j.MetaSys[metaTierObjName]; ok {
    		fi.TransitionedObjName = string(o)
    	}
    	if rv, ok := j.MetaSys[metaTierVersionID]; ok {
    		fi.TransitionVersionID = string(rv)
    	}
    	if sc, ok := j.MetaSys[metaTierName]; ok {
    		fi.TransitionTier = string(sc)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  9. okhttp/src/test/java/okhttp3/CacheTest.kt

            .build(),
        )
        val url = server.url("/")
        val urlKey = key(url)
        val entryMetadata =
          """
          $url
          GET
          0
          HTTP/1.1 200 OK
          7
          :status: 200 OK
          :version: HTTP/1.1
          etag: foo
          content-length: 3
          OkHttp-Received-Millis: ${System.currentTimeMillis()}
          X-Android-Response-Source: NETWORK 200
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K bytes
    - Viewed (0)
  10. internal/ioutil/ioutil.go

    // Close closes the WriteOnCloser. It behaves like io.Closer.
    func (w *WriteOnCloser) Close() error {
    	if !w.hasWritten {
    		_, err := w.Write(nil)
    		if err != nil {
    			return err
    		}
    	}
    	if closer, ok := w.Writer.(io.Closer); ok {
    		return closer.Close()
    	}
    	return nil
    }
    
    // HasWritten returns true if at least one write operation was performed.
    func (w *WriteOnCloser) HasWritten() bool { return w.hasWritten }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top