mydumper.h

/*
    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.

        Authors: 	Domas Mituzas, Facebook ( domas at fb dot com )
                        Mark Leith, Oracle Corporation (mark dot leith at oracle
   dot com) Andrew Hutchings, SkySQL (andrew at skysql dot com) Max Bubenick,
   Percona RDBA (max dot bubenick at percona dot com)

*/

#ifndef _mydumper_h
#define _mydumper_h

enum job_type {
  JOB_SHUTDOWN,
  JOB_RESTORE,
  JOB_DUMP,
  JOB_DUMP_NON_INNODB,
  JOB_CHECKSUM,
  JOB_SCHEMA,
  JOB_VIEW,
  JOB_TRIGGERS,
  JOB_SCHEMA_POST,
  JOB_BINLOG,
  JOB_LOCK_DUMP_NON_INNODB,
  JOB_CREATE_DATABASE,
  JOB_DUMP_DATABASE
};

struct configuration {
  char use_any_index;
  GAsyncQueue *queue;
  GAsyncQueue *queue_less_locking;
  GAsyncQueue *ready;
  GAsyncQueue *ready_less_locking;
  GAsyncQueue *ready_database_dump;
  GAsyncQueue *unlock_tables;
  GMutex *mutex;
  int done;
};

struct thread_data {
  struct configuration *conf;
  guint thread_id;
};

struct job {
  enum job_type type;
  void *job_data;
  struct configuration *conf;
};

// directory / database . table . first number . second number . extension
// directory is needed to support the snapshot functionality 
// first number : used when rows is used
// second number : when load data is used 
struct table_job {
  char *directory;
  char *database;
  char *table;
  char *filename;
  char *where;
  gboolean has_generated_fields;
  char *order_by;
  struct db_table *dbt;
};

struct table_checksum_job {
  char *database;
  char *table;
  char *filename;
};

struct tables_job {
  GList *table_job_list;
};

struct dump_database_job {
  struct database *database;
};

struct create_database_job {
  char *database;
  char *filename;
};

struct schema_job {
  char *database;
  char *table;
  char *filename;
};

struct view_job {
  char *database;
  char *table;
  char *filename;
  char *filename2;
};

struct schema_post_job {
  struct database *database;
  char *filename;
};

struct restore_job {
  char *database;
  char *table;
  char *filename;
};

struct binlog_job {
  char *filename;
  guint64 start_position;
  guint64 stop_position;
};

struct db_table {
  struct database *database;
  char *table;
  char *table_filename;
  char *escaped_table;
  guint64 datalength;
  guint rows;
  GMutex *rows_lock;
};

struct database {
  char *name;
  char *filename;
  char *escaped;
};

struct schema_post {
  struct database *database;
};

#endif