← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/plugin/transaction_applier.h

  • Committer: Padraig O'Sullivan
  • Date: 2009-12-17 04:48:59 UTC
  • mto: This revision was merged to the branch mainline in revision 1246.
  • Revision ID: osullivan.padraig@gmail.com-20091217044859-qorpkp4911zypfv3
Added some dtrace probes for tracing the optimizer.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/plugin/transaction_applier.h
1
1
/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
2
2
 *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
3
3
 *
4
 
 *  Copyright (C) 2008-2009 Sun Microsystems, Inc.
5
 
 *  Copyright (C) 2010 Jay Pipes
 
4
 *  Copyright (C) 2008-2009 Sun Microsystems
6
5
 *
7
6
 *  Authors:
8
7
 *
9
 
 *    Jay Pipes <jaypipes@gmail.com>
 
8
 *    Jay Pipes <joinfu@sun.com>
10
9
 *
11
10
 *  This program is free software; you can redistribute it and/or modify
12
11
 *  it under the terms of the GNU General Public License as published by
34
33
 */
35
34
 
36
35
#include "drizzled/plugin/plugin.h"
37
 
#include "drizzled/plugin/replication.h"
38
 
 
39
 
#include "drizzled/visibility.h"
 
36
#include "drizzled/atomics.h"
40
37
 
41
38
namespace drizzled
42
39
{
43
40
 
44
 
class Session;
45
 
 
46
41
namespace message { class Transaction; }
47
42
 
48
43
namespace plugin
51
46
/**
52
47
 * Base class for appliers of Transaction messages
53
48
 */
54
 
class DRIZZLED_API TransactionApplier : public Plugin
 
49
class TransactionApplier : public Plugin
55
50
{
56
51
  TransactionApplier();
57
52
  TransactionApplier(const TransactionApplier &);
58
53
  TransactionApplier& operator=(const TransactionApplier &);
 
54
  atomic<bool> is_enabled;
59
55
public:
60
56
  explicit TransactionApplier(std::string name_arg)
61
57
    : Plugin(name_arg, "TransactionApplier")
62
58
  {
 
59
    is_enabled= true;
63
60
  }
64
61
  virtual ~TransactionApplier() {}
65
62
  /**
77
74
   *
78
75
   * @param Transaction message to be replicated
79
76
   */
80
 
  virtual ReplicationReturnCode apply(Session &in_session,
81
 
                                      const message::Transaction &to_apply)= 0;
 
77
  virtual void apply(const message::Transaction &to_apply)= 0;
82
78
 
83
79
  static bool addPlugin(TransactionApplier *applier);
84
80
  static void removePlugin(TransactionApplier *applier);
 
81
  virtual bool isEnabled() const
 
82
  {
 
83
    return is_enabled;
 
84
  }
 
85
 
 
86
  virtual void enable()
 
87
  {
 
88
    is_enabled= true;
 
89
  }
 
90
 
 
91
  virtual void disable()
 
92
  {
 
93
    is_enabled= false;
 
94
  }
85
95
};
86
96
 
87
97
} /* namespace plugin */