Search Options

Results per page
Sort
Preferred Languages
Advance

Results 591 - 600 of 725 for bufLen (0.07 sec)

  1. istioctl/pkg/waypoint/waypoint_test.go

    			if err != nil {
    				t.Fatal(err)
    			}
    			expectedOut := string(defaultFile)
    			if len(expectedOut) == 0 {
    				t.Fatal("expected output is empty")
    			}
    
    			var out bytes.Buffer
    			rootCmd := Cmd(ctx)
    			rootCmd.SetArgs(tt.args)
    			rootCmd.SetOut(&out)
    			rootCmd.SetErr(&out)
    
    			fErr := rootCmd.Execute()
    			if fErr != nil {
    				t.Fatal(fErr)
    			}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Apr 04 15:53:09 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. docs/debugging/inspect/export.go

    				var header xlMetaV2VersionHeaderV2
    				if _, e := header.UnmarshalMsg(hdr); e != nil {
    					return e
    				}
    				b, e := header.MarshalJSON()
    				if e != nil {
    					return e
    				}
    				var buf bytes.Buffer
    				if _, e := msgp.UnmarshalAsJSON(&buf, meta); e != nil {
    					return e
    				}
    				versions[idx] = version{
    					Idx:      idx,
    					Header:   b,
    					Metadata: buf.Bytes(),
    				}
    				return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 08 15:58:02 UTC 2022
    - 9.1K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

    import okio.FileNotFoundException
    import okio.FileSystem
    import okio.ForwardingFileSystem
    import okio.ForwardingSource
    import okio.Path
    import okio.Sink
    import okio.Source
    import okio.blackholeSink
    import okio.buffer
    
    /**
     * A cache that uses a bounded amount of space on a filesystem. Each cache entry has a string key
     * and a fixed number of values. Each key must match the regex `[a-z0-9_-]{1,64}`. Values are byte
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb2/info/Smb2QueryDirectoryRequest.java

        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) {
            return 0;
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 10:41:31 UTC 2021
    - 6K bytes
    - Viewed (0)
  5. internal/s3select/select_benchmark_test.go

    	b := make([]byte, length)
    	for i := range b {
    		b[i] = charset[randSrc.Intn(len(charset))]
    	}
    	return string(b)
    }
    
    func genSampleCSVData(count int) []byte {
    	buf := &bytes.Buffer{}
    	csvWriter := csv.NewWriter(buf)
    	csvWriter.Write([]string{"id", "name", "age", "city"})
    
    	for i := 0; i < count; i++ {
    		csvWriter.Write([]string{
    			strconv.Itoa(i),
    			newRandString(10),
    			newRandString(5),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 5K bytes
    - Viewed (0)
  6. internal/grid/connection.go

    	queue := make([][]byte, 0, maxMergeMessages)
    	merged := make([]byte, 0, writeBufferSize)
    	var queueSize int
    	var buf bytes.Buffer
    	var wsw wsWriter
    	var lastSetDeadline time.Time
    
    	// Helper to write everything in buf.
    	// Return false if an error occurred and the connection is unusable.
    	// Buffer will be reset empty when returning successfully.
    	writeBuffer := func() (ok bool) {
    		now := time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  7. src/main/java/jcifs/dcerpc/DcerpcPipeHandle.java

        }
    
    
        @Override
        protected int doReceiveFragment ( byte[] buf ) throws IOException {
            if ( buf.length < getMaxRecv() ) {
                throw new IllegalArgumentException("buffer too small");
            }
    
            int off = this.handle.recv(buf, 0, buf.length);
            if ( buf[ 0 ] != 5 || buf[ 1 ] != 0 ) {
                throw new IOException("Unexpected DCERPC PDU header");
            }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jan 26 11:51:07 UTC 2020
    - 5.2K bytes
    - Viewed (0)
  8. internal/s3select/simdj/reader_amd64_test.go

    				if err == io.EOF {
    					break
    				}
    				if err != nil {
    					t.Error(err)
    				}
    				want, err := refDec.Read(nil)
    				if err != nil {
    					t.Error(err)
    				}
    				var gotB, wantB bytes.Buffer
    				opts := sql.WriteCSVOpts{
    					FieldDelimiter: ',',
    					Quote:          '"',
    					QuoteEscape:    '"',
    					AlwaysQuote:    false,
    				}
    				err = rec.WriteCSV(&gotB, opts)
    				if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/base/JoinerBenchmark.java

            delim = DELIMITER_STRING;
          }
          dummy ^= sb.toString().length();
        }
        return dummy;
      }
    
      /**
       * Always append the delimiter after the component, and in the very end shortens the buffer to get
       * rid of the extra trailing delimiter.
       */
      @Benchmark
      int alwaysAppendThenBackUp(int reps) {
        int dummy = 0;
        for (int i = 0; i < reps; i++) {
          StringBuilder sb = new StringBuilder();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.9K bytes
    - Viewed (0)
  10. cmd/metacache-stream.go

    	}
    	// temporary name buffer.
    	tmp := make([]byte, 0, 256)
    	for {
    		if more, err := r.mr.ReadBool(); !more {
    			switch err {
    			case nil:
    				r.err = io.EOF
    				return io.EOF
    			case io.EOF:
    				r.err = io.ErrUnexpectedEOF
    				return io.ErrUnexpectedEOF
    			}
    			r.err = err
    			return err
    		}
    		// Read name without allocating more than 1 buffer.
    		sz, err := r.mr.ReadStringHeader()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
Back to top