if m.init {
		return nil, errors.New("mux client already used")
	}
	m.init = true
	m.singleResp = true
	msg := message{
		Op:         OpRequest,
		MuxID:      m.MuxID,
		Handler:    h,
		Flags:      m.BaseFlags | FlagEOF,
		Payload:    req,
		DeadlineMS: uint32(m.deadline.Milliseconds()),
	}
	if m.subroute != nil {
		msg.Flags |= FlagSubroute
	}
	ch := make(chan Response, 1)

This was changed in version 0.110.0 to fix unhandled memory consumption from forwarded exceptions without a handler (internal server errors), and to make it consistent with the behavior of regular Python code.

ADDL $0x428a2f98, R15 MOVL R12, CX RORL $0x06, AX MOVL R12, DX RORL $0x0b, CX XORL CX, AX MOVL R12, CX RORL $0x19, DX ANDL R13, CX XORL AX, DX MOVL R12, AX NOTL AX ADDL DX, R15 ANDL R14, AX XORL CX, AX ADDL R15, AX MOVL R8, DI MOVL R10, BX RORL $0x02, DI MOVL R8, DX ANDL R9, BX RORL $0x0d, DX MOVL R8, CX ANDL R10, CX XORL DX, DI XORL CX, BX MOVL R8, DX MOVL R9, CX RORL $0x16, DX ANDL R8, CX XORL CX, BX XORL DX, DI ADDL DI, BX MOVL BX, R15 ADDL AX, R11 ADDL AX, R15 MOVL 4(SI), AX BSWAPL AX MOVL AX,...

    when (type) {
      TYPE_DATA -> readData(handler, length, flags, streamId)
      TYPE_HEADERS -> readHeaders(handler, length, flags, streamId)
      TYPE_PRIORITY -> readPriority(handler, length, flags, streamId)
      TYPE_RST_STREAM -> readRstStream(handler, length, flags, streamId)
      TYPE_SETTINGS -> readSettings(handler, length, flags, streamId)
      TYPE_PUSH_PROMISE -> readPushPromise(handler, length, flags, streamId)

Sometimes there's an action required like calling the application layer or responding to a ping, and the thread discovering the action is not the thread that should do the work. We enqueue a runnable on this executor and it gets handled by one of the executor's threads.

### Locks

We have 3 different things that we synchronize on.

#### Http2Connection

### German instructions about difficult to translate technical terms (written in first person, which is you)

        String origin = "https://example.com";
        TestCorsHandler handler = new TestCorsHandler("example-handler");

        // Execute
        corsHandlerFactory.add(origin, handler);
        CorsHandler result = corsHandlerFactory.get(origin);

        // Verify
        assertNotNull(result);
        assertEquals(handler, result);
        assertEquals("example-handler", ((TestCorsHandler) result).getName());
    }

    @Test

        assertArgumentNotNull("bundle", bundle);

        final Map<String, String> ret = newHashMap();
        for (final Enumeration<String> e = bundle.getKeys(); e.hasMoreElements();) {
            final String key = e.nextElement();
            final String value = bundle.getString(key);
            ret.put(key, value);
        }
        return ret;
    }

    /**

        System.clearProperty("java.protocol.handler.pkgs");
        SingletonContext.registerSmbURLHandler();
        assertEquals("jcifs", System.getProperty("java.protocol.handler.pkgs"));
    }

    @Test
    void testRegisterSmbURLHandlerWhenPkgsDoesNotContainJcifs() {
        // Test registerSmbURLHandler when java.protocol.handler.pkgs does not contain "jcifs"

        private String lastOrigin = null;
        private CorsHandler handler = null;

        @Override
        public CorsHandler get(String origin) {
            getCalled = true;
            lastOrigin = origin;
            return handler;
        }

        public void setHandler(CorsHandler handler) {
            this.handler = handler;
        }

        public boolean wasGetCalled() {