- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 92 for Read (0.35 sec)
-
internal/dsync/dsync-server_test.go
return false, fmt.Errorf("RUnlock attempted on a write locked entity: %s", args.Resources[0]) } if locksHeld > ReadLock { l.lockMap[args.Resources[0]] = locksHeld - ReadLock // Remove one of the read locks held } else { delete(l.lockMap, args.Resources[0]) // Remove the (last) read lock } return reply, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
} // RLock holds a read lock on lm. // // If one or more read lock are already in use, it will grant another lock. // Otherwise the calling go routine blocks until the mutex is available. func (lm *LRWMutex) RLock() { const isWriteLock = false lm.lockLoop(context.Background(), lm.id, lm.source, 1<<63-1, isWriteLock) } // GetRLock tries to get a read lock on lm before the timeout occurs.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
cmd/namespace-lock.go
} // Unlock - block until write lock is released. func (di *distLockInstance) Unlock(lc LockContext) { if lc.cancel != nil { lc.cancel() } di.rwMutex.Unlock(lc.ctx) } // RLock - block until read lock is taken or timeout has occurred. func (di *distLockInstance) GetRLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) { lockSource := getSource(2) start := UTCNow()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
cmd/bitrot.go
defer xioutil.ODirectPoolSmall.Put(bufp) for left > 0 { // Read expected hash... h.Reset() n, err := io.ReadFull(r, hashBuf) if err != nil { // Read's failed for object with right size, file is corrupt. return err } // Subtract hash length.. left -= int64(n) if left < shardSize { shardSize = left } read, err := io.CopyBuffer(h, io.LimitReader(r, shardSize), *bufp)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.6K bytes - Viewed (0) -
internal/s3select/simdj/reader_amd64_test.go
} } refDec := json.NewReader(io.NopCloser(bytes.NewBuffer(ref)), &json.ReaderArgs{ContentType: "json"}) for { rec, err := dec.Read(nil) if err == io.EOF { break } if err != nil { t.Error(err) } want, err := refDec.Read(nil) if err != nil { t.Error(err) } var gotB, wantB bytes.Buffer opts := sql.WriteCSVOpts{ FieldDelimiter: ',',
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.9K bytes - Viewed (0) -
docs/debugging/inspect/export.go
// Read metadata CRC (added in v2, ignore if not found) b = nbuf } _, e = msgp.CopyToJSON(buf, bytes.NewReader(v)) if e != nil { return nil, e } data = b case 3: v, b, e := msgp.ReadBytesZC(b) if e != nil { return nil, e } if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil { // Read metadata CRC (added in v2, ignore if not found)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 08 15:58:02 GMT 2022 - 9.1K bytes - Viewed (0) -
internal/config/identity/ldap/help.go
}, config.HelpKV{ Key: LookupBindDN, Description: `DN for LDAP read-only service account used to perform DN and group lookups` + defaultHelpPostfix(LookupBindDN), Optional: true, Type: "string", Sensitive: true, }, config.HelpKV{ Key: LookupBindPassword, Description: `Password for LDAP read-only service account used to perform DN and group lookups` + defaultHelpPostfix(LookupBindPassword),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 23 14:45:27 GMT 2023 - 3.6K bytes - Viewed (0) -
internal/grid/stream.go
"context" "errors" ) // A Stream is a two-way stream. // All responses *must* be read by the caller. // If the call is canceled through the context, // the appropriate error will be returned. type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes. // All responses *must* be read by the caller until either an error is returned or the channel is closed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/ioutil/wait_pipe.go
func (r *PipeReader) CloseWithError(err error) error { err = r.PipeReader.CloseWithError(err) r.wait() return err } // WaitPipe implements wait-group backend io.Pipe to provide // synchronization between read() end with write() end. func WaitPipe() (*PipeReader, *PipeWriter) { r, w := io.Pipe() var wg sync.WaitGroup wg.Add(1) return &PipeReader{ PipeReader: r, wait: wg.Wait, }, &PipeWriter{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Viewed (0) -
internal/lock/lock_windows.go
} var access uint32 switch flag { case syscall.O_RDONLY: access = syscall.GENERIC_READ case syscall.O_WRONLY: access = syscall.GENERIC_WRITE case syscall.O_RDWR: fallthrough case syscall.O_RDWR | syscall.O_CREAT: fallthrough case syscall.O_WRONLY | syscall.O_CREAT: access = syscall.GENERIC_READ | syscall.GENERIC_WRITE case syscall.O_WRONLY | syscall.O_CREAT | syscall.O_APPEND:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 7.9K bytes - Viewed (0)