- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 759 for clock (0.18 sec)
-
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 Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFile.java
* it will match that many characters <i>or less</i>. * <p> * Wildcard expressions will not filter workgroup names or server names. * * <blockquote><pre> * winnt> ls c?o* * clock.avi -rw-- 82944 Mon Oct 14 1996 1:38 AM * Cookies drw-- 0 Fri Nov 13 1998 9:42 PM * 2 items in 5ms * </pre></blockquote> *
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Mon Mar 13 12:00:57 GMT 2023 - 107.9K bytes - Viewed (2) -
internal/lock/lock_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package lock import ( "os" "testing" "time" ) // Test lock fails. func TestLockFail(t *testing.T) { f, err := os.CreateTemp("", "lock") if err != nil { t.Fatal(err) } f.Close() defer func() { err = os.Remove(f.Name()) if err != nil { t.Fatal(err)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.23.md
- github.com/Microsoft/hcsshim: [5eafd15 → v0.8.22](https://github.com/Microsoft/hcsshim/compare/5eafd15...v0.8.22) - github.com/benbjohnson/clock: [v1.0.3 → v1.1.0](https://github.com/benbjohnson/clock/compare/v1.0.3...v1.1.0) - github.com/bketelsen/crypt: [5cbc8cc → v0.0.4](https://github.com/bketelsen/crypt/compare/5cbc8cc...v0.0.4)
Plain Text - Registered: Fri Apr 26 09:05:10 GMT 2024 - Last Modified: Tue Feb 28 21:06:52 GMT 2023 - 424.5K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
block->data.resize(block_size_, 0); int64_t bytes_transferred; bytes_transferred = block_fetcher_(key.first, key.second, block_size_, block->data.data(), status); block->mu.Lock(); // Reacquire the lock immediately afterwards if (TF_GetCode(status) == TF_OK) { block->data.resize(bytes_transferred, 0);
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Thu Jul 16 01:39:09 GMT 2020 - 11.1K bytes - Viewed (0) -
internal/dsync/lock-args.go
// LockArgs is minimal required values for any dsync compatible lock operation. type LockArgs struct { // Unique ID of lock/unlock request. UID string // Resources contains single or multiple entries to be locked/unlocked. Resources []string // Source contains the line number, function and file name of the code // on the client node that requested the lock. Source string
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
internal/lock/lock_solaris.go
} } return &LockedFile{f}, nil } // TryLockedOpenFile - tries a new write lock, functionality // it is similar to LockedOpenFile with with syscall.LOCK_EX // mode but along with syscall.LOCK_NB such that the function // doesn't wait forever but instead returns if it cannot // acquire a write lock. func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.8K bytes - Viewed (0) -
cmd/handler-api.go
} func (t *apiConfig) odirectEnabled() bool { t.mu.RLock() defer t.mu.RUnlock() return t.enableODirect } func (t *apiConfig) shouldGzipObjects() bool { t.mu.RLock() defer t.mu.RUnlock() return t.gzipObjects } func (t *apiConfig) permitRootAccess() bool { t.mu.RLock() defer t.mu.RUnlock() return t.rootAccess }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 09:22:27 GMT 2024 - 10K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h
bool BlockNotStale(const std::shared_ptr<Block>& block) ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu_); /// Look up a Key in the block cache. std::shared_ptr<Block> Lookup(const Key& key) ABSL_LOCKS_EXCLUDED(mu_); void MaybeFetch(const Key& key, const std::shared_ptr<Block>& block, TF_Status* status) ABSL_LOCKS_EXCLUDED(mu_); /// Trim the block cache to make room for another entry.
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 04:46:34 GMT 2020 - 10.6K bytes - Viewed (0) -
internal/kms/kes.go
func (c *kesClient) Metrics(ctx context.Context) (kes.Metric, error) { c.lock.RLock() defer c.lock.RUnlock() return c.client.Metrics(ctx) } // Version retrieves version information func (c *kesClient) Version(ctx context.Context) (string, error) { c.lock.RLock() defer c.lock.RUnlock() return c.client.Version(ctx) } // APIs retrieves a list of supported API endpoints
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0)