← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/slave/queue_producer.cc

  • Committer: Mark Atwood
  • Date: 2011-11-30 07:06:47 UTC
  • mfrom: (2463.1.6 drizzle-include)
  • Revision ID: me@mark.atwood.name-20111130070647-ixp7oalp70hkbt6l
merge lp:~brianaker/drizzle/libdrizzle-2.0-not-install

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/slave/queue_producer.cc
18
18
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
19
19
 */
20
20
 
 
21
#include <config.h>
 
22
 
21
23
#include <plugin/slave/queue_producer.h>
22
24
#include <drizzled/errmsg_print.h>
23
25
#include <drizzled/sql/result_set.h>
133
135
 
134
136
bool QueueProducer::openConnection()
135
137
{
136
 
  if (drizzle_create(&_drizzle) == NULL)
137
 
  {
138
 
    _last_return= DRIZZLE_RETURN_INTERNAL_ERROR;
139
 
    _last_error_message= "Replication slave: ";
140
 
    _last_error_message.append(drizzle_error(&_drizzle));
141
 
    errmsg_printf(error::ERROR, _("%s"), _last_error_message.c_str());
142
 
    return false;
143
 
  }
144
 
  
145
 
  if (drizzle_con_create(&_drizzle, &_connection) == NULL)
146
 
  {
147
 
    _last_return= DRIZZLE_RETURN_INTERNAL_ERROR;
148
 
    _last_error_message= "Replication slave: ";
149
 
    _last_error_message.append(drizzle_error(&_drizzle));
150
 
    errmsg_printf(error::ERROR, _("%s"), _last_error_message.c_str());
151
 
    return false;
152
 
  }
153
 
  
154
 
  drizzle_con_set_tcp(&_connection, _master_host.c_str(), _master_port);
155
 
  drizzle_con_set_auth(&_connection, _master_user.c_str(), _master_pass.c_str());
 
138
  if ((_drizzle= drizzle_create()) == NULL)
 
139
  {
 
140
    _last_return= DRIZZLE_RETURN_INTERNAL_ERROR;
 
141
    _last_error_message= "Replication slave: ";
 
142
    _last_error_message.append(drizzle_error(_drizzle));
 
143
    errmsg_printf(error::ERROR, _("%s"), _last_error_message.c_str());
 
144
    return false;
 
145
  }
 
146
  
 
147
  if ((_connection= drizzle_con_create(_drizzle)) == NULL)
 
148
  {
 
149
    _last_return= DRIZZLE_RETURN_INTERNAL_ERROR;
 
150
    _last_error_message= "Replication slave: ";
 
151
    _last_error_message.append(drizzle_error(_drizzle));
 
152
    errmsg_printf(error::ERROR, _("%s"), _last_error_message.c_str());
 
153
    return false;
 
154
  }
 
155
  
 
156
  drizzle_con_set_tcp(_connection, _master_host.c_str(), _master_port);
 
157
  drizzle_con_set_auth(_connection, _master_user.c_str(), _master_pass.c_str());
156
158
 
157
 
  drizzle_return_t ret= drizzle_con_connect(&_connection);
 
159
  drizzle_return_t ret= drizzle_con_connect(_connection);
158
160
 
159
161
  if (ret != DRIZZLE_RETURN_OK)
160
162
  {
161
163
    _last_return= ret;
162
164
    _last_error_message= "Replication slave: ";
163
 
    _last_error_message.append(drizzle_error(&_drizzle));
 
165
    _last_error_message.append(drizzle_error(_drizzle));
164
166
    errmsg_printf(error::ERROR, _("%s"), _last_error_message.c_str());
165
167
    return false;
166
168
  }
177
179
 
178
180
  _is_connected= false;
179
181
 
180
 
  if (drizzle_quit(&_connection, &result, &ret) == NULL)
 
182
  if (drizzle_quit(_connection, &result, &ret) == NULL)
181
183
  {
182
184
    _last_return= ret;
183
185
    drizzle_result_free(&result);
246
248
 
247
249
  drizzle_return_t ret;
248
250
  drizzle_result_st result;
249
 
  drizzle_query_str(&_connection, &result, sql.c_str(), &ret);
 
251
  drizzle_query_str(_connection, &result, sql.c_str(), &ret);
250
252
  
251
253
  if (ret != DRIZZLE_RETURN_OK)
252
254
  {
253
255
    _last_return= ret;
254
256
    _last_error_message= "Replication slave: ";
255
 
    _last_error_message.append(drizzle_error(&_drizzle));
 
257
    _last_error_message.append(drizzle_error(_drizzle));
256
258
    errmsg_printf(error::ERROR, _("%s"), _last_error_message.c_str());
257
259
    drizzle_result_free(&result);
258
260
    return false;
264
266
  {
265
267
    _last_return= ret;
266
268
    _last_error_message= "Replication slave: ";
267
 
    _last_error_message.append(drizzle_error(&_drizzle));
 
269
    _last_error_message.append(drizzle_error(_drizzle));
268
270
    errmsg_printf(error::ERROR, _("%s"), _last_error_message.c_str());
269
271
    drizzle_result_free(&result);
270
272
    return false;
418
420
 
419
421
  drizzle_return_t ret;
420
422
  drizzle_result_st result;
421
 
  drizzle_query_str(&_connection, &result, sql.c_str(), &ret);
 
423
  drizzle_query_str(_connection, &result, sql.c_str(), &ret);
422
424
  
423
425
  if (ret != DRIZZLE_RETURN_OK)
424
426
  {
425
427
    _last_return= ret;
426
428
    _last_error_message= "Replication slave: ";
427
 
    _last_error_message.append(drizzle_error(&_drizzle));
 
429
    _last_error_message.append(drizzle_error(_drizzle));
428
430
    errmsg_printf(error::ERROR, _("%s"), _last_error_message.c_str());
429
431
    drizzle_result_free(&result);
430
432
    return ER_YES;
438
440
  {
439
441
    _last_return= ret;
440
442
    _last_error_message= "Replication slave: ";
441
 
    _last_error_message.append(drizzle_error(&_drizzle));
 
443
    _last_error_message.append(drizzle_error(_drizzle));
442
444
    errmsg_printf(error::ERROR, _("%s"), _last_error_message.c_str());
443
445
    drizzle_result_free(&result);
444
446
    return ER_YES;