- Sort Score
- Num 10 results
- Language All
Results 651 - 660 of 772 for uaAppend (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/erasure-coding.go
func erasureSelfTest() { // Approx runtime ~1ms var testConfigs [][2]uint8 for total := uint8(4); total < 16; total++ { for data := total / 2; data < total; data++ { parity := total - data testConfigs = append(testConfigs, [2]uint8{data, parity}) } } got := make(map[[2]uint8]map[ErasureAlgo]uint64, len(testConfigs)) // Copied from output of fmt.Printf("%#v", got) at the end.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 8.5K bytes - Click Count (0) -
internal/dsync/dsync_test.go
) // TestMain initializes the testing framework func TestMain(m *testing.M) { startLockServers() // Initialize locker clients for dsync. var clnts []NetLocker for i := range nodes { clnts = append(clnts, newClient(nodes[i].URL)) } ds = &Dsync{ GetLockers: func() ([]NetLocker, string) { return clnts, uuid.New().String() }, Timeouts: Timeouts{ Acquire: testDrwMutexAcquireTimeout,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.8K bytes - Click Count (0) -
cmd/xl-storage-disk-id-check.go
p.storage.setWriteAttribute(p.totalWrites.Add(1)) } done(0, &err) }() // Copy inline data to a new buffer to function with deadlines. if len(fi.Data) > 0 { fi.Data = append(grid.GetByteBufferCap(len(fi.Data))[:0], fi.Data...) } return xioutil.WithDeadline[RenameDataResp](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (res RenameDataResp, err error) { if len(fi.Data) > 0 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 34.5K bytes - Click Count (0) -
cmd/object-multipart-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } copy(objectEncryptionKey[:], key) var nonce [12]byte tmp := sha256.Sum256(fmt.Append(nil, uploadID, partID)) copy(nonce[:], tmp[:12]) partEncryptionKey := objectEncryptionKey.DerivePartKey(uint32(partID)) encReader, err := sio.EncryptReader(reader, sio.Config{ Key: partEncryptionKey[:],Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 07 16:13:09 GMT 2025 - 39.5K bytes - Click Count (1) -
finisher_api.go
} } fallthrough default: selectedUpdate := len(tx.Statement.Selects) != 0 // when updating, use all fields including those zero-value fields if !selectedUpdate { tx.Statement.Selects = append(tx.Statement.Selects, "*") } updateTx := tx.callbacks.Update().Execute(tx.Session(&Session{Initialized: true})) if updateTx.Error == nil && updateTx.RowsAffected == 0 && !updateTx.DryRun && !selectedUpdate {
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Fri Sep 19 01:49:06 GMT 2025 - 22.9K bytes - Click Count (0) -
src/archive/tar/tar_test.go
} if !v.wantValid { continue } gotAligned := alignSparseEntries(append([]sparseEntry{}, v.in...), v.size) if !slices.Equal(gotAligned, v.wantAligned) { t.Errorf("test %d, alignSparseEntries():\ngot %v\nwant %v", i, gotAligned, v.wantAligned) } gotInverted := invertSparseEntries(append([]sparseEntry{}, v.in...), v.size) if !slices.Equal(gotInverted, v.wantInverted) {Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Jul 25 00:25:45 GMT 2024 - 23.9K bytes - Click Count (0) -
guava/src/com/google/common/net/InetAddresses.java
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 47.4K bytes - Click Count (0) -
cmd/storage-rest-client.go
} // DeleteVol - Deletes a volume over the network. func (client *storageRESTClient) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) { return errInvalidArgument } // AppendFile - append to a file. func (client *storageRESTClient) AppendFile(ctx context.Context, volume string, path string, buf []byte) error { values := make(url.Values) values.Set(storageRESTVolume, volume)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 08 02:38:41 GMT 2025 - 30.4K bytes - Click Count (0) -
cmd/encryption-v1.go
ETag, err := etag.Parse(object.ETag) if err != nil { continue } if ETag.IsEncrypted() { SSES3SinglePartObjects[i] = true metadata = append(metadata, object.UserDefined) buckets = append(buckets, object.Bucket) names = append(names, object.Name) } } } // If there are no SSE-S3 single-part objects // we can skip the decryption process. However,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 38K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 14.1K bytes - Click Count (0)