- Sort Score
- Num 10 results
- Language All
Results 241 - 250 of 599 for readLen (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/archive/tar/writer_test.go
if !bytes.Contains(buf.Bytes(), []byte("PaxHeaders.0")) { t.Fatal("Expected at least one PAX header to be written.") } // Test that we can get a long name back out of the archive. reader := NewReader(&buf) hdr, err = reader.Next() if err != nil { t.Fatal(err) } if hdr.Name != longName { t.Fatal("Couldn't recover long file name") } } func TestPaxSymlink(t *testing.T) {
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Dec 15 16:34:13 GMT 2025 - 40.2K bytes - Click Count (0) -
internal/bucket/lifecycle/lifecycle.go
lc.Rules[i].ID = uuid.New().String() } } return &lc, nil } // ParseLifecycleConfig - parses data in given reader to Lifecycle. func ParseLifecycleConfig(reader io.Reader) (*Lifecycle, error) { var lc Lifecycle if err := xml.NewDecoder(reader).Decode(&lc); err != nil { return nil, err } return &lc, nil } // Validate - validates the lifecycle configuration
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Apr 03 06:45:06 GMT 2025 - 18.2K bytes - Click Count (0) -
internal/bucket/replication/replication.go
} // Maximum 2MiB size per replication config. const maxReplicationConfigSize = 2 << 20 // ParseConfig parses ReplicationConfiguration from xml func ParseConfig(reader io.Reader) (*Config, error) { config := Config{} if err := xml.NewDecoder(io.LimitReader(reader, maxReplicationConfigSize)).Decode(&config); err != nil { return nil, err } // By default, set replica modification to enabled if unset. for i := range config.Rules {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 8.9K bytes - Click Count (0) -
src/main/java/org/codelibs/core/collection/IndexedIterator.java
* } * </pre> * * <pre> * import static org.codelibs.core.collection.IndexedIterator.*; * import static org.codelibs.core.io.LineIterator.*; * * BufferedReader reader = ...; * for (Indexed<String> indexed : indexed(iterable(reader))) { * System.out.println(indexed.getIndex()); * System.out.println(indexed.getElement()); * } * </pre> * * @author wyukawa * @param <T> the element type
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jun 19 09:12:22 GMT 2025 - 3.3K bytes - Click Count (0) -
src/test/java/jcifs/netbios/SessionServicePacketTest.java
} @Test @DisplayName("readn should handle EOF correctly") void testReadnEOF() throws IOException { byte[] buffer = new byte[10]; ByteArrayInputStream bais = new ByteArrayInputStream(new byte[0]); int bytesRead = SessionServicePacket.readn(bais, buffer, 0, 5); assertEquals(0, bytesRead); } @Test @DisplayName("readn should handle multiple read calls")Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 15.5K bytes - Click Count (0) -
src/archive/zip/testdata/zip64-2.zip
README This small file is in ZIP64 format....
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Sep 08 04:08:51 GMT 2014 - 266 bytes - Click Count (0) -
compat/maven-model-builder/src/test/java/org/apache/maven/model/inheritance/DefaultInheritanceAssemblerTest.java
/** */ @Deprecated class DefaultInheritanceAssemblerTest { private DefaultModelReader reader; private ModelWriter writer; private InheritanceAssembler assembler; @BeforeEach void setUp() throws Exception { reader = new DefaultModelReader(); writer = new DefaultModelWriter(); assembler = new DefaultInheritanceAssembler(); }Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Sep 17 10:01:14 GMT 2025 - 8.2K bytes - Click Count (0) -
docs/contribute/concurrency.md
The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Click Count (0) -
cmd/batch-job-common-types_gen.go
// Code generated by github.com/tinylib/msgp DO NOT EDIT. package cmd import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BatchJobKV) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 21.9K bytes - Click Count (0) -
src/main/java/jcifs/smb1/netbios/Lmhosts.java
import java.io.BufferedReader; import java.io.File; import java.io.FileNotFoundException; import java.io.FileReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.Reader; import java.util.Hashtable; import jcifs.smb1.Config; import jcifs.smb1.smb1.SmbFileInputStream; import jcifs.smb1.util.LogStream; /** * Lmhosts file handling for NetBIOS name resolution. */
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 6K bytes - Click Count (0)