← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/protobuf_replicator/protobuf_replicator.cc

  • Committer: Jay Pipes
  • Date: 2009-04-10 05:31:39 UTC
  • mto: (971.1.47 mordred)
  • mto: This revision was merged to the branch mainline in revision 990.
  • Revision ID: jpipes@serialcoder-20090410053139-beat1rbcopkcgc4n
Changes libserialize to libdrizzledmessage per ML discussion.  All GPB messages are now in the drizzled::message namespace.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/protobuf_replicator/protobuf_replicator.cc
18
18
#include <drizzled/session.h>
19
19
#include <drizzled/error.h>
20
20
#include <drizzled/plugin/replicator.h>
21
 
#include <drizzled/serialize/serialize.h>
 
21
#include <drizzled/message/all.h>
22
22
 
23
23
#include <iostream>
24
24
#include <fstream>
29
29
static bool isEnabled;
30
30
static char *log_directory= NULL;
31
31
 
32
 
static bool write_to_disk(int file, drizzle::EventList *list)
 
32
static bool write_to_disk(int file, drizzled::message::EventList *list)
33
33
{
34
34
  string buffer;
35
35
  size_t length;
86
86
 
87
87
  virtual bool statement_hook(Session *session, const char *query, size_t)
88
88
  {
89
 
    using namespace drizzle;
 
89
    using namespace drizzled::message;
90
90
  
91
 
    drizzle::EventList list;
 
91
    drizzled::message::EventList list;
92
92
  
93
93
    if (isEnabled == false)
94
94
      return false;
95
95
    cerr << "Got into statement" <<endl;
96
96
  
97
 
    drizzle::Event *record= list.add_event();
 
97
    drizzled::message::Event *record= list.add_event();
98
98
    record->set_type(Event::DDL);
99
99
    record->set_autocommit(true);
100
100
    record->set_server_id("localhost");
108
108
  
109
109
  virtual bool session_init_hook(Session *session)
110
110
  {
111
 
    using namespace drizzle;
 
111
    using namespace drizzled::message;
112
112
  
113
113
    if (isEnabled == false)
114
114
      return false;
115
115
  
116
 
    drizzle::EventList *list= new drizzle::EventList;
 
116
    drizzled::message::EventList *list= new drizzled::message::EventList;
117
117
    session->setReplicationData(list);
118
118
  
119
 
    drizzle::Event *record= list->add_event();
 
119
    drizzled::message::Event *record= list->add_event();
120
120
  
121
121
    record->set_type(Event::DDL);
122
122
    record->set_autocommit(true);
131
131
  
132
132
  virtual bool row_insert_hook(Session *session, Table *)
133
133
  {
134
 
    using namespace drizzle;
 
134
    using namespace drizzled::message;
135
135
  
136
136
    if (isEnabled == false)
137
137
      return false;
138
138
  
139
 
    drizzle::EventList *list= (drizzle::EventList *)session->getReplicationData();
140
 
    drizzle::Event *record= list->add_event();
 
139
    drizzled::message::EventList *list= (drizzled::message::EventList *)session->getReplicationData();
 
140
    drizzled::message::Event *record= list->add_event();
141
141
  
142
142
    record->set_type(Event::INSERT);
143
143
    record->set_autocommit(true);
154
154
                               const unsigned char *, 
155
155
                               const unsigned char *)
156
156
  {
157
 
    using namespace drizzle;
 
157
    using namespace drizzled::message;
158
158
  
159
159
    if (isEnabled == false)
160
160
      return false;
161
161
  
162
 
    drizzle::EventList *list= (drizzle::EventList *)session->getReplicationData();
163
 
    drizzle::Event *record= list->add_event();
 
162
    drizzled::message::EventList *list= (drizzled::message::EventList *)session->getReplicationData();
 
163
    drizzled::message::Event *record= list->add_event();
164
164
  
165
165
    record->set_type(Event::UPDATE);
166
166
    record->set_autocommit(true);
175
175
  
176
176
  virtual bool row_delete_hook(Session *session, Table *)
177
177
  {
178
 
    using namespace drizzle;
 
178
    using namespace drizzled::message;
179
179
  
180
180
    if (isEnabled == false)
181
181
      return false;
182
182
  
183
 
    drizzle::EventList *list= (drizzle::EventList *)session->getReplicationData();
184
 
    drizzle::Event *record= list->add_event();
 
183
    drizzled::message::EventList *list= (drizzled::message::EventList *)session->getReplicationData();
 
184
    drizzled::message::Event *record= list->add_event();
185
185
  
186
186
    record->set_type(Event::DELETE);
187
187
    record->set_autocommit(true);
198
198
                                    bool autocommit, bool commit)
199
199
  {
200
200
    bool error;
201
 
    using namespace drizzle;
 
201
    using namespace drizzled::message;
202
202
  
203
203
    if (isEnabled == false)
204
204
      return false;
205
205
  
206
206
    cerr << "Got into end" <<endl;
207
207
  
208
 
    drizzle::EventList *list= (drizzle::EventList *)session->getReplicationData();
209
 
    drizzle::Event *record= list->add_event();
 
208
    drizzled::message::EventList *list= (drizzled::message::EventList *)session->getReplicationData();
 
209
    drizzled::message::Event *record= list->add_event();
210
210
  
211
211
    record->set_type(Event::DELETE);
212
212
    record->set_autocommit(true);