Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 767 for Mlock (0.43 sec)

  1. src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java

            setField(cmd, "timeout", 3000L);
            // arrays of one lock and one unlock range
            LockingAndXRange lock = new LockingAndXRange(false);
            lock.encode(new byte[20], 0); // initialise fields by encoding to set pid etc (though not needed)
            setField(lock, "pid", 123);
            setField(lock, "byteOffset", 100L);
            setField(lock, "lengthInBytes", 200L);
            LockingAndXRange unlock = new LockingAndXRange(false);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  2. cmd/metacache-stream.go

    			buf.Reset()
    			bytebufferpool.Put(buf)
    		}()
    
    		block := newMetacacheWriter(buf, 1<<20)
    		defer block.Close()
    		finishBlock := func() {
    			if err := block.Close(); err != nil {
    				w.streamErr = err
    				return
    			}
    			current.data = buf.Bytes()
    			w.streamErr = nextBlock(&current)
    			// Prepare for next
    			current.n++
    			buf.Reset()
    			block.Reset(buf)
    			current.First = ""
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  3. cmd/veeam-sos-api.go

    //     slots are used for object offloading or writing)
    //
    //   - <KbBlockSize>
    //     Veeam Block Size for backup and restore processing before compression is applied. The higher the block size, the more
    //     backup space is needed for incremental backups. Larger block sizes also mean less performance for random read restore
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

      }
    
      private fun logEvent(e: ConnectionEvent) {
        if (e.connection != null) {
          assertThat(Thread.holdsLock(e.connection), "Called with lock $${e.connection}")
            .isFalse()
        }
        for (lock in forbiddenLocks) {
          assertThat(Thread.holdsLock(lock), "Called with lock $lock")
            .isFalse()
        }
    
        if (enforceOrder) {
          checkForStartEvent(e)
        }
    
        eventSequence.offer(e)
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  5. docs/metrics/healthcheck/README.md

    HTTP/1.1 503 Service Unavailable
    Accept-Ranges: bytes
    Content-Length: 0
    Server: MinIO
    Vary: Origin
    X-Amz-Bucket-Region: us-east-1
    X-Minio-Write-Quorum: 3
    X-Amz-Request-Id: 16239D6AB80EBECF
    X-Xss-Protection: 1; mode=block
    Date: Tue, 21 Jul 2020 00:36:14 GMT
    ```
    
    ### Cluster-readable probe
    
    The reply is '200 OK' if cluster has read quorum if not it returns '503 Service Unavailable'.
    
    ```
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jul 06 16:18:38 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  6. docs/debugging/README.md

            "fe012443-6ba9-4ef2-bb94-b729d2060c78/test123/testw3c.pdf/xl.meta": {"Versions":[{"Type":1,"V2Obj":{"ID":"aGEA/ZUOR4ueRIZs...
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  7. docs/smb3-features/04-directory-leasing-design.md

            lock.readLock().lock();
            try {
                lastAccessTime = System.currentTimeMillis();
                return children.get(name);
            } finally {
                lock.readLock().unlock();
            }
        }
        
        public boolean hasChild(String name) {
            lock.readLock().lock();
            try {
                lastAccessTime = System.currentTimeMillis();
                return children.containsKey(name);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  8. src/main/webapp/css/admin/plugins/daterangepicker/daterangepicker.css

      float: none;
    }
    
    .daterangepicker.single .drp-selected {
      display: none;
    }
    
    .daterangepicker.show-calendar .drp-calendar {
      display: block;
    }
    
    .daterangepicker.show-calendar .drp-buttons {
      display: block;
    }
    
    .daterangepicker.auto-apply .drp-buttons {
      display: none;
    }
    
    .daterangepicker .drp-calendar {
      display: none;
      max-width: 270px;
    }
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

        return DerHeader(tagClass, tag, constructed, length)
      }
    
      /**
       * Consume a header and execute [block], which should consume the entire value described by the
       * header. It is an error to not consume a full value in [block].
       */
      internal inline fun <T> read(
        name: String?,
        block: (DerHeader) -> T,
      ): T {
        if (!hasNext()) throw ProtocolException("expected a value")
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  10. internal/s3select/csv/reader.go

    			r.columnNames = columns
    		}
    	}
    
    	r.bufferPool.New = func() []byte {
    		return make([]byte, csvSplitSize+1024)
    	}
    
    	// Return first block
    	next, nextErr := r.nextSplit(csvSplitSize, r.bufferPool.Get())
    	// Check if first block is valid.
    	if !utf8.Valid(next) {
    		return errInvalidTextEncodingError()
    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
Back to top