- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 374 for Sync (0.13 sec)
-
internal/lsync/lrwmutex_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package lsync_test import ( "context" "fmt" "runtime" "sync" "sync/atomic" "testing" "time" . "github.com/minio/minio/internal/lsync" ) func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) { ctx := context.Background() lrwm := NewLRWMutex()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/config/api/api.go
apiDisableODirect = "disable_odirect" apiODirect = "odirect" apiGzipObjects = "gzip_objects" apiRootAccess = "root_access" apiSyncEvents = "sync_events" apiObjectMaxVersions = "object_max_versions" EnvAPIRequestsMax = "MINIO_API_REQUESTS_MAX" EnvAPIRequestsDeadline = "MINIO_API_REQUESTS_DEADLINE"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
cmd/metrics-resource.go
resourceMetricsMapMu sync.RWMutex // resourceMetricsHelpMap maps metric name to its help string resourceMetricsHelpMap map[MetricName]string resourceMetricsGroups []*MetricsGroupV2 // initial values for drives (at the time of server startup) // used for calculating avg values for drive metrics latestDriveStats map[string]madmin.DiskIOStats latestDriveStatsMu sync.RWMutex lastDriveStatsRefresh time.Time )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v2/sync/errgroup" "github.com/minio/pkg/v2/wildcard" ) type erasureServerPools struct { poolMetaMutex sync.RWMutex poolMeta poolMeta rebalMu sync.RWMutex rebalMeta *rebalanceMeta deploymentID [16]byte distributionAlgo string serverPools []*erasureSets
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/erasure-sets.go
for _, endpoint := range endpoints.Endpoints { if _, ok := erasureLockers[endpoint.Host]; !ok { erasureLockers[endpoint.Host] = newLockAPI(endpoint) } } var wg sync.WaitGroup var lk sync.Mutex for i := 0; i < setCount; i++ { lockerEpSet := set.NewStringSet() for j := 0; j < setDriveCount; j++ { wg.Add(1) go func(i int, endpoint Endpoint) { defer wg.Done()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
cmd/data-scanner_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "encoding/xml" "fmt" "strings" "sync" "testing" "time" "github.com/google/uuid" "github.com/minio/minio/internal/bucket/lifecycle" "github.com/minio/minio/internal/bucket/object/lock" "github.com/minio/minio/internal/bucket/versioning" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
clause/expression_test.go
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Aug 10 05:34:33 GMT 2023 - 8.4K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.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 ( "math/rand" "runtime" "sync" "testing" "time" ) func TestDynamicTimeoutSingleIncrease(t *testing.T) { timeout := newDynamicTimeout(time.Minute, time.Second) initial := timeout.Timeout()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 5.4K bytes - Viewed (0) -
internal/config/heal/heal.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package heal import ( "errors" "fmt" "strconv" "strings" "sync" "time" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v2/env" ) // Compression environment variables const ( Bitrot = "bitrotscan" Sleep = "max_sleep"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
internal/logger/target/http/http.go
// Worker control workers int64 maxWorkers int64 // workerStartMu sync.Mutex lastStarted time.Time wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex // If this webhook is being re-configured we will
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0)