Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 519 for reflect (0.07 seconds)

  1. cmd/site-replication-metrics.go

    	s := SRStats{
    		M:               make(map[string]*SRStatus),
    		movingAvgTicker: time.NewTicker(time.Second * 2),
    	}
    	go s.trackEWMA()
    	return &s
    }
    
    func (sr *SRStats) trackEWMA() {
    	for {
    		select {
    		case <-sr.movingAvgTicker.C:
    			sr.updateMovingAvg()
    		case <-GlobalContext.Done():
    			return
    		}
    	}
    }
    
    func (sr *SRStats) updateMovingAvg() {
    	sr.lock.Lock()
    	defer sr.lock.Unlock()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  2. docs/en/docs/help-fastapi.md

    You can "watch" FastAPI in GitHub (clicking the "watch" button at the top right): <a href="https://github.com/fastapi/fastapi" class="external-link" target="_blank">https://github.com/fastapi/fastapi</a>. 👀
    
    There you can select "Releases only".
    
    By doing it, you will receive notifications (in your email) whenever there's a new release (a new version) of **FastAPI** with bug fixes and new features.
    
    ## Connect with the author { #connect-with-the-author }
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 10:49:48 GMT 2025
    - 14K bytes
    - Click Count (0)
  3. impl/maven-core/src/main/java/org/apache/maven/plugin/DefaultBuildPluginManager.java

                legacySupport.setSession(oldSession);
            }
        }
    
        /**
         * TODO pluginDescriptor classRealm and artifacts are set as a side effect of this
         *      call, which is not nice.
         * @throws PluginResolutionException
         */
        @Override
        public ClassRealm getPluginRealm(MavenSession session, PluginDescriptor pluginDescriptor)
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Sep 17 16:01:38 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  4. cmd/site-replication-utils.go

    		}
    	}
    	return &m
    }
    
    // save in-memory stats to disk
    func (sm *siteResyncMetrics) save(ctx context.Context) {
    	sTimer := time.NewTimer(siteResyncSaveInterval)
    	defer sTimer.Stop()
    	for {
    		select {
    		case <-sTimer.C:
    			if globalSiteReplicationSys.isEnabled() {
    				sm.Lock()
    				wg := sync.WaitGroup{}
    				for dID, rs := range sm.peerResyncMap {
    					st, ok := sm.resyncStatus[rs.resyncID]
    					if ok {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  5. cmd/data-usage-cache.go

    		for child := range existing.Children {
    			d.deleteRecursive(dataUsageHash(child))
    		}
    	}
    }
    
    // dui converts the flattened version of the path to madmin.DataUsageInfo.
    // As a side effect d will be flattened, use a clone if this is not ok.
    func (d *dataUsageCache) dui(path string, buckets []BucketInfo) DataUsageInfo {
    	e := d.find(path)
    	if e == nil {
    		// No entry found, return empty.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  6. internal/ringbuffer/ring_buffer_test.go

    	}
    
    	// check empty or full
    	if rb.IsEmpty() {
    		t.Fatalf("expect IsEmpty is false but got true")
    	}
    	if !rb.IsFull() {
    		t.Fatalf("expect IsFull is true but got false")
    	}
    
    	// write more 4 bytes, should reject
    	n, err = rb.Write([]byte(strings.Repeat("abcd", 1)))
    	if err == nil {
    		t.Fatalf("expect an error but got nil. n=%d, r.w=%d, r.r=%d", n, rb.w, rb.r)
    	}
    	if err != ErrIsFull {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  7. cmd/sftp-server_test.go

    	// ldap user accounts without policies are denied access in sftp.
    	policy := "mypolicy"
    	policyBytes := []byte(`{
     "Version": "2012-10-17",
     "Statement": [
      {
       "Effect": "Allow",
       "Action": [
        "s3:PutObject",
        "s3:GetObject",
        "s3:ListBucket"
       ],
       "Resource": [
        "arn:aws:s3:::BUCKET/*"
       ]
      }
     ]
    }`)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Feb 27 18:43:32 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  8. go.mod

    	github.com/minio/websocket v1.6.0 // indirect
    	github.com/mitchellh/mapstructure v1.5.0 // indirect
    	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
    	github.com/modern-go/reflect2 v1.0.2 // indirect
    	github.com/muesli/ansi v0.0.0-20230316100256-276c6243b2f6 // indirect
    	github.com/muesli/cancelreader v0.2.2 // indirect
    	github.com/muesli/reflow v0.3.0 // indirect
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 12.2K bytes
    - Click Count (0)
  9. cmd/xl-storage.go

    			r.Exists = true
    			r.Error = fmt.Sprintf("max size (%d) exceeded: %d", req.MaxSize, len(data))
    			select {
    			case <-ctx.Done():
    				return ctx.Err()
    			case resp <- r:
    				continue
    			}
    		}
    		found++
    		r.Exists = true
    		r.Data = data
    		r.Modtime = mt
    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		case resp <- r:
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  10. docs/tls/README.md

    ```
    setx path "%path%;C:\Users\MyUser\Downloads\gnutls-3.4.9-w64\bin"
    ```
    
    **Note:** PowerShell may need to be restarted for this change to take effect.
    
    #### 3.3.2 Generate a private key
    
    Run the following command to generate a private `.key` file:
    
    ```
    certtool.exe --generate-privkey --outfile private.key
    ```
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 8.6K bytes
    - Click Count (0)
Back to Top