Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for Tracker (0.18 sec)

  1. cmd/background-newdisks-heal-ops.go

    		tracker.resetHealing()
    		bugLogIf(ctx, tracker.update(ctx))
    
    		return errRetryHealing
    	}
    
    	if tracker.ItemsFailed > 0 {
    		healingLogEvent(ctx, "Healing of drive '%s' is incomplete, retried %d times (healed: %d, skipped: %d, failed: %d).", disk,
    			tracker.RetryAttempts, tracker.ItemsHealed, tracker.ItemsSkipped, tracker.ItemsFailed)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    		return errServerNotInitialized
    	}
    
    	started := tracker.Started
    	if started.IsZero() || started.Equal(timeSentinel) {
    		healingLogIf(ctx, fmt.Errorf("unexpected tracker healing start time found: %v", started))
    		started = time.Time{}
    	}
    
    	// Final tracer update before quitting
    	defer func() {
    		tracker.setObject("")
    		tracker.setBucket("")
    		healingLogIf(ctx, tracker.update(ctx))
    	}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    func diskHealthCheckOK(ctx context.Context, err error) bool {
    	// Check if context has a disk health check.
    	tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue)
    	if !ok {
    		// No tracker, return
    		return err == nil || errors.Is(err, io.EOF)
    	}
    	if err == nil || errors.Is(err, io.EOF) {
    		tracker.logSuccess()
    		return true
    	}
    	return false
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    func (ahs *allHealState) updateHealStatus(tracker *healingTracker) {
    	ahs.Lock()
    	defer ahs.Unlock()
    
    	tracker.mu.RLock()
    	t := *tracker
    	t.QueuedBuckets = append(make([]string, 0, len(tracker.QueuedBuckets)), tracker.QueuedBuckets...)
    	t.HealedBuckets = append(make([]string, 0, len(tracker.HealedBuckets)), tracker.HealedBuckets...)
    	ahs.healStatus[tracker.ID] = t
    	tracker.mu.RUnlock()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/HttpUrlJvmTest.kt

      }
    
      /** Confirm that URI retains other characters. https://github.com/square/okhttp/issues/5236 */
      @Test
      fun hostToUriStripsCharacters2() {
        val httpUrl = "http://\${tracker}/".toHttpUrl()
        assertThat(httpUrl.toUri().toString()).isEqualTo("http://\$tracker/")
      }
    
      @Test
      fun fragmentNonAsciiThatOffendsJavaNetUri() {
        val url = "http://host/#\u0080".toHttpUrl()
        assertThat(url.toString()).isEqualTo("http://host/#\u0080")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. CONTRIBUTING.md

    ### Security vulnerabilities
    
    Do not report security vulnerabilities to the public issue tracker. Follow our [Security Vulnerability Disclosure Policy](https://github.com/gradle/gradle/security/policy).
    
    ### Follow the Code of Conduct
    
    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. cmd/storage-rest-client.go

    func (client *storageRESTClient) Endpoint() Endpoint {
    	return client.endpoint
    }
    
    func (client *storageRESTClient) Healing() *healingTracker {
    	// This call is not implemented for remote client on purpose.
    	// healing tracker is always for local disks.
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    	for i, b := range pd.QueuedBuckets {
    		if b == bucket {
    			// Bucket is done.
    			pd.QueuedBuckets = append(pd.QueuedBuckets[:i], pd.QueuedBuckets[i+1:]...)
    			// Clear tracker info.
    			if pd.Bucket == bucket {
    				pd.Bucket = "" // empty this out for next bucket
    				pd.Prefix = "" // empty this out for the next bucket
    				pd.Object = "" // empty this out for next object
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/net/HostAndPort.java

       */
      private static String[] getHostAndPortFromBracketedHost(String hostPortString) {
        checkArgument(
            hostPortString.charAt(0) == '[',
            "Bracketed host-port string must start with a bracket: %s",
            hostPortString);
        int colonIndex = hostPortString.indexOf(':');
        int closeBracketIndex = hostPortString.lastIndexOf(']');
        checkArgument(
            colonIndex > -1 && closeBracketIndex > colonIndex,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 22:02:22 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  10. docs/features/https.md

        at com.android.org.conscrypt.NativeCrypto.SSL_do_handshake(Native Method)
    ```
    
    You can check a web server's configuration using [Qualys SSL Labs][qualys]. OkHttp's TLS
    configuration history is [tracked here](../security/tls_configuration_history.md).
    
    Applications expected to be installed on older Android devices should consider adopting the
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Dec 24 00:16:30 UTC 2022
    - 10.5K bytes
    - Viewed (0)
Back to top