}
}
- // ログに送信メッセージを出力する
- dump_bytes(isDumpReceiveLog,"SEND[" + sendData.length + "] ", sendData);
+ if (isDumpReceiveLog)
+ {
+ // ログに送信メッセージを出力する
+ dump_bytes("SEND[" + sendData.length + "] ", sendData);
+ }
// (データを)送信
dos.write(sendData);
{
// ログに受信メッセージを出力する
Log.v(TAG, "receive_from_camera() : " + read_bytes + " bytes.");
- dump_bytes(isDumpReceiveLog, "RECV[" + receive_body.length + "] ", receive_body);
+ dump_bytes("RECV[" + receive_body.length + "] ", receive_body);
}
if (callback != null)
{
* デバッグ用:ログにバイト列を出力する
*
*/
- private void dump_bytes(boolean isDumpReceiveLog, String header, byte[] data)
+ private void dump_bytes(String header, byte[] data)
{
- if (!isDumpReceiveLog)
- {
- // 受信ログを出さない
- return;
- }
-
int index = 0;
StringBuffer message;
message = new StringBuffer();
import net.osdn.gokigen.a01d.camera.fujix.wrapper.command.messages.StartMessage3rd;
import net.osdn.gokigen.a01d.camera.fujix.wrapper.command.messages.StartMessage4th;
import net.osdn.gokigen.a01d.camera.fujix.wrapper.command.messages.StartMessage5th;
-import net.osdn.gokigen.a01d.camera.fujix.wrapper.command.messages.StartReceiveOnly;
-import net.osdn.gokigen.a01d.camera.fujix.wrapper.command.messages.StartReceiveOnly2;
import net.osdn.gokigen.a01d.camera.fujix.wrapper.command.messages.StatusRequestMessage;
-import net.osdn.gokigen.a01d.camera.fujix.wrapper.command.messages.StatusRequestReceive;
import net.osdn.gokigen.a01d.preference.IPreferencePropertyAccessor;
public class FujiXCameraConnectSequence implements Runnable, IFujiXCommandCallback
public static final int SEQ_QUERY_CAMERA_CAPABILITIES = 11;
public static final int SEQ_START_RECEIVE2 = 12;
-
-
private final Activity context;
private final ICameraConnection cameraConnection;
private final ICameraStatusReceiver cameraStatusReceiver;
public void receivedMessage(int id, byte[] rx_body)
{
//Log.v(TAG, "receivedMessage : " + id + "[" + rx_body.length + " bytes]");
- int bodyLength = 0;
+ //int bodyLength = 0;
switch (id)
{
case SEQ_REGISTRATION:
break;
case SEQ_STATUS_REQUEST:
- bodyLength = ((((int) rx_body[3]) & 0xff) << 24) + ((((int) rx_body[2]) & 0xff) << 16) + ((((int) rx_body[1]) & 0xff) << 8) + (((int) rx_body[0]) & 0xff);
-/*
- if ((rx_body[4] == (byte) 0x02)&&(bodyLength == rx_body.length))
- {
- //// 受信データが分割されている場合、、もう一度受信する
- Log.v(TAG, "] BODY : " + rx_body.length + " BodyLength : " + bodyLength + " [");
- commandIssuer.enqueueCommand(new StatusRequestReceive(this));
- }
- else
-*/
- {
- Log.v(TAG, "[ BODY : " + rx_body.length + " BodyLength : " + bodyLength + " ]");
- commandIssuer.enqueueCommand(new QueryCameraCapabilities(this));
- }
+ commandIssuer.enqueueCommand(new QueryCameraCapabilities(this));
break;
case SEQ_STATUS_REQUEST_RECEIVE:
break;
case SEQ_QUERY_CAMERA_CAPABILITIES:
- bodyLength = ((((int) rx_body[3]) & 0xff) << 24) + ((((int) rx_body[2]) & 0xff) << 16) + ((((int) rx_body[1]) & 0xff) << 8) + (((int) rx_body[0]) & 0xff);
-/*
- if ((rx_body[4] == (byte) 0x02)&&(bodyLength == rx_body.length))
- {
- //// 受信データが分割されている場合、、もう一度受信する
- Log.v(TAG, "> BODY : " + rx_body.length + " BodyLength : " + bodyLength + " <");
- commandIssuer.enqueueCommand(new StartReceiveOnly2(this));
- }
- else
-*/
- {
- Log.v(TAG, "< BODY : " + rx_body.length + " BodyLength : " + bodyLength + " >");
- commandIssuer.enqueueCommand(new CameraRemoteMessage(this));
- }
+ commandIssuer.enqueueCommand(new CameraRemoteMessage(this));
break;
case SEQ_START_RECEIVE2:
commandIssuer.enqueueCommand(new CameraRemoteMessage(this));
break;
case SEQ_CAMERA_REMOTE:
- connectFinished(rx_body);
+ connectFinished();
break;
default:
return (true);
}
- private void connectFinished(byte[] rx_body)
+
+ private void connectFinished()
{
try
{
e.printStackTrace();
}
}
-
}