db_handle = NULL;
}
-void ctx::db_manager_impl::on_thread_event_popped(int type, void* data)
+void ctx::db_manager_impl::onEvent(int type, void* data)
{
IF_FAIL_VOID(data);
query_info_s *info = static_cast<query_info_s*>(data);
break;
}
- delete_thread_event(type, data);
+ deleteEvent(type, data);
}
-void ctx::db_manager_impl::delete_thread_event(int type, void* data)
+void ctx::db_manager_impl::deleteEvent(int type, void* data)
{
IF_FAIL_VOID(data);
query_info_s *info = static_cast<query_info_s*>(data);
info->id = query_id;
info->listener = listener;
- if (!push_thread_event(QTYPE_CREATE_TABLE, info)) {
+ if (!pushEvent(QTYPE_CREATE_TABLE, info)) {
_E("Pushing thread event failed");
delete info;
return false;
info->id = query_id;
info->listener = listener;
- if (!push_thread_event(QTYPE_INSERT, info)) {
+ if (!pushEvent(QTYPE_INSERT, info)) {
_E("Pushing thread event failed");
delete info;
return false;
info->query = query;
info->listener = listener;
- if (!push_thread_event(QTYPE_EXECUTE, info)) {
+ if (!pushEvent(QTYPE_EXECUTE, info)) {
_E("Pushing thread event failed");
delete info;
return false;
#include <json.h>
#include <sqlite3.h>
-#include <event_driven.h>
+#include <EventDrivenThread.h>
#include <db_listener_iface.h>
#include <db_mgr_iface.h>
namespace ctx {
- class db_manager_impl : public event_driven_thread, public db_manager_iface {
+ class db_manager_impl : public EventDrivenThread, public db_manager_iface {
private:
enum query_type_e {
QTYPE_CREATE_TABLE = 1,
sqlite3 *db_handle;
- void on_thread_event_popped(int type, void* data);
- void delete_thread_event(int type, void* data);
+ void onEvent(int type, void* data);
+ void deleteEvent(int type, void* data);
bool open();
void close();