From 18cb8848f120fdaaf9085025f9f75cee17116616 Mon Sep 17 00:00:00 2001 From: sears Date: Sat, 23 Jan 2010 02:16:06 +0000 Subject: [PATCH] port + test with stasis r1351 git-svn-id: svn+ssh://svn.corp.yahoo.com/yahoo/yrl/labs/pnuts/code/logstore@521 8dad8b1f-cf64-0410-95b6-bcf113ffbcfe --- datapage.cpp | 4 +++- logstore.cpp | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) 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); } }