mirror of https://github.com/schoebel/mars
light: add peer abort
This commit is contained in:
parent
7be31c47f4
commit
8309fb97e6
|
@ -118,6 +118,9 @@ EXPORT_SYMBOL_GPL(mars_propagate_interval);
|
||||||
int mars_sync_flip_interval = CONFIG_MARS_SYNC_FLIP_INTERVAL;
|
int mars_sync_flip_interval = CONFIG_MARS_SYNC_FLIP_INTERVAL;
|
||||||
EXPORT_SYMBOL_GPL(mars_sync_flip_interval);
|
EXPORT_SYMBOL_GPL(mars_sync_flip_interval);
|
||||||
|
|
||||||
|
int mars_peer_abort = 7;
|
||||||
|
EXPORT_SYMBOL_GPL(mars_peer_abort);
|
||||||
|
|
||||||
int mars_fast_fullsync =
|
int mars_fast_fullsync =
|
||||||
#ifdef CONFIG_MARS_FAST_FULLSYNC
|
#ifdef CONFIG_MARS_FAST_FULLSYNC
|
||||||
1
|
1
|
||||||
|
@ -1661,6 +1664,8 @@ int peer_thread(void *data)
|
||||||
}
|
}
|
||||||
do_kill = true;
|
do_kill = true;
|
||||||
peer->socket.s_shutdown_on_err = true;
|
peer->socket.s_shutdown_on_err = true;
|
||||||
|
peer->socket.s_send_abort = mars_peer_abort;
|
||||||
|
peer->socket.s_recv_abort = mars_peer_abort;
|
||||||
MARS_DBG("successfully opened socket to '%s'\n", real_peer);
|
MARS_DBG("successfully opened socket to '%s'\n", real_peer);
|
||||||
brick_msleep(100);
|
brick_msleep(100);
|
||||||
continue;
|
continue;
|
||||||
|
|
|
@ -295,6 +295,7 @@ ctl_table mars_table[] = {
|
||||||
INT_ENTRY("scan_interval_sec", mars_scan_interval, 0600),
|
INT_ENTRY("scan_interval_sec", mars_scan_interval, 0600),
|
||||||
INT_ENTRY("propagate_interval_sec", mars_propagate_interval, 0600),
|
INT_ENTRY("propagate_interval_sec", mars_propagate_interval, 0600),
|
||||||
INT_ENTRY("sync_flip_interval_sec", mars_sync_flip_interval, 0600),
|
INT_ENTRY("sync_flip_interval_sec", mars_sync_flip_interval, 0600),
|
||||||
|
INT_ENTRY("peer_abort", mars_peer_abort, 0600),
|
||||||
INT_ENTRY("do_fast_fullsync", mars_fast_fullsync, 0600),
|
INT_ENTRY("do_fast_fullsync", mars_fast_fullsync, 0600),
|
||||||
INT_ENTRY("logrot_auto_gb", global_logrot_auto, 0600),
|
INT_ENTRY("logrot_auto_gb", global_logrot_auto, 0600),
|
||||||
INT_ENTRY("required_total_space_0_gb", global_free_space_0, 0600),
|
INT_ENTRY("required_total_space_0_gb", global_free_space_0, 0600),
|
||||||
|
|
|
@ -23,6 +23,7 @@ extern int mars_rollover_interval;
|
||||||
extern int mars_scan_interval;
|
extern int mars_scan_interval;
|
||||||
extern int mars_propagate_interval;
|
extern int mars_propagate_interval;
|
||||||
extern int mars_sync_flip_interval;
|
extern int mars_sync_flip_interval;
|
||||||
|
extern int mars_peer_abort;
|
||||||
extern int mars_emergency_mode;
|
extern int mars_emergency_mode;
|
||||||
extern int mars_reset_emergency;
|
extern int mars_reset_emergency;
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue