- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for var (0.22 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
internal val logger: Logger = TaskRunner.logger, ) { val lock: ReentrantLock = ReentrantLock() val condition: Condition = lock.newCondition() private var nextQueueName = 10000 private var coordinatorWaiting = false private var coordinatorWakeUpAt = 0L /** * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
/** The task that's currently executing. Guarded by [TaskRunner.lock]. */ private var currentTask: SerialTask = TestThreadSerialTask /** The coordinator task if it's waiting, and how it will resume. Guarded by [TaskRunner.lock]. */ private var waitingCoordinatorTask: SerialTask? = null private var waitingCoordinatorInterrupted = false private var waitingCoordinatorNotified = false
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
cni/pkg/ipset/ipset.go
return m.Deps.deleteIP(m.V4Name, ipToDel, ipProto) } func (m *IPSet) Flush() error { var err error err = m.Deps.flush(m.V4Name) if m.V6Name != "" { v6err := m.Deps.flush(m.V6Name) err = errors.Join(err, v6err) } return err } func (m *IPSet) ClearEntriesWithComment(comment string) error { var err error err = m.Deps.clearEntriesWithComment(m.V4Name, comment) if m.V6Name != "" {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/erasure-object.go
if !opts.NoAuditLog { auditObjectErasureSet(ctx, object, &er) } var lc *lifecycle.Lifecycle var rcfg lock.Retention var replcfg *replication.Config if opts.Expiration.Expire { // Check if the current bucket has a configured lifecycle policy lc, err = globalLifecycleSys.Get(bucket)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 76.9K bytes - Viewed (2) -
cmd/iam-store.go
} } return ret, nil } // helper function - does not take locks. func filterPolicies(cache *iamCache, policyName string, bucketName string) (string, policy.Policy) { var policies []string mp := newMappedPolicy(policyName) var toMerge []policy.Policy for _, policy := range mp.toSlice() { if policy == "" { continue } p, found := cache.iamPolicyDocsMap[policy] if !found { continue
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/xl-storage.go
} } srcFilePath := pathutil.Join(srcVolumeDir, pathJoin(srcPath, xlStorageFormatFile)) dstFilePath := pathutil.Join(dstVolumeDir, pathJoin(dstPath, xlStorageFormatFile)) var srcDataPath string var dstDataPath string var dataDir string if !fi.IsRemote() { dataDir = retainSlash(fi.DataDir) } if dataDir != "" { srcDataPath = retainSlash(pathJoin(srcVolumeDir, srcPath, dataDir))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/storage-rest-server.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cni/pkg/cmd/root.go
registerStringParameter(constants.LogUDSAddress, "/var/run/istio-cni/log.sock", "The UDS server address which CNI plugin will copy log output to") registerStringParameter(constants.CNIEventAddress, "/var/run/istio-cni/pluginevent.sock", "The UDS server address which CNI plugin will forward ambient pod creation events to")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/erasure-multipart.go
// run multiple cleanup's local to this server. var wg sync.WaitGroup for _, disk := range er.getLocalDisks() { if disk != nil { wg.Add(1) go func(disk StorageAPI) { defer wg.Done() er.cleanupStaleUploadsOnDisk(ctx, disk, expiry) }(disk) } } wg.Wait() } func (er erasureObjects) deleteAll(ctx context.Context, bucket, prefix string) { var wg sync.WaitGroup
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0)