- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 524 for fbytes (0.03 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava-tests/test/com/google/common/io/FileBackedOutputStreamTest.java
* threshold"). (We then write some more afterward.) This differs from the existing * testThreshold() which writes exactly enough bytes to fill the buffer, then immediately writes * more bytes. * * <p>Note: Direct testing of the {@link IOException} scenario during write/flush is challenging
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Oct 30 16:30:29 GMT 2025 - 6.7K bytes - Click Count (0) -
cmd/metacache_gen_test.go
package cmd import ( "bytes" "testing" "github.com/tinylib/msgp/msgp" ) func TestMarshalUnmarshalmetacache(t *testing.T) { v := metacache{} bts, err := v.MarshalMsg(nil) if err != nil { t.Fatal(err) } left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.3K bytes - Click Count (0) -
internal/store/queuestore.go
return err } } path := filepath.Join(store.directory, key.String()) if key.Compress { err = os.WriteFile(path, s2.Encode(nil, buf.Bytes()), os.FileMode(0o770)) } else { err = os.WriteFile(path, buf.Bytes(), os.FileMode(0o770)) } buf.Reset() if err != nil { return err } // Increment the item count. store.entries[key.String()] = time.Now().UnixNano()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.8K bytes - Click Count (0) -
cmd/erasure-multipart-conditional_test.go
if err != nil { t.Fatal(err) } // Upload a part partData := bytes.Repeat([]byte("a"), 5*humanize.MiByte) md5Hex := getMD5Hash(partData) _, err = obj.PutObjectPart(ctx, bucket, object, res.UploadID, 1, mustGetPutObjReader(t, bytes.NewReader(partData), int64(len(partData)), md5Hex, ""), ObjectOptions{}) if err != nil { t.Fatal(err) }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 6.9K bytes - Click Count (0) -
cmd/batch-job-common-types_gen.go
} return } // MarshalMsg implements msgp.Marshaler func (z BatchJobSize) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) o = msgp.AppendInt64(o, int64(z)) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *BatchJobSize) UnmarshalMsg(bts []byte) (o []byte, err error) { { var zb0001 int64 zb0001, bts, err = msgp.ReadInt64Bytes(bts) if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 21.9K bytes - Click Count (0) -
samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java
listeners.put(state, listener); } return slackApi.authorizeUrl(scopes, redirectUrl(), state, team); } private ByteString randomToken() { byte[] bytes = new byte[16]; secureRandom.nextBytes(bytes); return ByteString.of(bytes); } private HttpUrl redirectUrl() { return mockWebServer.url("/oauth/"); }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Aug 12 07:26:27 GMT 2021 - 3.8K bytes - Click Count (1) -
tests/serializer_test.go
} type CustomSerializer struct { prefix []byte } func NewCustomSerializer(prefix string) *CustomSerializer { return &CustomSerializer{prefix: []byte(prefix)} } func (c *CustomSerializer) Scan(ctx context.Context, field *schema.Field, dst reflect.Value, dbValue interface{}) (err error) { switch value := dbValue.(type) { case []byte: err = field.Set(ctx, dst, bytes.TrimPrefix(value, c.prefix)) case string:Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sat Nov 22 03:14:36 GMT 2025 - 9.3K bytes - Click Count (0) -
internal/pubsub/pubsub.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package pubsub import ( "bytes" "encoding/json" "fmt" "sync" "sync/atomic" ) // GetByteBuffer returns a byte buffer from the pool. var GetByteBuffer = func() []byte { return make([]byte, 0, 4096) } // Sub - subscriber entity. type Sub[T Maskable] struct { ch chan T types Mask
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Click Count (0) -
internal/etag/etag.go
func (e ETag) IsEncrypted() bool { // An encrypted ETag must be at least 32 bytes long. // It contains the encrypted ETag value + an authentication // code generated by the AEAD cipher. // // Here is an incorrect implementation of IsEncrypted: // // return len(e) > 16 && !bytes.ContainsRune(e, '-') // // An encrypted ETag may contain some random bytes - e.g. // and nonce value. This nonce value may contain a '-'
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 16 14:27:42 GMT 2025 - 13.2K bytes - Click Count (0) -
docs/bucket/versioning/DESIGN.md
Inline data is optional. If no inline data is present, it is encoded as 0 bytes. | Entry | Encoding | Content | --------------------|-----------------------------|---------------------------------------- | xlMetaInlineDataVer | byte | version identifier | id -> data | msgp `map[string][]byte` | Map of string id -> byte content Currently only xlMetaInlineDataVer == 1 exists.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jul 17 15:43:14 GMT 2022 - 5.8K bytes - Click Count (0)