清水先生

安藤です

ありがとうございます。
この辺はまだ枯れてないので、次のリリースでは対応
していきたいと思います。いただいたソースも参考にさせていただきます。
ちなみに、InPortのSingle Bufferモードに関しては、
InPortBase::init() で以下のようにコンポーネントコンフィグファイルで
プロパティを与えているので本当はここで指定できるべきなんです。

void InPortBase::init(coil::Properties& prop)
{
RTC_TRACE(("init()"));
m_properties << prop;
if (m_singlebuffer)
{
RTC_DEBUG(("single buffer mode."));
m_thebuffer = CdrBufferFactory::instance().createObject("ring_buffer");
// ここは本当は以下のようになるべき。
// m_thebuffer =
CdrBufferFactory::instance().createObject(prop["buffer_type"].c_str());

if (m_thebuffer == 0)
{
RTC_ERROR(("default buffer creation failed"));
}
}
else
{
RTC_DEBUG(("multi buffer mode."));
}

で、コンフィグファイルで
port.inport.dataport.buffer_type: mybuffer
とかやれば、自作のバッファが使えるのではないかと思います。（未検証ですが）
もし、こうなっていたら清水さんのやりたいことが実現できるのではないでしょうか？

もし追加で何か情報があれば教えていただければ幸いです。
よろしくお願いいたします。

2012年10月18日 14:01 Masayuki Shimizu :
> 安藤様
>
> 清水です。
>
>> ちなみに、OutPortのほうは大丈夫でしたでしょうか？
> いまは、データフローがpush型、パブリッシャがflushの場合のみを試しています。
> その場合、OutPortのバッファはデータ送受信に関係ないため問題にはなっていません。
>
> pull型の場合や、push型でもflush以外のパブリッシャだと
> OutPort側で問題が起きる可能性がありますが、そこは調べてはいません。
>
> ソースに手を入れないと解決できなさそうなので、
> InPortをマルチバッファモードに変更するソース改変を行い、
> 自作バッファを使用できるようにしました。
>
> 具体的には、InPortBaseにpublicインタフェースを追加し、
> コンポーネントのInPortオブジェクトからそれを呼び出すようにしました。
> 以下、InPortBaseの追加部分です。
> --------------------------------
> bool InPortBase::setSingleBufferMode()
> {
> if(m_singlebuffer) return true;
> if(m_thebuffer == 0){
> m_thebuffer = CdrBufferFactory::instance().createObject("ring_buffer");
> if (m_thebuffer == 0) return false;
> }
> m_singlebuffer = true;
> return true;
> }
>
> bool InPortBase::setMultiBufferMode()
> {
> if(!m_singlebuffer) return true;
> if(m_thebuffer != 0){
> CdrBufferFactory::instance().deleteObject(m_thebuffer);
> m_thebuffer = 0;
> }
> m_singlebuffer = false;
> return true;
> }
> --------------------------------------------------------
>
> 本当は、シングルバッファモードでも、バッファをユーザが
> 指定できるようにしたいのですが、
> バッファの指定は、connect()時にConnectorProfileで渡ってくるものなので、
> connect()が発行されるまではバッファの型はInPortBaseでは分かりません。
> そのため、ポート接続が無いときにバッファをどうするかの検討が必要そうです。
> # 今はオリジナルと同様にring_bufferを入れておくようにしてあります。
>
> 清水