← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/slave/queue_producer.h

  • Committer: Monty Taylor
  • Date: 2011-03-07 21:37:51 UTC
  • mfrom: (2221.2.4 build)
  • Revision ID: mordred@inaugust.com-20110307213751-uhic4rghe4dmdi8d
Merge Monty - Pandora-build updates. Allow building of only libdrizzle.
Merge Andrew - libdrizzle result reuse problem.
Merge David - Slave plugin bugfixes.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/slave/queue_producer.h
21
21
#ifndef PLUGIN_SLAVE_QUEUE_PRODUCER_H
22
22
#define PLUGIN_SLAVE_QUEUE_PRODUCER_H
23
23
 
 
24
#include <client/client_priv.h>
 
25
#include <drizzled/error_t.h>
24
26
#include <plugin/slave/queue_thread.h>
25
27
#include <plugin/slave/sql_executor.h>
26
 
#include <client/client_priv.h>
27
28
#include <string>
28
29
#include <vector>
29
30
 
132
133
   */
133
134
  bool reconnect(bool initial_connection);
134
135
 
 
136
  /**
 
137
   * Get maximum commit ID that we have stored locally on the slave.
 
138
   *
 
139
   * This method determines where this slave is in relation to the master,
 
140
   * or, in other words, how "caught up" we are.
 
141
   *
 
142
   * @param[out] max_commit_id Maximum commit ID we have on this slave.
 
143
   */
135
144
  bool queryForMaxCommitId(uint64_t *max_commit_id);
136
 
  bool queryForReplicationEvents(uint64_t max_commit_id);
 
145
 
 
146
  /**
 
147
   * Get replication events/messages from the master.
 
148
   *
 
149
   * Calling this method will a limited number of events from the master.
 
150
   * It should be repeatedly called until it returns -1, which means there
 
151
   * were no more events to retrieve.
 
152
   *
 
153
   * @param[in] max_commit_id Largest commit ID we have stored locally.
 
154
   *
 
155
   * @retval EE_OK  Successfully retrieved events
 
156
   * @retval ER_NO  No errors, but no more events to retrieve
 
157
   * @retval ER_YES Error
 
158
   */
 
159
  enum drizzled::error_t queryForReplicationEvents(uint64_t max_commit_id);
 
160
 
137
161
  bool queryForTrxIdList(uint64_t max_commit_id, std::vector<uint64_t> &list);
138
162
  bool queueInsert(const char *trx_id,
139
163
                   const char *seg_id,