From 2d113532e4e92810cb050b0e5399e69f2770e8fe Mon Sep 17 00:00:00 2001 From: Ryo Kanbayashi Date: Mon, 15 Jul 2024 22:50:56 +0900 Subject: [PATCH] removed rest code for direct I/O. --- lib/samehada/samehada.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/lib/samehada/samehada.go b/lib/samehada/samehada.go index 12857187..cfa0bbfd 100644 --- a/lib/samehada/samehada.go +++ b/lib/samehada/samehada.go @@ -3,7 +3,6 @@ package samehada import ( "errors" "fmt" - "github.com/ncw/directio" "github.com/ryogrid/SamehadaDB/lib/catalog" "github.com/ryogrid/SamehadaDB/lib/common" "github.com/ryogrid/SamehadaDB/lib/concurrency" @@ -46,8 +45,8 @@ func reconstructIndexDataOfATbl(t *catalog.TableMetadata, c *catalog.Catalog, dm executionEngine := &executors.ExecutionEngine{} executorContext := executors.NewExecutorContext(c, t.Table().GetBufferPoolManager(), txn) - //zeroClearedBuf := make([]byte, common.PageSize) - zeroClearedBuf := directio.AlignedBlock(common.PageSize) + zeroClearedBuf := make([]byte, common.PageSize) + //zeroClearedBuf := directio.AlignedBlock(common.PageSize) bpm := t.Table().GetBufferPoolManager() for colIdx, index_ := range t.Indexes() {