- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for locks (0.12 sec)
-
cmd/erasure-common.go
} ignoredErrs := []error{ errFileNotFound, errVolumeNotFound, errFileVersionNotFound, io.ErrUnexpectedEOF, // some times we would read without locks, ignore these errors io.EOF, // some times we would read without locks, ignore these errors context.DeadlineExceeded, context.Canceled, } ignoredErrs = append(ignoredErrs, objectOpIgnoredErrs...) errs := g.Wait()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/metrics-v3-system-process.go
package cmd import ( "context" "runtime" "time" "github.com/prometheus/procfs" ) const ( processLocksReadTotal = "locks_read_total" processLocksWriteTotal = "locks_write_total" processCPUTotalSeconds = "cpu_total_seconds" processGoRoutineTotal = "go_routine_total" processIORCharBytes = "io_rchar_bytes"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 6.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
import java.util.concurrent.SynchronousQueue import java.util.concurrent.ThreadFactory import java.util.concurrent.ThreadPoolExecutor import java.util.concurrent.TimeUnit import java.util.concurrent.locks.Condition import java.util.concurrent.locks.ReentrantLock import java.util.logging.Logger import kotlin.concurrent.withLock import okhttp3.internal.addIfAbsent import okhttp3.internal.assertHeld
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
.teamcity/src/main/kotlin/promotion/BasePromotionBuildType.kt
// we only allow 1 promotion job running at the same time to avoid website xml conflicts feature { type = "JetBrains.SharedResources" param("locks-param", "WebsiteReleasesXml writeLock") } } }
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Wed Apr 24 03:34:53 GMT 2024 - 2.1K bytes - Viewed (0) -
docs/metrics/v3.md
| `locks_read_total` | `gauge` | Number of current READ locks on this peer | `server` | | `locks_write_total` | `gauge` | Number of current WRITE locks on this peer | `server` |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 28.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
import okhttp3.FakeRoutePlanner import okhttp3.OkHttpClient import okhttp3.Request import okhttp3.TestUtil.awaitGarbageCollection import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.connection.Locks.withLock import okhttp3.internal.http2.Http2 import okhttp3.internal.http2.Http2Connection import okhttp3.internal.http2.Http2ConnectionTest import okhttp3.internal.http2.MockHttp2Peer import okhttp3.internal.http2.Settings
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
cmd/metrics-v2.go
Namespace: minioNamespace, Subsystem: "locks", Name: "total", Help: "Number of current locks on this peer", Type: gaugeMetric, }, Value: float64(st.Total), }) metrics = append(metrics, MetricV2{ Description: MetricDescription{ Namespace: minioNamespace, Subsystem: "locks", Name: "write_total",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
maven-api-impl/pom.xml
<artifactId>maven-di</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.maven.resolver</groupId> <artifactId>maven-resolver-named-locks</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.maven.resolver</groupId> <artifactId>maven-resolver-connector-basic</artifactId> <scope>test</scope>
XML - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 9.8K bytes - Viewed (0) -
cmd/metrics-v3-types.go
mg.ExtraLabels) for _, metric := range promMetrics { ch <- metric } } // LockAndSetBuckets - locks the buckets and sets the given buckets. It returns // a function to unlock the buckets. func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() { mg.bucketsLock.Lock() mg.buckets = buckets return func() { mg.bucketsLock.Unlock() } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:05:22 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/object-api-interface.go
CreatedAt time.Time // only for site replication NoLock bool // does not lock the make bucket call if set to 'true' } // DeleteBucketOptions provides options for DeleteBucket calls. type DeleteBucketOptions struct { NoLock bool // does not lock the delete bucket call if set to 'true' NoRecreate bool // do not recreate bucket on delete failures
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0)