Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for newBuffer (0.05 sec)

  1. src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java

                BufferCache.releaseBuffer(buffer);
            }
    
            // Then - Should be able to get buffers again
            byte[] newBuffer = BufferCache.getBuffer();
            assertNotNull(newBuffer, "Should be able to get buffer after release");
            assertEquals(SmbComTransaction.TRANSACTION_BUF_SIZE, newBuffer.length, "Buffer should have correct size");
        }
    
        /**
         * Test that invalid buffer sizes are rejected during release.
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb1/smb1/Trans2QueryFSInformationTest.java

    class Trans2QueryFSInformationTest {
    
        /** Small helper to create a byte buffer larger than the maximum expected
         *  wire format so that we can observe only the bytes written by a method.
         */
        private static byte[] newBuffer(int length) {
            // initialise with distinct pattern to detect unused trailing bytes
            byte[] buf = new byte[length];
            Arrays.fill(buf, (byte) 0xFF);
            return buf;
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  3. src/bytes/buffer_test.go

    		}
    		s += string(fub)
    		check(t, testname+" (fill 4)", buf, s)
    	}
    	return s
    }
    
    func TestNewBuffer(t *testing.T) {
    	buf := NewBuffer(testBytes)
    	check(t, "NewBuffer", buf, testString)
    }
    
    var buf Buffer
    
    // Calling NewBuffer and immediately shallow copying the Buffer struct
    // should not result in any allocations.
    // This can be used to reset the underlying []byte of an existing Buffer.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 19 16:13:04 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  4. schema/serializer.go

    		switch v := dbValue.(type) {
    		case []byte:
    			bytesValue = v
    		default:
    			return fmt.Errorf("failed to unmarshal gob value: %#v", dbValue)
    		}
    		if len(bytesValue) > 0 {
    			decoder := gob.NewDecoder(bytes.NewBuffer(bytesValue))
    			err = decoder.Decode(fieldValue.Interface())
    		}
    	}
    	field.ReflectValueOf(ctx, dst).Set(fieldValue.Elem())
    	return
    }
    
    // Value implements serializer interface
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Jun 20 08:45:38 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. docs/debugging/healing-bin/main.go

    					r, err := file.Open()
    					if err != nil {
    						return err
    					}
    
    					b, err := io.ReadAll(r)
    					if err != nil {
    						return err
    					}
    					buf := bytes.NewBuffer(nil)
    					if _, err = msgp.CopyToJSON(buf, bytes.NewReader(b)); err != nil {
    						return err
    					}
    
    					dec := json.NewDecoder(buf)
    					// Use number to preserve integers.
    					dec.UseNumber()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  6. cmd/storage-datatypes_test.go

    	}
    
    	var buf bytes.Buffer
    	gob.NewEncoder(&buf).Encode(v)
    	encoded := buf.Bytes()
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    
    	for b.Loop() {
    		dec := gob.NewDecoder(bytes.NewBuffer(encoded))
    		err := dec.Decode(&v)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func BenchmarkEncodeDiskInfoMsgp(b *testing.B) {
    	v := DiskInfo{
    		Total:     1000,
    		Free:      1000,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  7. cmd/bucket-metadata.go

    	if err != nil {
    		return
    	}
    
    	outbuf := bytes.NewBuffer(nil)
    	objectKey := crypto.GenerateKey(key.Plaintext, rand.Reader)
    	sealedKey := objectKey.Seal(key.Plaintext, crypto.GenerateIV(rand.Reader), crypto.S3.String(), bucket, "")
    	crypto.S3.CreateMetadata(metadata, key.KeyID, key.Ciphertext, sealedKey)
    	_, err = sio.Encrypt(outbuf, bytes.NewBuffer(input), sio.Config{Key: objectKey[:], MinVersion: sio.Version20})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  8. src/bytes/buffer.go

    	slice, err := b.readSlice(delim)
    	return string(slice), err
    }
    
    // NewBuffer creates and initializes a new [Buffer] using buf as its
    // initial contents. The new [Buffer] takes ownership of buf, and the
    // caller should not use buf after this call. NewBuffer is intended to
    // prepare a [Buffer] to read existing data. It can also be used to set
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 19 17:38:56 UTC 2025
    - 16K bytes
    - Viewed (0)
  9. src/bytes/example_test.go

    		b = strconv.AppendInt(b, int64(i), 10)
    		b = append(b, ' ')
    		buf.Write(b)
    	}
    	os.Stdout.Write(buf.Bytes())
    	// Output: 0 1 2 3
    }
    
    func ExampleBuffer_Cap() {
    	buf1 := bytes.NewBuffer(make([]byte, 10))
    	buf2 := bytes.NewBuffer(make([]byte, 0, 10))
    	fmt.Println(buf1.Cap())
    	fmt.Println(buf2.Cap())
    	// Output:
    	// 10
    	// 10
    }
    
    func ExampleBuffer_Grow() {
    	var b bytes.Buffer
    	b.Grow(64)
    	bb := b.Bytes()
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 12 16:07:54 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  10. cmd/admin-handlers-users_test.go

    	_, err := client.PutObject(ctx, bucket, "some-object", bytes.NewBuffer([]byte("stuff")), 5, minio.PutObjectOptions{})
    	if err != nil {
    		c.Fatalf("upload did not succeed got %#v", err)
    	}
    }
    
    func (c *check) mustNotUpload(ctx context.Context, client *minio.Client, bucket string) {
    	c.Helper()
    	_, err := client.PutObject(ctx, bucket, "some-object", bytes.NewBuffer([]byte("stuff")), 5, minio.PutObjectOptions{})
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 47.4K bytes
    - Viewed (0)
Back to top