Lines Matching refs:env
88 ENV *env;
94 env = dbenv->env;
95 db_rep = env->rep_handle;
99 if ((ret = __repmgr_send_broadcast(env, REPMGR_REP_MESSAGE,
112 (site = __repmgr_available_site(env, db_rep->peer)) !=
114 RPRINT(env, DB_VERB_REPMGR_MISC,
115 (env, "sending request to peer"));
116 } else if ((site = __repmgr_available_site(env, eid)) ==
118 RPRINT(env, DB_VERB_REPMGR_MISC, (env,
126 if ((ret = __repmgr_send_one(env, conn, REPMGR_REP_MESSAGE,
128 (t_ret = __repmgr_bust_connection(env, conn)) != 0)
201 (void)__db_unknown_path(env, "__repmgr_send");
211 RPRINT(env, DB_VERB_REPMGR_MISC, (env,
213 ret = __repmgr_await_ack(env, lsnp);
219 DB_EVENT(env, DB_EVENT_REP_PERM_FAILED, NULL);
225 __repmgr_available_site(env, eid)
226 ENV *env;
232 db_rep = env->rep_handle;
249 * Caller must hold env->mutex.
254 __repmgr_send_broadcast(env, type, control, rec, nsitesp, npeersp)
255 ENV *env;
271 db_rep = env->rep_handle;
280 __os_gettime(env, &db_rep->last_bcast, 1);
293 DB_ASSERT(env, IS_VALID_EID(conn->eid) &&
319 if ((ret = __repmgr_send_internal(env,
326 if ((ret = __repmgr_bust_connection(env, conn)) != 0)
355 __repmgr_send_one(env, conn, msg_type, control, rec, blockable)
356 ENV *env;
365 return (__repmgr_send_internal(env, conn, &msg, blockable));
389 __repmgr_send_internal(env, conn, msg, blockable)
390 ENV *env;
403 db_rep = env->rep_handle;
405 DB_ASSERT(env,
413 RPRINT(env, DB_VERB_REPMGR_MISC,
414 (env, "msg to %s to be queued",
415 __repmgr_format_eid_loc(env->rep_handle,
419 RPRINT(env, DB_VERB_REPMGR_MISC, (env,
424 RPRINT(env, DB_VERB_REPMGR_MISC,
425 (env, "will await drain"));
427 ret = __repmgr_await_drain(env,
430 RPRINT(env, DB_VERB_REPMGR_MISC, (env,
441 return (enqueue_msg(env, conn, msg, 0));
443 RPRINT(env, DB_VERB_REPMGR_MISC,
444 (env, "queue limit exceeded"));
445 STAT(env->rep_handle->
468 __db_err(env, ret, "socket writing failure");
472 RPRINT(env, DB_VERB_REPMGR_MISC, (env, "wrote only %lu bytes to %s",
474 __repmgr_format_eid_loc(env->rep_handle, conn->eid, buffer)));
480 if ((ret = enqueue_msg(env, conn, msg, total_written)) != 0)
483 STAT(env->rep_handle->region->mstat.st_msgs_queued++);
496 __db_err(env, ret, "can't add FD_WRITE event bit");
500 return (__repmgr_wake_main_thread(env));
513 __repmgr_is_permanent(env, lsnp)
514 ENV *env;
522 db_rep = env->rep_handle;
604 (void)__db_unknown_path(env, "__repmgr_is_permanent");
622 __repmgr_bust_connection(env, conn)
623 ENV *env;
629 db_rep = env->rep_handle;
646 env, (u_int)eid, FALSE)) != 0)
656 env->dbenv, DB_MEMP_SYNC_INTERRUPT, 1);
658 env, ELECT_FAILURE_ELECTION)) != 0)
666 ret = __repmgr_wake_main_thread(env);
680 __repmgr_cleanup_connection(env, conn)
681 ENV *env;
687 db_rep = env->rep_handle;
689 if ((ret = __repmgr_close_connection(env, conn)) != 0)
704 ret = __repmgr_destroy_connection(env, conn);
711 __repmgr_close_connection(env, conn)
712 ENV *env;
717 DB_ASSERT(env,
718 conn->state == CONN_DEFUNCT || env->rep_handle->finished);
726 __db_err(env, ret, "closing socket");
737 __repmgr_destroy_connection(env, conn)
738 ENV *env;
751 __os_free(env, conn->input.rep_message);
755 __os_free(env, dbt->data);
758 __os_free(env, dbt->data);
766 __os_free(env, msg);
767 __os_free(env, out);
771 __os_free(env, conn);
776 enqueue_msg(env, conn, msg, offset)
777 ENV *env;
785 if (msg->fmsg == NULL && ((ret = flatten(env, msg)) != 0))
787 if ((ret = __os_malloc(env, sizeof(QUEUED_OUTPUT), &q_element)) != 0)
844 flatten(env, msg)
845 ENV *env;
852 DB_ASSERT(env, msg->fmsg == NULL);
855 if ((ret = __os_malloc(env, sizeof(*msg->fmsg) + msg_size,
876 __repmgr_find_site(env, host, port)
877 ENV *env;
885 db_rep = env->rep_handle;
909 __repmgr_pack_netaddr(env, host, port, list, addr)
910 ENV *env;
918 DB_ASSERT(env, host != NULL);
920 if ((ret = __os_strdup(env, host, &addr->host)) != 0)
933 __repmgr_getaddr(env, host, port, flags, result)
934 ENV *env;
951 __db_errx(env, "port %u larger than max port %u",
957 if (!env->rep_handle->wsa_inited &&
958 (ret = __repmgr_wsa_init(env)) != 0)
975 if (__os_getaddrinfo(env, host, port, buffer, &hints, &answer) != 0)
995 __repmgr_add_site(env, host, port, newsitep)
996 ENV *env;
1008 db_rep = env->rep_handle;
1010 if (IS_VALID_EID(eid = __repmgr_find_site(env, host, port))) {
1017 env, host, port, 0, &address_list)) == DB_REP_UNAVAIL) {
1024 env, host, port, address_list, &addr)) != 0) {
1025 __os_freeaddrinfo(env, address_list);
1029 if ((ret = __repmgr_new_site(env, &site, &addr, SITE_IDLE)) != 0) {
1030 __repmgr_cleanup_netaddr(env, &addr);
1036 env, (u_int)EID_FROM_SITE(site), TRUE)) != 0)
1073 __repmgr_listen(env)
1074 ENV *env;
1082 db_rep = env->rep_handle;
1094 DB_ASSERT(env, ai != NULL);
1128 __db_err(env, ret, "can't unblock listen socket");
1137 __db_err(env, ret, why);
1147 __repmgr_net_close(env)
1148 ENV *env;
1157 db_rep = env->rep_handle;
1164 if ((t_ret = __repmgr_close_connection(env, conn)) != 0 &&
1168 if ((t_ret = __repmgr_destroy_connection(env, conn)) != 0 &&
1198 __repmgr_net_destroy(env, db_rep)
1199 ENV *env;
1207 __repmgr_cleanup_netaddr(env, &db_rep->my_addr);
1215 __os_free(env, retry);
1220 (void)__repmgr_destroy_connection(env, conn);
1225 __repmgr_cleanup_netaddr(env, &site->net_addr);
1227 __os_free(env, db_rep->sites);