Home
last modified time | relevance | path

Searched refs:ctdb (Results 1 – 25 of 198) sorted by relevance

12345678

/dports/net/samba412/samba-4.12.15/ctdb/server/
H A Dctdb_monitor.c113 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 Dctdb_server.c42 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 Dctdbd.c83 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 Dctdb_daemon.c181 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 Dctdb_control.c44 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 Dctdb_recover.c79 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 Dctdb_keepalive.c79 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 Dctdb_banning.c44 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 Dctdb_statistics.c40 …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 Dctdb_fork.c75 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 Dctdb_recoverd.c281 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 Dctdb_freeze.c113 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 Dctdb_takeover.c316 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 Dctdb_client.c71 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 Dctdb_ltdb_server.c61 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 Dctdb_call.c174 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 Dctdb_persistent.c41 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 Dctdb_private.h50 #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 Dctdb_client.h34 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 Dtcp_init.c56 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 Dtcp_connect.c92 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 Dctdb.spec.in3 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 Dctdb.c207 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 Dcluster_mutex_test.c259 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 Dhelp18 # 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 …]

12345678