InputStreamは取りこぼすことがあるのでしょうか？

Question

###InputStreamは取りこぼすことがあるのでしょうか？
InputStream は、以下のような処理でデータを取得すると思います。

while (true) {
    read = in.read(buf);
    if (read == -1) {
        break;
    }

    // 取得したデータを処理
}

シリアル通信(SPP)のデータ受信処理を作っているのですが、少し疑問に思うことがありました。

データ送信側が定期的にデータを送信(100ms毎など)している場合は、このループを回しっぱなしでエンドコードを受信するまでなど、役目を終えるまで処理すると思います。

上の例だと sleep() などのウエイトなしですが、これを sleep(1000) などデータ送信側の間隔より遅い待機時間になった場合は、データを取りこぼすことになるのでしょうか？
それとも、上記の例ですと10回分のデータは取りこぼすことなく取れるものなのでしょうか？

現在はウエイトなしで問題なくデータ受信はできているのですが、ノーウエイトでループするのもCPUの負担になると思ったのと、ウエイトを入れた時にデータを取りこぼすことがあるのだろうかと思ったので質問しました。

もしご存知の方がいらっしゃいましたら、教えていただけると助かります。

よろしくお願いします。

---

追加情報です。
データ送信側の情報を記載します。
(マニュアル記載のままです)

ボーレート	9600bps
データ	8bit
パリティ	なし
ストップ	1bit
フロー制御	なし

この装置と Android(OS 4.4.x) アプリを bluetooth で接続してデータを読み取る仕組みとなっています。

Android は、
android.bluetooth.BluetoothAdapter
android.bluetooth.BluetoothDevice
android.bluetooth.BluetoothSocket
を使ってます。

---

結論として、read() は...

• 適切な wait が入る(具体的な処理内容は調べてみます)
• バッファサイズから溢れない限り取りこぼすことはない(バッファサイズの調整方法は調べてみます)

ということなので、
ループ処理に Thread.sleep() などの処理は不要で、極度に小さいバッファサイズや、長時間かかる処理をしなければ、溢れることを心配する必要がない。
ということで理解しました。

いろいろ情報をいただき、ありがとうございました。
よろしくお願いします。

Comments

[szk.]

javaのInputStreamというよりはシリアル通信(SPP)の規格がどうかだと思います。タグ変えられたほうがいいかと。

[pectin]

ありがとうございます。タグを変更します。

[matobaa]

もうちょっと環境について補足ください。OSとかBluetoothライブラリとか速度とか

[Stripe]

read()メソッドで自動的にウエイトが掛かることはご存知ですか？

[pectin]

matobaa さん、環境について情報を追記しましたので、これらの情報でわかるようなことがありましたら、教えていただけると助かります。よろしくお願いします。

[pectin]

Stripe さん、自動的に wait がかかることは知りませんでした。詳細を教えていただくことはできますでしょうか？不勉強ですみませんが、よろしくお願いします。

Answer 1

シリアル通信は普通、データ受信時にバッファにためて、
利用側のソフトはバッファの中身を読み出します。
なのでバッファの容量を超えない限りは読み落としません。

Comments

[pectin]

ありがとうございます。
基本的にはバッファサイズを超えないタイミングで読み出すことで、取りこぼしなく読めるということなら安心しました。
バッファサイズは、in.read(buf) の引数 buf のサイズになるのでしょうか？
それとも read() が内部的に決めたサイズになるのでしょうか？
よろしくお願いします。

Answer 2

こんにちは。

受信のトリガーは何でしょう？
多分、受信イベントによる通知だと思うので、sleepは不要ですね。

また、「InputStreamでの取りこぼし」の表現はそぐわず、sppでどのようなインターフェーを用い、
どのようなシーケンスで行っているかの情報を提供した上で、そのシーケンスで取りこぼしの可能性があるか？という問いであれば、もっと目的に則した回答が得られるのではないかと思います。

追記2

上記部分は私の理解不足だったようです。
ロスを防ぐという意味で、Android Beamを利用して待ち受けが不要になる、
こちら（BTSSPを自力で作る～Android BeamからのBluetooth通信～）が参考にならないでしょうか？

追記1

気にしておられるのは送受信に伴うデータの欠損が起こりうるのかどうかなので、
送受信双方向でどのようなやり取りが行われるかを明らかにすると良いと言うことです。

InputStreamでデータを受け取る場合は、ファイル全体を取得し割り込みが入る余地がないので、
気にするポイントがズレているというのを言いたい訳です。

で、こちら（Bluetooth通信の主な処理のシーケンス図）のようなことについて、どんな具合で実装している（予定？）なんだろうかと。

Comments

[pectin]

不勉強な部分もあり、質問内容もわかりづらい点がある点については申し訳ありませんでした。
気がついた点については、随時編集しておりますので、もしその内容でわかるようなことがありましたら、教えていただけると助かります。
ありがとうございました。

[sazi]

追記しました

[pectin]

ありがとうございました。
・BluetoothAdapter.getBondedDevices() でペアリング済みの機器一覧を取得
・接続したい機器の BluetoothDevice を取得
・取得した BluetoothDevice を BluetoothSocket を使ってソケット接続
・接続したソケットの getInputStream() で接続先機器から送信されるデータを read() で読み出しています
よろしくお願いします。

[sazi]

追記しました

Answer 3

結論として、read() は...

適切な wait が入る(具体的な処理内容は調べてみます)
バッファサイズから溢れない限り取りこぼすことはない(バッファサイズの調整方法は調べてみます)
ということなので、
ループ処理に Thread.sleep() などの処理は不要で、極度に小さいバッファサイズや、長時間かかる処理をしなければ、溢れることを心配する必要がない。
ということで理解しました。

いろいろ情報をいただき、ありがとうございました。
よろしくお願いします。