Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 581 - 590 of 857 for wlock (0.54 seconds)

  1. 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)
  2. 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)
  3. android/guava/src/com/google/common/collect/Tables.java

       * ...
       * Map<C, V> row = table.row(rowKey); // Needn't be in synchronized block
       * ...
       * synchronized (table) { // Synchronizing on table, not row!
       *   Iterator<Entry<C, V>> i = row.entrySet().iterator(); // Must be in synchronized block
       *   while (i.hasNext()) {
       *     foo(i.next());
       *   }
       * }
       * }
       *
    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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top