- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 767 for Mlock (0.01 sec)
-
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) -
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(¤t) // 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) -
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) -
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) -
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) -
docs/debugging/README.md
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 8.6K bytes - Viewed (0) -
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) -
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) -
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) -
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)