- Sort Score
- Result 10 results
- Languages All
Results 401 - 410 of 435 for atomic (1.25 sec)
-
internal/event/target/elasticsearch.go
parts := strings.Split(version, ".") if len(parts) < 1 { err = fmt.Errorf("bad ES version string: %s", version) return res, err } majorVersion, err := strconv.Atoi(parts[0]) if err != nil { err = fmt.Errorf("bad ES version string: %s", version) return res, err } switch { case majorVersion <= 6: res = ESSUnsupported default: res = ESSSupported }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
ctx := r.Context() objectAPI, cred := validateAdminReq(ctx, w, r, policy.ConfigUpdateAdminAction) if objectAPI == nil { return } vars := mux.Vars(r) count, err := strconv.Atoi(vars["count"]) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } chEntries, err := listServerConfigHistory(ctx, objectAPI, true, count) if err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15.8K bytes - Viewed (1) -
cmd/batch-expire.go
} if err := ri.loadOrInit(ctx, api, job); err != nil { return err } globalBatchJobsMetrics.save(job.ID, ri) lastObject := ri.Object now := time.Now().UTC() workerSize, err := strconv.Atoi(env.Get("_MINIO_BATCH_EXPIRATION_WORKERS", strconv.Itoa(runtime.GOMAXPROCS(0)/2))) if err != nil { return err } wk, err := workers.New(workerSize) if err != nil { // invalid worker size.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Apr 22 11:16:32 UTC 2025 - 23K bytes - Viewed (0) -
cmd/sftp-server.go
host, portStr, err := net.SplitHostPort(tokens[1]) if err != nil { logger.Fatal(fmt.Errorf("invalid arguments passed to --sftp=%s (%v)", arg, err), "unable to start SFTP server") } port, err = strconv.Atoi(portStr) if err != nil { logger.Fatal(fmt.Errorf("invalid arguments passed to --sftp=%s (%v)", arg, err), "unable to start SFTP server") } if port < 1 || port > 65535 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 16.5K bytes - Viewed (0) -
android/guava/src/com/google/common/net/InternetDomainName.java
* works for ASCII. So for now, assume any non-ASCII characters are valid. The only place this * seems to be documented is here: * https://groups.google.com/d/topic/google-web-toolkit-contributors/1UEzsryq1XI * * <p>ASCII characters in the part are expected to be valid per RFC 1035, with underscore also * being allowed due to widespread practice. */Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 27.9K bytes - Viewed (0) -
src/cmd/asm/internal/asm/parse.go
} } } // factor = const | '+' factor | '-' factor | '~' factor | '(' expr ')' func (p *Parser) factor() uint64 { tok := p.next() switch tok.ScanToken { case scanner.Int: return p.atoi(tok.String()) case scanner.Char: str, err := strconv.Unquote(tok.String()) if err != nil { p.errorf("%s", err) } r, w := utf8.DecodeRuneInString(str) if w == 1 && r == utf8.RuneError {Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Wed Nov 12 03:59:40 UTC 2025 - 37.3K bytes - Viewed (0) -
internal/dsync/drwmutex.go
dsyncLog = env.Get("_MINIO_DSYNC_TRACE", "0") == "1" lockRetryMinInterval = 250 * time.Millisecond if lri := env.Get("_MINIO_LOCK_RETRY_INTERVAL", ""); lri != "" { v, err := strconv.Atoi(lri) if err != nil { panic(err) } lockRetryMinInterval = time.Duration(v) * time.Millisecond } lockRetryBackOff = backoffWait( lockRetryMinInterval, 100*time.Millisecond, 5*time.Second,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.3K bytes - Viewed (0) -
cmd/testdata/undeleteable-object.tgz
y":"format","value":"namespace"},{"key":"index","value":""},{"key":"queue_dir","value":""},{"key":"queue_limit","value":"0"},{"key":"username","value":""},{"key":"password","value":""}]},"notify_kafka":{"_":[{"key":"enable","value":"off"},{"key":"topic","value":""},{"key":"brokers","value":""},{"key":"sasl_username","value":""},{"key":"sasl_password","value":""},{"key":"sasl_mechanism","value":"plain"},{"key":"client_tls_cert","value":""},{"key":"client_tls_key","value":""},{"key":"tls_client_au...
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Apr 26 00:31:12 UTC 2024 - 8.7M bytes - Viewed (0) -
cmd/common-main.go
OpenIDProviders: buildOpenIDConsoleConfig(), } server := consoleapi.NewServer(api) // register all APIs server.ConfigureAPI() consolePort, _ := strconv.Atoi(globalMinioConsolePort) server.Host = globalMinioConsoleHost server.Port = consolePort consoleapi.Port = globalMinioConsolePort consoleapi.Hostname = globalMinioConsoleHost if globalIsTLS {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.5K bytes - Viewed (3) -
.bazelrc
common:windows --features=compiler_param_file common:windows --features=archive_param_file # Speed Windows compile times. Available in VS 16.4 (we are on 16.11). See # https://groups.google.com/a/tensorflow.org/d/topic/build/SsW98Eo7l3o/discussion common:windows --copt=/d2ReducedOptimizeHugeFunctions common:windows --host_copt=/d2ReducedOptimizeHugeFunctions # Before VS 2017 15.8, the member "type" would non-conformingly have an
Registered: Tue Dec 30 12:39:10 UTC 2025 - Last Modified: Fri Dec 26 23:20:26 UTC 2025 - 56.8K bytes - Viewed (0)