Lines Matching defs:cntrl
334 __rep_control_args cntrl;
354 memset(&cntrl, 0, sizeof(cntrl));
358 ZERO_LSN(cntrl.lsn);
360 cntrl.lsn = *lsnp;
365 cntrl.rectype = rtype;
367 cntrl.rectype = __rep_msg_to_old(rep->version, rtype);
371 (u_long)cntrl.rectype));
372 if (cntrl.rectype == REP_INVALID)
380 cntrl.flags = ctlflags;
381 cntrl.rep_version = rep->version;
382 cntrl.log_version = lp->persist.version;
383 cntrl.gen = rep->gen;
414 F_SET(&cntrl, REPCTL_PERM);
421 F_SET(&cntrl, REPCTL_GROUP_ESTD);
440 F_SET(&cntrl, REPCTL_LEASE);
443 cntrl.msg_sec = (u_int32_t)msg_time.tv_sec;
444 cntrl.msg_nsec = (u_int32_t)msg_time.tv_nsec;
447 REP_PRINT_MESSAGE(env, eid, &cntrl, "rep_send_message", myflags);
458 !IS_ZERO_LSN(cntrl.lsn));
466 F_ISSET(&cntrl, REPCTL_INIT)) {
467 F_CLR(&cntrl, REPCTL_INIT);
468 F_SET(&cntrl, REPCTL_INIT_45);
470 ocntrl.rep_version = cntrl.rep_version;
471 ocntrl.log_version = cntrl.log_version;
472 ocntrl.lsn = cntrl.lsn;
473 ocntrl.rectype = cntrl.rectype;
474 ocntrl.gen = cntrl.gen;
475 ocntrl.flags = cntrl.flags;
479 cntrl46.rep_version = cntrl.rep_version;
480 cntrl46.log_version = cntrl.log_version;
481 cntrl46.lsn = cntrl.lsn;
482 cntrl46.rectype = cntrl.rectype;
483 cntrl46.gen = cntrl.gen;
484 cntrl46.msg_time.tv_sec = (time_t)cntrl.msg_sec;
485 cntrl46.msg_time.tv_nsec = (long)cntrl.msg_nsec;
486 cntrl46.flags = cntrl.flags;
490 (void)__rep_control_marshal(env, &cntrl, buf,
503 ret = db_rep->send(dbenv, &cdbt, dbt, &cntrl.lsn, eid, myflags);
569 __rep_new_master(env, cntrl, eid)
571 __rep_control_args *cntrl;
598 change = rep->gen != cntrl->gen || rep->master_id != eid;
632 if ((ret = __env_init_rec(env, cntrl->log_version)) != 0)
682 (u_long)rep->gen, (u_long)cntrl->gen, eid));
683 rep->gen = cntrl->gen;
690 __log_set_version(env, cntrl->log_version);
691 rep->version = cntrl->rep_version;
723 LOG_COMPARE(&lsn, &cntrl->lsn) < 0)) {
766 if (cntrl->lsn.file < lsn.file) {
776 if (cntrl->lsn.file < first_lsn.file)