You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mnemonic.apache.org by ga...@apache.org on 2017/10/22 15:34:43 UTC
incubator-mnemonic git commit: MNEMONIC-275 Implement a default
function to sync data to the persistent storage
Repository: incubator-mnemonic
Updated Branches:
refs/heads/master 29822230f -> 9cd39fc93
MNEMONIC-275 Implement a default function to sync data to the persistent storage
Project: http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/commit/9cd39fc9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/tree/9cd39fc9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/diff/9cd39fc9
Branch: refs/heads/master
Commit: 9cd39fc93591fb505cf99df1318d9b6b50be18be
Parents: 2982223
Author: Jie Liu <li...@gmail.com>
Authored: Sat Oct 21 15:54:55 2017 -0700
Committer: Jie Liu <li...@gmail.com>
Committed: Sat Oct 21 18:17:41 2017 -0700
----------------------------------------------------------------------
.../mnemonic/collections/DurableArrayImpl.java | 6 +-
.../collections/DurableHashMapImpl.java | 6 +-
.../collections/DurableHashSetImpl.java | 6 +-
.../mnemonic/collections/DurableTreeImpl.java | 6 +-
.../java/org/apache/mnemonic/Allocator.java | 6 +-
.../mnemonic/AnnotatedDurableEntityClass.java | 18 ++---
.../java/org/apache/mnemonic/ChunkBuffer.java | 12 +--
.../main/java/org/apache/mnemonic/Durable.java | 6 +-
.../java/org/apache/mnemonic/DurableBuffer.java | 12 +--
.../java/org/apache/mnemonic/DurableChunk.java | 12 +--
.../java/org/apache/mnemonic/GenericField.java | 78 ++++++++++----------
.../mnemonic/NonVolatileMemAllocator.java | 44 +++++------
.../java/org/apache/mnemonic/Persistence.java | 12 +--
.../org/apache/mnemonic/SysMemAllocator.java | 6 +-
.../apache/mnemonic/VolatileMemAllocator.java | 14 ++--
.../NonVolatileMemoryAllocatorService.java | 4 +-
.../memory/VolatileMemoryAllocatorService.java | 2 +-
.../memory/internal/JavaVMemServiceImpl.java | 2 +-
.../memory/internal/PMemServiceImpl.java | 6 +-
.../memory/internal/VMemServiceImpl.java | 2 +-
.../memory/internal/PMallocServiceImpl.java | 6 +-
.../memory/internal/SysVMemServiceImpl.java | 2 +-
22 files changed, 134 insertions(+), 134 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableArrayImpl.java
----------------------------------------------------------------------
diff --git a/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableArrayImpl.java b/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableArrayImpl.java
index a330937..549ad3b 100644
--- a/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableArrayImpl.java
+++ b/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableArrayImpl.java
@@ -141,7 +141,7 @@ public class DurableArrayImpl<A extends RestorableAllocator<A>, E>
* sync. this object
*/
@Override
- public void sync() {
+ public void syncToVolatileMemory() {
}
@@ -149,7 +149,7 @@ public class DurableArrayImpl<A extends RestorableAllocator<A>, E>
* Make any cached changes to this object persistent.
*/
@Override
- public void persist() {
+ public void syncToNonVolatileMemory() {
}
@@ -157,7 +157,7 @@ public class DurableArrayImpl<A extends RestorableAllocator<A>, E>
* flush processors cache for this object
*/
@Override
- public void flush() {
+ public void syncToLocal() {
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashMapImpl.java
----------------------------------------------------------------------
diff --git a/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashMapImpl.java b/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashMapImpl.java
index 048c1e8..a79e4f8 100644
--- a/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashMapImpl.java
+++ b/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashMapImpl.java
@@ -381,7 +381,7 @@ public class DurableHashMapImpl<A extends RestorableAllocator<A>, K, V>
* sync. this object
*/
@Override
- public void sync() {
+ public void syncToVolatileMemory() {
}
@@ -389,7 +389,7 @@ public class DurableHashMapImpl<A extends RestorableAllocator<A>, K, V>
* Make any cached changes to this object persistent.
*/
@Override
- public void persist() {
+ public void syncToNonVolatileMemory() {
}
@@ -397,7 +397,7 @@ public class DurableHashMapImpl<A extends RestorableAllocator<A>, K, V>
* flush processors cache for this object
*/
@Override
- public void flush() {
+ public void syncToLocal() {
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashSetImpl.java
----------------------------------------------------------------------
diff --git a/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashSetImpl.java b/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashSetImpl.java
index 3f38c88..8e84b77 100644
--- a/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashSetImpl.java
+++ b/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableHashSetImpl.java
@@ -99,7 +99,7 @@ public class DurableHashSetImpl<A extends RestorableAllocator<A>, E>
* sync. this object
*/
@Override
- public void sync() {
+ public void syncToVolatileMemory() {
}
@@ -107,7 +107,7 @@ public class DurableHashSetImpl<A extends RestorableAllocator<A>, E>
* Make any cached changes to this object persistent.
*/
@Override
- public void persist() {
+ public void syncToNonVolatileMemory() {
}
@@ -115,7 +115,7 @@ public class DurableHashSetImpl<A extends RestorableAllocator<A>, E>
* flush processors cache for this object
*/
@Override
- public void flush() {
+ public void syncToLocal() {
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableTreeImpl.java
----------------------------------------------------------------------
diff --git a/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableTreeImpl.java b/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableTreeImpl.java
index df709c1..a7359b0 100644
--- a/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableTreeImpl.java
+++ b/mnemonic-collections/src/main/java/org/apache/mnemonic/collections/DurableTreeImpl.java
@@ -497,7 +497,7 @@ public class DurableTreeImpl<A extends RestorableAllocator<A>, E extends Compara
* sync. this object
*/
@Override
- public void sync() {
+ public void syncToVolatileMemory() {
}
@@ -505,7 +505,7 @@ public class DurableTreeImpl<A extends RestorableAllocator<A>, E extends Compara
* Make any cached changes to this object persistent.
*/
@Override
- public void persist() {
+ public void syncToNonVolatileMemory() {
}
@@ -513,7 +513,7 @@ public class DurableTreeImpl<A extends RestorableAllocator<A>, E extends Compara
* flush processors cache for this object
*/
@Override
- public void flush() {
+ public void syncToLocal() {
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/Allocator.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/Allocator.java b/mnemonic-core/src/main/java/org/apache/mnemonic/Allocator.java
index 476b748..f69d49b 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/Allocator.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/Allocator.java
@@ -42,7 +42,7 @@ public interface Allocator<A extends CommonAllocator<A>> extends Allocatable<A>
* detect the length of this memory block
*
*/
- void sync(long addr, long length, boolean autodetect);
+ void syncToVolatileMemory(long addr, long length, boolean autodetect);
/**
* sync. a buffer to memory.
@@ -50,7 +50,7 @@ public interface Allocator<A extends CommonAllocator<A>> extends Allocatable<A>
* @param mbuf
* specify a buffer to be sync.
*/
- void sync(MemBufferHolder<A> mbuf);
+ void syncToVolatileMemory(MemBufferHolder<A> mbuf);
/**
* sync. a chunk to memory.
@@ -58,7 +58,7 @@ public interface Allocator<A extends CommonAllocator<A>> extends Allocatable<A>
* @param mchunk
* specify a chunk to be sync.
*/
- void sync(MemChunkHolder<A> mchunk);
+ void syncToVolatileMemory(MemChunkHolder<A> mchunk);
void syncAll();
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/AnnotatedDurableEntityClass.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/AnnotatedDurableEntityClass.java b/mnemonic-core/src/main/java/org/apache/mnemonic/AnnotatedDurableEntityClass.java
index 3c12463..bf49062 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/AnnotatedDurableEntityClass.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/AnnotatedDurableEntityClass.java
@@ -189,9 +189,9 @@ public class AnnotatedDurableEntityClass {
m_durablemtdinfo.put("getHandler", new ArrayList<MethodInfo>());
m_durablemtdinfo.put("autoReclaim", new ArrayList<MethodInfo>());
m_durablemtdinfo.put("destroy", new ArrayList<MethodInfo>());
- m_durablemtdinfo.put("sync", new ArrayList<MethodInfo>());
- m_durablemtdinfo.put("persist", new ArrayList<MethodInfo>());
- m_durablemtdinfo.put("flush", new ArrayList<MethodInfo>());
+ m_durablemtdinfo.put("syncToVolatileMemory", new ArrayList<MethodInfo>());
+ m_durablemtdinfo.put("syncToNonVolatileMemory", new ArrayList<MethodInfo>());
+ m_durablemtdinfo.put("syncToLocal", new ArrayList<MethodInfo>());
m_durablemtdinfo.put("getNativeFieldInfo", new ArrayList<MethodInfo>());
m_entitymtdinfo.put("initializeDurableEntity", new MethodInfo());
@@ -771,14 +771,14 @@ public class AnnotatedDurableEntityClass {
case "autoReclaim":
code.addStatement("return $1N", autoreclaimname);
break;
- case "sync":
- code.addStatement("$1N.sync()", holdername);
+ case "syncToVolatileMemory":
+ code.addStatement("$1N.syncToVolatileMemory()", holdername);
break;
- case "persist":
- code.addStatement("$1N.persist()", holdername);
+ case "syncToNonVolatileMemory":
+ code.addStatement("$1N.syncToNonVolatileMemory()", holdername);
break;
- case "flush":
- code.addStatement("$1N.flush()", holdername);
+ case "syncToLocal":
+ code.addStatement("$1N.syncToLocal()", holdername);
break;
case "destroy":
for (String fname : m_dynfieldsinfo.keySet()) {
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/ChunkBuffer.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/ChunkBuffer.java b/mnemonic-core/src/main/java/org/apache/mnemonic/ChunkBuffer.java
index f9e165b..6d79943 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/ChunkBuffer.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/ChunkBuffer.java
@@ -67,23 +67,23 @@ public class ChunkBuffer<A extends RetrievableAllocator<A>> {
return m_dchunk;
}
- public void persist() {
+ public void syncToNonVolatileMemory() {
if (m_dchunk.getAllocator() instanceof NonVolatileMemAllocator) {
NonVolatileMemAllocator alloc = (NonVolatileMemAllocator) m_dchunk.getAllocator();
- alloc.persist(m_dchunk.get() + m_offset, m_size, false);
+ alloc.syncToNonVolatileMemory(m_dchunk.get() + m_offset, m_size, false);
} else {
throw new UnsupportedOperationException("The ChunkBuffer does not backed by a non-volatile allocator");
}
}
- public void sync() {
- m_dchunk.getAllocator().sync(m_dchunk.get() + m_offset, m_size, false);
+ public void syncToVolatileMemory() {
+ m_dchunk.getAllocator().syncToVolatileMemory(m_dchunk.get() + m_offset, m_size, false);
}
- public void flush() {
+ public void syncToLocal() {
if (m_dchunk.getAllocator() instanceof NonVolatileMemAllocator) {
NonVolatileMemAllocator alloc = (NonVolatileMemAllocator) m_dchunk.getAllocator();
- alloc.flush(m_dchunk.get() + m_offset, m_size, false);
+ alloc.syncToLocal(m_dchunk.get() + m_offset, m_size, false);
} else {
throw new UnsupportedOperationException("The ChunkBuffer does not backed by a non-volatile allocator");
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/Durable.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/Durable.java b/mnemonic-core/src/main/java/org/apache/mnemonic/Durable.java
index f24735f..236d0f1 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/Durable.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/Durable.java
@@ -92,17 +92,17 @@ public interface Durable {
/**
* sync. this object
*/
- void sync();
+ void syncToVolatileMemory();
/**
* Make any cached changes to this object persistent.
*/
- void persist();
+ void syncToNonVolatileMemory();
/**
* flush processors cache for this object
*/
- void flush();
+ void syncToLocal();
/**
* manually destroy this object and release its memory resource
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/DurableBuffer.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/DurableBuffer.java b/mnemonic-core/src/main/java/org/apache/mnemonic/DurableBuffer.java
index dd2e0ee..27f4215 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/DurableBuffer.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/DurableBuffer.java
@@ -57,17 +57,17 @@ public class DurableBuffer<A extends RetrievableAllocator<A>> extends MemBufferH
* sync. this object
*/
@Override
- public void sync() {
- m_allocator.sync(this);
+ public void syncToVolatileMemory() {
+ m_allocator.syncToVolatileMemory(this);
}
/**
* Make any cached changes to this object persistent.
*/
@Override
- public void persist() {
+ public void syncToNonVolatileMemory() {
if (null != m_persistOps) {
- m_persistOps.persist(this);
+ m_persistOps.syncToNonVolatileMemory(this);
}
}
@@ -75,9 +75,9 @@ public class DurableBuffer<A extends RetrievableAllocator<A>> extends MemBufferH
* flush processors cache for this object
*/
@Override
- public void flush() {
+ public void syncToLocal() {
if (null != m_persistOps) {
- m_persistOps.flush(this);
+ m_persistOps.syncToLocal(this);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/DurableChunk.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/DurableChunk.java b/mnemonic-core/src/main/java/org/apache/mnemonic/DurableChunk.java
index e66c8a5..d1d6aac 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/DurableChunk.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/DurableChunk.java
@@ -55,17 +55,17 @@ public class DurableChunk<A extends RetrievableAllocator<A>> extends MemChunkHol
* sync. this object
*/
@Override
- public void sync() {
- m_allocator.sync(this);
+ public void syncToVolatileMemory() {
+ m_allocator.syncToVolatileMemory(this);
}
/**
* Make any cached changes to this object persistent.
*/
@Override
- public void persist() {
+ public void syncToNonVolatileMemory() {
if (null != m_persistOps) {
- m_persistOps.persist(this);
+ m_persistOps.syncToNonVolatileMemory(this);
}
}
@@ -73,9 +73,9 @@ public class DurableChunk<A extends RetrievableAllocator<A>> extends MemChunkHol
* flush processors cache for this object
*/
@Override
- public void flush() {
+ public void syncToLocal() {
if (null != m_persistOps) {
- m_persistOps.flush(this);
+ m_persistOps.syncToLocal(this);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/GenericField.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/GenericField.java b/mnemonic-core/src/main/java/org/apache/mnemonic/GenericField.java
index 6ca1921..bd6a61c 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/GenericField.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/GenericField.java
@@ -374,51 +374,51 @@ public class GenericField<A extends RestorableAllocator<A>, E> implements Durabl
* sync. this generic field
*/
@Override
- public void sync() {
+ public void syncToVolatileMemory() {
if (null != m_allocator) {
switch (m_dgftype) {
case BYTE:
- m_allocator.sync(m_fpos, Byte.BYTES, false);
+ m_allocator.syncToVolatileMemory(m_fpos, Byte.BYTES, false);
break;
case BOOLEAN:
- m_allocator.sync(m_fpos, Byte.BYTES, false);
+ m_allocator.syncToVolatileMemory(m_fpos, Byte.BYTES, false);
break;
case CHARACTER:
- m_allocator.sync(m_fpos, Character.BYTES, false);
+ m_allocator.syncToVolatileMemory(m_fpos, Character.BYTES, false);
break;
case SHORT:
- m_allocator.sync(m_fpos, Short.BYTES, false);
+ m_allocator.syncToVolatileMemory(m_fpos, Short.BYTES, false);
break;
case INTEGER:
- m_allocator.sync(m_fpos, Integer.BYTES, false);
+ m_allocator.syncToVolatileMemory(m_fpos, Integer.BYTES, false);
break;
case LONG:
- m_allocator.sync(m_fpos, Long.BYTES, false);
+ m_allocator.syncToVolatileMemory(m_fpos, Long.BYTES, false);
break;
case FLOAT:
- m_allocator.sync(m_fpos, Float.BYTES, false);
+ m_allocator.syncToVolatileMemory(m_fpos, Float.BYTES, false);
break;
case DOUBLE:
- m_allocator.sync(m_fpos, Double.BYTES, false);
+ m_allocator.syncToVolatileMemory(m_fpos, Double.BYTES, false);
break;
case STRING:
if (null != m_strfield) {
- m_strfield.sync();
+ m_strfield.syncToVolatileMemory();
}
break;
case DURABLE:
if (null != m_field) {
- m_field.sync();
+ m_field.syncToVolatileMemory();
}
break;
case CHUNK:
if (null != m_chunkfield) {
- m_chunkfield.sync();
+ m_chunkfield.syncToVolatileMemory();
}
break;
case BUFFER:
if (null != m_bufferfield) {
- m_bufferfield.sync();
+ m_bufferfield.syncToVolatileMemory();
}
break;
}
@@ -429,51 +429,51 @@ public class GenericField<A extends RestorableAllocator<A>, E> implements Durabl
* Make any cached changes to this generic field persistent.
*/
@Override
- public void persist() {
+ public void syncToNonVolatileMemory() {
if (null != m_persistOps) {
switch (m_dgftype) {
case BYTE:
- m_persistOps.persist(m_fpos, Byte.BYTES, false);
+ m_persistOps.syncToNonVolatileMemory(m_fpos, Byte.BYTES, false);
break;
case BOOLEAN:
- m_persistOps.persist(m_fpos, Byte.BYTES, false);
+ m_persistOps.syncToNonVolatileMemory(m_fpos, Byte.BYTES, false);
break;
case CHARACTER:
- m_persistOps.persist(m_fpos, Character.BYTES, false);
+ m_persistOps.syncToNonVolatileMemory(m_fpos, Character.BYTES, false);
break;
case SHORT:
- m_persistOps.persist(m_fpos, Short.BYTES, false);
+ m_persistOps.syncToNonVolatileMemory(m_fpos, Short.BYTES, false);
break;
case INTEGER:
- m_persistOps.persist(m_fpos, Integer.BYTES, false);
+ m_persistOps.syncToNonVolatileMemory(m_fpos, Integer.BYTES, false);
break;
case LONG:
- m_persistOps.persist(m_fpos, Long.BYTES, false);
+ m_persistOps.syncToNonVolatileMemory(m_fpos, Long.BYTES, false);
break;
case FLOAT:
- m_persistOps.persist(m_fpos, Float.BYTES, false);
+ m_persistOps.syncToNonVolatileMemory(m_fpos, Float.BYTES, false);
break;
case DOUBLE:
- m_persistOps.persist(m_fpos, Double.BYTES, false);
+ m_persistOps.syncToNonVolatileMemory(m_fpos, Double.BYTES, false);
break;
case STRING:
if (null != m_strfield) {
- m_strfield.persist();
+ m_strfield.syncToNonVolatileMemory();
}
break;
case DURABLE:
if (null != m_field) {
- m_field.persist();
+ m_field.syncToNonVolatileMemory();
}
break;
case CHUNK:
if (null != m_chunkfield) {
- m_chunkfield.persist();
+ m_chunkfield.syncToNonVolatileMemory();
}
break;
case BUFFER:
if (null != m_bufferfield) {
- m_bufferfield.persist();
+ m_bufferfield.syncToNonVolatileMemory();
}
break;
}
@@ -484,51 +484,51 @@ public class GenericField<A extends RestorableAllocator<A>, E> implements Durabl
* flush processors cache for this generic field
*/
@Override
- public void flush() {
+ public void syncToLocal() {
if (null != m_persistOps) {
switch (m_dgftype) {
case BYTE:
- m_persistOps.flush(m_fpos, Byte.BYTES, false);
+ m_persistOps.syncToLocal(m_fpos, Byte.BYTES, false);
break;
case BOOLEAN:
- m_persistOps.flush(m_fpos, Byte.BYTES, false);
+ m_persistOps.syncToLocal(m_fpos, Byte.BYTES, false);
break;
case CHARACTER:
- m_persistOps.flush(m_fpos, Character.BYTES, false);
+ m_persistOps.syncToLocal(m_fpos, Character.BYTES, false);
break;
case SHORT:
- m_persistOps.flush(m_fpos, Short.BYTES, false);
+ m_persistOps.syncToLocal(m_fpos, Short.BYTES, false);
break;
case INTEGER:
- m_persistOps.flush(m_fpos, Integer.BYTES, false);
+ m_persistOps.syncToLocal(m_fpos, Integer.BYTES, false);
break;
case LONG:
- m_persistOps.flush(m_fpos, Long.BYTES, false);
+ m_persistOps.syncToLocal(m_fpos, Long.BYTES, false);
break;
case FLOAT:
- m_persistOps.flush(m_fpos, Float.BYTES, false);
+ m_persistOps.syncToLocal(m_fpos, Float.BYTES, false);
break;
case DOUBLE:
- m_persistOps.flush(m_fpos, Double.BYTES, false);
+ m_persistOps.syncToLocal(m_fpos, Double.BYTES, false);
break;
case STRING:
if (null != m_strfield) {
- m_strfield.flush();
+ m_strfield.syncToLocal();
}
break;
case DURABLE:
if (null != m_field) {
- m_field.flush();
+ m_field.syncToLocal();
}
break;
case CHUNK:
if (null != m_chunkfield) {
- m_chunkfield.flush();
+ m_chunkfield.syncToLocal();
}
break;
case BUFFER:
if (null != m_bufferfield) {
- m_bufferfield.flush();
+ m_bufferfield.syncToLocal();
}
break;
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/NonVolatileMemAllocator.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/NonVolatileMemAllocator.java b/mnemonic-core/src/main/java/org/apache/mnemonic/NonVolatileMemAllocator.java
index bae656c..7b4757a 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/NonVolatileMemAllocator.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/NonVolatileMemAllocator.java
@@ -165,8 +165,8 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
*
*/
@Override
- public void sync(long addr, long length, boolean autodetect) {
- m_nvmasvc.sync(m_nid, addr, length, autodetect);
+ public void syncToVolatileMemory(long addr, long length, boolean autodetect) {
+ m_nvmasvc.syncToVolatileMemory(m_nid, addr, length, autodetect);
}
/**
@@ -413,8 +413,8 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
* specify a buffer to be sync.
*/
@Override
- public void sync(MemBufferHolder<NonVolatileMemAllocator> mbuf) {
- m_nvmasvc.sync(m_nid, getBufferAddress(mbuf), 0L, true);
+ public void syncToVolatileMemory(MemBufferHolder<NonVolatileMemAllocator> mbuf) {
+ m_nvmasvc.syncToVolatileMemory(m_nid, getBufferAddress(mbuf), 0L, true);
}
/**
@@ -424,8 +424,8 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
* specify a chunk to be sync.
*/
@Override
- public void sync(MemChunkHolder<NonVolatileMemAllocator> mchunk) {
- m_nvmasvc.sync(m_nid, getChunkAddress(mchunk), 0L, true);
+ public void syncToVolatileMemory(MemChunkHolder<NonVolatileMemAllocator> mchunk) {
+ m_nvmasvc.syncToVolatileMemory(m_nid, getChunkAddress(mchunk), 0L, true);
}
/**
@@ -433,7 +433,7 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
*/
@Override
public void syncAll() {
- m_nvmasvc.sync(m_nid, 0L, 0L, true);
+ m_nvmasvc.syncToVolatileMemory(m_nid, 0L, 0L, true);
}
/**
@@ -444,8 +444,8 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
* @param autodetect if NULL == address and autodetect : persist whole pool
*/
@Override
- public void persist(long addr, long length, boolean autodetect) {
- m_nvmasvc.persist(m_nid, addr, length, autodetect);
+ public void syncToNonVolatileMemory(long addr, long length, boolean autodetect) {
+ m_nvmasvc.syncToNonVolatileMemory(m_nid, addr, length, autodetect);
}
/**
@@ -456,8 +456,8 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
* @param autodetect if NULL == address and autodetect : flush whole pool
*/
@Override
- public void flush(long addr, long length, boolean autodetect) {
- m_nvmasvc.flush(m_nid, addr, length, autodetect);
+ public void syncToLocal(long addr, long length, boolean autodetect) {
+ m_nvmasvc.syncToLocal(m_nid, addr, length, autodetect);
}
/**
@@ -467,8 +467,8 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
* specify a buffer to be persisted
*/
@Override
- public void persist(MemBufferHolder<NonVolatileMemAllocator> mbuf) {
- m_nvmasvc.persist(m_nid, getBufferAddress(mbuf), 0L, true);
+ public void syncToNonVolatileMemory(MemBufferHolder<NonVolatileMemAllocator> mbuf) {
+ m_nvmasvc.syncToNonVolatileMemory(m_nid, getBufferAddress(mbuf), 0L, true);
}
/**
@@ -478,8 +478,8 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
* specify a chunk to be persisted
*/
@Override
- public void persist(MemChunkHolder<NonVolatileMemAllocator> mchunk) {
- m_nvmasvc.persist(m_nid, getChunkAddress(mchunk), 0L, true);
+ public void syncToNonVolatileMemory(MemChunkHolder<NonVolatileMemAllocator> mchunk) {
+ m_nvmasvc.syncToNonVolatileMemory(m_nid, getChunkAddress(mchunk), 0L, true);
}
/**
@@ -487,7 +487,7 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
*/
@Override
public void persistAll() {
- m_nvmasvc.persist(m_nid, 0L, 0L, true);
+ m_nvmasvc.syncToNonVolatileMemory(m_nid, 0L, 0L, true);
}
/**
@@ -497,8 +497,8 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
* specify a buffer to be flushed
*/
@Override
- public void flush(MemBufferHolder<NonVolatileMemAllocator> mbuf) {
- m_nvmasvc.flush(m_nid, getBufferAddress(mbuf), 0L, true);
+ public void syncToLocal(MemBufferHolder<NonVolatileMemAllocator> mbuf) {
+ m_nvmasvc.syncToLocal(m_nid, getBufferAddress(mbuf), 0L, true);
}
/**
@@ -508,8 +508,8 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
* specify a chunk to be flushed
*/
@Override
- public void flush(MemChunkHolder<NonVolatileMemAllocator> mchunk) {
- m_nvmasvc.flush(m_nid, getChunkAddress(mchunk), 0L, true);
+ public void syncToLocal(MemChunkHolder<NonVolatileMemAllocator> mchunk) {
+ m_nvmasvc.syncToLocal(m_nid, getChunkAddress(mchunk), 0L, true);
}
/**
@@ -517,7 +517,7 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
*/
@Override
public void flushAll() {
- m_nvmasvc.flush(m_nid, 0L, 0L, true);
+ m_nvmasvc.syncToLocal(m_nid, 0L, 0L, true);
}
/**
@@ -720,7 +720,7 @@ public class NonVolatileMemAllocator extends RestorableAllocator<NonVolatileMemA
/**
* Get a queryable object
- *
+ *f
* @return a queryable object
*/
Queryable useQuery() {
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/Persistence.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/Persistence.java b/mnemonic-core/src/main/java/org/apache/mnemonic/Persistence.java
index cc8af68..6a72a2a 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/Persistence.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/Persistence.java
@@ -34,7 +34,7 @@ public interface Persistence<A extends RetrievableAllocator<A>> {
* if NULL == address and autodetect : persist whole pool
* if 0L == length and autodetect : persist block
*/
- void persist(long addr, long length, boolean autodetect);
+ void syncToNonVolatileMemory(long addr, long length, boolean autodetect);
/**
* flush processors cache for a memory resource
@@ -49,7 +49,7 @@ public interface Persistence<A extends RetrievableAllocator<A>> {
* if NULL == address and autodetect : flush whole pool
* if 0L == length and autodetect : flush block
*/
- void flush(long addr, long length, boolean autodetect);
+ void syncToLocal(long addr, long length, boolean autodetect);
/**
* persist a buffer to persistent memory.
@@ -57,7 +57,7 @@ public interface Persistence<A extends RetrievableAllocator<A>> {
* @param mbuf
* specify a buffer to be persisted
*/
- void persist(MemBufferHolder<A> mbuf);
+ void syncToNonVolatileMemory(MemBufferHolder<A> mbuf);
/**
* persist a chunk to persistent memory.
@@ -65,7 +65,7 @@ public interface Persistence<A extends RetrievableAllocator<A>> {
* @param mchunk
* specify a chunk to be persisted
*/
- void persist(MemChunkHolder<A> mchunk);
+ void syncToNonVolatileMemory(MemChunkHolder<A> mchunk);
/**
* persist the memory pool to persistent memory.
@@ -78,7 +78,7 @@ public interface Persistence<A extends RetrievableAllocator<A>> {
* @param mbuf
* specify a buffer to be flushed
*/
- void flush(MemBufferHolder<A> mbuf);
+ void syncToLocal(MemBufferHolder<A> mbuf);
/**
* flush a chunk to persistent memory.
@@ -86,7 +86,7 @@ public interface Persistence<A extends RetrievableAllocator<A>> {
* @param mchunk
* specify a chunk to be flushed
*/
- void flush(MemChunkHolder<A> mchunk);
+ void syncToLocal(MemChunkHolder<A> mchunk);
/**
* flush the memory pool to persistent memory.
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/SysMemAllocator.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/SysMemAllocator.java b/mnemonic-core/src/main/java/org/apache/mnemonic/SysMemAllocator.java
index 286189d..5716ce4 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/SysMemAllocator.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/SysMemAllocator.java
@@ -169,7 +169,7 @@ public class SysMemAllocator extends CommonAllocator<SysMemAllocator> {
*
*/
@Override
- public void sync(long addr, long length, boolean autodetect) {
+ public void syncToVolatileMemory(long addr, long length, boolean autodetect) {
throw new UnsupportedOperationException("SysMemAllocator doesn't support sync");
}
@@ -179,7 +179,7 @@ public class SysMemAllocator extends CommonAllocator<SysMemAllocator> {
* @param mbuf specify a buffer to be sync.
*/
@Override
- public void sync(MemBufferHolder<SysMemAllocator> mbuf) {
+ public void syncToVolatileMemory(MemBufferHolder<SysMemAllocator> mbuf) {
throw new UnsupportedOperationException("SysMemAllocator doesn't support sync");
}
@@ -189,7 +189,7 @@ public class SysMemAllocator extends CommonAllocator<SysMemAllocator> {
* @param mchunk specify a chunk to be sync.
*/
@Override
- public void sync(MemChunkHolder<SysMemAllocator> mchunk) {
+ public void syncToVolatileMemory(MemChunkHolder<SysMemAllocator> mchunk) {
throw new UnsupportedOperationException("SysMemAllocator doesn't support sync");
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/VolatileMemAllocator.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/VolatileMemAllocator.java b/mnemonic-core/src/main/java/org/apache/mnemonic/VolatileMemAllocator.java
index a79e18a..44631b4 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/VolatileMemAllocator.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/VolatileMemAllocator.java
@@ -187,8 +187,8 @@ public class VolatileMemAllocator extends RestorableAllocator<VolatileMemAllocat
*
*/
@Override
- public void sync(long addr, long length, boolean autodetect) {
- m_vmasvc.sync(m_nid, addr, length, autodetect);
+ public void syncToVolatileMemory(long addr, long length, boolean autodetect) {
+ m_vmasvc.syncToVolatileMemory(m_nid, addr, length, autodetect);
}
/**
@@ -431,8 +431,8 @@ public class VolatileMemAllocator extends RestorableAllocator<VolatileMemAllocat
* specify a buffer to be sync.
*/
@Override
- public void sync(MemBufferHolder<VolatileMemAllocator> mbuf) {
- m_vmasvc.sync(m_nid, getBufferAddress(mbuf), 0L, true);
+ public void syncToVolatileMemory(MemBufferHolder<VolatileMemAllocator> mbuf) {
+ m_vmasvc.syncToVolatileMemory(m_nid, getBufferAddress(mbuf), 0L, true);
}
/**
@@ -442,8 +442,8 @@ public class VolatileMemAllocator extends RestorableAllocator<VolatileMemAllocat
* specify a chunk to be sync.
*/
@Override
- public void sync(MemChunkHolder<VolatileMemAllocator> mchunk) {
- m_vmasvc.sync(m_nid, getChunkAddress(mchunk), 0L, true);
+ public void syncToVolatileMemory(MemChunkHolder<VolatileMemAllocator> mchunk) {
+ m_vmasvc.syncToVolatileMemory(m_nid, getChunkAddress(mchunk), 0L, true);
}
/**
@@ -451,7 +451,7 @@ public class VolatileMemAllocator extends RestorableAllocator<VolatileMemAllocat
*/
@Override
public void syncAll() {
- m_vmasvc.sync(m_nid, 0L, 0L, true);
+ m_vmasvc.syncToVolatileMemory(m_nid, 0L, 0L, true);
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/NonVolatileMemoryAllocatorService.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/NonVolatileMemoryAllocatorService.java b/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/NonVolatileMemoryAllocatorService.java
index 73b9d30..4fcc64d 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/NonVolatileMemoryAllocatorService.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/NonVolatileMemoryAllocatorService.java
@@ -116,7 +116,7 @@ public interface NonVolatileMemoryAllocatorService extends VolatileMemoryAllocat
* if NULL == address and autodetect : persist whole pool
* if 0L == length and autodetect : persist block
*/
- void persist(long id, long addr, long length, boolean autodetect);
+ void syncToNonVolatileMemory(long id, long addr, long length, boolean autodetect);
/**
* flush processors cache for a memory resource
@@ -134,7 +134,7 @@ public interface NonVolatileMemoryAllocatorService extends VolatileMemoryAllocat
* if NULL == address and autodetect : flush whole pool
* if 0L == length and autodetect : flush block
*/
- void flush(long id, long addr, long length, boolean autodetect);
+ void syncToLocal(long id, long addr, long length, boolean autodetect);
/**
* wait for any memory resource stores to drain from HW buffers.
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/VolatileMemoryAllocatorService.java
----------------------------------------------------------------------
diff --git a/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/VolatileMemoryAllocatorService.java b/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/VolatileMemoryAllocatorService.java
index 72c53bc..c11385e 100644
--- a/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/VolatileMemoryAllocatorService.java
+++ b/mnemonic-core/src/main/java/org/apache/mnemonic/service/memory/VolatileMemoryAllocatorService.java
@@ -174,7 +174,7 @@ public interface VolatileMemoryAllocatorService extends QueryableService {
* if NULL == address and autodetect : sync. whole pool
* if 0L == length and autodetect : sync. block
*/
- void sync(long id, long addr, long length, boolean autodetect);
+ void syncToVolatileMemory(long id, long addr, long length, boolean autodetect);
/**
* get the capacity of its managed memory space
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-memory-services/mnemonic-java-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/JavaVMemServiceImpl.java
----------------------------------------------------------------------
diff --git a/mnemonic-memory-services/mnemonic-java-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/JavaVMemServiceImpl.java b/mnemonic-memory-services/mnemonic-java-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/JavaVMemServiceImpl.java
index d98d04b..4ee80c2 100644
--- a/mnemonic-memory-services/mnemonic-java-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/JavaVMemServiceImpl.java
+++ b/mnemonic-memory-services/mnemonic-java-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/JavaVMemServiceImpl.java
@@ -156,7 +156,7 @@ public class JavaVMemServiceImpl implements VolatileMemoryAllocatorService {
}
@Override
- public void sync(long id, long addr, long length, boolean autodetect) {
+ public void syncToVolatileMemory(long id, long addr, long length, boolean autodetect) {
throw new UnsupportedOperationException("Unsupported to synchronization operation");
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-memory-services/mnemonic-nvml-pmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMemServiceImpl.java
----------------------------------------------------------------------
diff --git a/mnemonic-memory-services/mnemonic-nvml-pmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMemServiceImpl.java b/mnemonic-memory-services/mnemonic-nvml-pmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMemServiceImpl.java
index ce61e90..701f969 100644
--- a/mnemonic-memory-services/mnemonic-nvml-pmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMemServiceImpl.java
+++ b/mnemonic-memory-services/mnemonic-nvml-pmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMemServiceImpl.java
@@ -59,7 +59,7 @@ public class PMemServiceImpl implements NonVolatileMemoryAllocatorService {
}
@Override
- public void sync(long id, long addr, long length, boolean autodetect) {
+ public void syncToVolatileMemory(long id, long addr, long length, boolean autodetect) {
nsync(id, addr, length, autodetect);
}
@@ -129,12 +129,12 @@ public class PMemServiceImpl implements NonVolatileMemoryAllocatorService {
}
@Override
- public void persist(long id, long addr, long length, boolean autodetect) {
+ public void syncToNonVolatileMemory(long id, long addr, long length, boolean autodetect) {
npersist(id, addr, length, autodetect);
}
@Override
- public void flush(long id, long addr, long length, boolean autodetect) {
+ public void syncToLocal(long id, long addr, long length, boolean autodetect) {
nflush(id, addr, length, autodetect);
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-memory-services/mnemonic-nvml-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/VMemServiceImpl.java
----------------------------------------------------------------------
diff --git a/mnemonic-memory-services/mnemonic-nvml-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/VMemServiceImpl.java b/mnemonic-memory-services/mnemonic-nvml-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/VMemServiceImpl.java
index eb823b3..a676053 100644
--- a/mnemonic-memory-services/mnemonic-nvml-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/VMemServiceImpl.java
+++ b/mnemonic-memory-services/mnemonic-nvml-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/VMemServiceImpl.java
@@ -66,7 +66,7 @@ public class VMemServiceImpl implements VolatileMemoryAllocatorService {
}
@Override
- public void sync(long id, long addr, long length, boolean autodetect) {
+ public void syncToVolatileMemory(long id, long addr, long length, boolean autodetect) {
nsync(id, addr, length, autodetect);
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-memory-services/mnemonic-pmalloc-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMallocServiceImpl.java
----------------------------------------------------------------------
diff --git a/mnemonic-memory-services/mnemonic-pmalloc-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMallocServiceImpl.java b/mnemonic-memory-services/mnemonic-pmalloc-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMallocServiceImpl.java
index b83d49c..8f250cf 100644
--- a/mnemonic-memory-services/mnemonic-pmalloc-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMallocServiceImpl.java
+++ b/mnemonic-memory-services/mnemonic-pmalloc-service/src/main/java/org/apache/mnemonic/service/memory/internal/PMallocServiceImpl.java
@@ -59,7 +59,7 @@ public class PMallocServiceImpl implements NonVolatileMemoryAllocatorService {
}
@Override
- public void sync(long id, long addr, long length, boolean autodetect) {
+ public void syncToVolatileMemory(long id, long addr, long length, boolean autodetect) {
nsync(id, addr, length, autodetect);
}
@@ -129,12 +129,12 @@ public class PMallocServiceImpl implements NonVolatileMemoryAllocatorService {
}
@Override
- public void persist(long id, long addr, long length, boolean autodetect) {
+ public void syncToNonVolatileMemory(long id, long addr, long length, boolean autodetect) {
npersist(id, addr, length, autodetect);
}
@Override
- public void flush(long id, long addr, long length, boolean autodetect) {
+ public void syncToLocal(long id, long addr, long length, boolean autodetect) {
nflush(id, addr, length, autodetect);
}
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/9cd39fc9/mnemonic-memory-services/mnemonic-sys-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/SysVMemServiceImpl.java
----------------------------------------------------------------------
diff --git a/mnemonic-memory-services/mnemonic-sys-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/SysVMemServiceImpl.java b/mnemonic-memory-services/mnemonic-sys-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/SysVMemServiceImpl.java
index 73a3e59..512a1fd 100644
--- a/mnemonic-memory-services/mnemonic-sys-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/SysVMemServiceImpl.java
+++ b/mnemonic-memory-services/mnemonic-sys-vmem-service/src/main/java/org/apache/mnemonic/service/memory/internal/SysVMemServiceImpl.java
@@ -66,7 +66,7 @@ public class SysVMemServiceImpl implements VolatileMemoryAllocatorService {
}
@Override
- public void sync(long id, long addr, long length, boolean autodetect) {
+ public void syncToVolatileMemory(long id, long addr, long length, boolean autodetect) {
nsync(id, addr, length, autodetect);
}