disposer.C

/*
 * This file is part of the "Archon" framework.
 * (http://files3d.sourceforge.net)
 *
 * Copyright © 2002 by Kristian Spangsege and Brian Kristiansen.
 *
 * Permission to use, copy, modify, and distribute this software and
 * its documentation under the terms of the GNU General Public License is
 * hereby granted. No representations are made about the suitability of
 * this software for any purpose. It is provided "as is" without express
 * or implied warranty. See the GNU General Public License
 * (http://www.gnu.org/copyleft/gpl.html) for more details.
 *
 * The characters in this file are ISO8859-1 encoded.
 *
 * The documentation in this file is in "Doxygen" style
 * (http://www.doxygen.org).
 */

#include <iostream>

#include <archon/x3d/proxy/disposer.H>

namespace Archon
{
  namespace X3D
  {
    namespace Proxy
    {
      Disposer::Disposer(x3d::sai::Session_ptr ref):
        more(disposerMutex)
      {
        session = x3d::sai::Session::_duplicate(ref);
      }

      Disposer::~Disposer()
      {
      }

      void Disposer::addContext(unsigned long id, unsigned long transCount)
      {
        {
          Mutex::Lock l(disposerMutex);
          contexts.push_back(Entry(id, transCount));
        }
        more.notifyAll();
      }


      void Disposer::addNode(unsigned long id, unsigned long transCount)
      {
        {
          Mutex::Lock l(disposerMutex);
          nodes.push_back(Entry(id, transCount));
        }
        more.notifyAll();
      }

      void Disposer::main()
      {
        for(;;)
        {
          vector<Entry> c, n;
          {
            Mutex::Lock l(disposerMutex);
            while(!contexts.size() && !nodes.size()) more.wait();
            swap(contexts, c);
            swap(nodes, n);
          }

          x3d::sai::DisposeSeq cs(c.size());
          cs.length(c.size());
          for(unsigned i=0; i<c.size(); ++i)
          {
            Entry &e = c[i];
            x3d::sai::DisposeEntry &f = cs[i];
            f.id = e.id;
            f.transCount = e.transCount;
          }
        
          x3d::sai::DisposeSeq ns(n.size());
          ns.length(n.size());
          for(unsigned i=0; i<n.size(); ++i)
          {
            Entry &e = n[i];
            x3d::sai::DisposeEntry &f = ns[i];
            f.id = e.id;
            f.transCount = e.transCount;
          }

          session->disposeBatch(cs, ns);
        }
      }
    }
  }
}

---