Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1721 - 1730 of 6,918 for RETURN (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. guava-testlib/src/com/google/common/testing/CollectorTester.java

              push(stack, collector.combiner().apply(left, right));
            }
            return pop(stack);
          }
    
          <E extends @Nullable Object> void push(List<E> stack, E value) {
            stack.add(value);
          }
    
          <E extends @Nullable Object> E pop(List<E> stack) {
            return stack.remove(stack.size() - 1);
          }
        };
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 17:40:56 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. 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)
  10. .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)
Back to top