Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 276 for buf1 (0.04 sec)

  1. internal/grid/connection.go

    			lastSetDeadline = now
    		}
    
    		_, err := buf.WriteTo(conn)
    		if err != nil {
    			if !xnet.IsNetworkOrHostDown(err, true) {
    				gridLogIf(ctx, fmt.Errorf("ws write: %w", err))
    			}
    			return false
    		}
    		if buf.Cap() > writeBufferSize*4 {
    			// Reset buffer if it gets too big, so we don't keep it around.
    			buf = bytes.Buffer{}
    		}
    		buf.Reset()
    		return true
    	}
    
    	for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. src/archive/zip/reader_test.go

    		"../foo",
    		"/foo",
    		"a/b/../../../c",
    		`a\b`,
    	} {
    		var buf bytes.Buffer
    		zw := NewWriter(&buf)
    		_, err := zw.Create(path)
    		if err != nil {
    			t.Errorf("zw.Create(%q) = %v", path, err)
    			continue
    		}
    		zw.Close()
    
    		zr, err := NewReader(bytes.NewReader(buf.Bytes()), int64(buf.Len()))
    		if err != ErrInsecurePath {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 55.6K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb1/trans/SmbComTransaction.java

            this.txn_buf = buffer;
        }
    
    
        /**
         * @return the txn_buf
         */
        public byte[] releaseBuffer () {
            byte[] buf = this.txn_buf;
            this.txn_buf = null;
            return buf;
        }
    
    
        /**
         * @return the subCommand
         */
        public final byte getSubCommand () {
            return this.subCommand;
        }
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 13:43:42 UTC 2020
    - 13.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/math/Stats.java

       *
       * <p><b>Note:</b> No guarantees are made regarding stability of the representation between
       * versions.
       */
      public byte[] toByteArray() {
        ByteBuffer buff = ByteBuffer.allocate(BYTES).order(ByteOrder.LITTLE_ENDIAN);
        writeTo(buff);
        return buff.array();
      }
    
      /**
       * Writes to the given {@link ByteBuffer} a byte representation of this instance.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  5. internal/bpool/bpool_test.go

    	}
    
    	bp.Put(b)
    
    	// Check the size of the pool.
    	if uint64(len(bp.c)) != size {
    		t.Fatalf("bytepool size invalid: got %v want %v", len(bp.c), size)
    	}
    
    	// lets drain the buf channel first before we validate invalid buffers.
    	for i := uint64(0); i < size; i++ {
    		bp.Get() // discard
    	}
    
    	// Try putting some invalid buffers into pool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessMultipartRequestHandler.java

            try {
                final InputStream is = request.getInputStream();
                try {
                    final byte[] buf = new byte[1024];
                    while ((is.read(buf)) != -1) {}
                } catch (final Exception ignored) {} finally {
                    try {
                        is.close();
                    } catch (final Exception ignored) {}
                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Wed Oct 23 13:27:21 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  7. internal/rest/client.go

    		Host:       u.Host,
    	}
    	req = req.WithContext(ctx)
    	if body != nil {
    		switch v := body.(type) {
    		case *bytes.Buffer:
    			req.ContentLength = int64(v.Len())
    			buf := v.Bytes()
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  8. cmd/data-usage-cache.go

    	select {
    	case <-ctx.Done():
    		return ctx.Err()
    	case maxConcurrentScannerSaves <- struct{}{}:
    	}
    
    	buf := bytebufferpool.Get()
    	defer func() {
    		<-maxConcurrentScannerSaves
    		buf.Reset()
    		bytebufferpool.Put(buf)
    	}()
    
    	if err := d.serializeTo(buf); err != nil {
    		return err
    	}
    
    	save := func(name string, timeout time.Duration) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  9. cmd/bucket-replication-handlers.go

    	if err = replicationConfig.Validate(bucket, sameTarget); err != nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErrWithErr(ErrReplicationValidationError, err), r.URL)
    		return
    	}
    	buf := bytes.Repeat([]byte("a"), 8)
    	for _, rule := range replicationConfig.Rules {
    		if rule.Status == replication.Disabled {
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  10. cmd/object-api-utils_test.go

    	}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			buf := make([]byte, 100) // make small buffer to ensure multiple reads are required for large case
    
    			r, idxCB := newS2CompressReader(bytes.NewReader(tt.data), int64(len(tt.data)), false)
    			defer r.Close()
    
    			var rdrBuf bytes.Buffer
    			_, err := io.CopyBuffer(&rdrBuf, r, buf)
    			if err != nil {
    				t.Fatal(err)
    			}
    			r.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
Back to top