- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for enBlocks (0.22 sec)
-
cmd/erasure-utils.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComLockingAndX.java
protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) throws SMBProtocolDecodingException { int start = bufferIndex; for ( int i = 0; i < this.unlocks.length; i++ ) { this.unlocks[ i ] = createLockRange(); bufferIndex += this.unlocks[ i ].decode(buffer, bufferIndex, buffer.length); } for ( int i = 0; i < this.locks.length; i++ ) { this.locks[ i ] = createLockRange();
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 4.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java
private OverflowAvoidingLockSupport() {} static void parkNanos(@CheckForNull Object blocker, long nanos) { // Even in the extremely unlikely event that a thread unblocks itself early after only 68 years, // this is indistinguishable from a spurious wakeup, which LockSupport allows. LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 1.6K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
return false default: if lm.lock(id, source, isWriteLock) { return true } time.Sleep(time.Duration(r.Float64() * float64(lockRetryInterval))) } } } // Unlock unlocks the write lock. // // It is a run-time error if lm is not locked on entry to Unlock. func (lm *LRWMutex) Unlock() { isWriteLock := true success := lm.unlock(isWriteLock) if !success {
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) -
internal/grid/muxserver.go
if msg.DeadlineMS == 0 || msg.DeadlineMS > uint32(lastPingThreshold/time.Millisecond) { go func() { wg.Wait() m.checkRemoteAlive() }() } return &m } // handleInbound sends unblocks when we have delivered the message to the handler. func (m *muxServer) handleInbound(c *Connection, inbound <-chan []byte, handlerIn chan<- []byte) { for in := range inbound { handlerIn <- in
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/grid/muxclient.go
if requests == nil { go m.handleOneWayStream(responseCh, responses) return &Stream{responses: responseCh, Requests: nil, ctx: m.ctx, cancel: m.cancelFn, muxID: m.MuxID}, nil } // Deliver responses and send unblocks back to the server. go m.handleTwowayResponses(responseCh, responses) go m.handleTwowayRequests(responses, requests)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/grid/connection.go
} // We can expect to receive unblocks for closed muxes return } v.unblockSend(m.Seq) } func (c *Connection) handleUnblockSrvMux(m message) { if m.Payload != nil { PutByteBuffer(m.Payload) } m.Payload = nil if v, ok := c.inStream.Load(m.MuxID); ok { v.unblockSend(m.Seq) return } // We can expect to receive unblocks for closed muxes if debugPrint {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// to indicate we haven't sufficiently unlocked lockers to avoid deadlocks. // // Caller may use this as an indication to call again. return !checkFailedUnlocks(*locks, tolerance) } // Unlock unlocks the write lock. // // It is a run-time error if dm is not locked on entry to Unlock. func (dm *DRWMutex) Unlock(ctx context.Context) { dm.m.Lock() dm.cancelRefresh() dm.m.Unlock()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/admin-router.go
if globalIsDistErasure { // Top locks adminRouter.Methods(http.MethodGet).Path(adminVersion + "/top/locks").HandlerFunc(adminMiddleware(adminAPI.TopLocksHandler)) // Force unlocks paths adminRouter.Methods(http.MethodPost).Path(adminVersion+"/force-unlock"). Queries("paths", "{paths:.*}").HandlerFunc(adminMiddleware(adminAPI.ForceUnlockHandler)) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/object-api-utils.go
} } } return compressedOffset, partSkip, firstPartIdx, decryptSkip, seqNum } // GetObjectReader is a type that wraps a reader with a lock to // provide a ReadCloser interface that unlocks on Close() type GetObjectReader struct { io.Reader ObjInfo ObjectInfo cleanUpFns []func() once sync.Once } // WithCleanupFuncs sets additional cleanup functions to be called when closing
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1)