- Sort Score
- Num 10 results
- Language All
Results 581 - 590 of 857 for wlock (0.26 seconds)
-
CLAUDE.md
├─ RobotsTxtException └─ SitemapsException ``` ### Thread-Local Storage Use `CrawlingParameterUtil` to set/get `CrawlerContext` and `UrlQueue` in worker threads. Always clear in finally block with `CrawlingParameterUtil.clearAll()`. ### Resource Cleanup Pattern Always use try-with-resources for `ResponseData` - temp files are auto-deleted on close. ## Log Message Guidelines
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Mar 12 03:39:20 GMT 2026 - 8.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
) } handler.windowUpdate(streamId, increment) } @Throws(IOException::class) override fun close() { source.close() } /** * Decompression of the header block occurs above the framing layer. This class lazily reads * continuation frames as they are needed by [Hpack.Reader.readHeaders]. */ internal class ContinuationSource( private val source: BufferedSource,Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 19.7K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Tables.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 24.9K bytes - Click Count (0) -
cmd/peer-rest-server.go
s.writeErrorResponse(w, err) return } } var errUnsupportedSignal = fmt.Errorf("unsupported signal") func waitingDrivesNode() map[string]madmin.DiskMetrics { globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrivesMap) globalLocalDrivesMu.RUnlock() errs := make([]error, len(localDrives)) infos := make([]DiskInfo, len(localDrives)) for i, drive := range localDrives {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
@BeforeEach fun setUp() { if (connectionType == H2) { platform.assumeHttp2Support() } // Sockets on some platforms can have large buffers that mean writes do not block when // required. These socket factories explicitly set the buffer sizes on sockets created. server = MockWebServer() server.serverSocketFactory =
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/bucket/lifecycle/expiration.go
expDate, err := time.Parse(time.RFC3339, dateStr) if err != nil { return errLifecycleInvalidDate } // Allow only date timestamp specifying midnight GMT hr, m, sec := expDate.Clock() nsec := expDate.Nanosecond() loc := expDate.Location() if hr != 0 || m != 0 || sec != 0 || nsec != 0 || loc.String() != time.UTC.String() { return errLifecycleDateNotMidnight }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 6.6K bytes - Click Count (0) -
cmd/metrics-v3-cache.go
totalDrives: totalDrives.Sum(), ioStats: map[string]driveIOStatMetrics{}, } currentStats := getCurrentDriveIOStats() now := time.Now().UTC() prevDriveIOStatsMu.Lock() if prevDriveIOStats != nil { duration := now.Sub(prevDriveIOStatsRefreshedAt) if duration.Seconds() > 1 { for d, cs := range currentStats { if ps, found := prevDriveIOStats[d]; found {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 8.1K bytes - Click Count (0) -
impl/maven-core/lifecycle-executor.txt
- plugin in any default values - check to see if anything is missing
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 9.7K bytes - Click Count (0) -
scripts/tests/test_translation_fixer/test_complex_doc/data/translated_doc.md
Комментарии внутри вложенного блока кода в тройных обратных кавычках НЕ БУДУТ сохранены. ```` Here is a code block with quadruple backticks that contains triple backticks inside: ```python # Этот комментарий НЕ будет сохранён def hello_world(): print("Hello, world") # Как и этот комментарий ``` ````
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Tue Feb 17 08:08:04 GMT 2026 - 11.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/create/Smb2CreateRequest.java
/** * Reserve an opportunistic lock filter on the open */ public static final int FILE_RESERVE_OPFILTER = 0x100000; /** * Open a reparse point and bypass normal reparse point processing */ public static final int FILE_OPEN_REPARSE_POINT = 0x200000; /** * Open does not cause an opportunistic lock break for the file */Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 22.9K bytes - Click Count (0)