| 81 | /// Work item for QueryExecMgr::cancellation_thread_pool_. |
| 82 | /// This class needs to support move construction and assignment for use in ThreadPool. |
| 83 | class QueryCancellationTask { |
| 84 | public: |
| 85 | // Empty constructor needed to make ThreadPool happy. |
| 86 | QueryCancellationTask() : qs_(nullptr), is_coord_active_(true) {} |
| 87 | QueryCancellationTask(QueryState* qs, bool is_coord_active) |
| 88 | : qs_(qs), is_coord_active_(is_coord_active) {} |
| 89 | |
| 90 | QueryState* GetQueryState() const { return qs_; } |
| 91 | bool IsCoordActive() const { return is_coord_active_; } |
| 92 | |
| 93 | private: |
| 94 | // QueryState to be cancelled. |
| 95 | QueryState* qs_; |
| 96 | // Is the coordinator active. |
| 97 | bool is_coord_active_; |
| 98 | }; |
| 99 | |
| 100 | private: |
| 101 |
no outgoing calls
no test coverage detected