43 #include "Teuchos_Assert.hpp" 44 #include "Teuchos_Exceptions.hpp" 65 RCPNodeInfo() : nodePtr(0) {}
67 : info(info_in), nodePtr(nodePtr_in)
74 typedef std::pair<const void*, RCPNodeInfo> VoidPtrNodeRCPInfoPair_t;
77 typedef std::multimap<const void*, RCPNodeInfo> rcp_node_list_t;
80 class RCPNodeInfoListPred {
82 bool operator()(
const rcp_node_list_t::value_type &v1,
83 const rcp_node_list_t::value_type &v2
87 return v1.second.nodePtr->insertion_number() < v2.second.nodePtr->insertion_number();
89 return v1.first < v2.first;
112 rcp_node_list_t*& rcp_node_list()
114 static rcp_node_list_t *s_rcp_node_list = 0;
122 return s_rcp_node_list;
126 bool& loc_isTracingActiveRCPNodes()
128 static bool s_loc_isTracingActiveRCPNodes =
129 #if defined(TEUCHOS_DEBUG) && defined(HAVE_TEUCHOS_DEBUG_RCP_NODE_TRACING) 135 return s_loc_isTracingActiveRCPNodes;
142 return s_loc_rcpNodeStatistics;
146 bool& loc_printRCPNodeStatisticsOnExit()
148 static bool s_loc_printRCPNodeStatisticsOnExit =
false;
149 return s_loc_printRCPNodeStatisticsOnExit;
168 const void* base_obj_map_key_void_ptr = rcp_node->get_base_obj_map_key_void_ptr();
169 if (base_obj_map_key_void_ptr)
170 return base_obj_map_key_void_ptr;
178 std::ostringstream oss;
180 <<
"RCPNode {address=" 183 <<
", base_obj_map_key_void_ptr=" << rcp_node->get_base_obj_map_key_void_ptr()
186 <<
", map_key_void_ptr=" << get_map_key_void_ptr(rcp_node)
189 <<
", insertionNumber="<< rcp_node->insertion_number()
207 void RCPNode::set_extra_data(
208 const any &extra_data,
const std::string& name
213 if(extra_data_map_==NULL) {
214 extra_data_map_ =
new extra_data_map_t;
216 const std::string type_and_name( extra_data.
typeName() + std::string(
":") + name );
217 extra_data_map_t::iterator itr = extra_data_map_->find(type_and_name);
220 (itr != extra_data_map_->end() && force_unique), std::invalid_argument
221 ,
"Error, the type:name pair \'" << type_and_name
222 <<
"\' already exists and force_unique==true!" );
224 if (itr != extra_data_map_->end()) {
226 itr->second = extra_data_entry_t(extra_data,destroy_when);
230 (*extra_data_map_)[type_and_name] =
231 extra_data_entry_t(extra_data,destroy_when);
236 any& RCPNode::get_extra_data(
const std::string& type_name,
const std::string& name )
240 extra_data_map_==NULL, std::invalid_argument
241 ,
"Error, no extra data has been set yet!" );
243 any *extra_data = get_optional_extra_data(type_name,name);
246 const std::string type_and_name( type_name + std::string(
":") + name );
248 extra_data == NULL, std::invalid_argument
249 ,
"Error, the type:name pair \'" << type_and_name <<
"\' is not found!" );
256 any* RCPNode::get_optional_extra_data(
const std::string& type_name,
257 const std::string& name )
259 if( extra_data_map_ == NULL )
return NULL;
260 const std::string type_and_name( type_name + std::string(
":") + name );
261 extra_data_map_t::iterator itr = extra_data_map_->find(type_and_name);
262 if(itr != extra_data_map_->end())
263 return &(*itr).second.extra_data;
268 void RCPNode::impl_pre_delete_extra_data()
271 extra_data_map_t::iterator itr = extra_data_map_->begin();
272 itr != extra_data_map_->end();
276 extra_data_map_t::value_type &entry = *itr;
277 if(entry.second.destroy_when == PRE_DESTROY)
278 entry.second.extra_data =
any();
291 bool RCPNodeTracer::isTracingActiveRCPNodes()
293 return loc_isTracingActiveRCPNodes();
297 #if defined(TEUCHOS_DEBUG) && !defined(HAVE_TEUCHOS_DEBUG_RCP_NODE_TRACING) 298 void RCPNodeTracer::setTracingActiveRCPNodes(
bool tracingActiveNodes)
300 loc_isTracingActiveRCPNodes() = tracingActiveNodes;
305 int RCPNodeTracer::numActiveRCPNodes()
309 return rcp_node_list()->size();
315 RCPNodeTracer::getRCPNodeStatistics()
317 return loc_rcpNodeStatistics();
320 void RCPNodeTracer::printRCPNodeStatistics(
325 <<
"\n*** RCPNode Tracing statistics:" 327 <<
"\n maxNumRCPNodes = "<<rcpNodeStatistics.maxNumRCPNodes
328 <<
"\n totalNumRCPNodeAllocations = "<<rcpNodeStatistics.totalNumRCPNodeAllocations
329 <<
"\n totalNumRCPNodeDeletions = "<<rcpNodeStatistics.totalNumRCPNodeDeletions
334 void RCPNodeTracer::setPrintRCPNodeStatisticsOnExit(
335 bool printRCPNodeStatisticsOnExit)
337 loc_printRCPNodeStatisticsOnExit() = printRCPNodeStatisticsOnExit;
341 bool RCPNodeTracer::getPrintRCPNodeStatisticsOnExit()
343 return loc_printRCPNodeStatisticsOnExit();
347 void RCPNodeTracer::printActiveRCPNodes(std::ostream &out)
349 #ifdef TEUCHOS_SHOW_ACTIVE_REFCOUNTPTR_NODE_TRACE 351 <<
"\nCalled printActiveRCPNodes() :" 352 <<
" rcp_node_list.size() = " << rcp_node_list().size() <<
"\n";
353 #endif // TEUCHOS_SHOW_ACTIVE_REFCOUNTPTR_NODE_TRACE 354 if (loc_isTracingActiveRCPNodes()) {
356 if (rcp_node_list()->size() > 0) {
357 out << getActiveRCPNodeHeaderString();
362 typedef std::vector<VoidPtrNodeRCPInfoPair_t> rcp_node_vec_t;
363 rcp_node_vec_t rcp_node_vec(rcp_node_list()->begin(), rcp_node_list()->end());
364 std::sort(rcp_node_vec.begin(), rcp_node_vec.end(), RCPNodeInfoListPred());
366 typedef rcp_node_vec_t::const_iterator itr_t;
368 for ( itr_t itr = rcp_node_vec.begin(); itr != rcp_node_vec.end(); ++itr ) {
369 const rcp_node_list_t::value_type &entry = *itr;
373 << std::setw(3) << std::right << i << std::left
374 <<
": RCPNode (map_key_void_ptr=" << entry.first <<
")\n" 375 <<
" Information = " << entry.second.info <<
"\n" 376 <<
" RCPNode address = " << entry.second.nodePtr <<
"\n" 378 <<
" insertionNumber = " << entry.second.nodePtr->insertion_number()
384 << getCommonDebugNotesString();
393 void RCPNodeTracer::addNewRCPNode(
RCPNode* rcp_node,
const std::string &info )
397 static int insertionNumber = 0;
402 rcp_node->set_insertion_number(insertionNumber);
405 if (loc_isTracingActiveRCPNodes()) {
409 #ifdef RCP_NODE_DEBUG_TRACE_PRINT 411 <<
"RCPNodeTracer::addNewRCPNode(...): Adding " 412 << convertRCPNodeToString(rcp_node) <<
" ...\n";
417 const void *
const map_key_void_ptr = get_map_key_void_ptr(rcp_node);
420 typedef rcp_node_list_t::iterator itr_t;
421 typedef std::pair<itr_t, itr_t> itr_itr_t;
422 const itr_itr_t itr_itr = rcp_node_list()->equal_range(map_key_void_ptr);
423 const bool rcp_node_already_exists = itr_itr.first != itr_itr.second;
424 RCPNode *previous_rcp_node = 0;
425 bool previous_rcp_node_has_ownership =
false;
426 for (itr_t itr = itr_itr.first; itr != itr_itr.second; ++itr) {
427 previous_rcp_node = itr->second.nodePtr;
429 previous_rcp_node_has_ownership =
true;
434 rcp_node_already_exists && rcp_node->
has_ownership() && previous_rcp_node_has_ownership,
436 "RCPNodeTracer::addNewRCPNode(rcp_node): Error, the client is trying to create a new\n" 437 "RCPNode object to an existing managed object in another RCPNode:\n" 439 " New " << convertRCPNodeToString(rcp_node) <<
"\n" 441 " Existing " << convertRCPNodeToString(previous_rcp_node) <<
"\n" 443 " Number current nodes = " << rcp_node_list()->size() <<
"\n" 445 "This may indicate that the user might be trying to create a weak RCP to an existing\n" 446 "object but forgot make it non-ownning. Perhaps they meant to use rcpFromRef(...)\n" 447 "or an equivalent function?\n" 449 << getCommonDebugNotesString();
458 (*rcp_node_list()).insert(
460 std::make_pair(map_key_void_ptr, RCPNodeInfo(info, rcp_node))
469 ++loc_rcpNodeStatistics().totalNumRCPNodeAllocations;
470 loc_rcpNodeStatistics().maxNumRCPNodes =
471 TEUCHOS_MAX(loc_rcpNodeStatistics().maxNumRCPNodes, numActiveRCPNodes());
476 #define TEUCHOS_RCPNODE_REMOVE_RCPNODE(CONDITION, RCPNODE) \ 477 TEUCHOS_TEST_FOR_EXCEPTION((CONDITION), \ 479 "RCPNodeTracer::removeRCPNode(node_ptr): Error, the " \ 480 << convertRCPNodeToString(RCPNODE) << " is not found in the list of" \ 481 " active RCP nodes being traced even though all nodes should be traced." \ 482 " This should not be possible and can only be an internal programming error!") 485 void RCPNodeTracer::removeRCPNode(
RCPNode* rcp_node )
498 typedef rcp_node_list_t::iterator itr_t;
499 typedef std::pair<itr_t, itr_t> itr_itr_t;
501 const itr_itr_t itr_itr =
502 rcp_node_list()->equal_range(get_map_key_void_ptr(rcp_node));
503 const bool rcp_node_exists = itr_itr.first != itr_itr.second;
505 #ifdef HAVE_TEUCHOS_DEBUG_RCP_NODE_TRACING 509 TEUCHOS_RCPNODE_REMOVE_RCPNODE(!rcp_node_exists, rcp_node);
518 if (rcp_node_exists) {
519 #ifdef RCP_NODE_DEBUG_TRACE_PRINT 521 <<
"RCPNodeTracer::removeRCPNode(...): Removing " 522 << convertRCPNodeToString(rcp_node) <<
" ...\n";
524 bool foundRCPNode =
false;
525 for(itr_t itr = itr_itr.first; itr != itr_itr.second; ++itr) {
526 if (itr->second.nodePtr == rcp_node) {
527 rcp_node_list()->erase(itr);
528 ++loc_rcpNodeStatistics().totalNumRCPNodeDeletions;
534 TEUCHOS_RCPNODE_REMOVE_RCPNODE(!foundRCPNode, rcp_node);
540 RCPNode* RCPNodeTracer::getExistingRCPNodeGivenLookupKey(
const void* p)
542 typedef rcp_node_list_t::iterator itr_t;
543 typedef std::pair<itr_t, itr_t> itr_itr_t;
546 const itr_itr_t itr_itr = rcp_node_list()->equal_range(p);
547 for (itr_t itr = itr_itr.first; itr != itr_itr.second; ++itr) {
548 RCPNode* rcpNode = itr->second.nodePtr;
559 std::string RCPNodeTracer::getActiveRCPNodeHeaderString()
563 "\n*** Warning! The following Teuchos::RCPNode objects were created but have" 564 "\n*** not been destroyed yet. A memory checking tool may complain that these" 565 "\n*** objects are not destroyed correctly." 567 "\n*** There can be many possible reasons that this might occur including:" 569 "\n*** a) The program called abort() or exit() before main() was finished." 570 "\n*** All of the objects that would have been freed through destructors" 571 "\n*** are not freed but some compilers (e.g. GCC) will still call the" 572 "\n*** destructors on static objects (which is what causes this message" 573 "\n*** to be printed)." 575 "\n*** b) The program is using raw new/delete to manage some objects and" 576 "\n*** delete was not called correctly and the objects not deleted hold" 577 "\n*** other objects through reference-counted pointers." 579 "\n*** c) This may be an indication that these objects may be involved in" 580 "\n*** a circular dependency of reference-counted managed objects." 586 std::string RCPNodeTracer::getCommonDebugNotesString()
589 "NOTE: To debug issues, open a debugger, and set a break point in the function where\n" 590 "the RCPNode object is first created to determine the context where the object first\n" 591 "gets created. Each RCPNode object is given a unique insertionNumber to allow setting\n" 592 "breakpoints in the code. For example, in GDB one can perform:\n" 594 "1) Open the debugger (GDB) and run the program again to get updated object addresses\n" 596 "2) Set a breakpoint in the RCPNode insertion routine when the desired RCPNode is first\n" 597 "inserted. In GDB, to break when the RCPNode with insertionNumber==3 is added, do:\n" 599 " (gdb) b 'Teuchos::RCPNodeTracer::addNewRCPNode( [TAB] ' [ENTER]\n" 600 " (gdb) cond 1 insertionNumber==3 [ENTER]\n" 602 "3) Run the program in the debugger. In GDB, do:\n" 604 " (gdb) run [ENTER]\n" 606 "4) Examine the call stack when the program breaks in the function addNewRCPNode(...)\n" 616 ActiveRCPNodesSetup::ActiveRCPNodesSetup()
618 #ifdef TEUCHOS_SHOW_ACTIVE_REFCOUNTPTR_NODE_TRACE 619 std::cerr <<
"\nCalled ActiveRCPNodesSetup::ActiveRCPNodesSetup() : count = " << count_ <<
"\n";
620 #endif // TEUCHOS_SHOW_ACTIVE_REFCOUNTPTR_NODE_TRACE 621 if (!rcp_node_list())
622 rcp_node_list() =
new rcp_node_list_t;
627 ActiveRCPNodesSetup::~ActiveRCPNodesSetup()
629 #ifdef TEUCHOS_SHOW_ACTIVE_REFCOUNTPTR_NODE_TRACE 630 std::cerr <<
"\nCalled ActiveRCPNodesSetup::~ActiveRCPNodesSetup() : count = " << count_ <<
"\n";
631 #endif // TEUCHOS_SHOW_ACTIVE_REFCOUNTPTR_NODE_TRACE 632 if( --count_ == 0 ) {
633 #ifdef TEUCHOS_SHOW_ACTIVE_REFCOUNTPTR_NODE_TRACE 634 std::cerr <<
"\nPrint active nodes!\n";
635 #endif // TEUCHOS_SHOW_ACTIVE_REFCOUNTPTR_NODE_TRACE 636 std::cout << std::flush;
639 RCPNodeTracer::getRCPNodeStatistics();
640 if (rcpNodeStatistics.maxNumRCPNodes
641 && RCPNodeTracer::getPrintRCPNodeStatisticsOnExit())
643 RCPNodeTracer::printRCPNodeStatistics(rcpNodeStatistics, std::cout);
645 RCPNodeTracer::printActiveRCPNodes(std::cerr);
646 delete rcp_node_list();
659 int Teuchos::ActiveRCPNodesSetup::count_ = 0;
667 void RCPNodeHandle::unbindOne()
673 if (node_->strong_count()==1 && strength()==RCP_STRONG) {
685 local_activeRCPNodesSetup.foo();
686 RCPNodeTracer::removeRCPNode(node_);
690 if ( (node_->strong_count() + node_->weak_count()) == 1 ) {
701 node_->deincr_count(strength());
715 void Teuchos::throw_null_ptr_error(
const std::string &type_name )
719 type_name <<
" : You can not call operator->() or operator*()" 720 <<
" if getRawPtr()==0!" );
Null reference error exception class.
#define TEUCHOS_TEST_FOR_EXCEPTION(throw_exception_test, Exception, msg)
Macro for throwing an exception with breakpointing to ease debugging.
Modified boost::any class, which is a container for a templated value.
void has_ownership(bool has_ownership_in)
Node class to keep track of address and the reference count for a reference-counted utility class and...
virtual const std::string get_base_obj_type_name() const =0
The Teuchos namespace contains all of the classes, structs and enums used by Teuchos, as well as a number of utility routines.
EPrePostDestruction
Used to specify a pre or post destruction of extra data.
std::string typeName() const
Return the name of the type.
#define TEUCHOS_ASSERT(assertion_test)
This macro is throws when an assert fails.
Reference-counted pointer node classes.
Thrown if a duplicate owning RCP is creatd the the same object.
#define TEUCHOS_TEST_FOR_EXCEPT(throw_exception_test)
This macro is designed to be a short version of TEUCHOS_TEST_FOR_EXCEPTION() that is easier to call...