# HG changeset patch # User kazz # Date 1328679076 -32400 # Node ID 17f88fd202ae8c213539610fc09d76357b85595e # Parent 0c2ad7c70f4e5dd867a78cc9d0e6028ff9f91ac9 refactor data segment diff -r 0c2ad7c70f4e -r 17f88fd202ae src/alice/datasegment/DataSegmentManager.java --- a/src/alice/datasegment/DataSegmentManager.java Tue Feb 07 19:34:50 2012 +0900 +++ b/src/alice/datasegment/DataSegmentManager.java Wed Feb 08 14:31:16 2012 +0900 @@ -11,7 +11,6 @@ public abstract class DataSegmentManager { - protected ConcurrentHashMap dataSegments = new ConcurrentHashMap(); protected ConcurrentHashMap seqHash = new ConcurrentHashMap(); public LinkedBlockingQueue replyQueue = new LinkedBlockingQueue(); protected AtomicInteger seq = new AtomicInteger(1); diff -r 0c2ad7c70f4e -r 17f88fd202ae src/alice/datasegment/LocalDataSegmentManager.java --- a/src/alice/datasegment/LocalDataSegmentManager.java Tue Feb 07 19:34:50 2012 +0900 +++ b/src/alice/datasegment/LocalDataSegmentManager.java Wed Feb 08 14:31:16 2012 +0900 @@ -1,14 +1,16 @@ package alice.datasegment; +import java.util.concurrent.ConcurrentHashMap; + import org.apache.log4j.Logger; import org.msgpack.type.Value; import alice.codesegment.CodeSegment; -import alice.datasegment.CommandType; public class LocalDataSegmentManager extends DataSegmentManager { - public String reverseKey = "local"; + private String reverseKey = "local"; + private ConcurrentHashMap dataSegments = new ConcurrentHashMap(); private Logger logger = Logger.getLogger("local");