feat: implement database and session info handling in request object …

…with compatibility retained
project-tsurugi · Dec 14, 2023 · 28bd4ec · 28bd4ec
1 parent d7ae6e5
commit 28bd4ec
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/jogasaki b/jogasaki
diff --git a/ogawayama b/ogawayama
diff --git a/tateyama b/tateyama
diff --git a/tsubakuro b/tsubakuro
+8 −0		mock/tateyama/api/server/mock/request_response.cpp
+51 −0		mock/tateyama/api/server/mock/request_response.h
+73 −33		src/jogasaki/api/impl/service.cpp
+22 −22		src/jogasaki/api/impl/service.h
+30 −26		src/jogasaki/executor/executor.cpp
+8 −7		src/jogasaki/executor/executor.h
+1 −1		src/jogasaki/executor/io/data_channel_writer.cpp
+4 −4		src/jogasaki/executor/io/data_channel_writer.h
+5 −5		src/jogasaki/executor/io/dump_channel.cpp
+6 −13		src/jogasaki/executor/io/dump_channel.h
+11 −9		src/jogasaki/executor/io/dump_channel_writer.cpp
+5 −5		src/jogasaki/executor/io/dump_channel_writer.h
+67 −0		src/jogasaki/executor/io/dump_option.h
+1 −2		src/jogasaki/executor/io/group_reader.h
+5 −5		src/jogasaki/executor/io/null_record_channel.h
+4 −4		src/jogasaki/executor/io/null_record_channel_writer.h
+3 −3		src/jogasaki/executor/io/reader_container.cpp
+3 −3		src/jogasaki/executor/io/reader_container.h
+6 −5		src/jogasaki/executor/io/record_channel.h
+3 −3		src/jogasaki/executor/io/record_channel_adapter.cpp
+4 −4		src/jogasaki/executor/io/record_channel_adapter.h
+1 −2		src/jogasaki/executor/io/record_reader.h
+1 −2		src/jogasaki/executor/io/record_writer.h
+181 −0		test/jogasaki/api/dump_arrow_test.cpp
+1 −1		src/tateyama/transport/client_wire.h
+157 −103		src/tateyama/transport/wire.h
+1 −1		test/ogawayama/stub/endpoint.h
+3 −1		docs/config_parameters.md
+71 −0		include/tateyama/api/server/database_info.h
+14 −0		include/tateyama/api/server/request.h
+107 −0		include/tateyama/api/server/session_info.h
+11 −5		include/tateyama/status/resource/bridge.h
+3 −0		include/tateyama/status/resource/core.h
+65 −0		src/tateyama/endpoint/common/session_info_impl.h
+61 −0		src/tateyama/endpoint/common/worker_common.h
+3 −6		src/tateyama/endpoint/ipc/bootstrap/ipc_endpoint.h
+14 −13		src/tateyama/endpoint/ipc/bootstrap/ipc_listener.h
+12 −3		src/tateyama/endpoint/ipc/bootstrap/server_wires_impl.h
+27 −5		src/tateyama/endpoint/ipc/bootstrap/worker.cpp
+18 −18		src/tateyama/endpoint/ipc/bootstrap/worker.h
+8 −0		src/tateyama/endpoint/ipc/ipc_request.cpp
+11 −2		src/tateyama/endpoint/ipc/ipc_request.h
+1 −1		src/tateyama/endpoint/ipc/ipc_response.h
+56 −31		src/tateyama/endpoint/ipc/wire.h
+14 −0		src/tateyama/endpoint/loopback/loopback_request.h
+1 −4		src/tateyama/endpoint/stream/bootstrap/stream_endpoint.h
+12 −12		src/tateyama/endpoint/stream/bootstrap/stream_listener.h
+37 −20		src/tateyama/endpoint/stream/bootstrap/stream_worker.cpp
+13 −14		src/tateyama/endpoint/stream/bootstrap/stream_worker.h
+14 −3		src/tateyama/endpoint/stream/stream.h
+9 −0		src/tateyama/endpoint/stream/stream_request.cpp
+8 −1		src/tateyama/endpoint/stream/stream_request.h
+15 −8		src/tateyama/status/resource/bridge.cpp
+55 −0		src/tateyama/status/resource/database_info_impl.h
+1 −0		test/CMakeLists.txt
+14 −0		test/tateyama/datastore/datastore_test.cpp
+122 −0		test/tateyama/endpoint/ipc/ipc_info_test.cpp
+4 −1		test/tateyama/endpoint/response_only_test.cpp
+6 −3		test/tateyama/endpoint/result_set_limit_test.cpp
+5 −2		test/tateyama/endpoint/result_set_test.cpp
+101 −0		test/tateyama/endpoint/stream/stream_client.cpp
+74 −0		test/tateyama/endpoint/stream/stream_client.h
+141 −0		test/tateyama/endpoint/stream/stream_info_test.cpp
+5 −2		test/tateyama/endpoint/writer_limit_test.cpp
+14 −0		test/tateyama/framework/router_test.cpp
+132 −98		test/tsubakuro/common/wire/wire.h
+1 −1		modules/ipc/src/main/native/include/udf_wires.h
+43 −4		modules/ipc/src/main/native/include/wire.h