- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,452 for aBlocks (0.25 sec)
-
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager_test.go
var block *pem.Block aBlocks := []*pem.Block{} for { block, a = pem.Decode(a) if block == nil { break } aBlocks = append(aBlocks, block) } sort.Slice(aBlocks, func(i, j int) bool { if aBlocks[i].Type < aBlocks[j].Type { return true } else if aBlocks[i].Type == aBlocks[j].Type { comp := bytes.Compare(aBlocks[i].Bytes, aBlocks[j].Bytes) return comp <= 0 } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 15.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt
import okhttp3.Dispatcher import okhttp3.internal.http2.Http2Connection import okhttp3.internal.http2.Http2Stream import okhttp3.internal.http2.Http2Writer /** * Centralisation of central locks according to docs/contribute/concurrency.md */ internal object Locks { inline fun <T> Dispatcher.withLock(action: () -> T): T { contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) } return lock.withLock(action) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 2.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComLockingAndX.java
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(); bufferIndex += this.locks[ i ].decode(buffer, bufferIndex, buffer.length); }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 4.9K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_fcntl.go
// // P.1 locks file A. // Q.3 locks file B. // Q.3 blocks on file A. // P.2 blocks on file B. (This is erroneously reported as a deadlock.) // P.1 unlocks file A. // Q.3 unblocks and locks file A. // Q.3 unlocks files A and B. // P.2 unblocks and locks file B. // P.2 unlocks file B. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 17 02:24:35 UTC 2023 - 5.5K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/lockedfile_test.go
func TestSpuriousEDEADLK(t *testing.T) { // P.1 locks file A. // Q.3 locks file B. // Q.3 blocks on file A. // P.2 blocks on file B. (Spurious EDEADLK occurs here.) // P.1 unlocks file A. // Q.3 unblocks and locks file A. // Q.3 unlocks files A and B. // P.2 unblocks and locks file B. // P.2 unlocks file B. testenv.MustHaveExec(t) dirVar := t.Name() + "DIR"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 5.7K bytes - Viewed (0) -
src/testing/allocs.go
Brad Fitzpatrick <******@****.***> 1456874515 +0000
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 02 00:13:47 UTC 2016 - 1.4K bytes - Viewed (0) -
src/runtime/rwmutex.go
systemstack(func() { rw.writer.set(m) unlock(&rw.rLock) notesleep(&m.park) noteclear(&m.park) }) } else { unlock(&rw.rLock) } } // unlock unlocks rw for writing. func (rw *rwmutex) unlock() { // Announce to readers that there is no active writer. r := rw.readerCount.Add(rwmutexMaxReaders) if r >= rwmutexMaxReaders { throw("unlock of unlocked rwmutex") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
List<ResourceLock> allLocks = new ArrayList<ResourceLock>(locks.size() + workerLeases.size()); allLocks.addAll(workerLeases); allLocks.addAll(locks); // We free the worker lease but keep shared resource leases. We don't want to free shared resources until a task completes, // regardless of whether it is actually doing work just to make behavior more predictable. This might change in the future.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 04:43:28 UTC 2024 - 20.9K bytes - Viewed (0) -
internal/dsync/drwmutex.go
break } } quorumLocked := checkQuorumLocked(locks, quorum) && locksFailed <= tolerance if !quorumLocked { log("dsync: Unable to acquire lock in quorum %#v\n", args) // Release all acquired locks without quorum. if !releaseAll(ctx, ds, tolerance, owner, locks, isReadLock, restClnts, names...) { log("Unable to release acquired locks, these locks will expire automatically %#v\n", args) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
isWriteLock bool ref int mu sync.Mutex // Mutex to prevent multiple simultaneous locks } // NewLRWMutex - initializes a new lsync RW mutex. 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
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 4.8K bytes - Viewed (0)