Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 241 - 250 of 599 for readLen (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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&lt;String&gt; 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top