bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

cql3: make select statement an execution stage

Browse Source
This commit is contained in:
Paweł Dziepak
2017-02-22 18:17:43 +00:00
parent 12135dbe21
commit d005b20071
2 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
cql3/statements/select_statement.cc
View File

@@ -49,6 +49,7 @@
#include "query-result-reader.hh"
#include "query_result_merger.hh"
#include "service/pager/query_pagers.hh"
#include <seastar/core/execution_stage.hh>
namespace cql3 {
@@ -226,8 +227,21 @@ bool select_statement::needs_post_query_ordering() const {
return _restrictions->key_is_in_relation() && !_parameters->orderings().empty();
}
struct select_statement_executor {
static auto get() { return &select_statement::do_execute; }
};
static thread_local auto select_stage = seastar::make_execution_stage(select_statement_executor::get());
future<shared_ptr<transport::messages::result_message>>
select_statement::execute(distributed<service::storage_proxy>& proxy,
service::query_state& state,
const query_options& options)
{
return select_stage(this, seastar::ref(proxy), seastar::ref(state), seastar::cref(options));
}
future<shared_ptr<transport::messages::result_message>>
select_statement::do_execute(distributed<service::storage_proxy>& proxy,
service::query_state& state,
const query_options& options)
{

4
cql3/statements/select_statement.hh
View File

@@ -90,6 +90,10 @@ private:
query::partition_slice::option_set _opts;
cql_stats& _stats;
private:
future<::shared_ptr<transport::messages::result_message>> do_execute(distributed<service::storage_proxy>& proxy,
service::query_state& state, const query_options& options);
friend class select_statement_executor;
public:
select_statement(schema_ptr schema,
uint32_t bound_terms,