- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 514 for pushed (0.07 seconds)
-
src/main/java/jcifs/internal/witness/WitnessRpcMessage.java
// Common return codes from MS-SWN specification /** Operation completed successfully */ public static final int ERROR_SUCCESS = 0x00000000; /** Invalid parameter was passed to the operation */ public static final int ERROR_INVALID_PARAMETER = 0x00000057; /** Buffer provided is insufficient */ public static final int ERROR_INSUFFICIENT_BUFFER = 0x0000007A;Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 5.5K bytes - Click Count (0) -
cmd/data-usage.go
scannerLogOnceIf(ctx, err, dataUsageObjNamePath) } attempts++ } } var prefixUsageCache = cachevalue.New[map[string]uint64]() // loadPrefixUsageFromBackend returns prefix usages found in passed buckets // // e.g.: /testbucket/prefix => 355601334 func loadPrefixUsageFromBackend(ctx context.Context, objAPI ObjectLayer, bucket string) (map[string]uint64, error) { z, ok := objAPI.(*erasureServerPools) if !ok {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu May 09 00:51:34 GMT 2024 - 5.6K bytes - Click Count (0) -
cmd/erasure_test.go
err = erasure.DecodeDataAndParityBlocks(t.Context(), encoded) } else { err = erasure.DecodeDataBlocks(encoded) } if err == nil && test.shouldFail { t.Errorf("Test %d: test should fail but it passed", i) } if err != nil && !test.shouldFail { t.Errorf("Test %d: test should pass but it failed: %v", i, err) } decoded := encoded if !test.shouldFail { if test.reconstructParity {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 4.8K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/PerCollectionSizeTestSuiteBuilder.java
* class (such as {@link #named(String)}) return this type, so that Builder methods of more * derived classes can be chained onto them without casting. * @param <G> The type of the generator to be passed to testers in the generated test suite. An * instance of G should somehow provide an instance of the class under test, plus any other * information required to parameterize the test. * @see FeatureSpecificTestSuiteBuilder
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 20:54:16 GMT 2025 - 5.4K bytes - Click Count (0) -
internal/jwt/parser_test.go
} if data.valid && err != nil { t.Errorf("Error while verifying token: %T:%v", err, err) } if !data.valid && err == nil { t.Errorf("Invalid token passed validation") } if data.errors != 0 { _, ok := err.(*jwt.ValidationError) if !ok { t.Errorf("Expected *jwt.ValidationError, but got %#v instead", err) } } }) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6K bytes - Click Count (0) -
.teamcity/mvnw.cmd
@REM M2_HOME - location of maven2's installed home dir @REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands @REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending @REM MAVEN_OPTS - parameters passed to the Java VM when running Maven @REM e.g. to debug Maven itself, use @REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000 @REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Feb 26 01:48:39 GMT 2020 - 6.5K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/SimplexTransferListener.java
private final boolean blockOnLastEvent; private final ArrayBlockingQueue<Exchange> eventQueue; private final AtomicBoolean closed; private final Thread updater; /** * Constructor that makes passed in delegate run on single thread, and will block on last event. */ public SimplexTransferListener(TransferListener delegate) { this(delegate, QUEUE_SIZE, BATCH_MAX_SIZE, true); } /**Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Feb 06 11:28:05 GMT 2025 - 8.7K bytes - Click Count (0) -
internal/http/server.go
w.Write([]byte(http.ErrServerClosed.Error())) return } atomic.AddInt32(&srv.requestCount, 1) defer atomic.AddInt32(&srv.requestCount, -1) // Handle request using passed handler. handler.ServeHTTP(w, r) }) srv.listenerMutex.Lock() srv.Handler = wrappedHandler srv.listener = listener srv.listenerMutex.Unlock() var l net.Listener = listener
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
* @param params search request parameters including pagination and filters * @param userBean optional user information for personalized search * @return list of search result documents with fused ranking scores */ public List<Map<String, Object>> search(final String query, final SearchRequestParams params, final OptionalThing<FessUserBean> userBean) {Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 27.5K bytes - Click Count (0) -
internal/logger/logger.go
} } } traceLevel++ // Read stack trace information from PC pc, file, lineNumber, ok = runtime.Caller(traceLevel) } return trace } // HashString - return the highway hash of the passed string func HashString(input string) string { hh, _ := highwayhash.New(magicHighwayHash256Key) hh.Write([]byte(input)) return hex.EncodeToString(hh.Sum(nil)) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.4K bytes - Click Count (0)