- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 183 for flag (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
) { this.withLock { if (closed) throw IOException("closed") var flags = FLAG_NONE if (outFinished) flags = flags or FLAG_END_STREAM dataFrame(streamId, flags, source, byteCount) } } @Throws(IOException::class) fun dataFrame( streamId: Int, flags: Int, buffer: Buffer?, byteCount: Int, ) { frameHeader(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
import okhttp3.internal.http2.Http2.CONNECTION_PREFACE import okhttp3.internal.http2.Http2.FLAG_ACK import okhttp3.internal.http2.Http2.FLAG_COMPRESSED import okhttp3.internal.http2.Http2.FLAG_END_HEADERS import okhttp3.internal.http2.Http2.FLAG_END_STREAM import okhttp3.internal.http2.Http2.FLAG_PADDED import okhttp3.internal.http2.Http2.FLAG_PRIORITY import okhttp3.internal.http2.Http2.INITIAL_MAX_FRAME_SIZE
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
data.write("ca00".decodeHex()) // Empty pong, flag 1 set. assertFailsWith<ProtocolException> { clientReader.processNextFrame() }.also { expected -> assertThat(expected.message).isEqualTo("Unexpected rsv1 flag") } } @Test fun reservedFlag1IsUnsupportedForControlFrames() { data.write("ca00".decodeHex()) // Empty pong, flag 1 set. assertFailsWith<ProtocolException> {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
import okhttp3.internal.EMPTY_BYTE_ARRAY import okhttp3.internal.http2.Http2.FLAG_COMPRESSED import okhttp3.internal.http2.Http2.FLAG_END_HEADERS import okhttp3.internal.http2.Http2.FLAG_END_STREAM import okhttp3.internal.http2.Http2.FLAG_NONE import okhttp3.internal.http2.Http2.FLAG_PADDED import okhttp3.internal.http2.Http2.FLAG_PRIORITY import okhttp3.internal.http2.Http2.TYPE_GOAWAY import okio.Buffer
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 28.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
import okhttp3.internal.toHexString import okhttp3.internal.ws.WebSocketProtocol.B0_FLAG_FIN import okhttp3.internal.ws.WebSocketProtocol.B0_FLAG_RSV1 import okhttp3.internal.ws.WebSocketProtocol.B0_FLAG_RSV2 import okhttp3.internal.ws.WebSocketProtocol.B0_FLAG_RSV3 import okhttp3.internal.ws.WebSocketProtocol.B0_MASK_OPCODE import okhttp3.internal.ws.WebSocketProtocol.B1_FLAG_MASK import okhttp3.internal.ws.WebSocketProtocol.B1_MASK_LENGTH
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
docs/bucket/replication/setup_ilm_expiry_replication.sh
./mc ilm rule list sitea/bucket ## Check ilm expiry flag ./mc admin replicate info sitea --json flag1=$(./mc admin replicate info sitea --json | jq '.sites[0]."replicate-ilm-expiry"') flag2=$(./mc admin replicate info sitea --json | jq '.sites[1]."replicate-ilm-expiry"') if [ "$flag1" != "true" ]; then echo "BUG: Expected ILM expiry replication not set for 'sitea'" exit 1 fi if [ "$flag2" != "true" ]; then
Shell Script - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 12.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java
/** * @return the flags */ public final int getFlags () { return this.flags; } /** * * @param flag */ public final void addFlags ( int flag ) { this.flags |= flag; } /** * * @param flag */ public final void clearFlags ( int flag ) { this.flags &= ~flag; }
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Sep 30 10:47:31 GMT 2018 - 19.9K bytes - Viewed (0) -
docs/bucket/replication/README.md
target to the srcbucket on myminio.By default, if --replicate flag is not specified, replication of delete marker, permanent deletes, existing object replication and replica modification sync are all enabled. If you are using older mc versions, the ARN needs to be generated as a separate step before adding a replication rule. > NOTE: If you are using a mc version below `RELEASE.2022-12-24T15-21-38Z`, the --remote-bucket flag needs an ARN generated by `mc admin bucket remote add` command....
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 24 23:46:33 GMT 2023 - 18.2K bytes - Viewed (0) -
cmd/admin-router.go
// this behavior. func adminMiddleware(f http.HandlerFunc, flags ...hFlag) http.HandlerFunc { // Collect all flags with bitwise-OR and assign operator var handlerFlags hFlag for _, flag := range flags { handlerFlags |= flag } // Get name of the handler using reflection. handlerName := getHandlerName(f, "adminAPIHandlers") var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
src/cmd/asm/internal/asm/endtoend_test.go
s := fmt.Sprintf(format, args...) if !strings.HasSuffix(s, "\n") { s += "\n" } errBuf.WriteString(s) } for _, flag := range flags { switch flag { case "dynlink": ctxt.Flag_dynlink = true default: t.Errorf("unknown flag %s", flag) } } pList.Firstpc, ok = parser.Parse() obj.Flushplist(ctxt, pList, nil) if ok && !failed { t.Errorf("asm: %s had no errors", file)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Dec 07 18:42:59 GMT 2023 - 11.6K bytes - Viewed (0)