← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/plugin/scheduler.cc

  • Committer: Stewart Smith
  • Date: 2009-10-08 06:16:39 UTC
  • mto: This revision was merged to the branch mainline in revision 1179.
  • Revision ID: stewart@flamingspork.com-20091008061639-p37e93j3h3hapwyj
don't even think of mucking around with opt_range.cc it burns like... burny things

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/plugin/scheduler.cc
17
17
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
18
18
 */
19
19
 
20
 
#include "config.h"
21
 
 
22
 
#include <algorithm>
23
 
 
 
20
#include "drizzled/server_includes.h"
24
21
#include "drizzled/plugin/scheduler.h"
 
22
#include "drizzled/plugin/registry.h"
25
23
 
26
24
#include "drizzled/gettext.h"
27
 
#include "drizzled/errmsg_print.h"
28
 
 
29
 
namespace drizzled
30
 
{
31
 
 
32
 
extern size_t my_thread_stack_size;
33
 
 
34
 
std::vector<plugin::Scheduler *> all_schedulers;
 
25
 
 
26
using namespace std;
 
27
 
 
28
using namespace drizzled;
 
29
 
 
30
vector<plugin::Scheduler *> all_schedulers;
35
31
 
36
32
/* Globals (TBK) */
37
33
static plugin::Scheduler *scheduler= NULL;
38
34
 
39
35
 
40
 
class FindSchedulerByName : public std::unary_function<plugin::Scheduler *, bool>
 
36
class FindSchedulerByName : public unary_function<plugin::Scheduler *, bool>
41
37
{
42
 
  const std::string *name;
 
38
  const string *name;
43
39
public:
44
 
  FindSchedulerByName(const std::string *name_arg)
 
40
  FindSchedulerByName(const string *name_arg)
45
41
    : name(name_arg) {}
46
42
  result_type operator() (argument_type sched)
47
43
  {
48
 
    return (bool)((name->compare(sched->getName()) == 0));
 
44
    return (bool)((name->compare(sched->name) == 0));
49
45
  }
50
46
};
51
47
 
52
48
 
53
49
bool plugin::Scheduler::addPlugin(plugin::Scheduler *sched)
54
50
{
55
 
  std::vector<plugin::Scheduler *>::iterator iter=
56
 
    std::find_if(all_schedulers.begin(), all_schedulers.end(), 
57
 
            FindSchedulerByName(&sched->getName()));
 
51
  vector<plugin::Scheduler *>::iterator iter=
 
52
    find_if(all_schedulers.begin(), all_schedulers.end(), 
 
53
            FindSchedulerByName(&sched->name));
58
54
 
59
55
  if (iter != all_schedulers.end())
60
56
  {
61
57
    errmsg_printf(ERRMSG_LVL_ERROR,
62
58
                  _("Attempted to register a scheduler %s, but a scheduler "
63
59
                    "has already been registered with that name.\n"),
64
 
                    sched->getName().c_str());
 
60
                    sched->name.c_str());
65
61
    return true;
66
62
  }
67
63
 
68
 
  sched->deactivate();
69
64
  all_schedulers.push_back(sched);
70
65
 
71
66
  return false;
74
69
 
75
70
void plugin::Scheduler::removePlugin(plugin::Scheduler *sched)
76
71
{
77
 
  all_schedulers.erase(std::find(all_schedulers.begin(),
 
72
  all_schedulers.erase(find(all_schedulers.begin(),
78
73
                            all_schedulers.end(),
79
74
                            sched));
80
75
}
81
76
 
82
77
 
83
 
bool plugin::Scheduler::setPlugin(const std::string& name)
 
78
bool plugin::Scheduler::setPlugin(const string& name)
84
79
{
85
 
  std::vector<plugin::Scheduler *>::iterator iter=
86
 
    std::find_if(all_schedulers.begin(), all_schedulers.end(), 
 
80
  vector<plugin::Scheduler *>::iterator iter=
 
81
    find_if(all_schedulers.begin(), all_schedulers.end(), 
87
82
            FindSchedulerByName(&name));
88
83
 
89
84
  if (iter != all_schedulers.end())
90
85
  {
91
 
    if (scheduler != NULL)
92
 
      scheduler->deactivate();
93
86
    scheduler= *iter;
94
 
    scheduler->activate();
 
87
 
95
88
    return false;
96
89
  }
97
90
 
106
99
{
107
100
  return scheduler;
108
101
}
109
 
 
110
 
} /* namespace drizzled */