- Sort Score
- Result 10 results
- Languages All
Results 301 - 310 of 442 for Opblock (0.57 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt
fun delayBeforeTrailersHttp1() { delayBeforeTrailers(Protocol.HTTP_1_1) } @Test fun delayBeforeTrailersHttp2() { trailers(Protocol.HTTP_2) } /** Confirm the client will block if necessary to consume trailers. */ private fun delayBeforeTrailers(protocol: Protocol) { enableProtocol(protocol) server.enqueue( MockResponse .Builder()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 08 21:45:04 UTC 2025 - 18.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/PermissionHelper.java
*/ public void setUserPrefix(final String userPrefix) { this.userPrefix = userPrefix; } /** * Extracts role type information from SMB (Server Message Block) response data. * Processes both SMB and SMB1 protocols to extract allowed and denied SIDs. * * @param responseData the response data containing SMB metadataRegistered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 13 05:54:52 UTC 2025 - 15.4K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
func (h *Target) Cancel() { // If queuestore is configured, cancel it's context to // stop the replay go-routine. if h.store != nil { h.storeCtxCancel() } // Set logch to nil and close it. // This will block all Send operations, // and finish the existing ones. // All future ones will be discarded. h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock() if h.producer != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 10.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
} finally { if (task != null) { task.cancel(); } if (p != null && p.isAlive()) { logger.warn("Process {} is still alive in finally block. Forcing destruction.", p); if (task == null) { task = new ProcessDestroyer(p, ist, commandDestroyTimeout); } if (!task.isExecuted()) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Dec 04 08:02:36 UTC 2025 - 16K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
connection.setReadTimeout(500) try { connection.getResponseCode() fail<Any>() } catch (expected: SocketTimeoutException) { } // Shutting down the server should unblock the dispatcher. server.shutdown() } @Test fun requestUrlReconstructed() { server.enqueue(MockResponse().setBody("hello world")) val url = server.url("/a/deep/path?key=foo%20bar").toUrl()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 03 13:16:34 UTC 2025 - 22.3K bytes - Viewed (0) -
lib/fips140/v1.0.0-c2097c7c.zip
too long") } var buf [4]byte dk := make([]byte, 0, numBlocks*hashLen) U := make([]byte, hashLen) for block := 1; block <= numBlocks; block++ { // N.B.: || means concatenation, ^ means XOR // for each block T_i = U_1 ^ U_2 ^ ... ^ U_iter // U_1 = PRF(password, salt || uint(i)) prf.Reset() prf.Write(salt) buf[0] = byte(block >> 24) buf[1] = byte(block >> 16) buf[2] = byte(block >> 8) buf[3] = byte(block) prf.Write(buf[:4]) dk = prf.Sum(dk) T := dk[len(dk)-hashLen:] copy(U, T) // U_n = PRF(password, U_(n-1))...
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Thu Sep 25 19:53:19 UTC 2025 - 642.7K bytes - Viewed (0) -
lib/fips140/v1.1.0-rc1.zip
too long") } var buf [4]byte dk := make([]byte, 0, numBlocks*hashLen) U := make([]byte, hashLen) for block := 1; block <= numBlocks; block++ { // N.B.: || means concatenation, ^ means XOR // for each block T_i = U_1 ^ U_2 ^ ... ^ U_iter // U_1 = PRF(password, salt || uint(i)) prf.Reset() prf.Write(salt) buf[0] = byte(block >> 24) buf[1] = byte(block >> 16) buf[2] = byte(block >> 8) buf[3] = byte(block) prf.Write(buf[:4]) dk = prf.Sum(dk) T := dk[len(dk)-hashLen:] copy(U, T) // U_n = PRF(password, U_(n-1))...
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Thu Dec 11 16:27:41 UTC 2025 - 663K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/FessBaseAction.java
return viewHelper.getActionHook().hookBefore(runtime, super::hookBefore); } /** * Hook method called in the finally block of action processing. * This method delegates to the view helper's action hook for final cleanup. * * @param runtime the action runtime context */ @Override
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 15K bytes - Viewed (0) -
src/main/webapp/css/admin/adminlte.min.css
757d;padding:4px}.list-link>a:hover{color:#212529}.user-block{float:left}.user-block img{float:left;height:40px;width:40px}.user-block .comment,.user-block .description,.user-block .username{display:block;margin-left:50px}.user-block .username{font-size:16px;font-weight:600;margin-top:-1px}.user-block .description{color:#6c757d;font-size:13px;margin-top:-3px}.user-block.user-block-sm img{width:1.875rem;height:1.875rem}.user-block.user-block-sm .comment,.user-block.user-block-sm .description,.use...Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Oct 26 01:49:09 UTC 2024 - 1.3M bytes - Viewed (0) -
src/main/webapp/js/admin/adminlte.min.js
),o=a&&(e.hasClass(L)||e.hasClass(D));a||o?this.show(a):i&&this.collapse()},t._init=function(){var e=this,t=n.default("body");t.hasClass(L)||t.hasClass(D)?(n.default(k).not(this._config.target).hide(),n.default(this._config.target).css("display","block")):n.default(k).hide(),this._fixHeight(),this._fixScrollHeight(),n.default(window).resize((function(){e._fixHeight(),e._fixScrollHeight()})),n.default(window).scroll((function(){var t=n.default("body");(t.hasClass(L)||t.hasClass(D))&&e._fixScrollH...
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Oct 26 01:49:09 UTC 2024 - 45.3K bytes - Viewed (0)