- Sort Score
- Num 10 results
- Language All
Results 551 - 560 of 1,514 for close (0.04 seconds)
-
build-logic/binary-compatibility/src/test/groovy/gradlebuild/binarycompatibility/PublicAPIRulesTest.groovy
injectAnnotation.fullyQualifiedName >> Inject.name repository = BinaryCompatibilityRepository.openRepositoryFor([new File(tmp.absolutePath)], []) } def cleanup() { repository?.close() } def "each new #apiElement requires a @Incubating annotation"() { given: JApiCompatibility jApiType = getProperty(jApiTypeName) def rule = withContext(new IncubatingMissingRule([:]))
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Jun 06 17:52:09 GMT 2025 - 16K bytes - Click Count (0) -
cmd/storage-rest-server.go
xioutil.SafeClose(c.done) c.done = nil } } return n, err } func (c *closeNotifier) Close() error { if c.done != nil { xioutil.SafeClose(c.done) c.done = nil } return c.rc.Close() } // keepHTTPReqResponseAlive can be used to avoid timeouts with long storage // operations, such as bitrot verification or data usage scanning. // Every 10 seconds a space character is sent.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/Hc5HttpClient.java
} if (httpClient != null) { try { httpClient.close(); if (logger.isDebugEnabled()) { logger.debug("HTTP client closed successfully"); } } catch (final IOException e) { logger.warn("Failed to close HTTP client", e); } httpClient = null;Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sat Jan 31 12:23:29 GMT 2026 - 62.2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
.isEqualTo("response D") requestBody.writeUtf8("request E\n") requestBody.flush() assertThat(responseBody.readUtf8Line()) .isEqualTo("response F") requestBody.close() assertThat(responseBody.readUtf8Line()).isNull() } body.awaitSuccess() } @Test fun trueDuplexServerWritesFirst() { enableProtocol(Protocol.HTTP_2) val body =
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 25.8K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.8K bytes - Click Count (0) -
src/main/java/jcifs/util/transport/Transport.java
final boolean timeout = ex instanceof SocketTimeoutException || msg != null && msg.equals("Read timed out"); final boolean closed = msg != null && msg.equals("Socket closed"); if (closed) { log.trace("Remote closed connection"); } else if (timeout) { log.debug("socket timeout in non peek state", ex); } else {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 27.8K bytes - Click Count (0) -
cmd/post-policy_test.go
} // Set the File formData writer, err := w.CreateFormFile("file", "upload.txt") if err != nil { // return nil, err return nil, err } writer.Write([]byte("hello world")) // Close before creating the new request. w.Close() // Set the body equal to the created policy. reader := bytes.NewReader(buf.Bytes()) req, err := http.NewRequest(http.MethodPost, makeTestTargetURL(endPoint, bucketName, "", nil), reader)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 30.6K bytes - Click Count (0) -
guava/src/com/google/common/base/internal/Finalizer.java
* @param frqReference a phantom reference to the FinalizableReferenceQueue, which will be queued * either when the FinalizableReferenceQueue is no longer referenced anywhere, or when its * close() method is called. */ public static void startFinalizer( Class<?> finalizableReferenceClass, ReferenceQueue<Object> queue, PhantomReference<Object> frqReference) { /*
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 11 03:19:29 GMT 2026 - 9.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt
private val server = MockWebServer() private var client = clientTestRule.newClient() private val callback = RecordingCallback() @Test fun applicationInterceptorsCanShortCircuitResponses() { server.close() // Accept no connections. val request = Request .Builder() .url("https://localhost:1/") .build() val interceptorResponse = Response .Builder()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 16:11:23 GMT 2025 - 28.2K bytes - Click Count (0) -
src/main/webapp/css/admin/adminlte.min.css
.modal-header{border-color:#343a40}.modal-content.bg-danger .close,.modal-content.bg-danger .mailbox-attachment-close,.modal-content.bg-info .close,.modal-content.bg-info .mailbox-attachment-close,.modal-content.bg-primary .close,.modal-content.bg-primary .mailbox-attachment-close,.modal-content.bg-secondary .close,.modal-content.bg-secondary .mailbox-attachment-close,.modal-content.bg-success .close,.modal-content.bg-success .mailbox-attachment-close{color:#fff;text-shadow:0 1px 0 #000}.dark-mode .modal-footer,.dark-mode...Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Oct 26 01:49:09 GMT 2024 - 1.3M bytes - Click Count (0)