gr_sptr_magic.cc

这是用python语言写的一个数字广播的信号处理工具包。利用它

/* -*- c++ -*- */
/*
 * Copyright 2008 Free Software Foundation, Inc.
 * 
 * This file is part of GNU Radio
 * 
 * GNU Radio is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3, or (at your option)
 * any later version.
 * 
 * GNU Radio is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License along
 * with this program; if not, write to the Free Software Foundation, Inc.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include <gr_sptr_magic.h>
#include <gr_hier_block2.h>
#include <map>
#include <stdexcept>


#if 0
  #include <boost/thread.hpp>
  typedef boost::mutex			mutex;
  typedef boost::mutex::scoped_lock	scoped_lock;
#else
  #include <omnithread.h>
  typedef omni_mutex			mutex;
  typedef omni_mutex_lock		scoped_lock;
#endif

namespace gnuradio {

  static mutex		s_mutex;
  typedef std::map<gr_basic_block*, gr_basic_block_sptr> sptr_map;
  static sptr_map	s_map;

  void
  detail::sptr_magic::create_and_stash_initial_sptr(gr_hier_block2 *p)
  {
    gr_basic_block_sptr sptr(p);
    scoped_lock	l();
    s_map.insert(sptr_map::value_type(static_cast<gr_basic_block *>(p), sptr));
  }


  gr_basic_block_sptr 
  detail::sptr_magic::fetch_initial_sptr(gr_basic_block *p)
  {
    /*
     * If p isn't a subclass of gr_hier_block2, just create the
     * shared ptr and return it.
     */
    gr_hier_block2 *hb2 = dynamic_cast<gr_hier_block2 *>(p);
    if (!hb2){
      return gr_basic_block_sptr(p);
    }

    /*
     * p is a subclass of gr_hier_block2, thus we've already created the shared pointer
     * and stashed it away.  Fish it out and return it.
     */
    scoped_lock	l();
    sptr_map::iterator pos = s_map.find(static_cast<gr_basic_block *>(p));
    if (pos == s_map.end())
      throw std::invalid_argument("gr_sptr_magic: invalid pointer!");

    gr_basic_block_sptr sptr = pos->second;
    s_map.erase(pos);
    return sptr;
  }
};