Lines Matching refs:env
27 ENV *env;
31 env = dbenv->env;
32 db_rep = env->rep_handle;
34 if (!F_ISSET(env, ENV_THREAD)) {
35 __db_errx(env,
42 __db_errx(env,
48 __db_errx(env,
59 __db_errx(env,
65 __db_errx(env,
70 if ((ret = __os_calloc(env, (u_int)nthreads,
75 if ((ret = __repmgr_net_init(env, db_rep)) != 0 ||
76 (ret = __repmgr_init_sync(env, db_rep)) != 0 ||
86 ret = __repmgr_become_master(env);
88 if ((ret = __repmgr_prepare_my_addr(env, &my_addr)) != 0)
91 __os_free(env, my_addr.data);
94 ret = __repmgr_init_election(env, ELECT_SEEK_MASTER);
101 if ((ret = __os_calloc(env, 1, sizeof(REPMGR_RUNNABLE), &selector))
104 selector->env = env;
106 if ((ret = __repmgr_thread_start(env, selector)) != 0) {
107 __db_err(env, ret, "can't start selector thread");
108 __os_free(env, selector);
114 if ((ret = __os_calloc(env, 1, sizeof(REPMGR_RUNNABLE),
118 messenger->env = env;
120 if ((ret = __repmgr_thread_start(env, messenger)) != 0) {
121 __os_free(env, messenger);
134 __repmgr_close(env)
135 ENV *env;
141 db_rep = env->rep_handle;
143 RPRINT(env, DB_VERB_REPMGR_MISC,
144 (env, "Stopping repmgr threads"));
145 ret = __repmgr_stop_threads(env);
146 if ((t_ret = __repmgr_await_threads(env)) != 0 && ret == 0)
148 RPRINT(env, DB_VERB_REPMGR_MISC,
149 (env, "Repmgr threads are finished"));
152 if ((t_ret = __repmgr_net_close(env)) != 0 && ret == 0)
155 if ((t_ret = __repmgr_close_sync(env)) != 0 && ret == 0)
169 ENV *env;
171 env = dbenv->env;
180 env->rep_handle->perm_policy = policy;
183 __db_errx(env,
197 ENV *env;
199 env = dbenv->env;
200 *policy = env->rep_handle->perm_policy;
208 __repmgr_env_create(env, db_rep)
209 ENV *env;
228 ret = __repmgr_queue_create(env, db_rep);
237 __repmgr_env_destroy(env, db_rep)
238 ENV *env;
241 __repmgr_queue_destroy(env);
242 __repmgr_net_destroy(env, db_rep);
244 __os_free(env, db_rep->messengers);
253 __repmgr_stop_threads(env)
254 ENV *env;
260 db_rep = env->rep_handle;
282 return (__repmgr_wake_main_thread(env));
290 __repmgr_await_threads(env)
291 ENV *env;
297 db_rep = env->rep_handle;
301 __os_free(env, db_rep->elect_thread);
309 __os_free(env, messenger);
312 __os_free(env, db_rep->messengers);
319 __os_free(env, db_rep->selector);
339 ENV *env;
343 env = dbenv->env;
346 return (__db_ferr(env, "DB_ENV->repmgr_set_local_site", 0));
348 db_rep = env->rep_handle;
350 __db_errx(env, "Listen address already set");
355 __db_errx(env,
361 env, host, port, AI_PASSIVE, &address_list)) != 0)
364 if ((ret = __repmgr_pack_netaddr(env,
366 __os_freeaddrinfo(env, address_list);
401 ENV *env;
405 env = dbenv->env;
407 if ((ret = __db_fchk(env,
412 __db_errx(env,
417 db_rep = env->rep_handle;
425 switch (ret = __repmgr_add_site(env, host, port, &site)) {