← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/scheduling.cc

  • Committer: Brian Aker
  • Date: 2009-01-24 04:31:39 UTC
  • Revision ID: brian@gir-3.local-20090124043139-5cu9wjefszrnyhe0
Refactored all current scheduler to be behind scheduler plugin api.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/scheduling.cc
20
20
#include <drizzled/server_includes.h>
21
21
#include <drizzled/scheduling.h>
22
22
#include <drizzled/gettext.h>
 
23
#include <drizzled/scheduler.h>
 
24
 
 
25
extern scheduler_functions thread_scheduler;
23
26
 
24
27
int scheduling_initializer(st_plugin_int *plugin)
25
28
{
33
36
 
34
37
  if (plugin->plugin->init)
35
38
  {
36
 
    if (plugin->plugin->init((void *)p))
 
39
    if (plugin->plugin->init((void *)&thread_scheduler))
37
40
    {
38
 
      /* TRANSLATORS: The leading word "scheduling" is the name
39
 
         of the plugin api, and so should not be translated. */
 
41
      /* 
 
42
        TRANSLATORS> The leading word "scheduling" is the name
 
43
        of the plugin api, and so should not be translated. 
 
44
      */
40
45
      errmsg_printf(ERRMSG_LVL_ERROR, _("scheduling plugin '%s' init() failed"),
41
46
                      plugin->name.str);
42
47
      goto err;
68
73
 
69
74
  return 0;
70
75
}
71
 
 
72
 
/* The plugin_foreach() iterator requires that we
73
 
   convert all the parameters of a plugin api entry point
74
 
   into just one single void ptr, plus the session.
75
 
   So we will take all the additional paramters of scheduling_do1,
76
 
   and marshall them into a struct of this type, and
77
 
   then just pass in a pointer to it.
78
 
*/
79
 
typedef struct scheduling_do1_parms_st
80
 
{
81
 
  void *parm1;
82
 
  void *parm2;
83
 
} scheduling_do1_parms_t;
84
 
 
85
 
/* This gets called by plugin_foreach once for each loaded scheduling plugin */
86
 
static bool scheduling_do1_iterate (Session *session, plugin_ref plugin, void *p)
87
 
{
88
 
  scheduling_t *l= plugin_data(plugin, scheduling_t *);
89
 
  scheduling_do1_parms_t *parms= (scheduling_do1_parms_t *) p;
90
 
 
91
 
  /* call this loaded scheduling plugin's scheduling_func1 function pointer */
92
 
  if (l && l->scheduling_func1)
93
 
  {
94
 
    if (l->scheduling_func1(session, parms->parm1, parms->parm2))
95
 
    {
96
 
      /* TRANSLATORS: The leading word "scheduling" is the name
97
 
         of the plugin api, and so should not be translated. */
98
 
      errmsg_printf(ERRMSG_LVL_ERROR, _("scheduling plugin '%s' scheduling_func1() failed"),
99
 
                      (char *)plugin_name(plugin));
100
 
      return true;
101
 
    }
102
 
  }
103
 
  return false;
104
 
}
105
 
 
106
 
/* This is the scheduling_do1 entry point.
107
 
   This gets called by the rest of the Drizzle server code */
108
 
bool scheduling_do1 (Session *session, void *parm1, void *parm2)
109
 
{
110
 
  scheduling_do1_parms_t parms;
111
 
  bool foreach_rv;
112
 
 
113
 
  /* marshall the parameters so they will fit into the foreach */
114
 
  parms.parm1= parm1;
115
 
  parms.parm2= parm2;
116
 
 
117
 
  /* call scheduling_do1_iterate
118
 
     once for each loaded scheduling plugin */
119
 
  foreach_rv= plugin_foreach(session,
120
 
                             scheduling_do1_iterate,
121
 
                             DRIZZLE_SCHEDULING_PLUGIN,
122
 
                             (void *) &parms);
123
 
  return foreach_rv;
124
 
}
125
 
 
126
 
/* The plugin_foreach() iterator requires that we
127
 
   convert all the parameters of a plugin api entry point
128
 
   into just one single void ptr, plus the session.
129
 
   So we will take all the additional paramters of scheduling_do2,
130
 
   and marshall them into a struct of this type, and
131
 
   then just pass in a pointer to it.
132
 
*/
133
 
typedef struct scheduling_do2_parms_st
134
 
{
135
 
  void *parm3;
136
 
  void *parm4;
137
 
} scheduling_do2_parms_t;
138
 
 
139
 
/* This gets called by plugin_foreach once for each loaded scheduling plugin */
140
 
static bool scheduling_do2_iterate (Session *session, plugin_ref plugin, void *p)
141
 
{
142
 
  scheduling_t *l= plugin_data(plugin, scheduling_t *);
143
 
  scheduling_do2_parms_t *parms= (scheduling_do2_parms_t *) p;
144
 
 
145
 
  /* call this loaded scheduling plugin's scheduling_func1 function pointer */
146
 
  if (l && l->scheduling_func2)
147
 
  {
148
 
    if (l->scheduling_func2(session, parms->parm3, parms->parm4))
149
 
    {
150
 
      /* TRANSLATORS: The leading word "scheduling" is the name
151
 
         of the plugin api, and so should not be translated. */
152
 
      errmsg_printf(ERRMSG_LVL_ERROR, _("scheduling plugin '%s' scheduling_func2() failed"),
153
 
                      (char *)plugin_name(plugin));
154
 
 
155
 
      return true;
156
 
    }
157
 
  }
158
 
  return false;
159
 
}
160
 
 
161
 
/* This is the scheduling_do2 entry point.
162
 
   This gets called by the rest of the Drizzle server code */
163
 
bool scheduling_do2 (Session *session, void *parm3, void *parm4)
164
 
{
165
 
  scheduling_do2_parms_t parms;
166
 
  bool foreach_rv;
167
 
 
168
 
  /* marshall the parameters so they will fit into the foreach */
169
 
  parms.parm3= parm3;
170
 
  parms.parm4= parm4;
171
 
 
172
 
  /* call scheduling_do2_iterate
173
 
     once for each loaded scheduling plugin */
174
 
  foreach_rv= plugin_foreach(session,
175
 
                             scheduling_do2_iterate,
176
 
                             DRIZZLE_SCHEDULING_PLUGIN,
177
 
                             (void *) &parms);
178
 
  return foreach_rv;
179
 
}