clm.c 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790
  1. /*
  2. * Copyright (c) 2002-2006 MontaVista Software, Inc.
  3. * Copyright (c) 2006 Red Hat, Inc.
  4. *
  5. * All rights reserved.
  6. *
  7. * Author: Steven Dake (sdake@mvista.com)
  8. *
  9. * This software licensed under BSD license, the text of which follows:
  10. *
  11. * Redistribution and use in source and binary forms, with or without
  12. * modification, are permitted provided that the following conditions are met:
  13. *
  14. * - Redistributions of source code must retain the above copyright notice,
  15. * this list of conditions and the following disclaimer.
  16. * - Redistributions in binary form must reproduce the above copyright notice,
  17. * this list of conditions and the following disclaimer in the documentation
  18. * and/or other materials provided with the distribution.
  19. * - Neither the name of the MontaVista Software, Inc. nor the names of its
  20. * contributors may be used to endorse or promote products derived from this
  21. * software without specific prior written permission.
  22. *
  23. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  24. * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  25. * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  26. * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
  27. * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  28. * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  29. * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  30. * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  31. * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  32. * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
  33. * THE POSSIBILITY OF SUCH DAMAGE.
  34. */
  35. #include <sys/types.h>
  36. #include <sys/socket.h>
  37. #include <sys/un.h>
  38. #if defined(OPENAIS_LINUX)
  39. #include <sys/sysinfo.h>
  40. #endif
  41. #if defined(OPENAIS_BSD) || defined(OPENAIS_DARWIN)
  42. #include <sys/sysctl.h>
  43. #endif
  44. #include <sys/ioctl.h>
  45. #include <netinet/in.h>
  46. #include <sys/uio.h>
  47. #include <unistd.h>
  48. #include <fcntl.h>
  49. #include <stdlib.h>
  50. #include <stdio.h>
  51. #include <errno.h>
  52. #include <signal.h>
  53. #include <time.h>
  54. #include <unistd.h>
  55. #include <netinet/in.h>
  56. #include <arpa/inet.h>
  57. #include "totem.h"
  58. #include "../include/saAis.h"
  59. #include "../include/saClm.h"
  60. #include "../include/ipc_gen.h"
  61. #include "../include/ipc_clm.h"
  62. #include "../include/mar_gen.h"
  63. #include "../include/mar_clm.h"
  64. #include "../include/list.h"
  65. #include "../include/queue.h"
  66. #include "../lcr/lcr_comp.h"
  67. #include "aispoll.h"
  68. #include "totempg.h"
  69. #include "main.h"
  70. #include "mempool.h"
  71. #include "service.h"
  72. #include "swab.h"
  73. #include "print.h"
  74. enum clm_message_req_types {
  75. MESSAGE_REQ_EXEC_CLM_NODEJOIN = 0
  76. };
  77. mar_clm_cluster_change_t my_cluster_node_last_change = SA_CLM_NODE_JOINED;
  78. mar_clm_cluster_node_t my_cluster_node;
  79. static mar_clm_cluster_node_t cluster_node_entries[PROCESSOR_COUNT_MAX];
  80. static int cluster_node_count = 0;
  81. static unsigned long long view_current = 0;
  82. static unsigned long long view_initial = 0;
  83. static DECLARE_LIST_INIT (library_notification_send_listhead);
  84. SaClmClusterNodeT *clm_get_by_nodeid (unsigned int node_id)
  85. {
  86. static SaClmClusterNodeT cluster_node;
  87. int i;
  88. if (node_id == SA_CLM_LOCAL_NODE_ID) {
  89. marshall_from_mar_clm_cluster_node_t (
  90. &cluster_node,
  91. &cluster_node_entries[0]);
  92. return (&cluster_node);
  93. }
  94. for (i = 0; i < cluster_node_count; i++) {
  95. if (cluster_node_entries[i].node_id == node_id) {
  96. marshall_from_mar_clm_cluster_node_t (
  97. &cluster_node,
  98. &cluster_node_entries[i]);
  99. return (&cluster_node);
  100. break;
  101. }
  102. }
  103. return (NULL);
  104. }
  105. /*
  106. * Service Interfaces required by service_message_handler struct
  107. */
  108. static void clm_confchg_fn (
  109. enum totem_configuration_type configuration_type,
  110. unsigned int *member_list, int member_list_entries,
  111. unsigned int *left_list, int left_list_entries,
  112. unsigned int *joined_list, int joined_list_entries,
  113. struct memb_ring_id *ring_id);
  114. static void clm_sync_init (void);
  115. static int clm_sync_process (void);
  116. static void clm_sync_activate (void);
  117. static void clm_sync_abort (void);
  118. static int clm_exec_init_fn (struct objdb_iface_ver0 *objdb);
  119. static int clm_lib_init_fn (void *conn);
  120. static int clm_lib_exit_fn (void *conn);
  121. static void message_handler_req_exec_clm_nodejoin (
  122. void *message,
  123. unsigned int nodeid);
  124. static void exec_clm_nodejoin_endian_convert (void *msg);
  125. static void message_handler_req_lib_clm_clustertrack (void *conn, void *message);
  126. static void message_handler_req_lib_clm_trackstop (void *conn, void *message);
  127. static void message_handler_req_lib_clm_nodeget (void *conn, void *message);
  128. static void message_handler_req_lib_clm_nodegetasync (void *conn, void *message);
  129. struct clm_pd {
  130. unsigned char track_flags;
  131. int tracking_enabled;
  132. struct list_head list;
  133. void *conn;
  134. };
  135. /*
  136. * Executive Handler Definition
  137. */
  138. static struct openais_lib_handler clm_lib_service[] =
  139. {
  140. { /* 0 */
  141. .lib_handler_fn = message_handler_req_lib_clm_clustertrack,
  142. .response_size = sizeof (struct res_lib_clm_clustertrack),
  143. .response_id = MESSAGE_RES_CLM_TRACKSTART, // TODO RESPONSE
  144. .flow_control = OPENAIS_FLOW_CONTROL_NOT_REQUIRED
  145. },
  146. { /* 1 */
  147. .lib_handler_fn = message_handler_req_lib_clm_trackstop,
  148. .response_size = sizeof (struct res_lib_clm_trackstop),
  149. .response_id = MESSAGE_RES_CLM_TRACKSTOP, // TODO RESPONSE
  150. .flow_control = OPENAIS_FLOW_CONTROL_NOT_REQUIRED
  151. },
  152. { /* 2 */
  153. .lib_handler_fn = message_handler_req_lib_clm_nodeget,
  154. .response_size = sizeof (struct res_clm_nodeget),
  155. .response_id = MESSAGE_RES_CLM_NODEGET, // TODO RESPONSE
  156. .flow_control = OPENAIS_FLOW_CONTROL_NOT_REQUIRED
  157. },
  158. { /* 3 */
  159. .lib_handler_fn = message_handler_req_lib_clm_nodegetasync,
  160. .response_size = sizeof (struct res_clm_nodegetasync),
  161. .response_id = MESSAGE_RES_CLM_NODEGETCALLBACK, // TODO RESPONSE
  162. .flow_control = OPENAIS_FLOW_CONTROL_NOT_REQUIRED
  163. }
  164. };
  165. static struct openais_exec_handler clm_exec_service[] =
  166. {
  167. {
  168. .exec_handler_fn = message_handler_req_exec_clm_nodejoin,
  169. .exec_endian_convert_fn = exec_clm_nodejoin_endian_convert
  170. }
  171. };
  172. struct openais_service_handler clm_service_handler = {
  173. .name = (unsigned char*)"openais cluster membership service B.01.01",
  174. .id = CLM_SERVICE,
  175. .private_data_size = sizeof (struct clm_pd),
  176. .lib_init_fn = clm_lib_init_fn,
  177. .lib_exit_fn = clm_lib_exit_fn,
  178. .lib_service = clm_lib_service,
  179. .lib_service_count = sizeof (clm_lib_service) / sizeof (struct openais_lib_handler),
  180. .exec_init_fn = clm_exec_init_fn,
  181. .exec_dump_fn = NULL,
  182. .exec_service = clm_exec_service,
  183. .exec_service_count = sizeof (clm_exec_service) / sizeof (struct openais_exec_handler),
  184. .confchg_fn = clm_confchg_fn,
  185. .sync_init = clm_sync_init,
  186. .sync_process = clm_sync_process,
  187. .sync_activate = clm_sync_activate,
  188. .sync_abort = clm_sync_abort,
  189. };
  190. /*
  191. * Dynamic loader definition
  192. */
  193. static struct openais_service_handler *clm_get_service_handler_ver0 (void);
  194. static struct openais_service_handler_iface_ver0 clm_service_handler_iface = {
  195. .openais_get_service_handler_ver0 = clm_get_service_handler_ver0
  196. };
  197. static struct lcr_iface openais_clm_ver0[1] = {
  198. {
  199. .name = "openais_clm",
  200. .version = 0,
  201. .versions_replace = 0,
  202. .versions_replace_count = 0,
  203. .dependencies = 0,
  204. .dependency_count = 0,
  205. .constructor = NULL,
  206. .destructor = NULL,
  207. .interfaces = NULL
  208. }
  209. };
  210. static struct lcr_comp clm_comp_ver0 = {
  211. .iface_count = 1,
  212. .ifaces = openais_clm_ver0
  213. };
  214. static struct openais_service_handler *clm_get_service_handler_ver0 (void)
  215. {
  216. return (&clm_service_handler);
  217. }
  218. __attribute__ ((constructor)) static void clm_comp_register (void) {
  219. lcr_interfaces_set (&openais_clm_ver0[0], &clm_service_handler_iface);
  220. lcr_component_register (&clm_comp_ver0);
  221. }
  222. struct req_exec_clm_nodejoin {
  223. struct req_header header __attribute__((aligned(8)));
  224. mar_clm_cluster_node_t cluster_node __attribute__((aligned(8)));
  225. };
  226. static int clm_exec_init_fn (struct objdb_iface_ver0 *objdb)
  227. {
  228. log_init ("CLM");
  229. memset (cluster_node_entries, 0,
  230. sizeof (mar_clm_cluster_node_t) * PROCESSOR_COUNT_MAX);
  231. /*
  232. * Build local cluster node data structure
  233. */
  234. sprintf ((char *)my_cluster_node.node_address.value, "%s",
  235. totemip_print (this_ip));
  236. my_cluster_node.node_address.length =
  237. strlen ((char *)my_cluster_node.node_address.value);
  238. if (this_ip->family == AF_INET) {
  239. my_cluster_node.node_address.family = SA_CLM_AF_INET;
  240. } else
  241. if (this_ip->family == AF_INET6) {
  242. my_cluster_node.node_address.family = SA_CLM_AF_INET6;
  243. } else {
  244. assert (0);
  245. }
  246. strcpy ((char *)my_cluster_node.node_name.value,
  247. (char *)my_cluster_node.node_address.value);
  248. my_cluster_node.node_name.length =
  249. my_cluster_node.node_address.length;
  250. my_cluster_node.node_id = this_ip->nodeid;
  251. my_cluster_node.member = 1;
  252. {
  253. #if defined(OPENAIS_LINUX)
  254. struct sysinfo s_info;
  255. time_t current_time;
  256. sysinfo (&s_info);
  257. current_time = time (NULL);
  258. /* (currenttime (s) - uptime (s)) * 1 billion (ns) / 1 (s) */
  259. my_cluster_node.boot_timestamp = ((SaTimeT)(current_time - s_info.uptime)) * 1000000000;
  260. #elif defined(OPENAIS_BSD) || defined(OPENAIS_DARWIN)
  261. int mib[2] = { CTL_KERN, KERN_BOOTTIME };
  262. struct timeval boot_time;
  263. size_t size = sizeof(boot_time);
  264. if ( sysctl(mib, 2, &boot_time, &size, NULL, 0) == -1 )
  265. boot_time.tv_sec = time (NULL);
  266. /* (currenttime (s) - uptime (s)) * 1 billion (ns) / 1 (s) */
  267. my_cluster_node.boot_timestmap = ((SaTimeT)boot_time.tv_sec) * 1000000000;
  268. #else /* defined(CTL_KERN) && defined(KERN_BOOTTIME) */
  269. #warning "no bootime support"
  270. #endif
  271. }
  272. memcpy (&cluster_node_entries[0], &my_cluster_node, sizeof (mar_clm_cluster_node_t));
  273. cluster_node_count = 1;
  274. main_clm_get_by_nodeid = clm_get_by_nodeid;
  275. return (0);
  276. }
  277. static int clm_lib_exit_fn (void *conn)
  278. {
  279. struct clm_pd *clm_pd = (struct clm_pd *)openais_conn_private_data_get (conn);
  280. /*
  281. * Delete track entry if there is one
  282. */
  283. list_del (&clm_pd->list);
  284. clm_pd->conn = conn;
  285. return (0);
  286. }
  287. static void library_notification_send (
  288. mar_clm_cluster_notification_t *cluster_notification_entries,
  289. int notify_count)
  290. {
  291. struct res_lib_clm_clustertrack res_lib_clm_clustertrack;
  292. struct clm_pd *clm_pd;
  293. struct list_head *list;
  294. int i;
  295. if (notify_count == 0) {
  296. return;
  297. }
  298. res_lib_clm_clustertrack.header.size = sizeof (struct res_lib_clm_clustertrack);
  299. res_lib_clm_clustertrack.header.id = MESSAGE_RES_CLM_TRACKCALLBACK;
  300. res_lib_clm_clustertrack.header.error = SA_AIS_OK;
  301. res_lib_clm_clustertrack.view = view_current;
  302. for (list = library_notification_send_listhead.next;
  303. list != &library_notification_send_listhead;
  304. list = list->next) {
  305. clm_pd = list_entry (list, struct clm_pd, list);
  306. /*
  307. * Track current and changes
  308. */
  309. if (clm_pd->track_flags & SA_TRACK_CHANGES) {
  310. /*
  311. * Copy all cluster nodes
  312. */
  313. for (i = 0; i < cluster_node_count; i++) {
  314. memcpy (&res_lib_clm_clustertrack.notification[i].cluster_node,
  315. &cluster_node_entries[i], sizeof (mar_clm_cluster_node_t));
  316. res_lib_clm_clustertrack.notification[i].cluster_change = SA_CLM_NODE_NO_CHANGE;
  317. res_lib_clm_clustertrack.notification[i].cluster_node.member = 1;
  318. }
  319. /*
  320. * Copy change_only notificaiton
  321. */
  322. res_lib_clm_clustertrack.number_of_items = notify_count + i;
  323. memcpy (&res_lib_clm_clustertrack.notification[i],
  324. cluster_notification_entries,
  325. sizeof (mar_clm_cluster_notification_t) * notify_count);
  326. } else
  327. /*
  328. * Track only changes
  329. */
  330. if (clm_pd->track_flags & SA_TRACK_CHANGES_ONLY) {
  331. res_lib_clm_clustertrack.number_of_items = notify_count;
  332. memcpy (&res_lib_clm_clustertrack.notification,
  333. cluster_notification_entries,
  334. sizeof (mar_clm_cluster_notification_t) * notify_count);
  335. }
  336. /*
  337. * Send notifications to all CLM listeners
  338. */
  339. openais_conn_send_response (
  340. clm_pd->conn,
  341. &res_lib_clm_clustertrack,
  342. sizeof (struct res_lib_clm_clustertrack));
  343. }
  344. }
  345. static void notification_join (mar_clm_cluster_node_t *cluster_node)
  346. {
  347. mar_clm_cluster_notification_t notification;
  348. /*
  349. * Generate notification element
  350. */
  351. notification.cluster_change = SA_CLM_NODE_JOINED;
  352. notification.cluster_node.member = 1;
  353. memcpy (&notification.cluster_node, cluster_node,
  354. sizeof (mar_clm_cluster_node_t));
  355. library_notification_send (&notification, 1);
  356. }
  357. static void lib_notification_leave (unsigned int *nodes, int nodes_entries)
  358. {
  359. mar_clm_cluster_notification_t cluster_notification[PROCESSOR_COUNT_MAX];
  360. int i, j;
  361. int notify_count;
  362. /*
  363. * Determine notification list
  364. */
  365. for (notify_count = 0, i = 0; i < cluster_node_count; i++) {
  366. for (j = 0; j < nodes_entries; j++) {
  367. if (cluster_node_entries[i].node_id == nodes[j]) {
  368. memcpy (&cluster_notification[notify_count].cluster_node,
  369. &cluster_node_entries[i],
  370. sizeof (mar_clm_cluster_node_t));
  371. cluster_notification[notify_count].cluster_change = SA_CLM_NODE_LEFT;
  372. cluster_notification[notify_count].cluster_node.member = 0;
  373. notify_count += 1;
  374. break;
  375. }
  376. }
  377. }
  378. /*
  379. * Remove entries from cluster_node_entries array
  380. */
  381. for (i = 0; i < nodes_entries; i++) {
  382. for (j = 0; j < cluster_node_count;) {
  383. if (nodes[i] == cluster_node_entries[j].node_id) {
  384. cluster_node_count -= 1;
  385. memmove (&cluster_node_entries[j], &cluster_node_entries[j + 1],
  386. (cluster_node_count - j) * sizeof (mar_clm_cluster_node_t));
  387. } else {
  388. /*
  389. * next cluster_node entry
  390. */
  391. j++;
  392. }
  393. }
  394. }
  395. library_notification_send (cluster_notification, notify_count);
  396. }
  397. static int clm_nodejoin_send (void)
  398. {
  399. struct req_exec_clm_nodejoin req_exec_clm_nodejoin;
  400. struct iovec req_exec_clm_iovec;
  401. int result;
  402. req_exec_clm_nodejoin.header.size = sizeof (struct req_exec_clm_nodejoin);
  403. req_exec_clm_nodejoin.header.id =
  404. SERVICE_ID_MAKE (CLM_SERVICE, MESSAGE_REQ_EXEC_CLM_NODEJOIN);
  405. my_cluster_node.initial_view_number = view_initial;
  406. memcpy (&req_exec_clm_nodejoin.cluster_node, &my_cluster_node,
  407. sizeof (mar_clm_cluster_node_t));
  408. req_exec_clm_iovec.iov_base = (char *)&req_exec_clm_nodejoin;
  409. req_exec_clm_iovec.iov_len = sizeof (req_exec_clm_nodejoin);
  410. result = totempg_groups_mcast_joined (openais_group_handle, &req_exec_clm_iovec, 1, TOTEMPG_AGREED);
  411. return (result);
  412. }
  413. static void clm_confchg_fn (
  414. enum totem_configuration_type configuration_type,
  415. unsigned int *member_list, int member_list_entries,
  416. unsigned int *left_list, int left_list_entries,
  417. unsigned int *joined_list, int joined_list_entries,
  418. struct memb_ring_id *ring_id)
  419. {
  420. int i;
  421. unsigned int node_ids[PROCESSOR_COUNT_MAX];
  422. view_current = ring_id->seq / 4;
  423. if (view_initial == 0) {
  424. view_initial = ring_id->seq / 4;
  425. }
  426. log_printf (LOG_LEVEL_NOTICE, "CLM CONFIGURATION CHANGE\n");
  427. log_printf (LOG_LEVEL_NOTICE, "New Configuration:\n");
  428. for (i = 0; i < member_list_entries; i++) {
  429. log_printf (LOG_LEVEL_NOTICE, "\t%s\n", totempg_ifaces_print (member_list[i]));
  430. }
  431. log_printf (LOG_LEVEL_NOTICE, "Members Left:\n");
  432. for (i = 0; i < left_list_entries; i++) {
  433. log_printf (LOG_LEVEL_NOTICE, "\t%s\n", totempg_ifaces_print (left_list[i]));
  434. }
  435. log_printf (LOG_LEVEL_NOTICE, "Members Joined:\n");
  436. for (i = 0; i < joined_list_entries; i++) {
  437. log_printf (LOG_LEVEL_NOTICE, "\t%s\n", totempg_ifaces_print (joined_list[i]));
  438. }
  439. for (i = 0; i < left_list_entries; i++) {
  440. node_ids[i] = left_list[i];
  441. }
  442. lib_notification_leave (node_ids, i);
  443. /*
  444. * Load the my_cluster_node data structure in case we are
  445. * transitioning to network interface up or down
  446. */
  447. sprintf ((char *)my_cluster_node.node_address.value, "%s", totemip_print (this_ip));
  448. my_cluster_node.node_address.length = strlen ((char *)my_cluster_node.node_address.value);
  449. if (this_ip->family == AF_INET) {
  450. my_cluster_node.node_address.family = SA_CLM_AF_INET;
  451. } else
  452. if (this_ip->family == AF_INET6) {
  453. my_cluster_node.node_address.family = SA_CLM_AF_INET6;
  454. } else {
  455. assert (0);
  456. }
  457. strcpy ((char *)my_cluster_node.node_name.value,
  458. (char *)my_cluster_node.node_address.value);
  459. my_cluster_node.node_name.length = my_cluster_node.node_address.length;
  460. my_cluster_node.node_id = this_ip->nodeid;
  461. }
  462. /*
  463. * This is a noop for this service
  464. */
  465. static void clm_sync_init (void)
  466. {
  467. return;
  468. }
  469. /*
  470. * If a processor joined in the configuration change and clm_sync_activate hasn't
  471. * yet been called, issue a node join to share CLM specific data about the processor
  472. */
  473. static int clm_sync_process (void)
  474. {
  475. /*
  476. * Send node information to other nodes
  477. */
  478. return (clm_nodejoin_send ());
  479. }
  480. /*
  481. * This is a noop for this service
  482. */
  483. static void clm_sync_activate (void)
  484. {
  485. return;
  486. }
  487. /*
  488. * This is a noop for this service
  489. */
  490. static void clm_sync_abort (void)
  491. {
  492. return;
  493. }
  494. static void exec_clm_nodejoin_endian_convert (void *msg)
  495. {
  496. struct req_exec_clm_nodejoin *node_join = msg;
  497. node_join->cluster_node.node_id = swab32(node_join->cluster_node.node_id);
  498. node_join->cluster_node.node_address.family = swab32(node_join->cluster_node.node_address.family);
  499. node_join->cluster_node.node_address.length = swab16(node_join->cluster_node.node_address.length);
  500. node_join->cluster_node.initial_view_number = swab64(node_join->cluster_node.initial_view_number);
  501. node_join->cluster_node.boot_timestamp = swab64(node_join->cluster_node.boot_timestamp);
  502. }
  503. static void message_handler_req_exec_clm_nodejoin (
  504. void *message,
  505. unsigned int nodeid)
  506. {
  507. struct req_exec_clm_nodejoin *req_exec_clm_nodejoin = (struct req_exec_clm_nodejoin *)message;
  508. int found = 0;
  509. int i;
  510. log_printf (LOG_LEVEL_NOTICE, "got nodejoin message %s\n",
  511. req_exec_clm_nodejoin->cluster_node.node_name.value);
  512. /*
  513. * Determine if nodejoin already received
  514. */
  515. for (found = 0, i = 0; i < cluster_node_count; i++) {
  516. if (cluster_node_entries[i].node_id == req_exec_clm_nodejoin->cluster_node.node_id) {
  517. found = 1;
  518. }
  519. }
  520. /*
  521. * If not received, add to internal list
  522. */
  523. if (found == 0) {
  524. notification_join (&req_exec_clm_nodejoin->cluster_node);
  525. memcpy (&cluster_node_entries[cluster_node_count],
  526. &req_exec_clm_nodejoin->cluster_node,
  527. sizeof (mar_clm_cluster_node_t));
  528. cluster_node_count += 1;
  529. }
  530. }
  531. static int clm_lib_init_fn (void *conn)
  532. {
  533. log_printf (LOG_LEVEL_DEBUG, "Got request to initalize cluster membership service.\n");
  534. struct clm_pd *clm_pd = (struct clm_pd *)openais_conn_private_data_get (conn);
  535. list_init (&clm_pd->list);
  536. clm_pd->conn = conn;
  537. return (0);
  538. }
  539. static void message_handler_req_lib_clm_clustertrack (void *conn, void *msg)
  540. {
  541. struct req_lib_clm_clustertrack *req_lib_clm_clustertrack = (struct req_lib_clm_clustertrack *)msg;
  542. struct res_lib_clm_clustertrack res_lib_clm_clustertrack;
  543. struct clm_pd *clm_pd = (struct clm_pd *)openais_conn_private_data_get (conn);
  544. int i;
  545. res_lib_clm_clustertrack.header.size = sizeof (struct res_lib_clm_clustertrack);
  546. res_lib_clm_clustertrack.header.id = MESSAGE_RES_CLM_TRACKSTART;
  547. res_lib_clm_clustertrack.header.error = SA_AIS_OK;
  548. res_lib_clm_clustertrack.view = view_current;
  549. res_lib_clm_clustertrack.number_of_items = 0;
  550. /*
  551. * If an immediate listing of the current cluster membership
  552. * is requested, generate membership list
  553. */
  554. if (req_lib_clm_clustertrack->track_flags & SA_TRACK_CURRENT ||
  555. req_lib_clm_clustertrack->track_flags & SA_TRACK_CHANGES) {
  556. for (i = 0; i < cluster_node_count; i++) {
  557. res_lib_clm_clustertrack.notification[i].cluster_change = SA_CLM_NODE_NO_CHANGE;
  558. memcpy (&res_lib_clm_clustertrack.notification[i].cluster_node,
  559. &cluster_node_entries[i], sizeof (mar_clm_cluster_node_t));
  560. }
  561. res_lib_clm_clustertrack.number_of_items = cluster_node_count;
  562. }
  563. /*
  564. * Record requests for cluster tracking
  565. */
  566. if (req_lib_clm_clustertrack->track_flags & SA_TRACK_CHANGES ||
  567. req_lib_clm_clustertrack->track_flags & SA_TRACK_CHANGES_ONLY) {
  568. clm_pd->track_flags = req_lib_clm_clustertrack->track_flags;
  569. clm_pd->tracking_enabled = 1;
  570. list_add (&clm_pd->list, &library_notification_send_listhead);
  571. }
  572. openais_conn_send_response (conn, &res_lib_clm_clustertrack,
  573. sizeof (struct res_lib_clm_clustertrack));
  574. if (req_lib_clm_clustertrack->return_in_callback) {
  575. res_lib_clm_clustertrack.header.id = MESSAGE_RES_CLM_TRACKCALLBACK;
  576. openais_conn_send_response (
  577. openais_conn_partner_get (conn),
  578. &res_lib_clm_clustertrack,
  579. sizeof (struct res_lib_clm_clustertrack));
  580. }
  581. }
  582. static void message_handler_req_lib_clm_trackstop (void *conn, void *msg)
  583. {
  584. struct res_lib_clm_trackstop res_lib_clm_trackstop;
  585. struct clm_pd *clm_pd = (struct clm_pd *)openais_conn_private_data_get (conn);
  586. res_lib_clm_trackstop.header.size = sizeof (struct res_lib_clm_trackstop);
  587. res_lib_clm_trackstop.header.id = MESSAGE_RES_CLM_TRACKSTOP;
  588. if (clm_pd->tracking_enabled) {
  589. res_lib_clm_trackstop.header.error = SA_AIS_OK;
  590. clm_pd->tracking_enabled = 0;
  591. } else {
  592. res_lib_clm_trackstop.header.error = SA_AIS_ERR_NOT_EXIST;
  593. }
  594. list_del (&clm_pd->list);
  595. list_init (&clm_pd->list);
  596. openais_conn_send_response (conn, &res_lib_clm_trackstop,
  597. sizeof (struct res_lib_clm_trackstop));
  598. }
  599. static void message_handler_req_lib_clm_nodeget (void *conn, void *msg)
  600. {
  601. struct req_lib_clm_nodeget *req_lib_clm_nodeget = (struct req_lib_clm_nodeget *)msg;
  602. struct res_clm_nodeget res_clm_nodeget;
  603. mar_clm_cluster_node_t *cluster_node = 0;
  604. int valid = 0;
  605. int i;
  606. log_printf (LOG_LEVEL_NOTICE, "nodeget: trying to find node %x\n",
  607. (int)req_lib_clm_nodeget->node_id);
  608. if (req_lib_clm_nodeget->node_id == SA_CLM_LOCAL_NODE_ID) {
  609. cluster_node = &cluster_node_entries[0];
  610. valid = 1;
  611. } else
  612. for (i = 0; i < cluster_node_count; i++) {
  613. if (cluster_node_entries[i].node_id == req_lib_clm_nodeget->node_id) {
  614. log_printf (LOG_LEVEL_DEBUG, "found host that matches one desired in nodeget.\n");
  615. cluster_node = &cluster_node_entries[i];
  616. valid = 1;
  617. break;
  618. }
  619. }
  620. res_clm_nodeget.header.size = sizeof (struct res_clm_nodeget);
  621. res_clm_nodeget.header.id = MESSAGE_RES_CLM_NODEGET;
  622. res_clm_nodeget.header.error = SA_AIS_OK;
  623. res_clm_nodeget.invocation = req_lib_clm_nodeget->invocation;
  624. res_clm_nodeget.valid = valid;
  625. if (valid) {
  626. memcpy (&res_clm_nodeget.cluster_node, cluster_node, sizeof (mar_clm_cluster_node_t));
  627. }
  628. openais_conn_send_response (conn, &res_clm_nodeget, sizeof (struct res_clm_nodeget));
  629. }
  630. static void message_handler_req_lib_clm_nodegetasync (void *conn, void *msg)
  631. {
  632. struct req_lib_clm_nodegetasync *req_lib_clm_nodegetasync = (struct req_lib_clm_nodegetasync *)msg;
  633. struct res_clm_nodegetasync res_clm_nodegetasync;
  634. struct res_clm_nodegetcallback res_clm_nodegetcallback;
  635. mar_clm_cluster_node_t *cluster_node = 0;
  636. int error = SA_AIS_ERR_INVALID_PARAM;
  637. int i;
  638. log_printf (LOG_LEVEL_DEBUG, "nodeget: trying to find node %x\n",
  639. (int)req_lib_clm_nodegetasync->node_id);
  640. if (req_lib_clm_nodegetasync->node_id == SA_CLM_LOCAL_NODE_ID) {
  641. cluster_node = &cluster_node_entries[0];
  642. error = SA_AIS_OK;
  643. } else
  644. for (i = 0; i < cluster_node_count; i++) {
  645. if (cluster_node_entries[i].node_id == req_lib_clm_nodegetasync->node_id) {
  646. log_printf (LOG_LEVEL_DEBUG, "found host that matches one desired in nodeget.\n");
  647. cluster_node = &cluster_node_entries[i];
  648. error = SA_AIS_OK;
  649. break;
  650. }
  651. }
  652. /*
  653. * Respond to library request
  654. */
  655. res_clm_nodegetasync.header.size = sizeof (struct res_clm_nodegetasync);
  656. res_clm_nodegetasync.header.id = MESSAGE_RES_CLM_NODEGETASYNC;
  657. res_clm_nodegetasync.header.error = SA_AIS_OK;
  658. openais_conn_send_response (conn, &res_clm_nodegetasync,
  659. sizeof (struct res_clm_nodegetasync));
  660. /*
  661. * Send async response
  662. */
  663. res_clm_nodegetcallback.header.size = sizeof (struct res_clm_nodegetcallback);
  664. res_clm_nodegetcallback.header.id = MESSAGE_RES_CLM_NODEGETCALLBACK;
  665. res_clm_nodegetcallback.header.error = error;
  666. res_clm_nodegetcallback.invocation = req_lib_clm_nodegetasync->invocation;
  667. if (error == SA_AIS_OK) {
  668. memcpy (&res_clm_nodegetcallback.cluster_node, cluster_node,
  669. sizeof (mar_clm_cluster_node_t));
  670. }
  671. openais_conn_send_response (openais_conn_partner_get (conn),
  672. &res_clm_nodegetcallback,
  673. sizeof (struct res_clm_nodegetcallback));
  674. }