- Sort Score
- Num 10 results
- Language All
Results 181 - 190 of 227 for Once (0.02 seconds)
-
internal/grid/connection.go
// StateConnected is the state when the connection has been established and is considered stable. // If the connection is lost, state will switch to StateConnecting. StateConnected // StateConnectionError is the state once a connection attempt has been made, and it failed. // The connection will remain in this stat until the connection has been successfully re-established. StateConnectionError
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
cmd/object-api-interface.go
} // GetObject - TODO(aead): This function just acts as an adapter for GetObject tests and benchmarks // since the GetObject method of the ObjectLayer interface has been removed. Once, the // tests are adjusted to use GetObjectNInfo this function can be removed.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.5K bytes - Click Count (0) -
src/archive/zip/writer_test.go
for j := 0; j < 3; j++ { w, _ := zw.CreateHeader(&FileHeader{ Name: "foo", Method: Deflate, }) w.Write(bigBuf) } zw.Close() } b.ReportAllocs() // Run once and then reset the timer. // This effectively discards the very large initial flate setup cost, // as well as the initialization of bigBuf. runOnce(&bytes.Buffer{}) b.ResetTimer()Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Jan 28 04:20:09 GMT 2025 - 14.4K bytes - Click Count (0) -
cmd/erasure-server-pool.go
objects = objects[:maxKeys] loi.IsTruncated = true } for _, obj := range objects { if obj.IsDir && obj.ModTime.IsZero() && delimiter != "" { // Only add each once. // With slash delimiter we only get the directory once. found := false if delimiter != slashSeparator { for _, p := range loi.Prefixes { if found { break } found = p == obj.Name }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/codegen/ApiTypeProvider.kt
) private typealias ApiTypeSupplier = () -> ApiType /** * Provides [ApiType] instances by Kotlin source name from a class path. * * Keeps JAR files open for fast lookup, must be closed. * Once closed, type graph navigation from [ApiType] and [ApiFunction] instances * will throw [IllegalStateException]. * * Limitations: * - supports Java byte code only, not Kotlin
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Mar 12 15:56:18 GMT 2025 - 20.2K bytes - Click Count (0) -
cmd/batch-handlers.go
writeSuccessNoContent(w) } //msgp:ignore BatchJobPool // BatchJobPool batch job pool type BatchJobPool struct { ctx context.Context objLayer ObjectLayer once sync.Once mu sync.Mutex jobCh chan *BatchJobRequest jmu sync.Mutex // protects jobCancelers jobCancelers map[string]context.CancelFunc workerKillCh chan struct{} workerSize int
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 63.5K bytes - Click Count (1) -
internal/rest/client.go
req.Header.Set(xhttp.AmzRequestID, tc.AmzReqID) } return req, nil } type respBodyMonitor struct { io.ReadCloser expectTimeouts bool errorStatusOnce sync.Once } func (r *respBodyMonitor) Read(p []byte) (n int, err error) { n, err = r.ReadCloser.Read(p) r.errorStatus(err) return n, err } func (r *respBodyMonitor) Close() (err error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
schema/relationship.go
// optimize match english letters and midline // The following code is basically called in for. // In order to avoid the performance problems caused by repeated compilation of regular expressions, // it only needs to be done once outside, so optimization is done here. if idx != -1 && regEnLetterAndMidline.MatchString(str[0:idx]) { name = str[0:idx] } else { name = rel.Schema.namer.RelationshipFKName(*rel) }
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Nov 16 04:11:05 GMT 2025 - 23.1K bytes - Click Count (1) -
cmd/streaming-signature-v4.go
_, err = io.ReadFull(cr.reader, cr.buffer) if err == io.EOF && size != 0 { err = io.ErrUnexpectedEOF } if err != nil && err != io.EOF { cr.err = err return n, cr.err } // Once we have read the entire chunk successfully, we verify // that the received signature matches our computed signature. cr.chunkSHA256Writer.Write(cr.buffer) newSignature := cr.getChunkSignature()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 18.2K bytes - Click Count (0) -
cmd/metrics-v2.go
maps.Copy(metric.VariableLabels, m.VariableLabels) maps.Copy(metric.Histogram, m.Histogram) return metric } // Get - returns cached value always upton the configured TTL, // once the TTL expires "read()" registered function is called // to return the new values and updated. func (g *MetricsGroupV2) Get() (metrics []MetricV2) { m, _ := g.metricsCache.Get() if len(m) == 0 { return []MetricV2{}
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 133.6K bytes - Click Count (0)