- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 374 for Sync (0.19 sec)
-
internal/dsync/locked_rand.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import ( "math/rand" "sync" ) // lockedRandSource provides protected rand source, implements rand.Source interface. type lockedRandSource struct { lk sync.Mutex src rand.Source } // Int63 returns a non-negative pseudo-random 63-bit integer as an int64. func (r *lockedRandSource) Int63() (n int64) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Oct 18 15:39:59 GMT 2021 - 1.3K bytes - Viewed (0) -
cmd/metrics-v3-cluster-iam.go
sinceLastSyncMillis = "since_last_sync_millis" syncFailures = "sync_failures" syncSuccesses = "sync_successes" ) var ( lastSyncDurationMillisMD = NewCounterMD(lastSyncDurationMillis, "Last successful IAM data sync duration in milliseconds")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 08:20:42 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
log.Debug("debug log") log.Info("info log") log.Warn("warn log") log.Error("error log") // This will error because stdout cannot sync, but the UDS part should sync // Ideally we would fail if the UDS part fails but the error library makes it kind of tricky _ = log.Sync() // Restore os stdout. os.Stdout = stdout assert.NoError(t, log.Configure(loggingOptions)) assert.NoError(t, w.Close())
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
src/archive/zip/register.go
type Decompressor func(r io.Reader) io.ReadCloser var flateWriterPool sync.Pool func newFlateWriter(w io.Writer) io.WriteCloser { fw, ok := flateWriterPool.Get().(*flate.Writer) if ok { fw.Reset(w) } else { fw, _ = flate.NewWriter(w, 5) } return &pooledFlateWriter{fw: fw} } type pooledFlateWriter struct { mu sync.Mutex // guards Close and Write fw *flate.Writer }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/globals.go
// Only needed for tracking globalServiceFreezeCnt int32 globalServiceFreezeMu sync.Mutex // Updates. // List of local drives to this node, this is only set during server startup, // and is only mutated by HealFormat. Hold globalLocalDrivesMu to access. globalLocalDrives []StorageAPI globalLocalDrivesMu sync.RWMutex
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
package lsync import ( "context" "math" "math/rand" "sync" "time" ) // A LRWMutex is a mutual exclusion lock with timeouts. type LRWMutex struct { id string source string isWriteLock bool ref int mu sync.Mutex // Mutex to prevent multiple simultaneous locks } // NewLRWMutex - initializes a new lsync RW mutex.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleBuildDocumentationPlugin.java
} private void applyConventions(Project project, TaskContainer tasks, ObjectFactory objects, ProjectLayout layout, GradleDocumentationExtension extension) { TaskProvider<Sync> stageDocs = tasks.register("stageDocs", Sync.class, task -> { // release notes goes in the root of the docs task.from(extension.getReleaseNotes().getRenderedDocumentation()); // DSL reference goes into dsl/
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Wed Apr 17 20:04:00 GMT 2024 - 7.4K bytes - Viewed (0) -
api/go1.9.txt
pkg runtime/pprof, type LabelSet struct pkg sync, method (*Map) Delete(interface{}) pkg sync, method (*Map) Load(interface{}) (interface{}, bool) pkg sync, method (*Map) LoadOrStore(interface{}, interface{}) (interface{}, bool) pkg sync, method (*Map) Range(func(interface{}, interface{}) bool) pkg sync, method (*Map) Store(interface{}, interface{}) pkg sync, type Map struct
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Mon Oct 04 20:20:20 GMT 2021 - 10.7K bytes - Viewed (0) -
schema/relationship_test.go
package schema_test import ( "sync" "testing" "gorm.io/gorm" "gorm.io/gorm/schema" ) func checkStructRelation(t *testing.T, data interface{}, relations ...Relation) { if s, err := schema.Parse(data, &sync.Map{}, schema.NamingStrategy{}); err != nil { t.Errorf("Failed to parse schema, got error %v", err) } else { for _, rel := range relations { checkSchemaRelation(t, s, rel) } } }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Apr 15 03:20:20 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/object-api-common.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "sync" "github.com/dustin/go-humanize" ) const ( // Block size used for all internal operations version 1. // TLDR.. // Not used anymore xl.meta captures the right blockSize
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2.1K bytes - Viewed (0)