- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 292 for getClock (0.13 sec)
-
platforms/native/testing-native/src/main/java/org/gradle/nativeplatform/test/xctest/internal/execution/XCTestExecuter.java
throw new UnsupportedOperationException(); } public IdGenerator<?> getIdGenerator() { return new LongIdGenerator(); } @Inject public Clock getClock() { throw new UnsupportedOperationException(); } @Inject public Clock getTimeProvider() { throw new UnsupportedOperationException(); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 8.1K bytes - Viewed (0) -
cmd/namespace-lock.go
) // local lock servers var globalLockServer *localLocker // RWLocker - locker interface to introduce GetRLock, RUnlock. type RWLocker interface { GetLock(ctx context.Context, timeout *dynamicTimeout) (lkCtx LockContext, timedOutErr error) Unlock(lkCtx LockContext) GetRLock(ctx context.Context, timeout *dynamicTimeout) (lkCtx LockContext, timedOutErr error) RUnlock(lkCtx LockContext) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 05 23:56:35 UTC 2023 - 9.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/BlockPayload.java
public abstract class BlockPayload { private Block block; public Block getBlock() { return block; } public void setBlock(Block block) { this.block = block; } public BlockPointer getPos() { return getBlock().getPos(); } public BlockPointer getNextPos() { return getBlock().getNextPos(); } protected abstract int getSize();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.4K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) { ctx := context.Background() lrwm := NewLRWMutex() if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
ctx1, cancel1 := context.WithCancel(context.Background()) if !drwm1.GetRLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(context.Background()) if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
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. func (lm *LRWMutex) GetRLock(ctx context.Context, id string, source string, timeout time.Duration) (locked bool) { const isWriteLock = false return lm.lockLoop(ctx, id, source, timeout, isWriteLock) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 4.8K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/FileBackedBlockStore.java
nextBlock = 0; } @Override public void attach(BlockPayload block) { if (block.getBlock() == null) { block.setBlock(new BlockImpl(block)); } } @Override public void remove(BlockPayload block) { BlockImpl blockImpl = (BlockImpl) block.getBlock(); blockImpl.detach(); } @Override public void flush() { }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 7.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/sparsecore/embedding_program_key.cc
}; // Checks if `op` is nested in `block`. bool OpInBlock(Operation* op, Block* block) { Block* op_block = op->getBlock(); while (op_block) { if (op_block == block) return true; if (auto* parent_op = op_block->getParentOp()) { op_block = parent_op->getBlock(); } else { break; } } return false; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 17.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/group_by_dialect.cc
} // We treat block arguments of inner blocks as "results", too, in // the sense that they're values produced inside this op. for (Region& region : op->getRegions()) { for (Block& block : region.getBlocks()) { for (BlockArgument& arg : block.getArguments()) { all_internal_results.insert(arg); } } } }); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Mar 17 07:31:01 UTC 2023 - 8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/transforms/legalize_tf_communication.cc
if (!llvm::hasSingleElement(block->getParent()->getBlocks())) return op->emitOpError() << "expects single block region ancestor(s)"; control_flow_ops.insert(parent); control_flow_blocks.insert(block); parent = block->getParentOp(); block = parent->getBlock(); } return success(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 40.5K bytes - Viewed (0)