mirror of
https://github.com/RGBCube/serenity
synced 2025-05-14 05:44:58 +00:00
1205d39fc3
The architecture of SQLServer is currently such that it sends results over IPC one row at a time. After the rows are exhausted, it sends a completion IPC. However, it does not wait for the client to finish processing a row before sending another row or the completion signal. This can result in clients hanging if the completion comes in while a row is being processed. At least in the case of WebView::Database, the result is that the completion signal is dropped, and the browser then hangs forever waiting for that signal (after it finishes processing the row). This patch makes SQLServer asynchronously wait for the client to tell it that the row has been processed and the next row (or completion) may be sent. We repurpose the `m_ongoing_executions` in SQLStatement for this purpose (this member was oddly being written to, but otherwise unused).
10 lines
423 B
Text
10 lines
423 B
Text
#include <LibSQL/Value.h>
|
|
|
|
endpoint SQLServer
|
|
{
|
|
connect(ByteString name) => (Optional<u64> connection_id)
|
|
prepare_statement(u64 connection_id, ByteString statement) => (Optional<u64> statement_id)
|
|
execute_statement(u64 statement_id, Vector<SQL::Value> placeholder_values) => (Optional<u64> execution_id)
|
|
ready_for_next_result(u64 statement_id, u64 execution_id) =|
|
|
disconnect(u64 connection_id) => ()
|
|
}
|