- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 119 for Hockin (0.21 sec)
-
android/guava/src/com/google/common/eventbus/SubscriberRegistry.java
* All registered subscribers, indexed by event type. * * <p>The {@link CopyOnWriteArraySet} values make it easy and relatively lightweight to get an * immutable snapshot of all current subscribers to an event without any locking. */ private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = Maps.newConcurrentMap(); /** The event bus this registry belongs to. */ @Weak private final EventBus bus;
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 10.5K bytes - Viewed (0) -
docs/changelogs/upgrading_to_okhttp_4.md
------------------------------ #### OkHttpClient final methods `OkHttpClient` has 26 accessors like `interceptors()` and `writeTimeoutMillis()` that were non-final in OkHttp 3.x and are final in 4.x. These were made non-final for use with mocking frameworks like [Mockito][mockito]. We believe subtyping `OkHttpClient` is the wrong way to test with OkHttp. If you must, mock `Call.Factory` which is the interface that `OkHttpClient` implements. #### Internal API changes
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Sun Feb 06 16:58:16 GMT 2022 - 10.9K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/BloomFilterStrategies.java
* * <p>Note that because of concurrent set calls and uses of atomics, this bitCount is a (very) * close *estimate* of the actual number of bits set. It's not possible to do better than an * estimate without locking. Note that the number, if not exactly accurate, is *always* * underestimating, never overestimating. */ long bitCount() { return bitCount.sum(); } LockFreeBitArray copy() {
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 10.7K bytes - Viewed (0) -
internal/dsync/dsync_test.go
func TestFailedRefreshLock(t *testing.T) { if testing.Short() { t.Skip("skipping test in short mode.") } // Simulate Refresh response to return no locking found for i := range lockServers[:3] { lockServers[i].setRefreshReply(false) defer lockServers[i].setRefreshReply(true) } dm := NewDRWMutex(ds, "aap") dm.refreshInterval = 500 * time.Millisecond
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
docs/security/README.md
#### Secure Erasure and Locking
Plain Text - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sat Feb 12 00:51:25 GMT 2022 - 13.8K bytes - Viewed (0) -
internal/grid/muxclient.go
m.closeLocked() return false } } func (m *muxClient) close() { if debugPrint { fmt.Println("closing outgoing mux", m.MuxID) } if !m.respMu.TryLock() { // Cancel before locking - will unblock any pending sends. if m.cancelFn != nil { m.cancelFn(context.Canceled) } // Wait for senders to release. m.respMu.Lock() } defer m.respMu.Unlock() m.closeLocked() }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 14.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
// way for it to return a false negative would be for the target value to jump around in the map // such that none of the subsequent iterations observed it, despite the fact that at every point // in time it was present somewhere int the map. This becomes increasingly unlikely as // CONTAINS_VALUE_RETRIES increases, though without locking it is theoretically possible.
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 91.9K bytes - Viewed (0) -
cmd/ftp-server-driver.go
} dirPath := buildMinioDir(prefix) _, err = clnt.PutObject(context.Background(), bucket, dirPath, bytes.NewReader([]byte("")), 0, // Always send Content-MD5 to succeed with bucket with // locking enabled. There is no performance hit since // this is always an empty object minio.PutObjectOptions{SendContentMd5: true}, ) return err } // GetFile implements ftpDriver
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 13.5K bytes - Viewed (0) -
cmd/testdata/xl-meta-merge.zip
PartASizes‘ÑJ©¤SizeÑJ©¥MTimeÓ ¹ô‡‰O/>§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¬content-typetext/markdown¤etagÙ 4af243ccccbadaf12545¡vÎeçnÐÎÓ° , ¤nullÅ%u&vÎ e ( Š[ ðKšÔŽX·šØü… ‘ˆ*¨Š ÂWåion. Certain features such as versioning, object locking, and bucket replication require distributed deploying MinIO with Erasure Coding. For extended development and production, deploy MinIO with Erasure Coding enabled - specifically, with a *minimum* of 4 drives per MinIO server. See [MinIO Erasure Code...
ZIP Archive - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 30.2K bytes - Viewed (0) -
cmd/sftp-server-driver.go
} dirPath := buildMinioDir(prefix) _, err = clnt.PutObject(context.Background(), bucket, dirPath, bytes.NewReader([]byte("")), 0, // Always send Content-MD5 to succeed with bucket with // locking enabled. There is no performance hit since // this is always an empty object minio.PutObjectOptions{SendContentMd5: true}, ) return err } return NotImplemented{} }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 13K bytes - Viewed (0)