# HG changeset patch # User Shoshi TAMAKI # Date 1360322071 -32400 # Node ID 18c5cb49beca8e4da62aced06314bfc16a07b6b7 # Parent 4ff16d970ffc0f2dfc9d1cbc165cee4dfdea172d mark diff -r 4ff16d970ffc -r 18c5cb49beca src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/persistent/DefaultChangeListWriter.java --- a/src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/persistent/DefaultChangeListWriter.java Fri Feb 08 19:36:16 2013 +0900 +++ b/src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/persistent/DefaultChangeListWriter.java Fri Feb 08 20:14:31 2013 +0900 @@ -2,6 +2,10 @@ import java.nio.ByteBuffer; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; + public class DefaultChangeListWriter implements ChangeListWriter { public DefaultChangeListWriter(ByteBuffer _buf) @@ -10,8 +14,17 @@ } @Override - public Result write(ChangeList _operations) + public synchronized Result write(ChangeList _operations) { + for(TreeOperation op : _operations){ + ByteBuffer treeOpBuf = serializeTreeOperation(op); + } + return null; + } + + private ByteBuffer serializeTreeOperation(TreeOperation op) + { + return null; } } diff -r 4ff16d970ffc -r 18c5cb49beca src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/persistent/DefaultJournalWriter.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/persistent/DefaultJournalWriter.java Fri Feb 08 20:14:31 2013 +0900 @@ -0,0 +1,31 @@ +package jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent; + +import java.io.FileNotFoundException; +import java.io.IOException; +import java.io.RandomAccessFile; + +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either; + +public class DefaultJournalWriter +{ + public DefaultJournalWriter(String _fileName) + { + + } + + public static Either newInstance(String _fileName) + { + RandomAccessFile journal = null; + try{ + journal = new RandomAccessFile(_fileName,"rw"); + //FileChannel ch = journal.getChannel(); + long length = journal.length(); + }catch(FileNotFoundException _e){ + + }catch(IOException _e){ + + } + + return null; + } +}