- Sort Score
- Num 10 results
- Language All
Results 1251 - 1260 of 1,541 for ending (0.04 seconds)
-
cmd/xl-storage.go
// for io.EOF. // // If an EOF happens after reading some but not all the bytes, // ReadFile returns ErrUnexpectedEOF. // // If the BitrotVerifier is not nil or not verified ReadFile // tries to verify whether the disk has bitrot. // // Additionally ReadFile also starts reading from an offset. ReadFile // semantics are same as io.ReadFull.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
/** * This method is called by {@link #stopAsync} when the service is still starting (i.e. {@link * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the * method to cancel pending work and then call {@link #notifyStopped} to stop the service. * * <p>This method should return promptly; prefer to do work on a different thread where it isCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 20.3K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.25.md
### Container Images All container images are available as manifest lists and support the described architectures. It is also possible to pull a specific architecture directly by adding the "-$ARCH" suffix to the container image name. name | architectures ---- | -------------
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Mon May 06 09:23:20 GMT 2024 - 419.1K bytes - Click Count (0) -
okhttp-tls/src/test/java/okhttp3/tls/HeldCertificateTest.kt
| """.trimMargin() val heldCertificate = decode(certificatePem + pkcs8Pem) assertThat(heldCertificate.certificatePem()).isEqualTo(certificatePem) // Slightly different encoding if (platform.isBouncyCastle()) { assertThat(heldCertificate.privateKeyPkcs8Pem()).isEqualTo(bcPkcs8Pem) } else { assertThat(heldCertificate.privateKeyPkcs8Pem()).isEqualTo(pkcs8Pem) }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 22.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
val requestBody = if (maintainBody) userResponse.request.body else null requestBuilder.method(method, requestBody) } if (!maintainBody) { requestBuilder.removeHeader("Transfer-Encoding") requestBuilder.removeHeader("Content-Length") requestBuilder.removeHeader("Content-Type") } } // When redirecting across hosts, drop all authentication headers. This
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue May 27 14:58:02 GMT 2025 - 12.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/ProtocolHelper.java
} /** * Checks if the given URL should skip URL decoding when extracting file names. * Some protocols (like SMB, FTP, S3, GCS) should preserve the original URL encoding. * * @param url the URL to check * @return true if URL decoding should be skipped for this protocol */ public boolean shouldSkipUrlDecode(final String url) {Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Dec 12 13:58:40 GMT 2025 - 12.4K bytes - Click Count (1) -
src/test/java/jcifs/smb/SmbOperationExceptionTest.java
// Then assertNotNull(exception.getContext()); assertTrue(exception.getContext().isEmpty()); // Adding null context should be safe exception.withContext(null); assertTrue(exception.getContext().isEmpty()); } @Test @DisplayName("Should be serializable")Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 16.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
for (Service service : copy) { service.addListener(new ServiceListener(service, stateReference), directExecutor()); // We check the state after adding the listener as a way to ensure that our listener was added // to a NEW service. checkArgument(service.state() == NEW, "Can only manage NEW services, %s", service); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 33.2K bytes - Click Count (1) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
for (Service service : copy) { service.addListener(new ServiceListener(service, stateReference), directExecutor()); // We check the state after adding the listener as a way to ensure that our listener was added // to a NEW service. checkArgument(service.state() == NEW, "Can only manage NEW services, %s", service); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 32.9K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/ServerMessageBlock2Test.java
} } @Nested @DisplayName("Edge Case Tests") class EdgeCaseTests { @Test @DisplayName("Should handle empty buffer encoding") void testEmptyBufferEncoding() { byte[] buffer = new byte[256]; testMessage.setBytesWritten(0); int len = testMessage.encode(buffer, 0);Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 39.5K bytes - Click Count (0)