- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 1,060 for readArg (0.18 sec)
-
src/test/java/org/codelibs/opensearch/extension/analysis/ReloadableKuromojiTokenizerFactory.java
public class ReloadableKuromojiTokenizerFactory extends AbstractTokenizerFactory { private static final boolean VERBOSE = false; // debug protected static final Reader ILLEGAL_STATE_READER = new Reader() { @Override public int read(final char[] cbuf, final int off, final int len) { throw new IllegalStateException("TokenStream contract violation: reset()/close() call missing, "
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 9.5K bytes - Viewed (0) -
platforms/core-execution/build-cache-local/src/main/java/org/gradle/caching/local/internal/DirectoryBuildCache.java
@Override public boolean load(HashCode key, IoConsumer<InputStream> reader) { AtomicBoolean loaded = new AtomicBoolean(false); loadLocally(key, file -> { try { Closer closer = Closer.create(); FileInputStream stream = closer.register(new FileInputStream(file)); try { reader.accept(stream); loaded.set(true);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:53 UTC 2024 - 7K bytes - Viewed (0) -
cmd/kubeadm/app/util/pkiutil/pki_helpers.go
if keyType == kubeadmapi.EncryptionAlgorithmECDSAP256 { return ecdsa.GenerateKey(elliptic.P256(), cryptorand.Reader) } rsaKeySize := rsaKeySizeFromAlgorithmType(keyType) if rsaKeySize == 0 { return nil, errors.Errorf("cannot obtain key size from unknown RSA algorithm: %q", keyType) } return rsa.GenerateKey(cryptorand.Reader, rsaKeySize) } // NewSignedCert creates a signed certificate using the given CA certificate and key
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 25.5K bytes - Viewed (0) -
internal/hash/reader_test.go
} } // Tests hash reader checksum verification. func TestHashReaderVerification(t *testing.T) { testCases := []struct { desc string src io.Reader size int64 actualSize int64 md5hex, sha256hex string err error }{ 0: {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 18 17:00:54 UTC 2023 - 10.3K bytes - Viewed (0) -
src/net/rpc/client.go
// WriteRequest partially failed, and call was already // removed; response is a server telling us about an // error reading request body. We should still attempt // to read error body, but there's no one to give it to. err = client.codec.ReadResponseBody(nil) if err != nil { err = errors.New("reading error body: " + err.Error()) } case response.Error != "": // We've got an error response. Give this to the request;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9K bytes - Viewed (0) -
src/crypto/rand/rand_test.go
} b := make([]byte, n) n, err := io.ReadFull(Reader, b) if n != len(b) || err != nil { t.Fatalf("ReadFull(buf) = %d, %s", n, err) } var z bytes.Buffer f, _ := flate.NewWriter(&z, 5) f.Write(b) f.Close() if z.Len() < len(b)*99/100 { t.Fatalf("Compressed %d -> %d", len(b), z.Len()) } } func TestReadEmpty(t *testing.T) { n, err := Reader.Read(make([]byte, 0)) if n != 0 || err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 19 20:02:21 UTC 2024 - 1.2K bytes - Viewed (0) -
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.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (2) -
platforms/core-configuration/input-tracking/src/main/java/org/gradle/internal/configuration/inputs/InstrumentedInputsListener.java
* * @param key the name of the property * @param value the value of the property at the time of reading or {@code null} if the property is not present * @param consumer the name of the class that is reading the property value */ void systemPropertyQueried(String key, @Nullable Object value, String consumer); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Nov 11 00:37:04 UTC 2023 - 3.3K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
connection.setRequestProperty("Accept-Language", "en-US") val inputStream = connection.inputStream val reader = BufferedReader(InputStreamReader(inputStream, StandardCharsets.UTF_8)) assertThat(connection.getResponseCode()).isEqualTo(HttpURLConnection.HTTP_OK) assertThat(reader.readLine()).isEqualTo("hello world") val request = server.takeRequest() assertThat(request.requestLine).isEqualTo("GET / HTTP/1.1")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 21.9K bytes - Viewed (0) -
src/cmd/link/internal/ld/macho_update_uuid.go
// locate it, overwrite it with a new value produced by // uuidFromGoBuildId. reader := loadCmdReader{next: int64(cmdOffset), f: outf, order: exem.ByteOrder} for i := uint32(0); i < exem.Ncmd; i++ { cmd, err := reader.Next() if err != nil { return err } if cmd.Cmd == LC_UUID { var u uuidCmd if err := reader.ReadAt(0, &u); err != nil { return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 18:45:27 UTC 2024 - 3.3K bytes - Viewed (0)