- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 463 for Blocks (0.23 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
internal inline fun <T> Logger.logElapsed( task: Task, queue: TaskQueue, block: () -> T, ): T { var startNs = -1L val loggingEnabled = isLoggable(Level.FINE) if (loggingEnabled) { startNs = queue.taskRunner.backend.nanoTime() log(task, queue, "starting") } var completedNormally = false try { val result = block() completedNormally = true return result } finally {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.6K bytes - Viewed (0) -
internal/grid/muxclient.go
} m.addResponse(Response{Err: ErrIncorrectSequence}) return false } m.RecvSeq++ return true } // response will send handleIncoming response to client. // may never block. // Should return whether the next call would block. func (m *muxClient) response(seq uint32, r Response) { if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "RESP") } if debugPrint {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15.9K bytes - Viewed (0) -
src/main/java/jcifs/SmbResourceException.java
case DISK_SPACE: return "Free up disk space or use a different location"; case QUOTA: return "Contact administrator to increase quota limits"; case LOCK: return "Release existing locks or wait for them to be released"; case BUFFER: return "Reduce buffer usage or increase buffer pool size"; case THREAD_POOL:Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 5.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java
} } /** * Constructs an AndX message block with configuration and command * @param config the configuration * @param command the SMB command */ protected AndXServerMessageBlock(final Configuration config, final byte command) { this(config, command, null); } /** * Constructs an AndX message block with command and chained command * @param config the configurationRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 15.8K bytes - Viewed (0) -
internal/kms/secret-key.go
} iv, nonce := random[:16], random[16:] prf := hmac.New(sha256.New, s.key) prf.Write(iv) key := prf.Sum(make([]byte, 0, prf.Size())) block, err := aes.NewCipher(key) if err != nil { return DEK{}, err } aead, err := cipher.NewGCM(block) if err != nil { return DEK{}, err } plaintext, err := sioutil.Random(32) if err != nil { return DEK{}, err }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Apr 21 16:23:51 UTC 2025 - 8.4K bytes - Viewed (0) -
cmd/grid.go
var globalGrid atomic.Pointer[grid.Manager] // globalLockGrid is the global lock grid manager. var globalLockGrid atomic.Pointer[grid.Manager] // globalGridStart is a channel that will block startup of grid connections until closed. var globalGridStart = make(chan struct{}) // globalLockGridStart is a channel that will block startup of lock grid connections until closed. var globalLockGridStart = make(chan struct{})
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 16 14:27:42 UTC 2025 - 3.7K bytes - Viewed (0) -
.github/PULL_REQUEST_TEMPLATE.md
--> #### Special notes for your reviewer: #### Does this PR introduce a user-facing change? <!-- If no, just write "NONE" in the release-note block below. If yes, a release note is required: Enter your extended release note in the block below. If the PR requires additional action from users switching to the new release, include the string "action required".
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Fri Jun 06 14:40:00 UTC 2025 - 3.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* * https://github.com/oracle/graal/issues/3008 */ @JvmStatic fun Throwable.assertSuppressed(block: (List<@JvmSuppressWildcards Throwable>) -> Unit) { if (isGraalVmImage) return block(suppressed.toList()) } @JvmStatic fun threadFactory(name: String): ThreadFactory = object : ThreadFactory { private var nextId = 1
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.3K bytes - Viewed (0) -
doc/godebug.md
distribution that disables transparent huge pages altogether. Go 1.22 added contention on runtime-internal locks to the [`mutex` profile](/pkg/runtime/pprof#Profile). Contention on these locks is always reported at `runtime._LostContendedRuntimeLock`. Complete stack traces of runtime locks can be enabled with the [`runtimecontentionstacks` setting](/pkg/runtime#hdr-Environment_Variables). These stack traces have
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Wed Dec 03 00:18:09 UTC 2025 - 24.7K bytes - Viewed (0) -
fess-crawler/src/test/resources/extractor/markdown/test.md
The extractor should handle: - YAML front matter extraction - Heading structure - **Bold text** and *italic text* - Lists and other formatting ### Code Examples Here is some inline `code` and a code block: ```java public class Example { public static void main(String[] args) { System.out.println("Hello, World!"); } } ``` ## LinksRegistered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 03:46:53 UTC 2025 - 767 bytes - Viewed (0)