~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/plugin/event_observer.cc

  • Committer: Lee Bieber
  • Date: 2011-03-23 01:55:35 UTC
  • mfrom: (2245.1.2 build)
  • Revision ID: kalebral@gmail.com-20110323015535-2aatqy8tyiuqtc2z
Merge Olaf - more code refactoring

Show diffs side-by-side

added added

removed removed

Lines of Context:
34
34
#include <drizzled/util/functors.h>
35
35
#include <algorithm>
36
36
 
37
 
 
38
 
 
39
 
namespace drizzled
40
 
{
41
 
 
42
 
namespace plugin
43
 
{
44
 
 
45
 
/*============================*/
46
 
  // Basic plugin registration stuff.
 
37
namespace drizzled {
 
38
namespace plugin {
 
39
 
47
40
  EventObserverVector all_event_plugins;
48
41
 
49
 
  const EventObserverVector &EventObserver::getEventObservers(void)
 
42
  const EventObserverVector &EventObserver::getEventObservers()
50
43
  {
51
44
    return all_event_plugins;
52
45
  }
53
46
 
54
 
  //---------
55
47
  bool EventObserver::addPlugin(EventObserver *handler)
56
48
  {
57
49
    if (handler != NULL)
59
51
    return false;
60
52
  }
61
53
 
62
 
  //---------
63
54
  void EventObserver::removePlugin(EventObserver *handler)
64
55
  {
65
56
    if (handler != NULL)
218
209
   if (all_event_plugins.empty())
219
210
      return;
220
211
 
221
 
    EventObserverList *observers;
222
 
 
223
 
    observers= table_share.getTableObservers();
 
212
    EventObserverList *observers= table_share.getTableObservers();
224
213
 
225
214
    if (observers) 
226
215
    {
262
251
  {
263
252
    if (all_event_plugins.empty())
264
253
      return;
265
 
 
266
 
    EventObserverList *observers;
267
 
 
268
 
    observers= session.getSchemaObservers(db);
269
 
 
 
254
    EventObserverList *observers= session.getSchemaObservers(db);
270
255
    if (observers == NULL) 
271
 
    {
272
 
      observers= new EventObserverList();
273
 
      session.setSchemaObservers(db, observers);
274
 
   }
 
256
      observers= session.setSchemaObservers(db, new EventObserverList());
275
257
 
276
258
    std::for_each(all_event_plugins.begin(), all_event_plugins.end(),
277
259
                  RegisterSchemaEventsIterate(db, *observers));