- Sort Score
- Result 10 results
- Languages All
Results 1721 - 1730 of 6,918 for RETURN (0.12 sec)
-
cmd/mrf.go
wg sync.WaitGroup } func newMRFState() mrfState { return mrfState{ opCh: make(chan PartialOperation, mrfOpsQueueSize), } } // Add a partial S3 operation (put/delete) when one or more disks are offline. func (m *mrfState) addPartialOp(op PartialOperation) { if m == nil { return } if atomic.LoadInt32(&m.closed) == 1 { return } m.wg.Add(1) defer m.wg.Done()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/config.go
lookupConfigs(srvCfg, objAPI) return srvCfg, nil } return nil, err } data, err = decryptData(data, configFile) if err != nil { lookupConfigs(srvCfg, objAPI) return nil, err } } json := jsoniter.ConfigCompatibleWithStandardLibrary if err := json.Unmarshal(data, &srvCfg); err != nil { return nil, err } // Add any missing entries
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 23 10:07:06 UTC 2023 - 6K bytes - Viewed (0) -
internal/config/policy/opa/config.go
CloseRespFn: closeRespFn, } if err = args.Validate(); err != nil { return args, err } return args, nil } // New - initializes opa policy engine connector. func New(args Args) *Opa { // No opa args. if args.URL == nil || args.URL.Scheme == "" && args.AuthToken == "" { return nil } return &Opa{ args: args, client: &http.Client{Transport: args.Transport}, } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 10 20:16:44 UTC 2024 - 5.3K bytes - Viewed (0) -
src/test/java/jcifs/tests/KerberosTest.java
builder.destroy(); return Krb5Util.credsToTicket(creds); } public static Subject getInitiatorSubject ( KerberosPrincipal principal, String password, Long expire ) throws Exception { KerberosTicket ticket = getKerberosTicket(principal, password, expire); Set<Object> privCreds = new HashSet<>(); privCreds.add(ticket);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Mar 01 09:46:04 UTC 2020 - 11.5K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/DelegatingLocalArtifactRepository.java
return userLocalArtifactRepository.getReleases(); } @Override public ArtifactRepositoryPolicy getSnapshots() { return userLocalArtifactRepository.getSnapshots(); } @Override public String getKey() { return userLocalArtifactRepository.getKey(); } @Override public String getUrl() {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/admin/dict/SynonymTests.java
@Override protected String getNamePrefix() { return NAME_PREFIX; } @Override protected String getApiPath() { return API_PATH; } @Override protected String getKeyProperty() { return KEY_PROPERTY; } @Override protected String getListEndpointSuffix() { return LIST_ENDPOINT_SUFFIX + "/" + dictId; } @Override
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/util/FieldConfigs.java
if ("cache".equalsIgnoreCase(value)) { return true; } } // backward compatibility if (values.length == 1 && Constants.TRUE.equalsIgnoreCase(values[0])) { return true; } return false; } public boolean isOverwrite() { for (final String value : values) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 2.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/CollectorTester.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 6.5K bytes - Viewed (0) -
build-logic/documentation/src/test/groovy/gradlebuild/docs/dsl/docbook/ClassDocPropertiesBuilderTest.groovy
_ * classMetaData.className >> name return classMetaData } def classDoc(String name = 'org.gradle.Class') { ClassDoc doc = Mock() _ * doc.name >> name _ * doc.toString() >> "ClassDoc '$name'" return doc } def property(String name, ClassMetaData classMetaData) { return property([:], name, classMetaData) }
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 7.6K bytes - Viewed (0) -
.teamcity/src/main/kotlin/model/bucket-extensions.kt
canRunTogether: (T, T) -> Boolean = { _, _ -> true } ): List<R> { if (list.isEmpty()) { return noElementSplitFunction(expectedBucketNumber) } if (expectedBucketNumber == 1) { return listOf(smallElementAggregateFunction(list)) } val expectedBucketSize = list.sumOf(toIntFunction) / expectedBucketNumber if (expectedBucketSize == 0) {
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Thu Nov 17 05:17:44 UTC 2022 - 4K bytes - Viewed (0)