- Sort Score
- Result 10 results
- Languages All
Results 961 - 970 of 3,084 for shouldn (0.17 sec)
-
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
*/ public long getNextRetryTime() { return nextRetryTime; } /** * Check if recovery should be attempted * * @return true if should retry */ public boolean shouldRetry() { return retryCount < 3; } /** * Increment retry count and update next retry time
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 11.6K bytes - Viewed (0) -
cmd/erasure-heal_test.go
closeBitrotReaders(readers) closeBitrotWriters(staleWriters) if err != nil && !test.shouldFail { t.Errorf("Test %d: should pass but it failed with: %v", i, err) } if err == nil && test.shouldFail { t.Errorf("Test %d: should fail but it passed", i) } if err == nil { // Verify that checksums of staleDisks // match expected values for i := range staleWriters {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 7.9K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/SmbComNtTransactionResponseTest.java
assertEquals(37, bytesRead); // 3 reserved + 32 (8*4) + 2 for setupCount assertEquals(10, response.totalParameterCount); assertEquals(10, response.bufDataStart); // Should be set to totalParameterCount assertEquals(20, response.totalDataCount); assertEquals(5, response.parameterCount); assertEquals(30, response.parameterOffset);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 5.6K bytes - Viewed (0) -
docs/bucket/replication/delete-replication.sh
out="$(./mc ls myminio1/foobucket/dir/)" if [ "$out" != "" ]; then echo "BUG: non versioned listing should not show pending/failed replicated delete:" echo "$out" exit 1 fi out="$(./mc ls --versions myminio1/foobucket/dir/)" if [ "$out" != "" ]; then echo "BUG: versioned listing should not show pending/failed replicated deletes:" echo "$out" exit 1 fi echo "Success"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 3.9K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/DefaultMirrorSelector.java
URL url = new URL(originalRepository.getUrl()); return !(isLocal(url.getHost()) || url.getProtocol().equals("file")); } catch (MalformedURLException e) { // bad url just skip it here. It should have been validated already, but the wagon lookup will deal with it return false; } } private static boolean isLocal(String host) {
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 8K bytes - Viewed (0) -
docs/erasure/storage-class/README.md
### Allowed values for STANDARD storage class `STANDARD` storage class implies more parity than `REDUCED_REDUNDANCY` class. So, `STANDARD` parity drives should be - Greater than or equal to 2, if `REDUCED_REDUNDANCY` parity is not set. - Greater than `REDUCED_REDUNDANCY` parity, if it is set.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 5.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
// In a real implementation, this should be passed from the session context jcifs.CIFSContext context = createDefaultContext(); // Create transport with multi-channel specific settings // Multi-channel transports should use signing consistently with the main session boolean forceSigning = context.getConfig().isSigningEnforced();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 20.5K bytes - Viewed (0) -
cmd/local-locker_test.go
// but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "encoding/hex" "fmt" "math/rand" "testing"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.8K bytes - Viewed (0) -
okhttp-urlconnection/src/main/kotlin/okhttp3/JavaNetCookieJar.kt
* * This implementation delegates everything to [okhttp3.java.net.cookiejar.JavaNetCookieJar], which * conforms to the package-naming limitations of JPMS. * * Callers should prefer to use [okhttp3.java.net.cookiejar.JavaNetCookieJar] directly. */ class JavaNetCookieJar private constructor( delegate: okhttp3.java.net.cookiejar.JavaNetCookieJar, ) : CookieJar by delegate {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 1.2K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/Uninterruptibles.java
public static <V extends @Nullable Object> V getUninterruptibly(Future<V> future) throws ExecutionException { try { return future.get(); } catch (InterruptedException e) { // Should never be thrown in GWT but play it safe throw new IllegalStateException(e); } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.3K bytes - Viewed (0)