# HG changeset patch # User Nobuyasu Oshiro # Date 1391080942 -32400 # Node ID cd3b8cf7a3a1ff86125d64458d4c41b96735e453 # Parent 618adf0a9b2b09d44174d5083c2063484538af6b Added file for gnuplot diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/.DS_Store Binary file paper/.DS_Store has changed diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/chapter3.tex --- a/paper/chapter3.tex Thu Jan 30 16:15:32 2014 +0900 +++ b/paper/chapter3.tex Thu Jan 30 20:22:22 2014 +0900 @@ -104,8 +104,7 @@ public class TestCodeSegment extends CodeSegment { public Receiver arg1 = ids.create(CommandType.TAKE); - public TestCodeSegment() { - } + public TestCodeSegment() { } public void run() { int count = ds.asInteger(); @@ -126,6 +125,7 @@ \end{lstlisting} これは, 数字を1から10まで出力を行い終了するプログラムである. コードの説明を行う. +17行目から19行目の処理が最初に行われる. まずTestCodeSegmentというCodeSegmentのインスタンスcsを生成する. csはarg1というReceiverクラスのフィールドを保持しており, Receiverクラスは DataSegmentを受けとるためのクラスである. @@ -135,15 +135,16 @@ この場合は自分自身を表す"local"になる. データの登録は\verb|ods.update|により行える. -上記のコード20行目ではupdateにより"count"をキーとして数値の0を登録している. +上記のコード19行目ではupdateにより"count"をキーとして数値の0を登録している. updateがされるとcsの計算が始まり別スレッドにより8行目からの処理が行われる. updateによりキー"count"に登録された数値0はReceiverであるdsを使って取ることができる. -8行目から14行目では\verb|ds.asInteger()|により, "count"に登録したデータの中身を受け取りインクリメントし出力する. +7行目から13行目では\verb|ds.asInteger()|により, "count"に登録したデータの中身を受け取りインクリメントし出力する. そして最後には\verb|ods.update|を行っている. 新たなTestCodeSegmentも生成しており, これはインクリメントされた"count"がupdateされることで実行される. この一連の処理を"count"の数値が10以上になるまで行う. +DataSegmentへデータの追加とCodeSegmentの実行について表した図\ref{fig:testcodesegment}になる. \begin{figure}[htpb] \begin{center} \includegraphics[scale=0.70]{figures/testcodesegment.pdf} @@ -163,60 +164,94 @@ その時に実際に作られるトポロジーを図\ref{fig:remote_cs}に示す. \begin{figure}[htpb] \begin{center} - \includegraphics[scale=0.70]{figures/testcodesegment.pdf} + \includegraphics[scale=0.70]{figures/remote_codesegment.pdf} \caption{トポロジーの形成} \label{fig:remote_cs} \end{center} \end{figure} -このトポロジー上で, 標準入力より入力されたメッセージを他サーバノードに送信 -するプログラムを考える. -server node0, server node1, server node2 がそれぞれ接続しあっている. -矢印に付いている - -\begin{lstlisting}[frame=lrbt,label=src:,caption=メッセージを受け取り他のサーバに流すCodeSegment,numbers=left] -public class SendMessageCodeSegment extends CodeSegment { +ネットワークを介したDataSegmentへのアクセスはそのサーバノードを示す +文字列のキーを追加することで行える. +他サーバノードを示す文字列のキーとは図\ref{fig:remote_cs}に矢印の隣に書かれている文字列 +"parent", "child1", "child2" のことを指す. +例えば, server node0 が server node1のDataSegmentに入っている"count"というデータを +を使用したい場合は, 次のようにsetKeyを行えばよい（\ref{src:remote_cs1}）. +\begin{lstlisting}[frame=lrbt,label=src:remote_cs1,caption=CodeSegmentで他サーバノードのDataSegmentを使用する,numbers=left] +CodeSegment cs = new RemoteCodeSegment(); +cs.arg1.setKey("child1", "count"); +\end{lstlisting} +また, 他サーバノードのDataSegmentにデータを送りたい場合は, putを行うときにサーバノードへのキーを +追加すればよい. +例として, server node1やserver node2がserver node0のDataSegmentに"message"というキーでデータを追加したい場合 +次のようになる（\ref{src:remote_cs2}）. +\begin{lstlisting}[frame=lrbt,label=src:remote_cs2,caption=他サーバーノードのDatasSegmentにデータを追加する,numbers=left] +ods.put("parent", "message", "Hello parent"); +\end{lstlisting} - Receiver sendNodeList = ids.create(CommandType.PEEK); - public SendMessageCodeSegment() { - sendNodeList.setKey("_CLIST"); - } - @Override - public void run() { - @SuppressWarnings("unchecked") - List list = sendNodeList.asClass(List.class); - BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); - String message = null; - try { - System.out.println("Please enter your message"); - while((message = reader.readLine()) != null ) { - for(String node : list) { - ods.put(node, "message", message); - System.out.println("send message to "+node); - } - } catch (IOException e) { - e.printStackTrace(); - } +\subsection{独自クラスのインスタンスの送受信} +最後に, 独自クラスのインスタンスのDataSegmentでの扱い方について述べる. +AliceではMessagePackを用いてシリアライズを行い他サーバノードへと送信している. +MessagePackはクラス単位でシリアライズを行うことができる. +そのため, Aliceではプリミティブな型に限らずクラスのインスタンスをDataSegmentとして +扱うことができる. + +MessagePackによりシリアライズとなるクラスはいくつか制限がある. +それはそのクラスに@Messageアノテーションを付けることと, そのクラスが保持するフィールドが +MessagePackによりシリアライズ可能であることである. +例えば次のようなクラスである. +\begin{lstlisting}[frame=lrbt,label=src:msgpack1,caption=MessagePackによりシリアライズ可能なクラス1,numbers=left] +import org.msgpack.annotation.Message + +@Message +public class Student { + String name; + int age; } \end{lstlisting} +上記のStudenクラスはプリミティブ型しか保持していない. +そのためシリアライズが可能である +また, 次のようなクラスもシリアライズ可能な型となる. +\begin{lstlisting}[frame=lrbt,label=src:msgpack2,caption=MessagePackによりシリアライズ可能なクラス2,numbers=left] +import org.msgpack.annotation.Message -\begin{lstlisting}[frame=lrbt,label=src:,caption=,numbers=left] - +@Message +public class Class { + List studentList; +} \end{lstlisting} +この場合, フィールドはプリミティブな型でないStudentクラスのフィールドを保持している. +しかし, Studentクラスはシリアライズ可能な形で作成しているため, クラスのフィールドとして +保持しても問題はない. -\begin{lstlisting}[frame=lrbt,label=src:,caption=,numbers=left] +これらの制約にそった形で作成しDataSegmentにネットワークを介してクラスのインスタンス +をupdateすることができる. +DataSegmentから受け取ったデータはそのままではシリアライズされたものため, 一度手元で +元のクラスにコンバートすることで扱う. +例として, AliceにおけるStudenクラス(Listing\ref{src:msgpack1})のコンバートを次に示す. +\begin{lstlisting}[frame=lrbt,label=src:msgpack3,caption=DataSegment,numbers=left] +// public Receiver arg1 = ids.create(CommandType.PEEK); +Student s = arg1.asClass(Student.class); +\end{lstlisting} +MessagePackでシリアライズ可能な形としているためDataSegmentはネットワークを介して +送受信が可能である. -\end{lstlisting} + +\section{Aliceを用いたJungleの分散実装} +ここまでAliceを用いたプログラミングの方法について述べた. -\section{ログのシリアライズ} +\subsection{ログのシリアライズ} ここでログのシリアライズについて述べる. + シリアライズとは, データをネットワーク上に流しても良い形式に変換することである. - +\subsection{} +% TreeOperationLog に木の名前の情報がない +% そのため木の名前を追加して持たせた +% 木がなければそのばでつくるようにした \section{掲示板プログラムにおけるマージの実装} Jungle に分散実装を行った後の問題としてデータ衝突がある. diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/figures/distributed_read_bench.pdf Binary file paper/figures/distributed_read_bench.pdf has changed diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/figures/distributed_write_bench.pdf Binary file paper/figures/distributed_write_bench.pdf has changed diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/figures/remote_codesegment.pdf Binary file paper/figures/remote_codesegment.pdf has changed diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/figures/remote_codesegment.xbb --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/paper/figures/remote_codesegment.xbb Thu Jan 30 20:22:22 2014 +0900 @@ -0,0 +1,8 @@ +%%Title: ./figures/remote_codesegment.pdf +%%Creator: extractbb 20130405 +%%BoundingBox: 0 0 295 166 +%%HiResBoundingBox: 0.000000 0.000000 295.000000 166.000000 +%%PDFVersion: 1.3 +%%Pages: 1 +%%CreationDate: Thu Jan 30 16:46:19 2014 + diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/gnuplot/distributed_read_cassandra_one.dat --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/paper/gnuplot/distributed_read_cassandra_one.dat Thu Jan 30 20:22:22 2014 +0900 @@ -0,0 +1,3 @@ +10 12 +20 12 +30 20 \ No newline at end of file diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/gnuplot/distributed_read_cassandra_quorum.dat --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/paper/gnuplot/distributed_read_cassandra_quorum.dat Thu Jan 30 20:22:22 2014 +0900 @@ -0,0 +1,3 @@ +10 23 +20 29 +30 27 \ No newline at end of file diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/gnuplot/distributed_read_jungle.dat --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/paper/gnuplot/distributed_read_jungle.dat Thu Jan 30 20:22:22 2014 +0900 @@ -0,0 +1,3 @@ +10 9 +20 8 +30 10 \ No newline at end of file diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/gnuplot/distributed_write_cassandra_one.dat --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/paper/gnuplot/distributed_write_cassandra_one.dat Thu Jan 30 20:22:22 2014 +0900 @@ -0,0 +1,3 @@ +10 25 +20 24 +30 38 diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/gnuplot/distributed_write_cassandra_quorum.dat --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/paper/gnuplot/distributed_write_cassandra_quorum.dat Thu Jan 30 20:22:22 2014 +0900 @@ -0,0 +1,3 @@ +10 50 +20 82 +30 113 diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/gnuplot/distributed_write_jungle.dat --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/paper/gnuplot/distributed_write_jungle.dat Thu Jan 30 20:22:22 2014 +0900 @@ -0,0 +1,3 @@ +10 16 +20 18 +30 20 diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/gnuplot/makegraph_distributed_read.sh --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/paper/gnuplot/makegraph_distributed_read.sh Thu Jan 30 20:22:22 2014 +0900 @@ -0,0 +1,9 @@ +#!/bin/sh +gnuplot << EOF +set terminal postscript eps +set output 'distributed_read_bench.eps' +set title 'distributed read benchmark (Requests : clients * 50,000)' +set xlabel 'number of nodes and clients' +set ylabel 'time(sec)' +plot 'distributed_read_jungle.dat' title 'Jungle' lt rgb "blue" with linespoints, 'distributed_read_cassandra_quorum.dat' title "Cassandra Consistency Level Quorum" lt rgb "red" with linespoints, 'distributed_read_cassandra_one.dat' title "Cassandra Consistency Level ONE" lt rgb "dark-red" with linespoints +EOF diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/gnuplot/makegraph_distributed_write.sh --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/paper/gnuplot/makegraph_distributed_write.sh Thu Jan 30 20:22:22 2014 +0900 @@ -0,0 +1,9 @@ +#!/bin/sh +gnuplot << EOF +set terminal postscript eps +set output 'distributed_write_bench.eps' +set title 'write benchmark (Requests : clients * 50,000)' +set xlabel 'number of nodes' +set ylabel 'time(sec)' +plot 'distributed_write_jungle.dat' title 'Jungle' lt rgb "blue" with linespoints, 'distributed_write_cassandra_quorum.dat' title "Cassandra Consistency Level Quorum" lt rgb "red" with linespoints,'distributed_write_cassandra_one.dat' title "Cassandra Consistency Level ONE" lt rgb "dark-red" with linespoints +EOF diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/graffle/remote_codesegment.graffle --- a/paper/graffle/remote_codesegment.graffle Thu Jan 30 16:15:32 2014 +0900 +++ b/paper/graffle/remote_codesegment.graffle Thu Jan 30 20:22:22 2014 +0900 @@ -133,7 +133,7 @@ Bounds - {{208.00003051757812, 224}, {75, 22}} + {{209.00003051757812, 224}, {75, 22}} Class ShapedGraphic ID @@ -517,7 +517,7 @@ MasterSheets ModificationDate - 2014-01-30 05:53:05 +0000 + 2014-01-30 07:54:48 +0000 Modifier Oshiro Nobuyasu NotesVisible diff -r 618adf0a9b2b -r cd3b8cf7a3a1 paper/master_paper.pdf Binary file paper/master_paper.pdf has changed