- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 127 for Hockin (0.18 sec)
-
cni/pkg/plugin/cnieventclient.go
"time" "github.com/containernetworking/cni/pkg/skel" cniv1 "github.com/containernetworking/cni/pkg/types/100" "istio.io/istio/cni/pkg/nodeagent" ) // newCNIClient is a unit test override variable for mocking. var newCNIClient = buildClient // An udsCore write entries to an UDS server with HTTP Post. Log messages will be encoded into a JSON array. type CNIEventClient struct { client *http.Client url string }
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
internal/lock/lock.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. // Package lock - implements filesystem locking wrappers around an // open file descriptor. package lock import ( "errors" "os" "sync" ) // ErrAlreadyLocked is returned if the underlying fd is already locked.
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.5K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
bool downloaded_block = false; auto reconcile_state = MakeCleanup([this, &downloaded_block, &key, &block] { // Perform this action in a cleanup callback to avoid locking mu_ after // locking block->mu. if (downloaded_block) { absl::MutexLock l(&mu_); // Do not update state if the block is already to be evicted. if (block->timestamp != 0) {
C++ - Registered: Tue Apr 16 12:39:09 GMT 2024 - Last Modified: Thu Jul 16 01:39:09 GMT 2020 - 11.1K bytes - Viewed (0) -
.teamcity/performance-tests-ci.json
"groups" : [ { "testProject" : "excludeRuleMergingBuild", "coverage" : { "per_commit" : [ "linux" ] } } ] }, { "testId" : "org.gradle.performance.regression.corefeature.LargeDependencyGraphPerformanceTest.resolve large dependency graph (parallel = false, locking = true)", "groups" : [ {
Json - Registered: Wed Apr 17 11:36:08 GMT 2024 - Last Modified: Tue Mar 05 17:23:51 GMT 2024 - 35.3K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
func closeNetns(netns NetnsCloser) { netns.Close() } func (p *podNetnsCache) ReadCurrentPodSnapshot() map[string]WorkloadInfo { p.mu.RLock() defer p.mu.RUnlock() // snapshot the cache to avoid long locking return maps.Clone(p.currentPodCache) } // Remove and return the Netns for the given uid // No need to return NetnsCloser here it will be closed automatically on GC.
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/service.go
} // freezeServices will freeze all incoming S3 API calls. // For each call, unfreezeServices must be called once. func freezeServices() { // Use atomics for globalServiceFreeze, so we can read without locking. // We need a lock since we are need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock() // If multiple calls, first one creates channel. globalServiceFreezeCnt++ if globalServiceFreezeCnt == 1 {
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
exec.awaitTermination(100, MILLISECONDS); } /** * Tests that all listeners complete, even if they were added before or after the future was * finishing. Also acts as a concurrency test to make sure the locking is done correctly when a * future is finishing so that no listeners can be lost. */ public void testAllListenersCompleteSuccessfully() throws InterruptedException, ExecutionException {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* MoreExecutors#newDirectExecutorService} and subject to the same constraints. * * <p>Although all tasks are immediately executed in the thread that submitted the task, this * {@code ExecutorService} imposes a small locking overhead on each task submission in order to * implement shutdown and termination behavior. * * <p>Because of the nature of single-thread execution, the methods {@code scheduleAtFixedRate}
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
docs/bucket/lifecycle/DESIGN.md
An object that is in transition tier will be deleted once the object hits expiry date or if removed via `mc rm` (`mc rm --vid` in the case of delete of a specific object version). Other rules specific to legal hold and object locking precede any lifecycle rules. ### Additional notes Tiering and lifecycle transition are applicable only to erasure/distributed MinIO. ## Explore Further
Plain Text - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 4.3K bytes - Viewed (0) -
cmd/bucket-object-lock.go
} logger.CriticalIf(context.Background(), err) return r, err } return config.ToRetention(), nil } // enforceRetentionForDeletion checks if it is appropriate to remove an // object according to locking configuration when this is lifecycle/ bucket quota asking. func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) { if objInfo.DeleteMarker { return false }
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (0)