- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 266 for Write (0.17 sec)
-
cmd/storage-rest-server.go
// concurrently, check for it before we // write the filler byte. select { case err := <-doneCh: if err != nil { write([]byte{1}) write([]byte(err.Error())) } else { write([]byte{0}) } return default: } // Response not ready, write a filler byte. write([]byte{32}) if canWrite { w.(http.Flusher).Flush()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/bucket-stats_gen.go
// map header, size 14 // write "ReplicatedSize" err = en.Append(0x8e, 0xae, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65, 0x64, 0x53, 0x69, 0x7a, 0x65) if err != nil { return } err = en.WriteInt64(z.ReplicatedSize) if err != nil { err = msgp.WrapError(err, "ReplicatedSize") return } // write "ReplicaSize"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 57.5K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
} if reply = locksHeld == WriteLock; !reply { // Unless it is a write lock return false, fmt.Errorf("Unlock attempted on a read locked entity: %s (%d read locks active)", args.Resources[0], locksHeld) } delete(l.lockMap, args.Resources[0]) // Remove the write lock return true, nil } const ReadLock = 1
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
cmd/bitrot_test.go
writer := newBitrotWriter(disk, "", volume, filePath, 35, bitrotAlgo, 10) _, err = writer.Write([]byte("aaaaaaaaaa")) if err != nil { t.Fatal(err) } _, err = writer.Write([]byte("aaaaaaaaaa")) if err != nil { t.Fatal(err) } _, err = writer.Write([]byte("aaaaaaaaaa")) if err != nil { t.Fatal(err) } _, err = writer.Write([]byte("aaaaa")) if err != nil { t.Fatal(err) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 2.1K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
func NewLRWMutex() *LRWMutex { return &LRWMutex{} } // Lock holds a write lock on lm. // // If the lock is already in use, the calling go routine // blocks until the mutex is available. func (lm *LRWMutex) Lock() { const isWriteLock = true lm.lockLoop(context.Background(), lm.id, lm.source, math.MaxInt64, isWriteLock) } // GetLock tries to get a write lock on lm before the timeout occurs.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
src/archive/zip/example_test.go
// license that can be found in the LICENSE file. package zip_test import ( "archive/zip" "bytes" "compress/flate" "fmt" "io" "log" "os" ) func ExampleWriter() { // Create a buffer to write our archive to. buf := new(bytes.Buffer) // Create a new zip archive. w := zip.NewWriter(buf) // Add some files to the archive. var files = []struct { Name, Body string }{
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Jan 27 00:22:03 GMT 2016 - 2K bytes - Viewed (0) -
cmd/benchmark-utils_test.go
mustGetPutObjReader(b, bytes.NewReader(textData), int64(len(textData)), md5hex, sha256hex), ObjectOptions{}) if err != nil { b.Fatal(err) } if objInfo.ETag != md5hex { b.Fatalf("Write no: %d: Md5Sum mismatch during object write into the bucket: Expected %s, got %s", i+1, objInfo.ETag, md5hex) } } // Benchmark ends here. Stop timer. b.StopTimer() } // Benchmark utility functions for ObjectLayer.PutObjectPart().
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 8.2K bytes - Viewed (0) -
cmd/tier-journal_gen.go
func (z jentry) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "obj" err = en.Append(0x83, 0xa3, 0x6f, 0x62, 0x6a) if err != nil { return } err = en.WriteString(z.ObjName) if err != nil { err = msgp.WrapError(err, "ObjName") return } // write "vid" err = en.Append(0xa3, 0x76, 0x69, 0x64) if err != nil { return }
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 6.1K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue21897.go
import ( "runtime/debug" "testing" "unsafe" ) func test21897(t *testing.T) { // Please write barrier, kick in soon. defer debug.SetGCPercent(debug.SetGCPercent(1)) for i := 0; i < 10000; i++ { testCFNumberRef() testCFDateRef() testCFBooleanRef() // Allocate some memory, so eventually the write barrier is enabled // and it will see writes of bad pointers in the test* functions below.
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri May 12 12:00:02 GMT 2023 - 1.4K bytes - Viewed (0) -
internal/lock/lock_windows.go
} } return &LockedFile{File: f}, nil } // TryLockedOpenFile - tries a new write lock, functionality // it is similar to LockedOpenFile with with syscall.LOCK_EX // mode but along with syscall.LOCK_NB such that the function // doesn't wait forever but instead returns if it cannot // acquire a write lock. func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 7.9K bytes - Viewed (0)