- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for 000000 (0.16 sec)
-
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
assertThat(log).containsExactly("run@100000") taskFaker.advanceUntil(150.µs) assertThat(log).containsExactly("run@100000", "run@150000") taskFaker.advanceUntil(299.µs) assertThat(log).containsExactly("run@100000", "run@150000") taskFaker.advanceUntil(300.µs) assertThat(log).containsExactly("run@100000", "run@150000", "run@300000") taskFaker.assertNoMoreTasks()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0) -
cmd/mrf.go
package cmd import ( "context" "time" "github.com/google/uuid" "github.com/minio/madmin-go/v3" "github.com/minio/pkg/v2/wildcard" ) const ( mrfOpsQueueSize = 100000 ) // partialOperation is a successful upload/delete of an object // but not written in all disks (having quorum) type partialOperation struct { bucket string object string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/bucket-replication.go
lrgworkers: make([]chan ReplicationWorkerOperation, 0, LargeWorkerCount), mrfReplicaCh: make(chan ReplicationWorkerOperation, 100000), mrfWorkerKillCh: make(chan struct{}, failedWorkers), resyncer: newresyncer(), mrfSaveCh: make(chan MRFReplicateEntry, 100000), mrfStopCh: make(chan struct{}, 1), ctx: ctx, objLayer: o, priority: priority,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/bucket-lifecycle.go
// via its Init method. func newTransitionState(ctx context.Context) *transitionState { return &transitionState{ transitionCh: make(chan transitionTask, 100000), ctx: ctx, killCh: make(chan struct{}), lastDayStats: make(map[string]*lastDayTierStats), } } // Init initializes t with given objAPI and instantiates the configured number
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/testdata/undeleteable-object.tgz
¼x-minio-internal-inline-dataÄ true§MetaUsr‚¬content-type°application/json¤etagÙ 83a7a4f493d028750df8¡v ÎX‹—_ ¤nullÄѱUÛă⪠O®ü[² ECüúk†ä½÷ +µ8æɉ4Ú,"LESS_THAN_1024_B":0},"objectsVersionsHisto":{"BETWEEN_1000_AND_10000":0,"BETWEEN_100_AND_1000":0,"BETWEEN_10_AND_100":0,"BETWEEN_2_AND_10":0,"GREATER_THAN_10000":0,"SINGLE multisitea/data/disterasure/xl10/.minio.sys/buckets/bucket/.metadata.bin/xl.meta XL2 Æ } Ä$•Ä Ó É Ñ©XÈÄ Í#| Å Qƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ „ï P L;»ô5,éº ¡¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Viewed (0) -
cmd/xl-storage.go
return disk.MakeVolBulk(context.TODO(), volumes...) } // Initialize a new storage disk. func newXLStorage(ep Endpoint, cleanUp bool) (s *xlStorage, err error) { immediatePurgeQueue := 100000 if globalIsTesting || globalIsCICD { immediatePurgeQueue = 1 } s = &xlStorage{ drivePath: ep.Path, endpoint: ep, globalSync: globalFSOSync,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/admin-handlers.go
// Trace Publisher and peer-trace-client uses nonblocking send and hence does not wait for slow receivers. // Keep 100k buffered channel. // If receiver cannot keep up with that we drop events. traceCh := make(chan []byte, 100000) peers, _ := newPeerRestClients(globalEndpoints) err = globalTrace.SubscribeJSON(traceOpts.TraceTypes(), traceCh, ctx.Done(), func(entry madmin.TraceInfo) bool { return shouldTrace(entry, traceOpts) }, nil)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
doc/go_spec.html
HTML - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Thu May 02 22:43:51 GMT 2024 - 279.6K bytes - Viewed (0)