- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 481 for clocks (0.16 sec)
-
src/sync/rwmutex.go
runtime_Semrelease(&rw.writerSem, false, 1) } } // Lock locks rw for writing. // If the lock is already locked for reading or writing, // Lock blocks until the lock is available. func (rw *RWMutex) Lock() { if race.Enabled { _ = rw.w.state race.Disable() } // First, resolve competition with other writers. rw.w.Lock() // Announce to readers there is a pending writer.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
src/cmd/vendor/rsc.io/markdown/list.go
item *itemBuilder todo func() line } func (b *listBuilder) build(p buildState) Block { blocks := p.blocks() pos := p.pos() // list can have wrong pos b/c extend dance. pos.EndLine = blocks[len(blocks)-1].Pos().EndLine Loose: for i, c := range blocks { c := c.(*Item) if i+1 < len(blocks) { if blocks[i+1].Pos().StartLine-c.EndLine > 1 { b.loose = true break Loose } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 7.2K bytes - Viewed (0) -
cmd/object-api-input-checks.go
import ( "context" "encoding/base64" "runtime" "strings" "github.com/minio/minio-go/v7/pkg/s3utils" ) // Checks on CopyObject arguments, bucket and object. func checkCopyObjArgs(ctx context.Context, bucket, object string) error { return checkBucketAndObjectNames(ctx, bucket, object) } // Checks on GetObject arguments, bucket and object. func checkGetObjArgs(ctx context.Context, bucket, object string) error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 5.7K bytes - Viewed (0) -
src/go/types/labels.go
} } } // A block tracks label declarations in a block and its enclosing blocks. type block struct { parent *block // enclosing block lstmt *ast.LabeledStmt // labeled statement to which this block belongs, or nil labels map[string]*ast.LabeledStmt // allocated lazily } // insert records a new label declaration for the current block.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 7.2K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/deadcode.go
if reachable[b.ID] { f.Blocks[i] = b i++ } else { if len(b.Values) > 0 { b.Fatalf("live values in unreachable block %v: %v", b, b.Values) } f.freeBlock(b) } } // zero remainder to help GC tail := f.Blocks[i:] for j := range tail { tail[j] = nil } f.Blocks = f.Blocks[:i] } // removeEdge removes the i'th outgoing edge from b (and
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 08 00:29:01 UTC 2023 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/metrics.go
return newInstrumentedAuthenticatorWithClock(jwtIssuer, delegate, clock.RealClock{}) } func newInstrumentedAuthenticatorWithClock(jwtIssuer string, delegate AuthenticatorTokenWithHealthCheck, clock clock.PassiveClock) *instrumentedAuthenticator { RegisterMetrics() return &instrumentedAuthenticator{ jwtIssuerHash: getHash(jwtIssuer), delegate: delegate, clock: clock, } } type instrumentedAuthenticator struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 19:29:33 UTC 2024 - 3.3K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/impl/legacy/DefaultBuildScanClock.java
import org.gradle.internal.time.Clock; import javax.inject.Inject; public class DefaultBuildScanClock implements BuildScanClock { private final Clock clock; @Inject public DefaultBuildScanClock(Clock clock) { this.clock = clock; } @Override public long getCurrentTime() { return clock.getCurrentTime(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 15 17:58:47 UTC 2024 - 1.1K bytes - Viewed (0) -
cmd/erasure-utils.go
"github.com/klauspost/reedsolomon" ) // getDataBlockLen - get length of data blocks from encoded blocks. func getDataBlockLen(enBlocks [][]byte, dataBlocks int) int { size := 0 // Figure out the data block length. for _, block := range enBlocks[:dataBlocks] { size += len(block) } return size } // Writes all the data blocks from encoded blocks until requested // outSize length. Provides a way to skip bytes until the offset.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress_test.go
"k8s.io/klog/v2" "k8s.io/klog/v2/ktesting" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) var ( pollPeriod = time.Millisecond minimalNoChange = 20 * time.Millisecond pollTimeout = 5 * time.Second ) func TestConditionalProgressRequester(t *testing.T) { _, ctx := ktesting.NewTestContext(t) logger := klog.FromContext(ctx) clock := testingclock.NewFakeClock(time.Now())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/SuiteTestClassProcessor.java
Clock clock) { this.suiteDescriptor = suiteDescriptor; this.processor = processor; this.clock = clock; } @Override public void startProcessing(TestResultProcessor testResultProcessor) { try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 3.3K bytes - Viewed (0)