public class Rci.Invoker
extends java.lang.Object
implements java.lang.Runnable
修飾子とタイプ | フィールドと説明 |
---|---|
protected CryptFilter |
cryptFilter
暗号化するか平文にするかを判定するフィルター
|
protected java.io.DataInputStream |
dis |
protected java.io.DataOutputStream |
dos |
protected boolean |
isIncrementalSleep
待ち回数が増えるごとにスリープ時間を増やす(待ち回数をスリープ時間に掛ける)場合はtrue
(早い応答には速やかに対応し、遅い応答にはCPUをあまり使わないようにする。)
|
protected boolean |
isThreadRead |
protected java.util.LinkedList<Packet> |
list |
protected com.graveng.rci.client.DataReceivedListener |
listener |
protected long |
recvSleepMs
ミリ秒の応答待ち1回のスリープ時間
|
protected int |
recvSleepRetryCount
応答待ち繰り返し最大数(この数を超えるとTimeoutExceptionを投げる)
|
protected java.net.Socket |
socket |
コンストラクタと説明 |
---|
Invoker(java.net.Socket socket) |
修飾子とタイプ | メソッドと説明 |
---|---|
void |
close() |
com.graveng.rci.client.DataReceivedListener |
getListener() |
long |
getRecvSleepMs()
ミリ秒の応答待ち1回のスリープ時間を取得する。
|
int |
getRecvSleepRetryCount()
応答待ち繰り返し最大数を取得する。
|
protected void |
init() |
boolean |
isIncrementalSleep()
待ち回数が増えるごとにスリープ時間を増やすかを取得する。
|
boolean |
isThreadRead()
非同期通知に対応するためスレッドでソケットを読み込むかを取得する。
|
protected void |
recieved(Packet res) |
protected Packet |
recv() |
protected Packet |
recvBlock() |
protected Packet |
recvQueue() |
protected Packet |
recvQueue(long sleepTime,
int count,
boolean isIncrementalSleep) |
void |
run() |
protected void |
send(Packet req) |
void |
setIncrementalSleep(boolean isIncrementalSleep)
待ち回数が増えるごとにスリープ時間を増やすかを設定する。
|
void |
setListener(com.graveng.rci.client.DataReceivedListener listener) |
void |
setRecvSleepMs(long recvSleepMs)
ミリ秒の応答待ち1回のスリープ時間を設定する。
|
void |
setRecvSleepRetryCount(int recvSleepRetryCount)
応答待ち繰り返し最大数を設定する。
|
protected java.net.Socket socket
protected java.io.DataInputStream dis
protected java.io.DataOutputStream dos
protected java.util.LinkedList<Packet> list
protected com.graveng.rci.client.DataReceivedListener listener
protected boolean isThreadRead
protected long recvSleepMs
protected int recvSleepRetryCount
protected boolean isIncrementalSleep
protected CryptFilter cryptFilter
public long getRecvSleepMs()
public void setRecvSleepMs(long recvSleepMs)
recvSleepMs
- ミリ秒の応答待ち1回のスリープ時間public int getRecvSleepRetryCount()
public void setRecvSleepRetryCount(int recvSleepRetryCount)
recvSleepRetryCount
- 応答待ち繰り返し最大数public boolean isIncrementalSleep()
public void setIncrementalSleep(boolean isIncrementalSleep)
isIncrementalSleep
- 待ち回数が増えるごとにスリープ時間を増やすかpublic boolean isThreadRead()
public com.graveng.rci.client.DataReceivedListener getListener()
public void setListener(com.graveng.rci.client.DataReceivedListener listener)
public void close()
protected void init()
public void run()
run
インタフェース内 java.lang.Runnable
protected Packet recvQueue() throws java.io.IOException
java.io.IOException
protected Packet recvQueue(long sleepTime, int count, boolean isIncrementalSleep) throws java.io.IOException
java.io.IOException
protected void recieved(Packet res) throws java.io.IOException
java.io.IOException
protected Packet recvBlock() throws java.io.IOException
java.io.IOException
protected Packet recv() throws java.io.IOException
java.io.IOException
protected void send(Packet req) throws java.io.IOException
java.io.IOException