問題タブ [fifo]

名前付きパイプを使用して、デーモンとクライアント間の双方向通信をセットアップしようとしています。入力に使用される名前付きパイプを開こうとすると、コードがハングする なぜ?

2つの単方向FIFOを介してメッセージを送受信したい

データの流れ

境界構造化メッセージ mesg_len+mesg_type+mesg_data が必要です

この機能は、クライアントに指示する stdin でユーザーが「Knock Knock」を入力した場合、クライアントはこのメッセージを FIFO1 を介してサーバーに送信し、サーバーは文字列を比較し、「Knock Knock」と一致する場合、サーバーは「Who's there?」というメッセージを返信します。FIFO2 を介してクライアントに送信し、クライアントはこのメッセージを stdout に書き込みます。

インタラクティブな部分は次のようになります。

以下は私のコードです：

クライアントが "exit" を入力したときの kill() シグナルについて助けが必要です。だから私はctrl + cを入力して終了する必要があります

私を助けてください。どうもありがとう！

次のようにN行に制限されたテキストファイルの行に循環バッファを実装するPythonスクリプトが必要です。

最善の解決策は何ですか？

編集：このスクリプトは、最新のN行のみを含むテキストファイルを作成および維持する必要があります。次に、押し込まれた最初の行をポップする必要があります。FIFOバッファのように。

ディレクトリに、並べ替えられた gzip ファイルがいくつかあります。それらのいくつかを別のソートされたgzipファイルに結合するにはどうすればよいですか? 現在、明示的な fifo を使用しています。なしでbashでそれを行う方法はありますか? 私は少しバッシュ初心者なので、私のスタイルの欠如を許してください.

これを次のようなものに変換しようとしています...

...しかし、方法がわからない。パラメータを文字列に構築するループが必要ですか? これにはある種の魔法のシ​​ョートカットがありますか? たぶんmap gzcat $@？

注: 各ファイルは 10 GB を超えています (解凍すると 100 GB になります)。私は2TBのドライブを持っているので、これは実際には問題ではありません. また、このプログラムは O(n) で実行する必要があります。そうしないと実行できなくなります。

一定期間後にサーバー側からデータをプッシュするためにイベントソースRPCプラグを使用しています。200ミリ秒なので、クライアントリクエストは存在しません。したがって、サーバーは大量のデータを送信し（200ミリ秒は非常に高速です）、クライアント側のグラフにデータを表示するために（GChartを使用しています）、クライアント側にバッファー（FIFO）が必要です。クライアント側でスムーズに表示する必要があるため、データを保持して値（x、y）（x1、y1）（x2、y3）....（を表示するためにクライアント側にバッファーが必要です。 Xn、Yn）...グラフ内でFIFO方式でスムーズに実行され、クライアントのパフォーマンスに応じて200msの遅延を動的に調整し、サーバーに情報を送り返すことができます。

クライアントとサーバー間の通信は、以下のように人間の会話として書くことができます

クライアント：mrサーバーの速度を低下させます。あまり多くのデータを処理できず、FIFOバッファがいっぱいです。

サーバー：わかりました。遅延時間を200ミリ秒から500ミリ秒に変更していますが、実行するデータが少ない場合は、200ミリ秒というより速いムードにもう一度変更することをお知らせください。

クライアント：わかりました。バッファが空の高速データを送信します。

事前に感謝しますGwt、gchart、event-source

測定デバイスが存在しないかproc1 | proc2のように動作を変更することなく、パイプを流れるビットレートを正確に測定する方法はありますか? ティーのようなものは大丈夫ですか？私は欲しいですproc1 | tee proc2 > flow_measurement_thingかproc1 | tee flow_measurement_thing > proc2？私がパイプを正しく理解していれば、Unixパイプはデフォルトで4096バイトを噛むことができ、受信者が入ってくるのと同じくらい速くデータを読み取っていない場合、それらはブロックされる可能性があるため、測定デバイス自体が「層流」フロースルーを引き起こす可能性があるのではないかと心配しています.正しく実装しないと、パイプが「乱流」になります。

実際の使用例は python に接着されており、os からの名前付きパイプが使用されています。これは非常に単純化された例です。

簡単にするために、コンバーターがビットレートを変更しないと仮定してcapture | convert | /dev/null、同じレートでビットをポンピングしていることを確認できるようにしたいcapture | /dev/null

Go言語でUNIXFIFOを作成する方法はありますか？名前付きFIFOは主にposixOSで使用されると思いましたが、パッケージにはありませMkfifoん。実際、名前なしFIFO（パイプ）を作成する機能はありますが、名前付きパイプを作成する機能はありません。Mknodos

それらを必要としているのは私だけですか？

非ブロッキング/非同期の名前付きパイプまたはシェルで同様のものを作成する方法はありますか? プログラムが行を配置できるように、それらの行はRAMに留まり、一部のプログラムがパイプからいくつかの行を読み取ることができたときに、読み取らなかったものをFIFOに残しますか? また、プログラムがこの fifo に同時に書き込みと読み取りを行う可能性も非常に高くなります。最初はファイルを使用してこれを行うことができるかもしれませんが、Web を少し検索した後、ファイルが同時に読み書きされるという事実からは何も得られないようです。名前付きパイプはほとんど機能しますが、2 つの問題があります。1 つ目は、反対側に誰もいない場合に読み取り/書き込みをブロックすることです。各プロセスで1行を書き込もうとして、次に試してくださいhead -n 1 <fifo>必要に応じて 1 行だけ取​​得しますが、両方の書き込みプロセスが終了し、2 行目が失われます。助言がありますか？

編集:おそらく、これを支援するために、ライターとリーダーの間の仲介者のように機能する中間プログラムを使用できますか?

4 つの FIFO キューと、FIFO インデックスを検索するブロックを実装しました。空でない FIFO が見つかった場合は、データの末尾を抽出し、それをシリアルに送信します。

これはコードです：

いっぱいではなく、送信が実行されている 1 つのキューにデータを挿入するまでは、問題なく動作します。そのステップは省略されています。そのため、送信は機能しません。独立して活躍してほしい。

元 ：

Altium Designer Winter 09 で作業 (fpga でシミュレーションおよび実装)

同じ優先度の要素のFIFO順序を維持する優先度ブロックキューをJavaで作成しようとしています。Oracleのドキュメントはそれについていくらかの助けを提供します、しかし私はまだ非常に絡み合っています。

次のトピックはすべて私にとって非常に新しいものであることに注意してください：Generics、Interfaces as Types、およびstaticnestedclasses。これらはすべて、次のクラス定義で機能します。特にジェネリックは紛らわしいので、ここで完全に台無しにしたと思います。

現在発生しているコンパイラエラーを特定するためのコメントを含めました。

いくつかの具体的な質問：

1. クラスがキューに入れられたイベントオブジェクトを表し、実際のキューが静的クラスメンバーであっても大丈夫ですか？

2. OracleのFIFOイベント「ラッパー」を静的なネストされたクラスとして含めることは合理的でしたか？

3. 私は少なくともここで正しい方向に進んでおり、すべてを1つの外部クラスで行っていますか？

これが私が書いたクラスです：