- Sort Score
- Num 10 results
- Language All
Results 1131 - 1140 of 1,861 for filled (0.26 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/grid/stream.go
// Channel *must* be closed to signal the end of the stream. // If the request context is canceled, the stream will no longer process requests. // Requests sent cannot be used any further by the called. Requests chan<- []byte muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jun 07 15:51:52 GMT 2024 - 3.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
rawSocket.soTimeout = socketReadTimeoutMillis try { Platform.get().connectSocket(rawSocket, route.socketAddress, socketConnectTimeoutMillis) } catch (e: ConnectException) { throw ConnectException("Failed to connect to ${route.socketAddress}").apply { initCause(e) } } // The following try/catch block is a pseudo hacky way to get around a crash on Android 7.0 // More details:Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 19.3K bytes - Click Count (2) -
src/main/java/org/codelibs/fess/util/ThreadDumpUtil.java
} /** * Writes thread dump information to the specified file. * * @param file the file path to write the thread dump to */ public static void writeThreadDump(final String file) { try (final Writer writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file), Constants.CHARSET_UTF_8))) { processThreadDump(s -> { try {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 3.3K bytes - Click Count (0) -
android-test/src/test/kotlin/okhttp/android/test/AndroidLoggingTest.kt
assertThat( logs.map { it.msg.replace( "\\d+".toRegex(), "", ) }, ).containsExactly( "--> GET http://google.com/robots.txt", "<-- HTTP FAILED: java.net.UnknownHostException: shortcircuit. ${request.url} (ms)", ) // We should consider if these logs should retain Exceptions assertThat(logs.last().throwable).isNull() } @Test
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Aug 21 14:27:04 GMT 2025 - 3.2K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/ModelBuilderException.java
/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at *
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Sep 25 21:57:56 GMT 2025 - 2.9K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/AbstractMavenLifecycleParticipant.java
/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at *
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 2.9K bytes - Click Count (0) -
build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/precommit/PomValidationTask.java
}); validateNonNull("scm", model.getScm(), () -> validateString("scm.url", model.getScm().getUrl())); } if (foundError) { throw new GradleException("Check failed for task '" + getPath() + "', see console log for details"); } } private void logError(String element, String message) { foundError = true;Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 3.4K bytes - Click Count (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/event/ExecutionEventLogger.java
/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at *
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Nov 08 08:49:11 GMT 2024 - 17.2K bytes - Click Count (0) -
schema/field_test.go
func TestParseFieldWithPermission(t *testing.T) { user, err := schema.Parse(&UserWithPermissionControl{}, &sync.Map{}, schema.NamingStrategy{}) if err != nil { t.Fatalf("Failed to parse user with permission, got error %v", err) } fields := []*schema.Field{
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Feb 19 09:02:53 GMT 2022 - 12.7K bytes - Click Count (0) -
cmd/sftp-server-driver.go
// When TransferError() is called Close() will also // be called, so we do not need to Wait() here. func (w *writerAt) TransferError(err error) { _ = w.w.CloseWithError(err) _ = w.r.CloseWithError(err) w.err = err } func (w *writerAt) Close() (err error) { switch { case len(w.buffer) > 0: err = errors.New("some file segments were not flushed from the queue")
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Feb 10 16:35:49 GMT 2025 - 11.6K bytes - Click Count (0)