public
void
run() {
Log.i(TAG,
"BEGIN mConnectedThread"
);
byte
[] buffer =
new
byte
[
1024
];
int
bytes;
int
check_bytes =
0
;
byte
[] buffer_b =
new
byte
[
1024
];
while
(
true
) {
try
{
bytes = mmInStream.read(buffer);
if
(bytes ==
1
)
{
System.arraycopy(buffer,
0
, buffer_b,
0
,
1
);
check_bytes =
1
;
}
else
{
if
(check_bytes==
1
)
{
System.arraycopy(buffer,
0
, buffer_b,
1
, bytes);
mHandler.obtainMessage(Sensor_mode.MESSAGE_READ, bytes+
1
, -
1
, buffer_b)
.sendToTarget();
check_bytes=
0
;
}
else
{
mHandler.obtainMessage(Sensor_mode.MESSAGE_READ, bytes, -
1
, buffer)
.sendToTarget();
}
}
}
catch
(IOException e) {
Log.e(TAG,
"disconnected"
, e);
connectionLost();
break
;
}
}
}