aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/memory_map
diff options
context:
space:
mode:
authorj.laycock <joseph.laycock@4sightimaging.com>2019-08-28 16:59:42 +0100
committerj.laycock <joseph.laycock@4sightimaging.com>2019-08-30 12:30:00 +0100
commitdc50701e7d69f4349e6a952b622841e6705f3260 (patch)
treeb18b46351d15e70c528856d6261a66331f9e727b /weed/storage/memory_map
parent523f3a12b3c02070f00c3baff3be06175732db3b (diff)
downloadseaweedfs-dc50701e7d69f4349e6a952b622841e6705f3260.tar.xz
seaweedfs-dc50701e7d69f4349e6a952b622841e6705f3260.zip
Overload createFile function, expose File in memory_map struct, delete from memory_map map on delete
Diffstat (limited to 'weed/storage/memory_map')
-rw-r--r--weed/storage/memory_map/memory_map_windows.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/storage/memory_map/memory_map_windows.go b/weed/storage/memory_map/memory_map_windows.go
index 8ddbaa948..069587334 100644
--- a/weed/storage/memory_map/memory_map_windows.go
+++ b/weed/storage/memory_map/memory_map_windows.go
@@ -20,7 +20,7 @@ type MemoryBuffer struct {
}
type MemoryMap struct {
- file_handle *os.File
+ File *os.File
file_memory_map_handle uintptr
write_map_views []MemoryBuffer
max_length uint64
@@ -48,7 +48,7 @@ func CreateMemoryMap(file *os.File, maxlength uint64) MemoryMap {
file_memory_map_handle, err := windows.CreateFileMapping(windows.Handle(file.Fd()), nil, windows.PAGE_READWRITE, maxlength_high, maxlength_low, nil)
if err != nil {
- mem_map.file_handle = file
+ mem_map.File = file
mem_map.file_memory_map_handle = uintptr(file_memory_map_handle)
mem_map.max_length = maxlength
mem_map.End_Of_File = -1
@@ -59,7 +59,7 @@ func CreateMemoryMap(file *os.File, maxlength uint64) MemoryMap {
func DeleteFileAndMemoryMap(mem_map MemoryMap) {
windows.CloseHandle(windows.Handle(mem_map.file_memory_map_handle))
- windows.CloseHandle(windows.Handle(mem_map.file_handle.Fd()))
+ windows.CloseHandle(windows.Handle(mem_map.File.Fd()))
for _, view := range mem_map.write_map_views {
ReleaseMemory(view)