問題タブ [pipelining]

C# Mono (Linux では Mono バージョン 3.12.1) サーバーでパイプライン化されたリクエストを処理する必要がありますが、パイプラインの 2 番目のリクエストが常に無視されることに気付きました。

パイプラインをテストするための netcat コマンドは次のとおりです。

httppipe.txt の内容は次のとおりです。

Java サーバーで正常にテストしたため、netcat のアプローチが機能すると確信しています。(つまり、私は 2 つの応答を見ました)

私の C# サーバーでは、GetResult と GetResultAsync の両方を試しました。GetResultAsync を使用したコードは、基本的に MSDN の例からそのまま引用されています。次のようになります。

編集：LinuxでMono 4.0でも試してみましたが、役に立ちませんでした。

次のコードは、C64x+ でコンパイルするとパイプライン化されません。

私の IDE (Code Composer v6) は、内側のループに対して次のメッセージを表示します。

問題はネストされたループにあるようですが、これほど単純なループの最適化に関する情報はこれ以上見つかりません。

誰かが以前に同様の問題を解決しましたか?

- 追加情報 -

• プロセッサー: TMS320C64x+

• コンパイラ: TI v8.0.3

• コンパイラ フラグ:-mv6400+ --abi=eabi -O3 --opt_for_speed=4 --include_path="D:/TI/ccsv6/tools/compiler/ti-cgt-c6000_8.0.3/include" --advice:performance -g --issue_remarks --verbose_diagnostics --diag_warning=225 --gen_func_subsections=on --debug_software_pipeline --gen_opt_info=2 --gen_profile_info -k --c_src_interlist --asm_listing --output_all_syms

• リンカ フラグ: -mv6400+ --abi=eabi -O3 --opt_for_speed=4 --advice:performance -g --issue_remarks --verbose_diagnostics --diag_warning=225 --gen_func_subsections=on --debug_software_pipeline --gen_opt_info=2 -- gen_profile_info -k --c_src_interlist --asm_listing --output_all_syms -z -m"dsp.map" -i"D:/TI/ccsv6/tools/compiler/ti-cgt-c6000_8.0.3/lib" -i"D: /TI/ccsv6/tools/compiler/ti-cgt-c6000_8.0.3/include" --reread_libs --warn_sections --xml_link_info="dsp_linkInfo.xml" --rom_model

と の 2 つの PowerShell プログラムを実行しているProducer.ps1としConsumer.ps1ます。

2 つのファイル間でクライアントとサーバーの関係を確立する方法はあります.ps1か?

具体的には、含まれるログイン情報をProducer.ps1出力します。2 つのオブジェクト間にリスナーと名前付きパイプPSObjectを確立して、これを直接 に渡す方法はありますか?PSObjectProducer.ps1Consumer.ps1

(注: 2 つのファイルは、それぞれ別の Windows ユーザーとして実行する必要があるため、組み合わせることはできません。通信するための 1 つの可能な解決策はPSObject、text/xml ファイルに書き込み、クライアントにそのファイルを読み取って消去させることですが、資格情報が公開されるので、私はむしろこれをしたくありません.私はあなたが持っているどんな提案にもオープンです)

私の DataFlow パイプラインは で始まり、BatchBlockいくつかのタスクがアイテムを this に投稿していBatchBlockます。これで、メソッドBatchBlockの助けを借りて、Timer に応じて次のブロックにデータが伝播されます。TriggerBatch()

この場合、作成時に提供された (非常に大きな) バッチ サイズのバッチはないと想定BatchBlockできます。つまり、トリガーされた各バッチのサイズが異なる可能性があります。

をトリガーする直前にBatchBlock、パイプラインの次のブロックに伝播しようとしているバッチに存在するすべての重複アイテムを削除したいと思います。それを行う方法はありますか？

SignalR の「Persistant Connections」について学び始めたばかりで、たとえば、事前にシリアル化された json を送信できることが好きです。

しかし、クライアントから送信し、サーバー側で受信してから再度応答を返すというこの方法は、少し直感に反しています。

ハブに頼らずに、「永続的な接続」の上にいくつかの単純な基本的なパイペラインを実行する方法はありますか?

次のようなことができるようになりたいだけです。

また、サーバーの OnReceived で例外がスローされた場合、どこに行くのでしょうか? SignalR に飲み込まれますか? ある種のエラーオブジェクトを自分でキャッチして送り返す必要がありますか?