/dports/net/samba412/samba-4.12.15/ctdb/server/ |
H A D | ctdb_monitor.c | 113 struct ctdb_node *node = ctdb->nodes[ctdb->pnn]; in ctdb_health_callback() 176 tevent_add_timer(ctdb->ev, ctdb->monitor->monitor_context, in ctdb_health_callback() 190 ctdb_daemon_send_message(ctdb, ctdb->pnn, in ctdb_health_callback() 222 tevent_add_timer(ctdb->ev, ctdb->monitor->monitor_context, in ctdb_startup_callback() 239 tevent_add_timer(ctdb->ev, ctdb->monitor->monitor_context, in ctdb_startup_callback() 260 tevent_add_timer(ctdb->ev, ctdb->monitor->monitor_context, in ctdb_run_startup() 274 tevent_add_timer(ctdb->ev, ctdb->monitor->monitor_context, in ctdb_run_startup() 296 if (ctdb->nodes[ctdb->pnn]->flags & NODE_FLAGS_STOPPED) { in ctdb_wait_until_recovered() 433 ctdb->monitor = talloc(ctdb, struct ctdb_monitor_state); in ctdb_wait_for_first_recovery() 434 CTDB_NO_MEMORY_FATAL(ctdb, ctdb->monitor); in ctdb_wait_for_first_recovery() [all …]
|
H A D | ctdb_server.c | 42 ctdb->transport = talloc_strdup(ctdb, transport); in ctdb_set_transport() 43 CTDB_NO_MEMORY(ctdb, ctdb->transport); in ctdb_set_transport() 113 node->ctdb = ctdb; in convert_node_map_to_list() 126 node_map = ctdb_read_nodes_file(ctdb, ctdb->nodes_file); in ctdb_load_nodes_file() 132 ret = convert_node_map_to_list(ctdb, ctdb, node_map, in ctdb_load_nodes_file() 133 &ctdb->nodes, &ctdb->num_nodes); in ctdb_load_nodes_file() 153 ctdb->address = talloc(ctdb, ctdb_sock_addr); in ctdb_set_address() 154 CTDB_NO_MEMORY(ctdb, ctdb->address); in ctdb_set_address() 160 ctdb->name = talloc_asprintf(ctdb, "%s:%u", in ctdb_set_address() 208 if (ctdb->nodes[ctdb->pnn]->flags & NODE_FLAGS_BANNED) { in ctdb_input_pkt() [all …]
|
H A D | ctdbd.c | 83 if (ctdb == NULL) { in ctdb_init() 87 ctdb->ev = ev; in ctdb_init() 90 ret = reqid_init(ctdb, INT_MAX-200, &ctdb->idr); in ctdb_init() 93 talloc_free(ctdb); in ctdb_init() 97 ret = srvid_init(ctdb, &ctdb->srv); in ctdb_init() 100 talloc_free(ctdb); in ctdb_init() 104 ctdb->daemon.name = path_socket(ctdb, "ctdbd"); in ctdb_init() 145 return ctdb; in ctdb_init() 302 ctdb->nodes_file = talloc_asprintf(ctdb, "%s/nodes", ctdb_base); in main() 371 ctdb->event_script_dir = talloc_asprintf(ctdb, in main() [all …]
|
H A D | ctdb_daemon.c | 181 tevent_add_timer(ctdb->ev, ctdb, in ctdb_cpu_check_threshold() 189 tevent_add_timer(ctdb->ev, ctdb, in ctdb_start_cpu_check_threshold() 205 tevent_add_timer(ctdb->ev, ctdb, in ctdb_time_tick() 215 tevent_add_timer(ctdb->ev, ctdb, in ctdb_start_time_tickd() 717 dfc->w->ctdb = ctdb_db->ctdb; in requeue_duplicate_fetch() 770 w->ctdb = ctdb; in daemon_request_call_from_client() 1133 client->ctdb = ctdb; in ctdb_accept_client() 1153 client_pid->ctdb = ctdb; in ctdb_accept_client() 1383 ctdb->pnn = ctdb_ip_to_pnn(ctdb, ctdb->address); in ctdb_set_my_pnn() 1813 m->ctdb = ctdb; in ctdb_local_message() [all …]
|
H A D | ctdb_control.c | 44 struct ctdb_context *ctdb; member 135 ctdb->statistics.num_clients = ctdb->num_clients; in ctdb_control_dispatch() 136 ctdb->statistics.frozen = (ctdb_db_all_frozen(ctdb) ? 1 : 0); in ctdb_control_dispatch() 137 ctdb->statistics.recovering = (ctdb->recovery_mode == CTDB_RECOVERY_ACTIVE); in ctdb_control_dispatch() 162 for (ctdb_db = ctdb->db_list; in ctdb_control_dispatch() 215 return ctdb->recovery_mode; in ctdb_control_dispatch() 229 return ctdb->pnn; in ctdb_control_dispatch() 233 return ctdb->num_clients; in ctdb_control_dispatch() 828 ctdb->pnn, hdr->reqid)); in ctdb_reply_control() 925 state->ctdb = ctdb; in ctdb_daemon_send_control() [all …]
|
H A D | ctdb_recover.c | 79 ctdb->vnn_map = talloc(ctdb, struct ctdb_vnn_map); in ctdb_control_setvnnmap() 80 CTDB_NO_MEMORY(ctdb, ctdb->vnn_map); in ctdb_control_setvnnmap() 85 CTDB_NO_MEMORY(ctdb, ctdb->vnn_map->map); in ctdb_control_setvnnmap() 210 struct ctdb_context *ctdb = params->ctdb; in traverse_pulldb() local 269 params.ctdb = ctdb; in ctdb_control_pull_db() 390 state.ctdb = ctdb; in ctdb_control_db_pull() 656 state->ctdb = ctdb; in ctdb_control_db_push_start() 841 ctdb->release_ips_ctx = talloc_new(ctdb); in ctdb_deferred_drop_all_ips() 842 CTDB_NO_MEMORY(ctdb, ctdb->release_ips_ctx); in ctdb_deferred_drop_all_ips() 918 state->ctdb = ctdb; in ctdb_control_set_recmode() [all …]
|
H A D | ctdb_keepalive.c | 79 if (ctdb->methods == NULL) { in ctdb_send_keepalive() 85 r = ctdb_transport_allocate(ctdb, ctdb, CTDB_REQ_KEEPALIVE, in ctdb_send_keepalive() 88 CTDB_NO_MEMORY_FATAL(ctdb, r); in ctdb_send_keepalive() 97 ctdb_queue_packet(ctdb, &r->hdr); in ctdb_send_keepalive() 120 if (node->pnn == ctdb->pnn) { in ctdb_check_for_dead_nodes() 157 tevent_add_timer(ctdb->ev, ctdb->keepalive_ctx, in ctdb_check_for_dead_nodes() 167 ctdb->keepalive_ctx = talloc_new(ctdb); in ctdb_start_keepalive() 168 CTDB_NO_MEMORY_FATAL(ctdb, ctdb->keepalive_ctx); in ctdb_start_keepalive() 170 te = tevent_add_timer(ctdb->ev, ctdb->keepalive_ctx, in ctdb_start_keepalive() 173 CTDB_NO_MEMORY_FATAL(ctdb, te); in ctdb_start_keepalive() [all …]
|
H A D | ctdb_banning.c | 44 if (!ctdb_db_all_frozen(ctdb)) { in ctdb_ban_node_event() 47 ctdb_ban_self(ctdb); in ctdb_ban_node_event() 52 ctdb->nodes[ctdb->pnn]->flags &= ~NODE_FLAGS_BANNED; in ctdb_ban_node_event() 56 ctdb->banning_ctx = NULL; in ctdb_ban_node_event() 77 ctdb->banning_ctx = NULL; in ctdb_control_set_ban_state() 92 ctdb->banning_ctx = talloc(ctdb, struct ctdb_ban_state); in ctdb_control_set_ban_state() 103 tevent_add_timer(ctdb->ev, ctdb->banning_ctx, in ctdb_control_set_ban_state() 105 ctdb_ban_node_event, ctdb); in ctdb_control_set_ban_state() 118 CTDB_NO_MEMORY(ctdb, bantime); in ctdb_control_get_ban_state() 123 bantime->pnn = ctdb->pnn; in ctdb_control_get_ban_state() [all …]
|
H A D | ctdb_statistics.c | 40 …memmove(&ctdb->statistics_history[1], &ctdb->statistics_history[0], (MAX_STAT_HISTORY-1)*sizeof(st… in ctdb_statistics_update() 41 memcpy(&ctdb->statistics_history[0], &ctdb->statistics_current, sizeof(struct ctdb_statistics)); in ctdb_statistics_update() 48 tevent_add_timer(ctdb->ev, ctdb, in ctdb_statistics_update() 50 ctdb_statistics_update, ctdb); in ctdb_statistics_update() 53 int ctdb_statistics_init(struct ctdb_context *ctdb) in ctdb_statistics_init() argument 55 bzero(&ctdb->statistics, sizeof(struct ctdb_statistics)); in ctdb_statistics_init() 56 ctdb->statistics.statistics_start_time = timeval_current(); in ctdb_statistics_init() 61 bzero(ctdb->statistics_history, sizeof(ctdb->statistics_history)); in ctdb_statistics_init() 63 tevent_add_timer(ctdb->ev, ctdb, in ctdb_statistics_init() 65 ctdb_statistics_update, ctdb); in ctdb_statistics_init() [all …]
|
H A D | ctdb_fork.c | 75 if (ctdb->ev != NULL) { in ctdb_fork() 76 talloc_free(ctdb->ev); in ctdb_fork() 77 ctdb->ev = NULL; in ctdb_fork() 80 close(ctdb->daemon.sd); in ctdb_fork() 81 ctdb->daemon.sd = -1; in ctdb_fork() 83 if (ctdb->methods != NULL && ctdb->methods->shutdown != NULL) { in ctdb_fork() 84 ctdb->methods->shutdown(ctdb); in ctdb_fork() 88 if (ctdb->do_setsched) { in ctdb_fork() 101 ctdb_track_child(ctdb, pid); in ctdb_fork() 190 ctdb->child_processes = trbt_create(ctdb, 0); in ctdb_init_sigchld() [all …]
|
H A D | ctdb_recoverd.c | 281 struct ctdb_context *ctdb = rec->ctdb; in ctdb_ban_node() local 360 struct ctdb_context *ctdb = rec->ctdb; in update_capabilities() local 434 struct ctdb_context *ctdb = rec->ctdb; in update_flags_on_all_nodes() local 533 struct ctdb_context *ctdb = rec->ctdb; in ctdb_wait_election() local 549 struct ctdb_context *ctdb = rec->ctdb; in update_flags() local 693 struct ctdb_context *ctdb = rec->ctdb; in ctdb_recovery_lock() local 763 struct ctdb_context *ctdb = rec->ctdb; in ban_misbehaving_nodes() local 1673 ctdb->ev, ctdb, in election_handler() 1734 ctdb->ev, ctdb, in force_election() 2923 rec->ctdb = ctdb; in monitor_cluster() [all …]
|
H A D | ctdb_freeze.c | 113 struct ctdb_context *ctdb; member 254 CTDB_NO_MEMORY(ctdb, w); in ctdb_control_db_freeze() 255 w->ctdb = ctdb; in ctdb_control_db_freeze() 316 struct ctdb_context *ctdb = h->ctdb; in ctdb_freeze_handle_destructor() local 437 w->ctdb = h->ctdb; in db_freeze() 523 h->ctdb = ctdb; in ctdb_start_freeze() 525 ctdb->freeze_handle = h; in ctdb_start_freeze() 565 ctdb_start_freeze(ctdb); in ctdb_control_freeze() 585 CTDB_NO_MEMORY(ctdb, w); in ctdb_control_freeze() 586 w->ctdb = ctdb; in ctdb_control_freeze() [all …]
|
H A D | ctdb_takeover.c | 316 flags = ctdb->nodes[ctdb->pnn]->flags; in ctdb_vnn_available() 438 arp->ctdb = ctdb; in ctdb_announce_vnn_iface() 502 ctdb_daemon_send_message(ctdb, ctdb->pnn, CTDB_SRVID_TAKE_IP, data); in ctdb_do_takeip_callback() 1316 ip->ctdb = ctdb; in ctdb_control_tcp_client() 2102 tevent_add_timer(ctdb->ev, ctdb->tickle_update_context, in ctdb_update_tcp_tickles() 2112 ctdb->tickle_update_context = talloc_new(ctdb); in ctdb_start_tcp_tickle_update() 2114 tevent_add_timer(ctdb->ev, ctdb->tickle_update_context, in ctdb_start_tcp_tickle_update() 2189 arp->ctdb = ctdb; in ctdb_control_send_gratious_arp() 2416 ctdb->vnn = NULL; in ctdb_reloadips_child() 2500 ctdb, in ctdb_reloadips_child() [all …]
|
H A D | ctdb_client.c | 71 if (ctdb->vnn_map) { in _ctdbd_allocate_pkt() 87 struct ctdb_context *ctdb = ctdb_db->ctdb; in ctdb_call_local() local 90 CTDB_NO_MEMORY(ctdb, c); in ctdb_call_local() 296 ctdb->daemon.sd = -1; in ctdb_socket_connect() 313 ctdb->daemon.queue = ctdb_queue_setup(ctdb, ctdb, ctdb->daemon.sd, in ctdb_socket_connect() 388 struct ctdb_context *ctdb = ctdb_db->ctdb; in ctdb_client_call_local_send() local 420 struct ctdb_context *ctdb = ctdb_db->ctdb; in ctdb_call_send() local 533 return srvid_register(ctdb->srv, ctdb, srvid, handler, private_data); in ctdb_client_set_message_handler() 570 r = ctdbd_allocate_pkt(ctdb, ctdb, CTDB_REQ_MESSAGE, in ctdb_client_send_message() 718 state->ctdb = ctdb; in ctdb_control_send() [all …]
|
H A D | ctdb_ltdb_server.c | 61 struct ctdb_context *ctdb = ctdb_db->ctdb; in ctdb_ltdb_store_server() local 321 state->ctdb = ctdb_db->ctdb; in ctdb_ltdb_lock_requeue() 758 ctdb_db->ctdb = ctdb; in ctdb_local_attach() 1061 struct ctdb_context *ctdb = da_ctx->ctdb; in ctdb_deferred_attach_timeout() local 1072 struct ctdb_context *ctdb = da_ctx->ctdb; in ctdb_deferred_attach_callback() local 1110 struct ctdb_node *node = ctdb->nodes[ctdb->pnn]; in ctdb_control_db_attach() 1155 da_ctx->ctdb = ctdb; in ctdb_control_db_attach() 1381 ctdb->pnn); in ctdb_attach_databases() 1389 ctdb->db_persistent_health = tdb_wrap_open(ctdb, persistent_health_path, in ctdb_attach_databases() 1525 struct ctdb_context *ctdb = ctdb_db->ctdb; in ctdb_ltdb_seqnum_check() local [all …]
|
H A D | ctdb_call.c | 174 struct ctdb_context *ctdb = ctdb_db->ctdb; in ctdb_send_dmaster_reply() local 179 if (ctdb->pnn != ctdb_lmaster(ctdb, &key)) { in ctdb_send_dmaster_reply() 235 struct ctdb_context *ctdb = ctdb_db->ctdb; in ctdb_call_send_dmaster() local 345 struct ctdb_context *ctdb = ctdb_db->ctdb; in ctdb_become_dmaster() local 569 call->ctdb = ctdb_db->ctdb; in dmaster_defer_add() 725 sr->ctdb = ctdb; in ctdb_make_record_sticky() 758 struct ctdb_context *ctdb = handle->ctdb; in pinned_down_requeue() local 771 handle->ctdb = pinned_down->ctdb; in pinned_down_destructor() 814 pinned_down->ctdb = ctdb; in ctdb_defer_pinned_down_request() 1861 rev_hdl->ctdb = ctdb; in ctdb_start_revoke_ro_record() [all …]
|
H A D | ctdb_persistent.c | 41 struct ctdb_context *ctdb; member 69 if (ctdb->recovery_mode != CTDB_RECOVERY_NORMAL) { in ctdb_persistent_callback() 89 ctdb->recovery_mode = CTDB_RECOVERY_ACTIVE; in ctdb_persistent_callback() 205 ctdb_db = find_ctdb_db(ctdb, m->db_id); in ctdb_control_trans3_commit() 227 state->ctdb = ctdb; in ctdb_control_trans3_commit() 234 for (i = 0; i < ctdb->vnn_map->size; i++) { in ctdb_control_trans3_commit() 235 struct ctdb_node *node = ctdb->nodes[ctdb->vnn_map->map[i]]; in ctdb_control_trans3_commit() 272 tevent_add_timer(ctdb->ev, state, in ctdb_control_trans3_commit() 337 TALLOC_CTX *mem_ctx = talloc_new(ctdb); in ctdb_get_db_seqnum() 340 ctdb_db = find_ctdb_db(ctdb, db_id); in ctdb_get_db_seqnum() [all …]
|
/dports/net/samba412/samba-4.12.15/ctdb/include/ |
H A D | ctdb_private.h | 50 #define ctdb_validate_pnn(ctdb, pnn) (((uint32_t)(pnn)) < (ctdb)->num_nodes) argument 61 struct ctdb_context *ctdb; member 76 struct ctdb_context *ctdb; member 135 ctdb->statistics.counter = value; \ 144 ctdb->statistics.counter++; \ 150 if (ctdb->statistics.counter > 0) \ 151 ctdb->statistics.counter--; \ 184 ctdb->statistics.counter.num++; \ 221 ctdb->statistics.counter.max = l; \ 235 ctdb->statistics.counter.num++; \ [all …]
|
H A D | ctdb_client.h | 34 struct ctdb_context *ctdb; member 72 void ctdb_request_message(struct ctdb_context *ctdb, 77 int ctdb_socket_connect(struct ctdb_context *ctdb); 112 int ctdb_control_recv(struct ctdb_context *ctdb, 129 struct ctdb_context *ctdb, 150 struct ctdb_context *ctdb, 193 int ctdb_ctrl_get_ifaces(struct ctdb_context *ctdb, 210 uint32_t ctdb_get_pnn(struct ctdb_context *ctdb); 254 struct ctdb_context *ctdb, 274 struct ctdb_context *ctdb, [all …]
|
/dports/net/samba412/samba-4.12.15/ctdb/tcp/ |
H A D | tcp_init.c | 56 CTDB_NO_MEMORY(node->ctdb, tnode); 59 tnode->ctdb = node->ctdb; 75 if (ctdb_tcp_listen(ctdb) != 0) { 98 struct ctdb_context *ctdb = node->ctdb; 140 TALLOC_FREE(ctdb->transport_data); 191 ctcp->ctdb->transport_data = NULL; 192 ctcp->ctdb->methods = NULL; 205 CTDB_NO_MEMORY(ctdb, ctcp); 208 ctcp->ctdb = ctdb; 209 ctdb->transport_data = ctcp; [all …]
|
H A D | tcp_connect.c | 92 struct ctdb_context *ctdb = node->ctdb; in ctdb_node_connect_write() local 174 struct ctdb_context *ctdb = node->ctdb; in ctdb_tcp_start_outgoing() local 206 sock_in = *ctdb->address; in ctdb_tcp_start_outgoing() 410 if (ctdb->num_nodes == 0) { in ctdb_tcp_listen_automatic() 486 if (i == ctdb->num_nodes) { in ctdb_tcp_listen_automatic() 490 ctdb->address = talloc_memdup(ctdb, in ctdb_tcp_listen_automatic() 493 if (ctdb->address == NULL) { in ctdb_tcp_listen_automatic() 499 ctdb->name = talloc_asprintf(ctdb, "%s:%u", in ctdb_tcp_listen_automatic() 502 if (ctdb->name == NULL) { in ctdb_tcp_listen_automatic() 545 if (!ctdb->address) { in ctdb_tcp_listen() [all …]
|
/dports/net/samba412/samba-4.12.15/ctdb/packaging/RPM/ |
H A D | ctdb.spec.in | 3 Name: ctdb 12 URL: http://ctdb.samba.org/ 117 install -m644 config/ctdb.conf $RPM_BUILD_ROOT%{_sysconfdir}/ctdb 118 install -m644 config/ctdb.tunables $RPM_BUILD_ROOT%{_sysconfdir}/ctdb 129 install -m755 config/ctdb.init $RPM_BUILD_ROOT%{initdir}/ctdb 180 %config(noreplace) %{_sysconfdir}/ctdb/ctdb.conf 181 %config(noreplace) %{_sysconfdir}/ctdb/ctdb.tunables 185 %config(noreplace) %{_sysconfdir}/ctdb/ctdb-crash-cleanup.sh 218 %{_bindir}/ctdb 225 %dir %{_libdir}/ctdb [all …]
|
/dports/net/samba412/samba-4.12.15/ctdb/tools/ |
H A D | ctdb.c | 207 ctdb->nodemap = talloc_steal(ctdb, nodemap); in get_nodemap() 969 ret = ctdb_ctrl_ping(mem_ctx, ctdb->ev, ctdb->client, in control_ping() 1914 ctdb->client, ctdb->cmd_pnn, in control_process_exists() 2879 if (ctdb->pnn == ctdb->cmd_pnn) { in control_shutdown() 2892 if (ctdb->pnn == ctdb->cmd_pnn) { in control_shutdown() 3229 ctdb->client, ctdb->cmd_pnn, in process_clist_send() 3333 ctdb->client, ctdb->cmd_pnn, in control_addtickle() 6231 ctdb->ev = tevent_context_init(ctdb); in process_command() 6243 ret = ctdb_client_init(ctdb, ctdb->ev, ctdb_socket, &ctdb->client); in process_command() 6254 ctdb->pnn = ctdb_client_pnn(ctdb->client); in process_command() [all …]
|
/dports/net/samba412/samba-4.12.15/ctdb/tests/src/ |
H A D | cluster_mutex_test.c | 259 dl->ctdb = ctdb; in test_lock_unlock() 279 dl1->ctdb = ctdb; in test_lock_lock_unlock() 283 dl2->ctdb = ctdb; in test_lock_lock_unlock() 307 dl1->ctdb = ctdb; in test_lock_unlock_lock_unlock() 311 dl2->ctdb = ctdb; in test_lock_unlock_lock_unlock() 338 dl->ctdb = ctdb; in test_lock_cancel_check() 362 dl->ctdb = ctdb; in test_lock_cancel_unlock() 386 dl->ctdb = ctdb; in test_lock_wait_unlock() 429 dl->ctdb = ctdb; in test_lock_ppid_gone_lock_unlock() 542 dl->ctdb = ctdb; in test_lock_file_wait_recheck_unlock() [all …]
|
/dports/net/samba412/samba-4.12.15/ctdb/utils/pmda/ |
H A D | help | 18 # ctdb PMDA help file in the ASCII format 34 @ ctdb.num_clients number of clients connected to ctdbd 36 @ ctdb.frozen whether any databases are frozen 38 @ ctdb.recovering whether recovery is active 44 @ ctdb.node_packets_sent number of packets sent to other nodes 80 @ ctdb.total_calls total number of client ctdb request calls received 82 @ ctdb.pending_calls total number of client ctdb request calls in progress 84 @ ctdb.lockwait_calls number of tdb chainlock lockwait calls 88 @ ctdb.childwrite_calls number of childwrite calls 92 @ ctdb.memory_used total size of the ctdbd null talloc pool [all …]
|