- Sort Score
- Num 10 results
- Language All
Results 331 - 340 of 618 for Flock (0.02 seconds)
-
okhttp/src/commonTest/kotlin/okhttp3/CompressionInterceptorTest.kt
/* * Copyright (c) 2025 Block, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS,
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Aug 01 06:04:22 GMT 2025 - 3K bytes - Click Count (0) -
internal/lock/lock_windows_test.go
// GNU Affero General Public License for more details. // // 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 import ( "strings" "testing" ) func TestFixLongPath(t *testing.T) { // 248 is long enough to trigger the longer-than-248 checks in // fixLongPath, but short enough not to make a path component
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 2.2K bytes - Click Count (0) -
cmd/data-scanner-metric.go
if c != nil { c2 := c.clone() c = &c2 } p.cycleInfoMu.Lock() p.cycleInfo = c p.cycleInfoMu.Unlock() } // getCycle returns the current cycle metrics. // If not nil, the returned value can safely be modified. func (p *scannerMetrics) getCycle() *currentScannerCycle { p.cycleInfoMu.Lock() defer p.cycleInfoMu.Unlock() if p.cycleInfo == nil { return nil }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 01 06:06:01 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/config/lambda/target/lazyinit.go
m sync.Mutex } func (l *lazyInit) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doSlow(f) } return nil } func (l *lazyInit) doSlow(f func() error) error { l.m.Lock() defer l.m.Unlock() if atomic.LoadUint32(&l.done) == 0 { if err := f(); err != nil { return err } // Mark as done only when f() is successful atomic.StoreUint32(&l.done, 1) } return nil
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 1.3K bytes - Click Count (0) -
internal/stmt_store/stmt_store.go
// isTransaction: Indicates whether this operation is part of a transaction, which may affect the caching strategy. // connPool: A connection pool that provides database connections. // locker: A synchronization lock that is unlocked after initialization to avoid deadlocks. // Returns: // *Stmt: A newly created statement object for executing SQL operations. // error: An error if the statement preparation fails.
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Apr 27 06:05:16 GMT 2025 - 6K bytes - Click Count (0) -
src/archive/tar/common.go
} pre = cur } return true } // alignSparseEntries mutates src and returns dst where each fragment's // starting offset is aligned up to the nearest block edge, and each // ending offset is aligned down to the nearest block edge. // // Even though the Go tar Reader and the BSD tar utility can handle entries // with arbitrary offsets and lengths, the GNU tar utility can only handle
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Oct 07 19:46:36 GMT 2025 - 24.5K bytes - Click Count (0) -
cmd/auth-handler.go
if cred.AccessKey == "" { return ErrAccessDenied } conditions := getConditionValues(r, "", cred) conditions["object-lock-mode"] = []string{string(retMode)} conditions["object-lock-retain-until-date"] = []string{retDate.UTC().Format(time.RFC3339)} if retDays > 0 { conditions["object-lock-remaining-retention-days"] = []string{strconv.Itoa(retDays)} } if retMode == objectlock.RetGovernance && byPassSet {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportWorkAction.kt
return ktFile.viewProvider.document?.getLineNumber(startOffset)?.plus(1) ?: -1 } private fun KtFile.forEachIncubatingDeclaration(block: (KtNamedDeclaration) -> Unit) { collectDescendantsOfType<KtNamedDeclaration>().filter { it.isIncubating }.forEach(block) } private val KtNamedDeclaration.isIncubating: Boolean get() = annotationEntries.any { it.shortName?.asString() == "Incubating" }
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Mon Jun 02 09:57:54 GMT 2025 - 14.1K bytes - Click Count (0) -
mkdocs.yml
repo_url: https://github.com/square/okhttp site_description: "Square’s meticulous HTTP client for the JVM, Android, and GraalVM" site_author: Square, Inc. remote_branch: gh-pages edit_uri: "" copyright: 'Copyright © 2022 Block, Inc.' theme: name: 'material' favicon: assets/images/icon-square.png logo: assets/images/icon-square.png palette: - media: "(prefers-color-scheme: light)" scheme: default primary: teal
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Nov 21 07:19:31 GMT 2024 - 3.9K bytes - Click Count (0) -
docs/logging/README.md
"X-Amz-Id-2": "dd9025bab4ad464b049177c95eb6ebf374d3b3fd1af9251148b658df7ac2e3e8", "X-Amz-Request-Id": "17CDC1F4D7E69123", "X-Content-Type-Options": "nosniff", "X-Xss-Protection": "1; mode=block" }, "tags": { "objectLocation": { "name": "hosts", "poolId": 1, "setId": 1, "drives": [ "/mnt/data1", "/mnt/data2", "/mnt/data3",
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 10.5K bytes - Click Count (0)