diff --git a/datapage.cpp b/datapage.cpp index b931e10..91ca013 100644 --- a/datapage.cpp +++ b/datapage.cpp @@ -396,7 +396,9 @@ void DataPage::force_region_rid(int xid, void *conf) pageid_t pid; Tread(xid,a.regionList,&pid); stasis_dirty_page_table_flush_range((stasis_dirty_page_table_t*)stasis_runtime_dirty_page_table(), pid, pid+a.regionSize); - forcePageRange(pid, pid+a.regionSize); + stasis_buffer_manager_t *bm = + (stasis_buffer_manager_t*)stasis_runtime_buffer_manager(); + bm->forcePageRange(bm, pid, pid+a.regionSize); } } diff --git a/logstore.cpp b/logstore.cpp index 08d28b7..1a04d49 100644 --- a/logstore.cpp +++ b/logstore.cpp @@ -86,7 +86,9 @@ void logtree::force_region_rid(int xid, void *conf) pageid_t pid; Tread(xid,a.regionList,&pid); stasis_dirty_page_table_flush_range((stasis_dirty_page_table_t*)stasis_runtime_dirty_page_table(), pid, pid+a.regionSize); - forcePageRange(pid, pid+a.regionSize); + stasis_buffer_manager_t *bm = + (stasis_buffer_manager_t*)stasis_runtime_buffer_manager(); + bm->forcePageRange(bm, pid, pid+a.regionSize); } }