- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for function (0.65 sec)
-
cmd/storage-rest-server.go
return errXLBackend } return nil } // A single function to write certain errors to be fatal // or informative based on the `exit` flag, please look // at each implementation of error for added hints. // // FIXME: This is an unusual function but serves its purpose for // now, need to revisit the overall erroring structure here. // Do not like it :-(
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/global-heal.go
// in the beginning of erasure set healing if _, err := objAPI.HealBucket(ctx, bucket, madmin.HealOpts{ ScanMode: scanMode, }); err != nil { // Set this such that when we return this function // we let the caller retry this disk again for the // buckets that failed healing. retErr = err healingLogIf(ctx, err) continue } var ( vc *versioning.Versioning
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
cmd/storage-rest-client.go
case strings.Contains(err.Error(), "server closed idle connection"): return true } return false } // Converts network error to storageErr. This function is // written so that the storageAPI errors are consistent // across network disks. func toStorageErr(err error) error { if err == nil { return nil } if isNetworkError(err) { return errDiskNotFound
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
log.Debugf("ignoring error deleting optional iptables rule: %v", err) } } } return errors.Join(delErrs...) } // Setup iptables rules for in-pod mode. Ideally this should be an idempotent function. // NOTE that this expects to be run from within the pod network namespace! func (cfg *IptablesConfigurator) CreateInpodRules(hostProbeSNAT *netip.Addr) error { // Append our rules here
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 19.6K bytes - Viewed (0) -
cni/README.md
- CAP_SYS_ADMIN - CAP_NET_ADMIN - CAP_NET_RAW ## Ambient mode details Fundamentally, this component is responsible for the following:
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/metrics-v3.go
systemGoCollectorPath: collectors.NewGoCollector(), } // Add all `MetricGroup` collectors to the map. for _, mg := range allMetricGroups { collectors[mg.CollectorPath] = mg } // Helper function to register a collector and return a gatherer for it. mustRegister := func(c ...prometheus.Collector) prometheus.Gatherer { subRegistry := prometheus.NewRegistry() for _, col := range c {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 10K bytes - Viewed (0) -
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.Arrays; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import java.util.function.BiConsumer; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Collectors; import java.util.stream.Stream; import static java.util.regex.Pattern.quote; /**
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Apr 26 09:46:00 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/erasure.go
// NewNSLock - initialize a new namespace RWLocker instance. func (er erasureObjects) NewNSLock(bucket string, objects ...string) RWLocker { return er.nsMutex.NewNSLock(er.getLockers, bucket, objects...) } // Shutdown function for object storage interface. func (er erasureObjects) Shutdown(ctx context.Context) error { // Add any object layer shutdown activities here. closeStorageDisks(er.getDisks()...) return nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
maven-api-impl/src/test/java/org/apache/maven/internal/impl/standalone/RepositorySystemSupplier.java
package org.apache.maven.internal.impl.standalone; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.concurrent.atomic.AtomicBoolean; import java.util.function.Supplier; import org.apache.maven.api.services.ModelBuilder; import org.apache.maven.internal.impl.DefaultModelUrlNormalizer; import org.apache.maven.internal.impl.DefaultModelVersionParser;
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 26 13:10:42 GMT 2024 - 43.7K bytes - Viewed (0) -
cmd/object-api-errors.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "fmt" "io" ) // Converts underlying storage error. Convenience function written to // handle all cases where we have known types of errors returned by // underlying storage layer. func toObjectErr(oerr error, params ...string) error { if oerr == nil { return nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 21.3K bytes - Viewed (0)