Problem of election after split-drain repeated with two nodes

Hello

I use a custom source based on BDB - 5.1.19 (excxx_repquote)

with two site-MASTER and SLAVE on the other...

NSite = 2
ACK = quorum

-the master is written at the rate of 10 txn quotedb per second
-l' test is to isolate the customer from the master (brain) and reconnect after a random time include 1 sec to 10 sec

the test run of about 10 times, but at some point, the slave to process receive DB_EVENT_REP_ELECTION_FAILED
and the captain enter the mode of election and never leave the CLIENT mode. I have to say that I decided to freeze the client to kill me (kill-9 my pid) when I get this event...


Here is the log in light on the master...

[1307872770:871621] [6510/47655809107168] MASTER: rep_send_function returned: 110
[1307872770:973655] [6510/47655809107168] MASTER: bulk_msg: Send copy due to PERM after buffer
[1307872770:973667] [6510/47655809107168] MASTER: send_bulk: send 266 bytes of the buffer in bulk (0x10a)
[1307872770:973672] [6510/47655809107168] MASTER: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 68 eid - 1, type bulk_log, LSN [21] [986648] perm
[1307872770:973693] [6510/47655809107168] MASTER: wait for the acknowledgement of receipt: need 1
[1307872771:26623] [6510/47655809107168] MASTER: rep_send_function returned: 110
[1307872771:126380] [6510/1162996032] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 70 eid 0, Journal type, LSN [21] [946345]
[1307872771:126407] [6510/1162996032] MASTER: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 68 eid - 1, type dupmaster, LSN [0] [0] nobuf
[1307872771:126695] [6510/1162996032] MASTER: rep_start: old version 17 journal found
[1307872771:126753] [6510/1162996032] CLIENT: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 68 eid - 1, type newclient, LSN [0] [0] nobuf
[1307872771:126833] [6510/1183975744] CUSTOMER: from the election thread
[1307872771:126876] [6510/1183975744] CLIENT: Start election Europe 2, ack 1, priority 100
[1307872771:126890] [6510/1183975744] CLIENT: Election thread has egen 69
[1307872771:127423] [6510/1173485888] CLIENT: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 70 eid 0, type newclient, LSN [0] [0]
[1307872771:130079] [6510/1183975744] CLIENT: count VOTE1 [0] (2147483647, 69)
[1307872771:130113] [6510/1183975744] CLIENT: count an election
[1307872771:130134] [6510/1183975744] CLIENT: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 68 eid - 1, type vote1, LSN [21] [986728] nobuf
[1307872771:130147] [6510/1173485888] CLIENT: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 68 eid - 1, type master_req, LSN [0] [0] nobuf
[1307872771:130438] [6510/1152506176] CLIENT: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 70 eid 0, type vote1, LSN [21] [946437]
[1307872771:130460] [6510/1162996032] CLIENT: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 70 eid 0, living type, LSN [21] [986728]
[1307872771:130467] [6510/1152506176] CLIENT: update of gen from 68 to 70
[1307872771:130482] [6510/1162996032] CLIENT: received egen ALIVE of 71, 69 mine
[1307872771:130503] [6510/1162996032] CLIENT: Election completed in 0.003602000 sec
[1307872771:130515] [6510/1162996032] CLIENT: Election; Egen 70
[1307872771:130534] [6510/1152506176] CLIENT: received vote1 egen egen 71, 71
[1307872771:130581] [6510/1152506176] CLIENT: count VOTE1 [0] (0, 71)
[1307872771:130593] [6510/1089075520] CUSTOMER: from the election thread
[1307872771:130619] [6510/1152506176] CLIENT: Vote Incoming: (eid) 0 (pri) 100 ELECTABLE (gen) 70 (egen) 71 [21,946437]
[1307872771:130642] [6510/1152506176] CLIENT: not in election, but receipts vote1 0x282c 0x8
[1307872771:130674] [6510/1089075520] CLIENT: Start election Europe 2, ack 1, priority 100
[1307872771:130692] [6510/1089075520] CLIENT: Election thread has 71 egen
[1307872771:130704] [6510/1194465600] CUSTOMER: from the election thread
[1307872771:130733] [6510/1194465600] CLIENT: Start election Europe 2, ack 1, priority 100
[1307872771:132922] [6510/1089075520] CLIENT: count VOTE1 [1] (2147483647, 71)
[1307872771:132949] [6510/1089075520] CLIENT: accept the new vote
[1307872771:132958] [6510/1089075520] CLIENT: count an election
[1307872771:132973] [6510/1089075520] CLIENT: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 70 eid - 1, type vote1, LSN [21] [986728] nobuf
[1307872771:132985] [6510/1194465600] CLIENT: fate of election thread
[1307872771:133012] [6510/1089075520] CLIENT: count VOTE2 [0] (2147483647, 71)
[1307872771:133037] [6510/1089075520] CLIENT: counted my vote 1
[1307872771:133048] [6510/1089075520] CLIENT: jump phase2 waiting: already had 1 vote
[1307872771:133060] [6510/1089075520] CLIENT: got enough votes to win. election of fact; Gen (prev) 70
[1307872771:133071] [6510/1089075520] CLIENT: Election completed in 0.002367000 sec
[1307872771:133084] [6510/1089075520] CLIENT: Election; Egen 72
[1307872771:133111] [6510/1089075520] CLIENT: flag of election ending in 0, e_th 1, egen 72, 0x2a2c, e_fl, 0x0, lo_fl 0 x 6
[1307872771:133170] [6510/1173485888] CLIENT: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 70 eid 0, living type, LSN [0] [0]
[1307872771:133187] [6510/1173485888] CLIENT: Racing replication msg lockout, ignore the message.
[1307872771:173744] [6510/1162996032] CLIENT: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 70 eid 0, type vote2, LSN [0] [0]
[1307872771:173769] [6510/1162996032] CLIENT: Racing replication msg lockout, ignore the message.
[1307872771:231593] [6510/1183975744] CLIENT: flag of election ending in 0, e_th 0, egen 72, 0x2a2c, e_fl, 0x0, lo_fl 0x1c
[1307872771:231629] [6510/1183975744] CLIENT: fate of election thread
[1307872777:443794] [6510/1131526464] CLIENT: connect to 2.0.0.210:12345 site with result 115 init
[1307872971:644194] [6510/1131526464] CLIENT: connect to 2.0.0.210:12345 site with result 115 init
[1307873165:844583] [6510/1131526464] CLIENT: connect to 2.0.0.210:12345 site with result 115 init
[1307873360:44955] [6510/1131526464] CLIENT: connect to 2.0.0.210:12345 site with result 115 init
[1307873554:245347] [6510/1131526464] CLIENT: connect to 2.0.0.210:12345 site with result 115 init
[1307873748:445736] [6510/1131526464] CLIENT: connect to 2.0.0.210:12345 site with result 115 init
[1307873942:646117] [6510/1131526464] CLIENT: connect to 2.0.0.210:12345 site with result 115 init
[1307874136:846509] [6510/1131526464] CLIENT: connect to 2.0.0.210:12345 site with result 115 init

... and stay infinite this situation



My question is why the master is suddenly transformed into CUSTOMER and why he never returns to the MASTER



Thanks in advance...



Here is the log for the customer

[1307872315:455113] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, Journal type, LSN [21] [984396]
[1307872315:455134] [1282/1160603968] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, Journal type, LSN [21] [984483] perm
[1307872315:609962] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type bulk_log, LSN [21] [984733] perm
[1307872315:764958] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type bulk_log, LSN [21] [984986] perm
[1307872315:919962] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type bulk_log, LSN [21] [985238] perm
[1307872316:75018] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type bulk_log, LSN [21] [985491] perm
[1307872316:229959] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type bulk_log, LSN [21] [985741] perm
[1307872316:384949] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type bulk_log, LSN [21] [985993] perm
[1307872316:499899] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type bulk_log, LSN [21] [986141] perm
[1307872316:539895] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, Journal type, LSN [21] [986221]
[1307872316:540078] [1282/1171093824] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, Journal type, LSN [21] [986307]
[1307872316:540100] [1282/1160603968] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, Journal type, LSN [21] [986394] perm
[1307872316:694950] [1282/1171093824] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type bulk_log, LSN [21] [986648] perm
[1307872316:847349] [1282/1129134400] MASTER: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 70 eid - 1, Journal type, LSN [21] [946345]
[1307872316:847698] [1282/1171093824] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, dupmaster, LSN type [0] [0]
[1307872316:847999] [1282/1181583680] MASTER: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type newclient, LSN [0] [0]
[1307872316:848168] [1282/1171093824] MASTER: rep_start: old version 17 journal found
[1307872316:848222] [1282/1181583680] CLIENT: Racing replication msg lockout, ignore the message.
[1307872316:848398] [1282/1171093824] CLIENT: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 70 eid - 1, type newclient, LSN [0] [0] nobuf
[1307872316:848504] [1282/1192073536] CUSTOMER: from the election thread
[1307872316:848542] [1282/1192073536] CLIENT: Start election Europe 2, ack 1, priority 100
[1307872316:848566] [1282/1192073536] CLIENT: Election thread has 71 egen
[1307872316:849634] [1282/1192073536] CLIENT: count VOTE1 [0] (2147483647, 71)
[1307872316:849654] [1282/1192073536] CLIENT: count an election
[1307872316:849680] [1282/1192073536] CLIENT: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 70 eid - 1, type vote1, LSN [21] [946437] nobuf
[1307872316:851403] [1282/1160603968] CLIENT: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, type vote1, LSN [21] [986728]
[1307872316:851448] [1282/1160603968] CLIENT: received vote1 egen egen 69, 71
[1307872316:851470] [1282/1160603968] CLIENT: received the old vote egen 69, 71, ignoring vote1
[1307872316:851481] [1282/1160603968] CLIENT: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 70 eid 0, living type, LSN [21] [986728] nobuf
[1307872316:851538] [1282/1171093824] CLIENT: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 68 eid 0, master_req, LSN type [0] [0]
[1307872316:851558] [1282/1171093824] CLIENT: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 70 eid 0, living type, LSN [0] [0] nobuf
[1307872316:854254] [1282/1160603968] CLIENT: / opt/bdb/rep_process_message: msgv = 5 logv 17 gen = 70 eid 0, type vote1, LSN [21] [986728]
[1307872316:854275] [1282/1160603968] CLIENT: received vote1 egen egen 71, 71
[1307872316:854317] [1282/1160603968] CLIENT: count VOTE1 [1] (0, 71)
[1307872316:854339] [1282/1160603968] CLIENT: Vote Incoming: (eid) 0 (pri) 100 ELECTABLE (gen) 70 (egen) 71 [21,986728]
[1307872316:854353] [1282/1160603968] CLIENT: Vote existing: (eid) 2147483647 (pri) 100 (gen) 70 (sites) 2 [21,946437]
[1307872316:854369] [1282/1160603968] CLIENT: accept the new vote
[1307872316:854379] [1282/1160603968] CLIENT: Election of phase 1 done
[1307872316:854395] [1282/1160603968] CLIENT: vote for 0
[1307872316:854407] [1282/1160603968] CLIENT: / opt/bdb/rep_send_message: msgv = 5 logv 17 gen = 70 eid 0, type vote2, LSN [0] [0] nobuf
[1307872317:960344] [1282/1192073536] CLIENT: after the phase 2: votes 0, nvotes 1, Europe 2
[1307872317:960389] [1282/1192073536] CLIENT: Election completed in 1.111809000 sec
[1307872317:960401] [1282/1192073536] CLIENT: Election; Egen 72
[1307872317:960412] [1282/1192073536] CLIENT: flag of completed election with-30974, e_th 0, egen 72, 0x282c, e_fl, 0x0, lo_fl 0x0
Kill me!



-my source

on the master, I executed manually:

txn_rate 1
loop_rate 10
loop 1 20000

------
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2001-2010 Oracle and/or its affiliates. All rights reserved.
*
* $Id$
*/

/*
* In this application, specify us all communications via the command line. In
* a real application, one would expect that the information on other sites
* in the system would be maintained in a sort of configuration file. The
* most of this interface, it is that we assume at the start that we can
* knowledge
(* 1) what is our environment home Berkeley DB,.
(* 2) which host/port we want to hear about the connections. and
(* 3) an optional list of other sites, we should try to connect to.
*
* These items of information are expressed by the following indicators.
* h House (required; h means home directory)
*-l host: port (required; l means local)
* - C or - M (optional; will start as customer or master)
* r - host: port (optional; r mean distance; no matter how many of them may be)
* specified)
* R - host: port (optional; R stands for the remote peer; only one of them can
* to be specified)
* - an all the | quorum (optional; a is synonymous with the ACK policy)
* b (optional; b means in bulk)
* Europe - n (optional, number of sites in the replication group; default is 0)
* to try to dynamically calculate Europe)
* priority Pei (optional; default is 100)
* - v (optional; v means verbose)
*/

#include < cstdlib >
#include < a > cstring

#include < iostream >
#include < String >
#include < sstream >

#include < sys/types.h >
#include < signal.h >


#include < db_cxx.h >
#include "RepConfigInfo.h".
#include "dbc_auto.h".

using std::cout;
using std::cin;
using std::cerr;
using std::endl;
using std::ends;
using std::flush;
using std::istream;
using std::istringstream;
using std::ostringstream;
using std::string;
using std::getline;

#include < stdio.h >
#include < readline/readline.h >
#include < readline/history.h >

#define CACHESIZE (10 * 1024 * 1024)
#define of DATABASE 'quote.db '.
#define «quote2.db» base2

const char * progname = "excxx_repquote";

#include < errno.h >
#ifdef _WIN32
#define WIN32_LEAN_AND_MEAN
#include < windows.h >
#define _snprintf snprintf
#define sleep (s) sleep (1000 * (s))

extern "C" {}
extern int getopt (int, char * const *, const char *);
extern char * optarg;
}

typedef HANDLE thread_t;
typedef DWORD thread_exit_status_t;
#define thread_create (thrp, attr, func, arg).
(((* (thrp) = CreateThread (NULL, 0,-))))
(LPTHREAD_START_ROUTINE) ((((func), (arg), 0, NULL)) == NULL)? (1: 0)
#define thread_join (thr, statusp).
((WaitForSingleObject ((THR), Infinite) == WAIT_OBJECT_0) & & \)
GetExitCodeThread ((thr), (LPDWORD) (statusp))? 0: - 1).
#else / *! _WIN32 * /.
#include < pthread.h >

typedef pthread_t thread_t;
typedef void * thread_exit_status_t;
#define thread_create (thrp, attr, func, arg).
pthread_create ((thrp), (attr), (func), (arg))
#define (thr, statusp) thread_join pthread_join ((thr), (statusp))
#endif

Struct used to store information in the field of app_private Db.
typedef struct {}
bool app_finished;
bool in_client_sync;
bool is_master;
bool no_dummy_wr;
} APP_DATA.

public static void log(const char *);
void checkpoint_thread (Sub );
void log_archive_thread (Sub );
void dummy_write_thread (Sub );

Class RepQuoteExample {}
public:
RepQuoteExample();
void init (RepConfigInfo * config);
void doloop();
terminate() int;

public static void event_callback (DbEnv * dbenv, u_int32_t, void * info);
void print_stocks_size(Db *dbp);

private:
disable the copy constructor.
RepQuoteExample(const RepQuoteExample &);
void operator = (const RepQuoteExample &);

internal data members.
APP_DATA app_data.
RepConfigInfo * app_config;
DbEnv cur_env;
thread_t ckp_thr;
thread_t lga_thr;
thread_t dmy_thr;

private methods.
void print_stocks(Db *dbp);
void print_env(DbEnv *dbenv);

prompt() Sub;
};

RepQuoteExample * g_runner = NULL;
RepConfigInfo * g_config = NULL;

Class DbHolder {}
public:
DbHolder ( env, const char _dbname DbEnv): env (env)
{
DBP = 0;
If (_dbname) dbname = _dbname;
else dbname = database;
}

{~ DbHolder()}
try {}
Close();
} catch (...) {
Ignore: this may mean that another exception is waiting
}
}

bool ensure_open (bool creation) {}
If (dbp)
return (true);
DBP = new Db (env, 0);

u_int32_t flags = DB_AUTO_COMMIT;
If (creation)
flags | = DB_CREATE;
try {}
DBP-> open (NULL, NULL, DB_BTREE, DATABASE, flags, 0);
DBP-> open (NULL, dbname, NULL, DB_BTREE, flags, 0);
DBP-> open (NULL, NULL, dbname, DB_BTREE, flags, 0);
return (true);
} catch (DbDeadlockException e) {}
} catch (DbRepHandleDeadException e) {}
} catch (DbException e) {}
If (e.get_errno () == DB_REP_LOCKOUT) {}
Just fall through.
} ElseIf (e.get_errno () == ENOENT & &! creation) {}
Provide a little extra explanation.
//
Log ("Stock DB is not still exist");
} else
throw;
}

(All renewable errors pass here).
//
Log ("Please try again");
Close();
Return (false) End Function
}

{} void close()
If {(dbp)
try {}
DBP-> close (0);
Remove dbp;
DBP = 0;
} catch (...) {
Remove dbp;
DBP = 0;
throw;
}
}
}

operator Db * () {}
return of dbp;
}

DB * operator-> () {}
return of dbp;
}

private:
DB * dbp;
DbEnv * env;
const char * dbname;
};

Class StringDbt: public {Dbt
public:
#define GET_STRING_OK 0
#define GET_STRING_INVALID_PARAM 1
#define GET_STRING_SMALL_BUFFER 2
#define GET_STRING_EMPTY_DATA 3
int get_string (char * buf, size_t buf_len)
{
size_t copy_len;
int ret = GET_STRING_OK;
If (buf == NULL) {}
ECRR < < "Invalid entry to get_string stamp" < < endl;
Return GET_STRING_INVALID_PARAM;
}

Make sure that the string is null terminated.
Memset (* buf, 0, buf_len);

If there is no string, simply return.
If (get_data() == NULL | get_size() == 0)
Return GET_STRING_OK;

If (get_size() > = buf_len) {}
RET = GET_STRING_SMALL_BUFFER;
copy_len = buf_len - 1; save room for a terminator.
} else
copy_len = get_size();
memcpy (* buf, get_data(), copy_len);

return ret;
}
size_t get_string_length()
{
If (get_size() == 0)
return 0;
Return strlen ((char *) get_data());
}
Sub set_string(char *string)
{
SET_DATA (String);
set_Size ((u_int32_t) strlen (String));
}

StringDbt(char *string):
DBT (string, (u_int32_t) strlen (string)) {};
StringDbt(): Dbt() {};
~ StringDbt() {};

Do not add additional data to this subcategory because we want to keep it
compatible with objects Dbt created in-house by Berkeley DB.
};

DB * g_repquote = NULL;

RepQuoteExample::RepQuoteExample(): app_config (0), cur_env (0) {}
App_Data.app_finished = 0;
App_Data.in_client_sync = 0;
App_Data.is_master = 0; Suppose I have as a customer initially
App_Data.no_dummy_wr = 0; prevent to run dummy writing
}

/*
int (* old_rep_process_message)
__P ((DB_ENV *, DBT *, DBT *, int, DB_LSN *));

int my_rep_process_message __P ((DB_ENV DBT, arg1 , arg2, arg3, arg4 int, DB_LSN $arg5 DBT))
{
printf ("EZ-> > > my_rep_process_message:%p\n",arg5 ");
old_rep_process_message (Arg1, Arg2, Arg3, Arg4, $arg5);
}
*/

void RepQuoteExample::init(RepConfigInfo *config) {}
app_config = config;

cur_env.set_app_private (& App_Data);
cur_env.set_errfile (stderr);
App_Data.no_dummy_wr = config-> no_dummy_wr;
If (app_data.no_dummy_wr)
printf ("no dummy! \n");

EZ-> cur_env.set_errpfx (progname);
cur_env.set_event_notify (event_callback);

Configure the transfer block to send groups of documents to customers
When a single network transfers. This is useful for sites of masters
and customers participating in the synchronization from client to client.
//
If (app_config-> in bulk)
cur_env.rep_set_config (DB_REP_CONF_BULK, 1);

Set the total number of sites in the replication group.
It is used by the treatment of election internal repmgr.
//
If (app_config-> totalsites > 0)
cur_env.rep_set_nsites (app_config-> totalsites);

Turn on the output of debugging and application information.
If (app_config-> verbose)
cur_env.set_verbose (DB_VERB_REPLICATION, 1);

cur_env.set_verbose (DB_VERB_REPMGR_MISC, 1);
cur_env.set_verbose (DB_VERB_RECOVERY, 1);
cur_env.set_verbose (DB_VERB_REPLICATION, 1);
cur_env.set_verbose (DB_VERB_REP_ELECT, 1);
cur_env.set_verbose (DB_VERB_REP_LEASE, 1);
cur_env.set_verbose (DB_VERB_REP_SYNC, 1);
cur_env.set_verbose (DB_VERB_REPMGR_MISC, 1);

Set the priority of replication for this environment group election.
An election first selects the site with the most recent log
documents such as the new master. If several sites are the most
recent log records, the site with the highest priority value
is selected as the master.
//
cur_env.rep_set_priority (app_config-> priority);

Set the policy that determines how master and client sites
treat the acknowledgment of replication messages required for
permanent record. The default policy of "quorum" requires only
a quorum of the likely to be elected peers sufficient to ensure a permanent
record remains durable if the election is held. The option 'all '.
requires that all clients to recognize a permanent replication
message instead.
//
cur_env.repmgr_set_ack_policy (app_config-> ack_policy);

Set the threshold for the minimum and maximum of the client time
wait before asking the retransmission of a missing message.
These core values on the characteristics of performance and load
host master and client as well as the tower platforms
message trigger time.
//
cur_env.rep_set_request (20000, 500000);

Configure the detection of blockages to ensure that blockages of locks?
are broken by the presence of one of the queries of locks in conflict
has rejected. DB_LOCK_DEFAULT uses the specified lock strategy
at the time of the creation environment or DB_LOCK_RANDOM if none has been
specified.
//
cur_env.set_lk_detect (DB_LOCK_DEFAULT);

The following features of the basic replication can also be useful to your
request. See Berkeley DB documentation for more details.
-Master leases: strict consistency for data reads
on a main site.
-Delivery time: Customize the amount of time that waiting for Berkeley DB
for such things as the election must be concluded or a master
lease to be granted.
-Client synchronization delay: managing the main site
resources by spreading intensive customer resources
synchronizations.
-Blocked customer operations: return immediately with an error
rather than wait indefinitely if a customer is operation
blocked by a current client synchronization.

cur_env.repmgr_set_local_site (app_config-> this_host.host,
app_config-> this_host.port, 0);

for (REP_HOST_INFO * cur = app_config-> other_hosts; cur! = NULL;)
Cur = cur-> next) {}
cur_env.repmgr_add_remote_site (cur-> host, cur-> port,
NULL, cur-> peers? DB_REPMGR_PEER: 0);
}

Configure heartbeat timeouts so that repmgr monitors the
health of the TCP connection. Master sites disseminate a heartbeat
at the frequency specified by the timeout DB_REP_HEARTBEAT_SEND.
Customer sites waiting for activity of the messages of the length of the
DB_REP_HEARTBEAT_MONITOR timeout before concluding that the
connection to the master is lost. The DB_REP_HEARTBEAT_MONITOR
timeout must be longer than the time-out DB_REP_HEARTBEAT_SEND.
//
cur_env.rep_set_timeout (DB_REP_HEARTBEAT_SEND, 5000000);
cur_env.rep_set_timeout (DB_REP_HEARTBEAT_MONITOR, 10000000);

The following features of repmgr can also be useful to your
request. See Berkeley DB documentation for more details.
-Regulates two sites of strict majority - in a two-site replication
the group, to ask the two sites are available to elect a new
master.
-Timeout - customize the amount of time repmgr awaits
for things as pending or try thanks
to reconnect to other sites.
-The site list - returns a list of currently known sites at repmgr.

Now we can open our environment, although we are not ready to
start replication. However, we want to have a dbenv autour
so that we can send it in one of our message handlers.
//
cur_env.set_CacheSize (0, CACHESIZE, 0);
cur_env.set_flags (DB_REP_PERMANENT, 1);
cur_env.set_flags (DB_TXN_WRITE_NOSYNC, 1);

/ * u_int32_t maxlocks = 300000;
If (maxlocks! = 0)
cur_env.set_lk_max_locks (MAXLOCKS);

u_int32_t maxlocks_o = 300000;
If (maxlocks_o! = 0)
cur_env.set_lk_max_objects (maxlocks_o);

u_int32_t maxmutex = 300000;
If (maxmutex! = 0)
cur_env.mutex_set_max (maxmutex);
*/

DbEnv * m_env = & cur_env;
m_env-> set_flags (DB_TXN_NOSYNC, 1);
m_env-> set_lk_max_lockers (60000);
m_env-> set_lk_max_objects (60000);
m_env-> set_lk_max_locks (60000);
m_env-> set_tx_max (60000);

m_env-> repmgr_set_ack_policy (DB_REPMGR_ACKS_NONE);

m_env-> rep_set_timeout (DB_REP_ACK_TIMEOUT, 50 * 1000); 50ms
m_env-> rep_set_timeout (DB_REP_CHECKPOINT_DELAY, 0);
m_env-> rep_set_timeout (DB_REP_CONNECTION_RETRY, 30 * 1000 * 1000); 30 seconds
m_env-> rep_set_timeout (DB_REP_ELECTION_TIMEOUT, 1 * 1000 * 1000); 5 seconds
m_env-> rep_set_timeout (DB_REP_FULL_ELECTION_TIMEOUT, 5 * 1000 * 1000); 5 seconds
m_env-> rep_set_timeout (DB_REP_CONNECTION_RETRY, 5 * 1000 * 1000);
m_env-> rep_set_timeout (DB_REP_ELECTION_RETRY, 10 * 1000 * 1000); 10 seconds

m_env-> rep_set_timeout (DB_REP_HEARTBEAT_MONITOR, 80 * 1000 * 1000); 80 seconds
m_env-> rep_set_timeout (DB_REP_HEARTBEAT_SEND, 500 * 1000); 500 milliseconds

The minimum number of microseconds that a client will wait before requesting a retransmission
u_int32_t rep_req_min = 40000; 40 000 microsec = 40 mili
The maximum number of milliseconds that a client will wait before requesting a retransmission
u_int32_t rep_req_max = 1280000. / / 1 280 000 microsec = 1.28 sec

u_int32_t rep_limit_gbytes = 0;
u_int32_t rep_limit_bytes = 100 * 1024 * 1024; 100 MB
m_env-> rep_set_request (rep_req_min, rep_req_max);
m_env-> rep_set_limit (rep_limit_gbytes, rep_limit_bytes);


cur_env. Open (app_config-> homepage, DB_CREATE |) DB_RECOVER |
DB_THREAD | DB_INIT_REP | DB_INIT_LOCK | DB_INIT_LOG |
DB_INIT_MPOOL | DB_INIT_TXN, 0);

keep the old string function
old_rep_process_message = cur_env.get_DB_ENV ()-> rep_process_message;
deviant
cur_env.get_DB_ENV ()-> rep_process_message = my_rep_process_message;

/ * int _i;
cur_env.log_get_config (DB_LOG_DIRECT & _i); printf ("DB_LOG_DIRECT = %d\n",_i);
cur_env.log_get_config (DB_LOG_DSYNC & _i); printf ("DB_LOG_DSYNC = %d\n",_i);
cur_env.log_get_config (DB_LOG_AUTO_REMOVE & _i); printf ("DB_LOG_AUTO_REMOVE = %d\n",_i);
cur_env.log_get_config (DB_LOG_IN_MEMORY & _i); printf ("DB_LOG_IN_MEMORY = %d\n",_i);
cur_env.log_get_config (DB_LOG_ZERO & _i); printf ("DB_LOG_ZERO = %d\n",_i);
*/

Start checkpoint and newspaper archive support threads.
(void) thread_create (& ckp_thr, NULL, checkpoint_thread, & cur_env);
(void) thread_create (& lga_thr, NULL, log_archive_thread, & cur_env);
(void) thread_create (& dmy_thr, NULL, dummy_write_thread, & cur_env);

cur_env.repmgr_start (3, app_config-> start_policy);
}