Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for _milliseconds (0.12 sec)

  1. internal/grid/muxclient.go

    	m.init = true
    	m.singleResp = true
    	msg := message{
    		Op:         OpRequest,
    		MuxID:      m.MuxID,
    		Handler:    h,
    		Flags:      m.BaseFlags | FlagEOF,
    		Payload:    req,
    		DeadlineMS: uint32(m.deadline.Milliseconds()),
    	}
    	if m.subroute != nil {
    		msg.Flags |= FlagSubroute
    	}
    	ch := make(chan Response, 1)
    	m.respMu.Lock()
    	if m.closed {
    		m.respMu.Unlock()
    		return nil, ErrDisconnected
    	}
    	m.respWait = ch
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. cmd/bucket-stats.go

    func (rl ReplicationLatency) getUploadLatency() (ret map[string]uint64) {
    	ret = make(map[string]uint64)
    	avg := rl.UploadHistogram.GetAvgData()
    	for k, v := range avg {
    		// Convert nanoseconds to milliseconds
    		ret[sizeTagToString(k)] = uint64(v.avg() / time.Millisecond)
    	}
    	return
    }
    
    // Update replication upload latency with a new value
    func (rl *ReplicationLatency) update(size int64, duration time.Duration) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    			b, err = handler(m.Payload)
    			if debugPrint {
    				fmt.Println(c.Local, "Handler returned payload:", bytesOrLength(b), "err:", err)
    			}
    		}()
    
    		if m.DeadlineMS > 0 && time.Since(start).Milliseconds()+c.addDeadline.Milliseconds() > int64(m.DeadlineMS) {
    			if debugReqs {
    				fmt.Println(m.MuxID, c.StringReverse(), "DEADLINE EXCEEDED")
    			}
    			// No need to return result
    			PutByteBuffer(b)
    			return
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. internal/dsync/dsync_test.go

    	"github.com/google/uuid"
    )
    
    const (
    	testDrwMutexAcquireTimeout         = 250 * time.Millisecond
    	testDrwMutexRefreshCallTimeout     = 250 * time.Millisecond
    	testDrwMutexUnlockCallTimeout      = 250 * time.Millisecond
    	testDrwMutexForceUnlockCallTimeout = 250 * time.Millisecond
    	testDrwMutexRefreshInterval        = 100 * time.Millisecond
    )
    
    // TestMain initializes the testing framework
    func TestMain(m *testing.M) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. internal/kms/kms.go

    }
    
    var defaultLatencyBuckets = []time.Duration{
    	10 * time.Millisecond,
    	50 * time.Millisecond,
    	100 * time.Millisecond,
    	250 * time.Millisecond,
    	500 * time.Millisecond,
    	1000 * time.Millisecond, // 1s
    	1500 * time.Millisecond,
    	3000 * time.Millisecond,
    	5000 * time.Millisecond,
    	10000 * time.Millisecond, // 10s
    }
    
    // KMS is a connection to a key management system.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/list.md

    | `minio_node_replication_max_link_latency_ms`            | Maximum replication link latency in milliseconds seen since server start                                 |
    | `minio_node_replication_current_link_latency_ms`        | Current replication link latency in milliseconds                                                         |
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:48:51 UTC 2024
    - 43.3K bytes
    - Viewed (0)
  7. cmd/local-locker_test.go

    								t.Fatal("failed:", err, ok)
    							}
    						}
    					}
    					start := time.Now()
    					l.expireOldLocks(time.Hour)
    					t.Logf("Scan Took: %v. Left: %d/%d", time.Since(start).Round(time.Millisecond), len(l.lockUID), len(l.lockMap))
    					if len(l.lockMap) != locks {
    						t.Fatalf("objects deleted, want %d != got %d", locks, len(l.lockMap))
    					}
    					if len(l.lockUID) != locks*readers {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  8. internal/grid/grid_test.go

    		start := time.Now()
    		if st.Requests != nil {
    			defer close(st.Requests)
    		}
    		// Fill up queue.
    		for sendReq {
    			select {
    			case st.Requests <- []byte("Hello"):
    				time.Sleep(10 * time.Millisecond)
    			default:
    				sendReq = false
    			}
    		}
    		cancel()
    		<-serverCanceled
    		t.Log("server cancel time:", time.Since(start))
    		clientEnd := <-clientCanceled
    		if !errors.Is(err, context.Canceled) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/mylasta/direction/FessEnv.java

         * one day: 86400000, three days: 259200000, five days: 432000000, one week: 604800000, one year: 31556926000<br>
         * special script :: absolute mode: $(2014/07/10), relative mode: addDay(3).addMonth(4)<br>
         * The milliseconds for (relative or absolute) adjust time (set only when test) @LongType *dynamic in development
         * @return The value of found property. (NotNull: if not found, exception but basically no way)
         */
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  10. internal/grid/benchmark_test.go

    				if spent > 0 && n > 0 {
    					// Since we are benchmarking n parallel servers we need to multiply by n.
    					// This will give an estimate of the total ops/s.
    					latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond)
    					b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s")
    					b.ReportMetric(latency/float64(ops), "ms/op")
    				}
    			})
    		}
    	})
    	b.Run("rpc", func(b *testing.B) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
Back to top