llcoros.cpp
上传用户:king477883
上传日期:2021-03-01
资源大小:9553k
文件大小:5k
源码类别:

游戏引擎

开发平台:

C++ Builder

  1. /**
  2.  * @file   llcoros.cpp
  3.  * @author Nat Goodspeed
  4.  * @date   2009-06-03
  5.  * @brief  Implementation for llcoros.
  6.  * 
  7.  * $LicenseInfo:firstyear=2009&license=viewergpl$
  8.  * 
  9.  * Copyright (c) 2009-2010, Linden Research, Inc.
  10.  * 
  11.  * Second Life Viewer Source Code
  12.  * The source code in this file ("Source Code") is provided by Linden Lab
  13.  * to you under the terms of the GNU General Public License, version 2.0
  14.  * ("GPL"), unless you have obtained a separate licensing agreement
  15.  * ("Other License"), formally executed by you and Linden Lab.  Terms of
  16.  * the GPL can be found in doc/GPL-license.txt in this distribution, or
  17.  * online at http://secondlifegrid.net/programs/open_source/licensing/gplv2
  18.  * 
  19.  * There are special exceptions to the terms and conditions of the GPL as
  20.  * it is applied to this Source Code. View the full text of the exception
  21.  * in the file doc/FLOSS-exception.txt in this software distribution, or
  22.  * online at
  23.  * http://secondlifegrid.net/programs/open_source/licensing/flossexception
  24.  * 
  25.  * By copying, modifying or distributing this software, you acknowledge
  26.  * that you have read and understood your obligations described above,
  27.  * and agree to abide by those obligations.
  28.  * 
  29.  * ALL LINDEN LAB SOURCE CODE IS PROVIDED "AS IS." LINDEN LAB MAKES NO
  30.  * WARRANTIES, EXPRESS, IMPLIED OR OTHERWISE, REGARDING ITS ACCURACY,
  31.  * COMPLETENESS OR PERFORMANCE.
  32.  * $/LicenseInfo$
  33.  */
  34. // Precompiled header
  35. #include "linden_common.h"
  36. // associated header
  37. #include "llcoros.h"
  38. // STL headers
  39. // std headers
  40. // external library headers
  41. #include <boost/bind.hpp>
  42. // other Linden headers
  43. #include "llevents.h"
  44. #include "llerror.h"
  45. #include "stringize.h"
  46. LLCoros::LLCoros()
  47. {
  48.     // Register our cleanup() method for "mainloop" ticks
  49.     LLEventPumps::instance().obtain("mainloop").listen(
  50.         "LLCoros", boost::bind(&LLCoros::cleanup, this, _1));
  51. }
  52. bool LLCoros::cleanup(const LLSD&)
  53. {
  54.     // Walk the mCoros map, checking and removing completed coroutines.
  55.     for (CoroMap::iterator mi(mCoros.begin()), mend(mCoros.end()); mi != mend; )
  56.     {
  57.         // Has this coroutine exited (normal return, exception, exit() call)
  58.         // since last tick?
  59.         if (mi->second->exited())
  60.         {
  61.             LL_INFOS("LLCoros") << "LLCoros: cleaning up coroutine " << mi->first << LL_ENDL;
  62.             // The erase() call will invalidate its passed iterator value --
  63.             // so increment mi FIRST -- but pass its original value to
  64.             // erase(). This is what postincrement is all about.
  65.             mCoros.erase(mi++);
  66.         }
  67.         else
  68.         {
  69.             // Still live, just skip this entry as if incrementing at the top
  70.             // of the loop as usual.
  71.             ++mi;
  72.         }
  73.     }
  74.     return false;
  75. }
  76. std::string LLCoros::generateDistinctName(const std::string& prefix) const
  77. {
  78.     // Allowing empty name would make getName()'s not-found return ambiguous.
  79.     if (prefix.empty())
  80.     {
  81.         LL_ERRS("LLCoros") << "LLCoros::launch(): pass non-empty name string" << LL_ENDL;
  82.     }
  83.     // If the specified name isn't already in the map, just use that.
  84.     std::string name(prefix);
  85.     // Find the lowest numeric suffix that doesn't collide with an existing
  86.     // entry. Start with 2 just to make it more intuitive for any interested
  87.     // parties: e.g. "joe", "joe2", "joe3"...
  88.     for (int i = 2; ; name = STRINGIZE(prefix << i++))
  89.     {
  90.         if (mCoros.find(name) == mCoros.end())
  91.         {
  92.             LL_INFOS("LLCoros") << "LLCoros: launching coroutine " << name << LL_ENDL;
  93.             return name;
  94.         }
  95.     }
  96. }
  97. bool LLCoros::kill(const std::string& name)
  98. {
  99.     CoroMap::iterator found = mCoros.find(name);
  100.     if (found == mCoros.end())
  101.     {
  102.         return false;
  103.     }
  104.     // Because this is a boost::ptr_map, erasing the map entry also destroys
  105.     // the referenced heap object, in this case the boost::coroutine object,
  106.     // which will terminate the coroutine.
  107.     mCoros.erase(found);
  108.     return true;
  109. }
  110. std::string LLCoros::getNameByID(const void* self_id) const
  111. {
  112.     // Walk the existing coroutines, looking for one from which the 'self_id'
  113.     // passed to us comes.
  114.     for (CoroMap::const_iterator mi(mCoros.begin()), mend(mCoros.end()); mi != mend; ++mi)
  115.     {
  116.         namespace coro_private = boost::coroutines::detail;
  117.         if (static_cast<void*>(coro_private::coroutine_accessor::get_impl(const_cast<coro&>(*mi->second)).get())
  118.             == self_id)
  119.         {
  120.             return mi->first;
  121.         }
  122.     }
  123.     return "";
  124. }
  125. /*****************************************************************************
  126. *   MUST BE LAST
  127. *****************************************************************************/
  128. // Turn off MSVC optimizations for just LLCoros::launchImpl() -- see
  129. // DEV-32777. But MSVC doesn't support push/pop for optimization flags as it
  130. // does for warning suppression, and we really don't want to force
  131. // optimization ON for other code even in Debug or RelWithDebInfo builds.
  132. #if LL_MSVC
  133. // work around broken optimizations
  134. #pragma warning(disable: 4748)
  135. #pragma optimize("", off)
  136. #endif // LL_MSVC
  137. std::string LLCoros::launchImpl(const std::string& prefix, coro* newCoro)
  138. {
  139.     std::string name(generateDistinctName(prefix));
  140.     mCoros.insert(name, newCoro);
  141.     /* Run the coroutine until its first wait, then return here */
  142.     (*newCoro)(std::nothrow);
  143.     return name;
  144. }
  145. #if LL_MSVC
  146. // reenable optimizations
  147. #pragma optimize("", on)
  148. #endif // LL_MSVC