Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 186 for isOnline (0.05 sec)

  1. cmd/metrics-v2.go

    		tgts := append(logger.SystemTargets(), logger.AuditTargets()...)
    		metrics := make([]MetricV2, 0, len(tgts)*4)
    		for _, t := range tgts {
    			isOnline := 0
    			if t.IsOnline(ctx) {
    				isOnline = 1
    			}
    			labels := map[string]string{
    				"name":     t.String(),
    				"endpoint": t.Endpoint(),
    			}
    			metrics = append(metrics, MetricV2{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 133.6K bytes
    - Viewed (0)
  2. cmd/xl-storage-disk-id-check.go

    	if xl.healthCheck {
    		go xl.monitorDiskWritable(xl.diskCtx)
    	}
    	return &xl
    }
    
    func (p *xlStorageDiskIDCheck) String() string {
    	return p.storage.String()
    }
    
    func (p *xlStorageDiskIDCheck) IsOnline() bool {
    	storedDiskID, err := p.storage.GetDiskID()
    	if err != nil {
    		return false
    	}
    	return storedDiskID == *p.diskID.Load()
    }
    
    func (p *xlStorageDiskIDCheck) LastConn() time.Time {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		stats = append(stats, madmin.KMS{
    			Status:   string(state),
    			Endpoint: endpoint,
    		})
    	}
    	return stats
    }
    
    func targetStatus(ctx context.Context, h logger.Target) madmin.Status {
    	if h.IsOnline(ctx) {
    		return madmin.Status{Status: string(madmin.ItemOnline)}
    	}
    	return madmin.Status{Status: string(madmin.ItemOffline)}
    }
    
    // fetchLoggerInfo return log info
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 99.7K bytes
    - Viewed (0)
  4. cmd/xl-storage.go

    			ModTime: st.ModTime(),
    		})
    	}
    	return stat, nil
    }
    
    // CleanAbandonedData will read metadata of the object on disk
    // and delete any data directories and inline data that isn't referenced in metadata.
    // Metadata itself is not modified, only inline data.
    func (s *xlStorage) CleanAbandonedData(ctx context.Context, volume string, path string) error {
    	if volume == "" || path == "" {
    		return nil // Ignore
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  5. cmd/test-utils_test.go

    	pools := obj.(*erasureServerPools)
    	t := time.Now()
    	for _, pool := range pools.serverPools {
    		for _, sets := range pool.erasureDisks {
    			for _, s := range sets {
    				if !s.IsLocal() {
    					for !s.IsOnline() {
    						time.Sleep(100 * time.Millisecond)
    						if time.Since(t) > 10*time.Second {
    							return nil, nil, errors.New("timeout waiting for disk to come online")
    						}
    					}
    				}
    			}
    		}
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  6. cmd/xl-storage-meta-inline.go

    	"fmt"
    	"slices"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    // xlMetaInlineData is serialized data in [string][]byte pairs.
    type xlMetaInlineData []byte
    
    // xlMetaInlineDataVer indicates the version of the inline data structure.
    const xlMetaInlineDataVer = 1
    
    // versionOK returns whether the version is ok.
    func (x xlMetaInlineData) versionOK() bool {
    	if len(x) == 0 {
    		return true
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  7. cmd/testdata/xl-meta-inline-notinline.zip

    1 disk2/testbucket/file/xl.meta XL2 Æ X ¨Versions‘‚¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ Ÿl;âF?Gq¦Ç ºª?ò¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDist” ¨CSumAlgo ¨PartNums‘ ©PartETags‘ ©PartSizes‘Ò ªPartASizes‘Ò ¤SizeÒ ¥MTimeÓ ð ÞÍ &˜§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¤etagÙ fffb6377948ebea75ad2¬content-type¸application/octet-streamÎ7£ï; disk1/testbucket/file/xl.meta 䱘′ ÆĀ腘嚨牥楳湯酳ꒂ祔数ꔁ㉖扏 ᄀ䦢쑄 ꐀ䑄物Ⴤ沟㽆煇잦Вꪺ䖦䅣杬ů䖣䵣ꌂ捅Ɏ䖧䉣楓敺Ò ꜀捅湉敤ɸ䖦䑣獩鑴̂Ą䎨畓䅭杬ů储牡乴浵酳꤁慐瑲呅条酳ꦠ慐瑲楓敺酳ÒЂꨀ慐瑲十穩獥튑Ȁ 厤穩퉥Ȁ 䶥楔敭ᛓ翰췞☝Ꞙ敍慴祓腳碼洭湩潩椭瑮牥慮⵬湩楬敮搭瑡쑡琄...
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 24 13:26:38 UTC 2022
    - 131.6K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Lockable.kt

     * there are multiple `this` objects in scope.
     */
    interface Lockable
    
    internal inline fun Lockable.wait() = (this as Object).wait()
    
    internal inline fun Lockable.notify() = (this as Object).notify()
    
    internal inline fun Lockable.notifyAll() = (this as Object).notifyAll()
    
    internal inline fun Lockable.awaitNanos(nanos: Long) {
      val ms = nanos / 1_000_000L
      val ns = nanos - (ms * 1_000_000L)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  9. src/main/webapp/WEB-INF/view/admin/general/admin_general.jsp

                                                key="labels.web_api_json_enabled"/></span>
                                        <div class="form-inline col-sm-9">
                                            <la:errors property="webApiJson"/>
                                            <div class="form-check">
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 13 02:21:17 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          return inline.invokeAll(tasks, timeout, unit);
        }
    
        // Define the invokeAny methods to invoke the first task
        @Override
        public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
            throws ExecutionException, InterruptedException {
          assertTaskWrapped(tasks);
          lastMethodCalled = "invokeAny";
          return inline.submit(Iterables.get(tasks, 0)).get();
        }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
Back to top