Skip to content

Commit d969eb6

Browse files
committed
spew every 1000 send/received remtran
Signed-off-by: Dorin Hogea <dhogea@bloomberg.net>
1 parent 50a1182 commit d969eb6

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

plugins/remsql/fdb_comm.c

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3325,6 +3325,13 @@ int fdb_send_begin(struct sqlclntstate *clnt, fdb_msg_t *msg, fdb_tran_t *trans,
33253325
{
33263326
int rc;
33273327

3328+
static int counter = 0;
3329+
3330+
if (counter % 1000 == 0) {
3331+
++counter;
3332+
logmsg(LOGMSG_ERROR, "SENDING REMTRAN %d!\n", counter);
3333+
}
3334+
33283335
/* clean previous whatever */
33293336
fdb_msg_clean_message(msg);
33303337

@@ -3972,6 +3979,13 @@ int handle_remtran_request(comdb2_appsock_arg_t *arg)
39723979

39733980
sb = arg->sb;
39743981

3982+
static int counter = 0;
3983+
3984+
if (counter % 1000 == 0) {
3985+
++counter;
3986+
logmsg(LOGMSG_ERROR, "RECEIVED REMTRAN %d!\n", counter);
3987+
}
3988+
39753989
bzero(&msg, sizeof(msg));
39763990

39773991
/* This does insert on behalf of an sql transaction */

0 commit comments

Comments
 (0)