プロジェクト

全般

プロフィール

操作
リンクをコピー

バグ #3574

完了

Manager::getORB() 等のリファレンスカウントとownershipを整理する

n-ando さんが9年以上前に追加. 約9年前に更新.

ステータス:
終了
優先度:
通常
担当者:
n-ando
対象バージョン:
-
開始日:
2016/07/19
期日:
進捗率:

100%

予定工数:

説明

getORB(),getPOA(),getPOAManager() などはリファレンスカウントを増やさずに参照を返すため_varで受けるとオブジェクトが削除される問題。
CORBAのマナー的には、関数内でduplicateなどでリファレンスカウントを増やしownershipを保持したまま、参照を返すべき。

安藤様

宮本です。

direct接続したときに発生する不具合ですが、原因を特定できたのでご報告します。

まず原因箇所はOutPortBaseクラスのgetLocalInPort関数の以下の部分でした。

CORBA::ORB_var orb = RTC::Manager::instance().getORB();

PortableServer::POA_var poa = RTC::Manager::instance().getPOA();

この部分を以下のように修正したら不具合は発生しなくなりました。

CORBA::ORB_var orb = CORBA::ORB::_duplicate(RTC::Manager::instance().getORB());

PortableServer::POA_var poa = PortableServer::POA::_duplicate(RTC::Manager::instance().getPOA());

修正前のようにgetORB関数で取得したポインタをそのまま渡してしまうと、ORB_varのデストラクタでCORBA::release関数を呼び出してリファレンスカウントが1つ減ります。
つまりgetLocalInPort関数を呼び出すたびにリファレンスカウントが減ってしまうのが原因なので、_duplicate関数でリファレンスカウントを増やしてやれば不具合はなくなるはずです。

ソースコードを読んだ結果、以下の部分にも同様の記述があったので修正する必要があると思います。

・CORBA_SeqUtil.cppのrefToVstring関数
・CorbaNamingクラスのコンストラクタ

以上です。
操作
リンクをコピー
 #1

n-ando さんが9年以上前に更新

getORB()を利用している関数

CORBA_SeqUtil.h:    CORBA::ORB_ptr orb = ::RTC::Manager::instance().getORB();
CorbaPort.h:        CORBA::ORB_ptr orb = Manager::instance().getORB();
CorbaPort.h:        CORBA::ORB_ptr orb = Manager::instance().getORB();
CorbaPort.h:        CORBA::ORB_ptr orb = ::RTC::Manager::instance().getORB();
Manager.h:    CORBA::ORB_var getORB();
InPortCorbaCdrConsumer.cpp:    CORBA::ORB_ptr orb = RTC::Manager::instance().getORB();
InPortCorbaCdrConsumer.cpp:    CORBA::ORB_ptr orb = RTC::Manager::instance().getORB();
InPortCorbaCdrProvider.cpp:    CORBA::ORB_ptr orb = ::RTC::Manager::instance().getORB();
Manager.cpp:  CORBA::ORB_ptr Manager::getORB()
Manager.cpp:    RTC_TRACE(("Manager::getORB()"));
ManagerServant.cpp:        obj = m_mgr.getORB()->resolve_initial_references("omniINSPOA");
ManagerServant.cpp:        obj = m_mgr.getORB()->resolve_initial_references((char*)"omniINSPOA");
ManagerServant.cpp:        ior = m_mgr.getORB()->
ManagerServant.cpp:        mobj = m_mgr.getORB()->string_to_object(mgrloc.c_str());
ManagerServant.cpp:        ior = m_mgr.getORB()->object_to_string(RTM::Manager::_duplicate(mgr));
NamingManager.cpp:        ior = RTC::Manager::instance().getORB()->object_to_string(obj.in());
NamingManager.cpp:          getORB()->string_to_object(iorstr.c_str());
NamingManager.cpp:        ior = RTC::Manager::instance().getORB()->object_to_string(obj.in());
NamingManager.cpp:          getORB()->string_to_object(iorstr.c_str());
NamingManager.cpp:        ior = RTC::Manager::instance().getORB()->object_to_string(obj.in());
NamingManager.cpp:          getORB()->string_to_object(iorstr.c_str());
NamingManager.cpp:            orb = CORBA::ORB::_duplicate(m_manager->getORB());
OutPortBase.cpp:    CORBA::ORB_var orb = RTC::Manager::instance().getORB();
OutPortCorbaCdrConsumer.cpp:        CORBA::ORB_ptr orb = ::RTC::Manager::instance().getORB();
OutPortCorbaCdrConsumer.cpp:        CORBA::ORB_ptr orb = RTC::Manager::instance().getORB();
OutPortCorbaCdrProvider.cpp:    CORBA::ORB_ptr orb = ::RTC::Manager::instance().getORB();
RTObject.cpp:      m_pORB(CORBA::ORB::_duplicate(manager->getORB())),
RTObject.cpp:      m_portAdmin(manager->getORB(), manager->getPOA()),

getPOA()を利用している関数

CorbaPort.h:        m_oid = Manager::instance().getPOA()->servant_to_id(m_servant);
CorbaPort.h:              getPOA()->activate_object_with_id(m_oid, m_servant);
CorbaPort.h:        obj = Manager::instance().getPOA()->id_to_reference(m_oid);
CorbaPort.h:        m_oid = Manager::instance().getPOA()->servant_to_id(m_servant);
CorbaPort.h:              getPOA()->activate_object_with_id(m_oid, m_servant);
CorbaPort.h:            Manager::instance().getPOA()->deactivate_object(m_oid);
Manager.h:    PortableServer::POA_ptr getPOA();
Manager.h:    PortableServer::POAManager_ptr getPOAManager();
Manager.cpp:        if(CORBA::is_nil(this->getPOAManager()))
Manager.cpp:    this->getPOAManager()->activate();
Manager.cpp:  PortableServer::POA_ptr Manager::getPOA()
Manager.cpp:    RTC_TRACE(("Manager::getPOA()"));
Manager.cpp:  PortableServer::POAManager_ptr Manager::getPOAManager()
Manager.cpp:    RTC_TRACE(("Manager::getPOAManager()"));
OutPortBase.cpp:            PortableServer::POA_var poa = RTC::Manager::instance().getPOA();
RTObject.cpp:      m_pPOA(PortableServer::POA::_duplicate(manager->getPOA())),
RTObject.cpp:      m_portAdmin(manager->getORB(), manager->getPOA()),
RTObjectStateMachine.cpp:    PortableServer::POA_ptr poa = RTC::Manager::instance().getPOA();

getPOAManager()を利用している関数

Manager.h:    PortableServer::POAManager_ptr getPOAManager();
Manager.cpp:        if(CORBA::is_nil(this->getPOAManager()))
Manager.cpp:    this->getPOAManager()->activate();
Manager.cpp:  PortableServer::POAManager_ptr Manager::getPOAManager()
Manager.cpp:    RTC_TRACE(("Manager::getPOAManager()"));
操作
リンクをコピー
 #2

n-ando さんが9年以上前に更新

  • ステータス を 新規 から 解決 に変更
  • 進捗率 を 0 から 100 に変更

getORB, getPOA, getPOAManager の振る舞いを変更。すべて、内部で参照をduplicateすることにした。
加えて、theORB, thePOA, thePOAManager 関数を追加。これらはduplicateせずに参照を返すのみの関数。

操作
リンクをコピー
 #3

n-ando さんが約9年前に更新

  • ステータス を 解決 から 終了 に変更
操作
リンクをコピー

他の形式にエクスポート: Atom PDF