- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,002 for readN (0.18 sec)
-
internal/etag/reader.go
if er.readN == 0 && Equal(etag, er.checksum) { return er } } if len(forceMD5) != 0 { return &Reader{ src: r, md5: NewUUIDHash(forceMD5), checksum: etag, } } return &Reader{ src: r, md5: md5.New(), checksum: etag, } } // Read reads up to len(p) bytes from the underlying // io.Reader as specified by the io.Reader interface.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/metacache-stream_test.go
} want := loadMetacacheSampleNames if !reflect.DeepEqual(names, want) { t.Errorf("got unexpected result: %#v", names) } } func Test_metacacheReader_readN(t *testing.T) { r := loadMetacacheSample(t) defer r.Close() entries, err := r.readN(-1, false, true, false, "") if err != io.EOF { t.Fatal(err, entries.len()) } want := loadMetacacheSampleNames for i, entry := range entries.entries() {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 15K bytes - Viewed (0) -
src/main/java/jcifs/netbios/SessionServicePacket.java
return ( ( src[ srcIndex++ ] & 0x01 ) << 16 ) + ( ( src[ srcIndex++ ] & 0xFF ) << 8 ) + ( src[ srcIndex++ ] & 0xFF ); } static int readn ( InputStream in, byte[] b, int off, int len ) throws IOException { int i = 0, n; while ( i < len ) { n = in.read(b, off + i, len - i); if ( n <= 0 ) { break; } i += n; } return i;
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 4.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 31.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/SessionServicePacket.java
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 4.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
if ( r.getByteCount() > 0 && pad > 0 && pad < 4 ) readn(this.in, buffer, 4 + off, pad); if ( r.getDataLength() > 0 ) { readn(this.in, r.getData(), r.getOffset(), r.getDataLength()); /* read direct */ } } else { readn(this.in, buffer, 4 + SMB1_HEADER_LENGTH, size - SMB1_HEADER_LENGTH);
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Wed Jan 18 23:47:00 GMT 2023 - 67K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/transport/Transport.java
static int id = 0; static LogStream log = LogStream.getInstance(); public static int readn( InputStream in, byte[] b, int off, int len ) throws IOException { int i = 0, n = -5; while (i < len) { n = in.read( b, off + i, len - i ); if (n <= 0) { break; } i += n;
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 9K bytes - Viewed (0) -
cmd/metacache-stream.go
} r.err = err return err } } } // readN will return all the requested number of entries in order // or all if n < 0. // Will return io.EOF if end of stream is reached. // If requesting 0 objects nil error will always be returned regardless of at end of stream. // Use peek to determine if at end of stream.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
private static final Logger log = LoggerFactory.getLogger(Transport.class); /** * Read bytes from the input stream into a buffer * * @param in * @param b * @param off * @param len * @return number of bytes read * @throws IOException */ public static int readn ( InputStream in, byte[] b, int off, int len ) throws IOException { int i = 0, n = -5;
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Sun Nov 01 18:12:21 GMT 2020 - 24.1K bytes - Viewed (0) -
cmd/metacache-set.go
}) if (err != nil && errors.Is(err, io.EOF)) || pastPrefix || r.nextEOF() { return entries, io.EOF } return entries, err } // We should not need to filter more. return r.readN(o.Limit, o.InclDeleted, o.IncludeDirectories, o.Versioned, o.Prefix) } func (er *erasureObjects) streamMetadataParts(ctx context.Context, o listPathOptions) (entries metaCacheEntriesSorted, err error) { retries := 0
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 18 04:42:11 GMT 2024 - 30.4K bytes - Viewed (0)