[BACK]Return to control.tex CVS log [TXT][DIR] Up to [local] / OpenXM / doc / OpenXM-specs

Annotation of OpenXM/doc/OpenXM-specs/control.tex, Revision 1.4

1.4     ! noro        1: %% $OpenXM: OpenXM/doc/OpenXM-specs/control.tex,v 1.3 2000/01/24 00:57:11 noro Exp $
1.2       noro        2: \section{Session Management}
1.1       noro        3:
1.2       noro        4: \subsection{Control server}
1.1       noro        5: /*&jp
1.2       noro        6: OpenXM では, 次に述べるような単純かつロバストなサーバの制御方法
                      7: を採用している.
                      8:
                      9: OpenXM サーバは論理的に 2 つの I/O channel をもつ: 一方は計算データ
                     10: 用であり, 他方は計算制御用である. 制御 channel はサーバを制御する
                     11: ためのコマンドを送るために使われる.
                     12: サンプルサーバ ({\tt oxmain.c}) では, そのようなコントロールメッセージ
                     13: は別のプロセスが行っている. 以下, そのプロセスをコントロールサーバ
                     14: と呼ぶ. これに対して, 計算用サーバをエンジンと呼ぶ.
                     15: コントロールサーバとエンジンは同一のマシン上で動作する.
                     16: このため, コントロールサーバからエンジンに signal を送ることは容易である.
                     17: コントロールサーバ自体も OX スタックマシンであり
                     18: {\tt SM\_control\_*} コマンドを受け取る. それらはエンジンへの
                     19: signal 送信, engine process の終了などの request のためのコマンドである.
                     20: */
                     21:
                     22: /*&eg
                     23: In OpenXM we adopted the following simple and robust method to
                     24: control servers.
                     25:
                     26: An OpenXM server has logically two I/O channels: one for exchanging
                     27: data for computations and the other for controlling computations. The
                     28: control channel is used to send commands to control execution on the
                     29: server. The sample server ({\tt oxmain.c}) processes such control
                     30: messages on another process. We call such a process a {\it
                     31: control server}. In contrast, we call a server for computation an {\it
                     32: engine}. As the control server and the engine runs on the
                     33: same machine, it is easy to send a signal from the control server.
                     34: A control server is also an
                     35: OpenXM stack machine and it accepts {\tt SM\_control\_*} commands
                     36: to send signals to a server or to terminate a server.
                     37: */
                     38:
                     39: \subsection{OpenXM reset protocol}
                     40:
                     41: /*&jp
                     42: クライアントはコントロールサーバ経由でいつでもエンジンに signal を
                     43: 送ることができる. しかし, I/O 操作は通常バッファリングされている
                     44: ため, トラブルが生ずる場合がある. エンジンを安全にリセットするため
                     45: 次が必要である.
                     46:
1.1       noro       47: \begin{enumerate}
1.2       noro       48: \item 全ての OX メッセージは Java の意味で synchronized object である.
                     49:
                     50: \item エンジンのリセット後に送られるクライアントからの計算要求メッセージと
                     51: エンジンからの返答が正しく対応していなければならない.
                     52: \end{enumerate}
                     53:
                     54: {\tt SM\_control\_reset\_connection} は, エンジンの安全なリセットを
                     55: 行う一連の手続きを開始するための SM コマンドである.
                     56: クライアントから {\tt SM\_control\_reset\_connection} がコントロール
                     57: サーバに送られると, コントロールサーバは {\tt SIGUSR1} をエンジンに
                     58: 送る. 以後の手続きは次の通りである.
                     59:
                     60: \vskip 2mm
                     61: \noindent
                     62: {\it クライアント側}
                     63: \begin{enumerate}
                     64: \item {\tt SM\_control\_reset\_connection} をコントロールサーバに
                     65: 送った後, クライアントはリセット状態に入る. リセット状態では,
                     66: {\tt OX\_SYNC\_BALL} を受け取るまですべてのメッセージを読みとばす.
                     67: \item {\tt OX\_SYNC\_BALL} を受け取ったあと, クライアントは
                     68: {\tt OX\_SYNC\_BALL} をエンジンに送り, 通常状態に戻る.
                     69: \end{enumerate}
                     70:
                     71: \noindent
                     72: {\it エンジン側}
                     73: \begin{enumerate}
                     74: \item
                     75: {\tt SIGUSR1} をコントロールサーバから受け取ったら, エンジンは
                     76: リセット状態に入る. {\tt OX\_SYNC\_BALL} をクライアントに送る.
                     77: この時点でクライアントは既にリセット状態にあるので, この送信が
                     78: ブロックされることはない.
                     79: \item エンジンは
                     80: {\tt OX\_SYNC\_BALL} を受け取るまですべてのメッセージを読みとばす.
                     81: {\tt OX\_SYNC\_BALL} を受け取ったら通常状態に戻る.
                     82: \end{enumerate}
                     83: */
                     84: /*&eg
                     85: A client can send a signal to an engine by using the control channel
                     86: at any time. However, I/O operations are usually buffered,
                     87: which may cause troubles.
                     88: To reset an engine safely the following are required.
                     89:
                     90: \begin{enumerate}
                     91: \item Any OX message must be a synchronized object in the sense of Java.
                     92:
                     93: \item After restarting an engine, a request from a client
                     94: must correctly corresponds to the response from the engine.
                     95: \end{enumerate}
                     96:
                     97: {\tt SM\_control\_reset\_connection} is a stack machine command to
                     98: initiate a safe resetting of an engine.
                     99: The control server sends {\tt SIGUSR1} to the engine if it receives
                    100: {\tt SM\_control\_reset\_connection} from the client.
                    101: Under the OpenXM reset protocol, an engine and a client act as follows.
                    102:
                    103: \vskip 2mm
                    104: \noindent
                    105: {\it Client side}
                    106: \begin{enumerate}
                    107: \item After sending {\tt SM\_control\_reset\_connection} to the
                    108: control server, the client enters the resetting state. It discards all {\tt
                    109: OX} messages from the engine until it receives {\tt OX\_SYNC\_BALL}.
                    110: \item After receiving {\tt OX\_SYNC\_BALL} the client sends
                    111: {\tt OX\_SYNC\_BALL} to the engine and returns to the usual state.
                    112: \end{enumerate}
                    113:
                    114: \noindent
                    115: {\it Engine side}
                    116: \begin{enumerate}
                    117: \item
                    118: After receiving {\tt SIGUSR1} from the control server,
                    119: the engine enters the resetting state.
                    120: The engine sends {\tt OX\_SYNC\_BALL} to the client.
                    121: The operation does not block because
                    122: the client is now in the resetting state.
                    123: \item The engine discards all OX messages from the engine until it
                    124: receives {\tt OX\_SYNC\_BALL}. After receiving {\tt OX\_SYNC\_BALL}
                    125: the engine returns to the usual state.
                    126: \end{enumerate}
                    127: */
                    128:
                    129: /*&eg
                    130: Figure \ref{reset} illustrates the flow of data.
                    131: {\tt OX\_SYNC\_BALL} is a special OX message and
                    132: is used to mark the end of data remaining in the
                    133: I/O streams. After reading it, it is assured that each stream is empty
                    134: and that the subsequent request from a client correctly
                    135: corresponds to the response from the engine.
                    136: */
                    137: /*&jp
                    138: 図 \ref{reset} はデータの流れを示す.
                    139: {\tt OX\_SYNC\_BALL} は特殊な OX メッセージであり,
                    140: I/O stream に残るデータの終りを示す.
                    141: {\tt OX\_SYNC\_BALL} を読んだ後, それぞれの stream は空であり,
                    142: 後に続くクライアントからのリクエストと, エンジンからの返答が
                    143: 正しく対応する.
                    144: */
1.3       noro      145: \begin{figure}[htbp]
                    146: \epsfxsize=12cm
                    147: \epsffile{reset.eps}
                    148: \caption{OpenXM reset procedure}
                    149: \label{reset}
                    150: \end{figure}
                    151:
1.2       noro      152: \subsection{Control message (SMObject/TCPIP/Control)}
                    153:
                    154: \begin{enumerate}
                    155: \item
                    156: \begin{verbatim}
                    157: SM_control_reset_connection
                    158: \end{verbatim}
                    159: /*&jp
                    160: コントロールサーバに, {\tt SIGUSR1} をエンジンに送るよう要求する.
                    161: */
                    162: /*&eg
                    163: It requests a control server to send {\tt SIGUSR1} to the engine.
                    164: The control server should immediately reply an acknowledgment to
                    165: the client.
                    166: */
                    167: Request:
1.1       noro      168: \begin{tabular}{|c|c|}  \hline
                    169: {\tt int32 OX\_COMMAND} & {\tt int32 SM\_control\_reset\_connection}  \\
                    170: \hline
                    171: \end{tabular}
1.2       noro      172: Result:
1.1       noro      173: \begin{tabular}{|c|c|}  \hline
                    174: {\tt int32 OX\_DATA} & {\tt CMO\_INT32} {\rm result} \\
                    175: \hline
                    176: \end{tabular}
                    177:
                    178: \item
1.2       noro      179: \begin{verbatim}
                    180: SM_control_kill
                    181: \end{verbatim}
                    182: /*&jp
                    183: サーバはこのメッセージを受信したら
                    184: %ただちに返答をおくり,
                    185: すべてのファイルをクローズして終了する.
                    186: */
                    187: /*&eg
                    188: It requests a control server to terminate the engine and the control server
                    189: itself.
                    190: %The control server should immediately reply an acknowledgment to
                    191: %the client.
                    192: All files and streams should be closed before the termination of servers.
                    193: */
                    194: Request:
1.1       noro      195: \begin{tabular}{|c|c|}  \hline
                    196: {\tt int32 OX\_COMMAND} & {\tt int32 SM\_control\_kill}  \\
                    197: \hline
1.4     ! noro      198: \end{tabular}\\
1.2       noro      199: Result: none.
1.1       noro      200: \end{enumerate}
                    201:
                    202: \medbreak
                    203: \noindent
1.2       noro      204: //&jp {\bf 例}: (シリアル番号は省略してある.)
                    205: //&eg {\bf Example}: (serial numbers are omitted.)
1.1       noro      206: \begin{verbatim}
                    207: 0  0 2 01 (OX_COMMAND)
                    208: 0  0 4 06 (SM_control_reset_connection)
                    209: \end{verbatim}
                    210:
1.2       noro      211: //&jp Reset に対する返事.
                    212: //&eg Reply to the reset request
1.1       noro      213: \begin{verbatim}
                    214: 0  0 2 02 (OX_DATA)
                    215: 0  0 0  2 (CMO_INT32)
                    216: 0  0 0  0 (  0   )
                    217: \end{verbatim}
                    218:
                    219:
1.2       noro      220: //&jp 第1のチャンネルでは次の {\tt OX\_SYNC\_BALL} が交換されて同期が取られる.
                    221: //&eg {\tt OX\_SYNC\_BALL} are exchanged on the data channel for synchronization.
                    222:
1.1       noro      223: \begin{verbatim}
                    224: 0   0   2   03   (OX_SYNC_BALL)
                    225: \end{verbatim}
                    226:
                    227:

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>