- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 362 for picard (0.13 sec)
-
platforms/software/resources-sftp/src/main/java/org/gradle/internal/resource/transport/sftp/SftpClientFactory.java
if (!client.isConnected()) { LOGGER.info("Tried to reuse an existing sftp client, but unexpectedly found it disconnected. Discarding and trying again."); discard(client); client = reuseExistingOrCreateNewClient(sftpHost); } else { LOGGER.debug("Reusing an existing sftp client."); } } return client;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 7.9K bytes - Viewed (0) -
platforms/core-execution/hashing/src/main/java/org/gradle/internal/hash/DefaultStreamHasher.java
} finally { returnBuffer(buffer); } } private void returnBuffer(byte[] buffer) { // Retain buffer if there is capacity in the queue, otherwise discard buffers.offer(buffer); } private byte[] takeBuffer() { byte[] buffer = buffers.poll(); if (buffer == null) { buffer = new byte[8192]; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:43:29 UTC 2023 - 2.5K bytes - Viewed (0) -
src/net/sendfile_test.go
} }() wg.Add(1) go func() { // Connect to the server started two goroutines up and // discard any data that it writes. defer wg.Done() conn, err := Dial("tcp", ln.Addr().String()) if err != nil { t.Error(err) return } defer conn.Close() io.Copy(io.Discard, conn) }() // Wait for the byte to be copied, meaning that sendfile has // been called on the pipe.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0) -
src/compress/lzw/reader_test.go
for i := 0; i < b.N; i++ { io.Copy(io.Discard, NewReader(bytes.NewReader(buf1), LSB, 8)) } }) b.Run(fmt.Sprint("1e-Reuse", e), func(b *testing.B) { b.StopTimer() b.SetBytes(int64(n)) buf1 := getInputBuf(buf, n) runtime.GC() b.StartTimer() r := NewReader(bytes.NewReader(buf1), LSB, 8) for i := 0; i < b.N; i++ { io.Copy(io.Discard, r) r.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 16:57:58 UTC 2024 - 7.6K bytes - Viewed (0) -
platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/ProviderCodecs.kt
value.isMissing -> { // Can serialize a fixed value and discard the provider // TODO - should preserve information about the source, for diagnostics at execution time writeByte(1) } value.hasFixedValue() && sideEffect == null -> { // Can serialize a fixed value and discard the provider
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 17.2K bytes - Viewed (0) -
internal/ioutil/ioutil_test.go
} } func TestCloseOnWriter(t *testing.T) { writer := WriteOnClose(io.Discard) if writer.HasWritten() { t.Error("WriteOnCloser must not be marked as HasWritten") } writer.Write(nil) if !writer.HasWritten() { t.Error("WriteOnCloser must be marked as HasWritten") } writer = WriteOnClose(io.Discard) writer.Close() if !writer.HasWritten() { t.Error("WriteOnCloser must be marked as HasWritten")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
src/time/zoneinfo_windows_test.go
// license that can be found in the LICENSE file. package time_test import ( "internal/syscall/windows/registry" "testing" . "time" ) func testZoneAbbr(t *testing.T) { t1 := Now() // discard nsec t1 = Date(t1.Year(), t1.Month(), t1.Day(), t1.Hour(), t1.Minute(), t1.Second(), 0, t1.Location()) t2, err := Parse(RFC1123, t1.Format(RFC1123)) if err != nil { t.Fatalf("Parse failed: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 14 07:20:34 UTC 2023 - 1.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
import okhttp3.HttpUrl import okhttp3.OkHttpClient import okhttp3.Request import okhttp3.Response import okhttp3.internal.EMPTY_HEADERS import okhttp3.internal.checkOffsetAndCount import okhttp3.internal.discard import okhttp3.internal.headersContentLength import okhttp3.internal.http.ExchangeCodec import okhttp3.internal.http.HTTP_CONTINUE import okhttp3.internal.http.RequestLine import okhttp3.internal.http.StatusLine
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 16.2K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/moduleconverter/DefaultRootComponentMetadataBuilder.java
} @Override public MutationValidator getValidator() { return holder; } @Override public void discardAll() { holder.discard(); } private static class MetadataHolder implements MutationValidator { @Nullable private SoftReference<LocalComponentGraphResolveState> reference; @Nullable
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 11.6K bytes - Viewed (0) -
platforms/jvm/jvm-services/src/main/java/org/gradle/internal/jvm/inspection/JvmVendor.java
APPLE("apple", "Apple"), AZUL("azul systems", "Azul Zulu"), BELLSOFT("bellsoft", "BellSoft Liberica"), GRAAL_VM("graalvm community", "GraalVM Community"), HEWLETT_PACKARD("hewlett-packard", "HP-UX"), IBM("ibm", "ibm|international business machines corporation", "IBM"), JETBRAINS("jetbrains", "JetBrains"), MICROSOFT("microsoft", "Microsoft"), ORACLE("oracle", "Oracle"),
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 02 23:55:59 UTC 2023 - 3.6K bytes - Viewed (0)