aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/dirty_pages_temp_file.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/filesys/dirty_pages_temp_file.go')
-rw-r--r--weed/filesys/dirty_pages_temp_file.go11
1 files changed, 1 insertions, 10 deletions
diff --git a/weed/filesys/dirty_pages_temp_file.go b/weed/filesys/dirty_pages_temp_file.go
index 274b2a09e..3826008b7 100644
--- a/weed/filesys/dirty_pages_temp_file.go
+++ b/weed/filesys/dirty_pages_temp_file.go
@@ -6,7 +6,6 @@ import (
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
"io"
"os"
- "path/filepath"
"sync"
"time"
)
@@ -24,14 +23,6 @@ type TempFileDirtyPages struct {
replication string
}
-var (
- tmpDir = filepath.Join(os.TempDir(), "sw")
-)
-
-func init() {
- os.Mkdir(tmpDir, 0755)
-}
-
func newTempFileDirtyPages(file *File, writeOnly bool) *TempFileDirtyPages {
tempFile := &TempFileDirtyPages{
@@ -49,7 +40,7 @@ func (pages *TempFileDirtyPages) AddPage(offset int64, data []byte) {
defer pages.pageAddLock.Unlock()
if pages.tf == nil {
- tf, err := os.CreateTemp(tmpDir, "")
+ tf, err := os.CreateTemp(pages.f.wfs.option.getTempFilePageDir(), "")
if err != nil {
glog.Errorf("create temp file: %v", err)
pages.lastErr = err