mars/kernel/mars_copy.h

118 lines
2.9 KiB
C
Raw Normal View History

2014-11-21 10:51:34 +00:00
/*
* MARS Long Distance Replication Software
*
* This file is part of MARS project: http://schoebel.github.io/mars/
*
* Copyright (C) 2010-2014 Thomas Schoebel-Theuer
* Copyright (C) 2011-2014 1&1 Internet AG
*
* 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 2 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, write to the Free Software Foundation, Inc.,
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/
2011-02-23 20:48:06 +00:00
#ifndef MARS_COPY_H
#define MARS_COPY_H
#include <linux/wait.h>
#include <linux/semaphore.h>
#define INPUT_A_IO 0
#define INPUT_A_COPY 1
#define INPUT_B_IO 2
#define INPUT_B_COPY 3
extern int mars_copy_overlap;
extern int mars_copy_timeout;
extern int mars_copy_read_prio;
extern int mars_copy_write_prio;
2013-07-22 07:15:53 +00:00
extern int mars_copy_read_max_fly;
extern int mars_copy_write_max_fly;
2011-02-23 20:48:06 +00:00
enum {
COPY_STATE_RESET = -1,
COPY_STATE_START = 0, // don't change this, it _must_ be zero
COPY_STATE_START2,
2012-08-02 08:16:55 +00:00
COPY_STATE_READ1,
COPY_STATE_READ2,
COPY_STATE_READ3,
COPY_STATE_WRITE,
COPY_STATE_WRITTEN,
COPY_STATE_CLEANUP,
COPY_STATE_FINISHED,
2011-06-10 13:57:52 +00:00
};
struct copy_state {
struct mref_object *table[2];
2011-06-17 11:32:38 +00:00
bool active[2];
2011-06-10 13:57:52 +00:00
char state;
bool writeout;
2011-06-10 13:57:52 +00:00
short prev;
short len;
short error;
2011-02-23 20:48:06 +00:00
};
struct copy_mref_aspect {
GENERIC_ASPECT(mref);
struct copy_brick *brick;
int queue;
};
struct copy_brick {
MARS_BRICK(copy);
// parameters
struct mars_limiter *copy_limiter;
2012-02-01 12:47:35 +00:00
loff_t copy_start;
loff_t copy_end; // stop working if == 0
2011-05-26 14:32:32 +00:00
int io_prio;
int append_mode; // 1 = passively, 2 = actively
bool verify_mode; // 0 = copy, 1 = checksum+compare
2012-08-02 08:16:55 +00:00
bool repair_mode; // whether to repair in case of verify errors
bool recheck_mode; // whether to re-check after repairs (costs performance)
2011-05-26 14:32:32 +00:00
bool utilize_mode; // utilize already copied data
bool abort_mode; // abort on IO error (default is retry forever)
2011-05-26 14:32:32 +00:00
// readonly from outside
2011-06-17 11:32:38 +00:00
loff_t copy_last; // current working position
2014-02-10 12:08:01 +00:00
struct timespec copy_last_stamp;
int copy_error;
2012-08-22 12:37:34 +00:00
int copy_error_count;
2012-08-02 08:16:55 +00:00
int verify_ok_count;
int verify_error_count;
2011-02-23 20:48:06 +00:00
bool low_dirty;
bool is_aborting;
2011-02-23 20:48:06 +00:00
// internal
2012-02-01 12:47:35 +00:00
bool trigger;
unsigned long clash;
2012-12-20 10:22:41 +00:00
atomic_t total_clash_count;
2011-02-23 20:48:06 +00:00
atomic_t io_flight;
2013-07-22 07:15:53 +00:00
atomic_t copy_read_flight;
atomic_t copy_write_flight;
2011-03-07 05:55:10 +00:00
long long last_jiffies;
2011-02-23 20:48:06 +00:00
wait_queue_head_t event;
struct semaphore mutex;
struct task_struct *thread;
struct copy_state **st;
2011-02-23 20:48:06 +00:00
};
struct copy_input {
MARS_INPUT(copy);
};
struct copy_output {
MARS_OUTPUT(copy);
};
MARS_TYPES(copy);
#endif