<!doctype html><!-- webkit-test-runner [ IPCTestingAPIEnabled=true ] -->
<title>Test that stream processing drains autorelease pool if needed for the platform</title>
<script src="../resources/testharness.js"></script>
<script src="../resources/testharnessreport.js"></script>
<body>
<script>
promise_test(async t => {
    if (!window.IPC)
        return;
    const defaultTimeout = 1000;
    const bufferSize = 100;
    const streamTesterID = 447;
    for (const processTarget of IPC.processTargets) {
        const streamConnection = IPC.createStreamClientConnection(processTarget, bufferSize);
        IPC.sendMessage(processTarget, 0, IPC.messages.IPCTester_CreateStreamTester.name, [
            { type: 'uint64_t', value: streamTesterID },
            { type: 'StreamConnectionBuffer', value: streamConnection.streamBuffer() },
        ]);
        const arguments = IPC.waitForMessage(processTarget, streamTesterID, IPC.messages.IPCStreamTesterProxy_WasCreated.name, defaultTimeout);
        streamConnection.setSemaphores(arguments[0].value, arguments[1].value);

        // Test starts here.
        try {
            let result = streamConnection.sendSyncMessage(streamTesterID, IPC.messages.IPCStreamTester_CheckAutoreleasePool.name, defaultTimeout, []);
            let previousValue = result.arguments[0];

            assert_equals(previousValue.type, "int32_t", `for ${ processTarget }`);
            assert_equals(previousValue.value, 1, `for ${ processTarget }`);
            // Autoreleasepool drains between message processing. Add an idle wait so that it no
            // messages are posted, so the pool drains.
            await new Promise((resolve) => setTimeout(resolve, 300));
            result = streamConnection.sendSyncMessage(streamTesterID, IPC.messages.IPCStreamTester_CheckAutoreleasePool.name, defaultTimeout, []);
            previousValue = result.arguments[0];
            assert_equals(previousValue.type, "int32_t", `for ${ processTarget }`);
            assert_equals(previousValue.value, 1, `for ${ processTarget }`);
        } finally {
            IPC.sendSyncMessage(processTarget, 0, IPC.messages.IPCTester_ReleaseStreamTester.name, defaultTimeout, [{ type: 'uint64_t', value: streamTesterID }]);
        }
    }
});
</script>
</body>