main.c 47 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554
  1. /*
  2. * Copyright (c) 2002-2006 MontaVista Software, Inc.
  3. * Copyright (c) 2006-2009 Red Hat, Inc.
  4. *
  5. * All rights reserved.
  6. *
  7. * Author: Steven Dake (sdake@redhat.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. /**
  36. * \mainpage Corosync
  37. *
  38. * This is the doxygen generated developer documentation for the Corosync
  39. * project. For more information about Corosync, please see the project
  40. * web site, <a href="http://www.corosync.org">corosync.org</a>.
  41. *
  42. * \section license License
  43. *
  44. * This software licensed under BSD license, the text of which follows:
  45. *
  46. * Redistribution and use in source and binary forms, with or without
  47. * modification, are permitted provided that the following conditions are met:
  48. *
  49. * - Redistributions of source code must retain the above copyright notice,
  50. * this list of conditions and the following disclaimer.
  51. * - Redistributions in binary form must reproduce the above copyright notice,
  52. * this list of conditions and the following disclaimer in the documentation
  53. * and/or other materials provided with the distribution.
  54. * - Neither the name of the MontaVista Software, Inc. nor the names of its
  55. * contributors may be used to endorse or promote products derived from this
  56. * software without specific prior written permission.
  57. *
  58. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  59. * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  60. * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  61. * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
  62. * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  63. * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  64. * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  65. * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  66. * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  67. * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
  68. * THE POSSIBILITY OF SUCH DAMAGE.
  69. */
  70. #include <config.h>
  71. #include <pthread.h>
  72. #include <assert.h>
  73. #include <sys/types.h>
  74. #include <sys/file.h>
  75. #include <sys/poll.h>
  76. #include <sys/uio.h>
  77. #include <sys/mman.h>
  78. #include <sys/socket.h>
  79. #include <sys/un.h>
  80. #include <sys/time.h>
  81. #include <sys/resource.h>
  82. #include <sys/stat.h>
  83. #include <netinet/in.h>
  84. #include <arpa/inet.h>
  85. #include <unistd.h>
  86. #include <fcntl.h>
  87. #include <stdlib.h>
  88. #include <stdio.h>
  89. #include <errno.h>
  90. #include <signal.h>
  91. #include <sched.h>
  92. #include <time.h>
  93. #include <semaphore.h>
  94. #include <qb/qbdefs.h>
  95. #include <qb/qbloop.h>
  96. #include <qb/qbutil.h>
  97. #include <qb/qbipcs.h>
  98. #include <corosync/swab.h>
  99. #include <corosync/corotypes.h>
  100. #include <corosync/corodefs.h>
  101. #include <corosync/list.h>
  102. #include <corosync/lcr/lcr_ifact.h>
  103. #include <corosync/totem/totempg.h>
  104. #include <corosync/engine/objdb.h>
  105. #include <corosync/engine/config.h>
  106. #include <corosync/engine/logsys.h>
  107. #include "quorum.h"
  108. #include "totemsrp.h"
  109. #include "mainconfig.h"
  110. #include "totemconfig.h"
  111. #include "main.h"
  112. #include "sync.h"
  113. #include "syncv2.h"
  114. #include "timer.h"
  115. #include "util.h"
  116. #include "apidef.h"
  117. #include "service.h"
  118. #include "schedwrk.h"
  119. #include "evil.h"
  120. #ifdef HAVE_SMALL_MEMORY_FOOTPRINT
  121. #define IPC_LOGSYS_SIZE 1024*64
  122. #else
  123. #define IPC_LOGSYS_SIZE 8192*128
  124. #endif
  125. LOGSYS_DECLARE_SYSTEM ("corosync",
  126. LOGSYS_MODE_OUTPUT_STDERR | LOGSYS_MODE_THREADED | LOGSYS_MODE_FORK,
  127. 0,
  128. NULL,
  129. LOG_INFO,
  130. LOG_DAEMON,
  131. LOG_INFO,
  132. NULL,
  133. IPC_LOGSYS_SIZE);
  134. LOGSYS_DECLARE_SUBSYS ("MAIN");
  135. #define SERVER_BACKLOG 5
  136. static int sched_priority = 0;
  137. static unsigned int service_count = 32;
  138. static qb_thread_lock_t *serialize_lock_f;
  139. static struct totem_logging_configuration totem_logging_configuration;
  140. static int num_config_modules;
  141. static struct config_iface_ver0 *config_modules[MAX_DYNAMIC_SERVICES];
  142. static struct objdb_iface_ver0 *objdb = NULL;
  143. static struct corosync_api_v1 *api = NULL;
  144. static enum cs_sync_mode minimum_sync_mode;
  145. static int sync_in_process = 1;
  146. static qb_loop_t *corosync_poll_handle;
  147. struct sched_param global_sched_param;
  148. static hdb_handle_t object_memb_handle;
  149. static corosync_timer_handle_t corosync_stats_timer_handle;
  150. static const char *corosync_lock_file = LOCALSTATEDIR"/run/corosync.pid";
  151. static void serialize_unlock (void);
  152. static void serialize_lock (void);
  153. qb_loop_t *cs_poll_handle_get (void)
  154. {
  155. return (corosync_poll_handle);
  156. }
  157. int cs_poll_dispatch_add (qb_loop_t * handle,
  158. int fd,
  159. int events,
  160. void *data,
  161. int (*dispatch_fn) (int fd,
  162. int revents,
  163. void *data))
  164. {
  165. return qb_loop_poll_add(handle, QB_LOOP_MED, fd, events, data,
  166. dispatch_fn);
  167. }
  168. int cs_poll_dispatch_delete(qb_loop_t * handle, int fd)
  169. {
  170. return qb_loop_poll_del(handle, fd);
  171. }
  172. void corosync_state_dump (void)
  173. {
  174. int i;
  175. for (i = 0; i < SERVICE_HANDLER_MAXIMUM_COUNT; i++) {
  176. if (ais_service[i] && ais_service[i]->exec_dump_fn) {
  177. ais_service[i]->exec_dump_fn ();
  178. }
  179. }
  180. }
  181. static void unlink_all_completed (void)
  182. {
  183. /*
  184. * The schedwrk_do API takes the global serializer lock
  185. * but doesn't release it because this exit callback is called
  186. * before it finishes. Since we know we are exiting, we unlock it
  187. * here
  188. */
  189. serialize_unlock ();
  190. api->timer_delete (corosync_stats_timer_handle);
  191. qb_loop_stop (corosync_poll_handle);
  192. serialize_lock ();
  193. }
  194. void corosync_shutdown_request (void)
  195. {
  196. corosync_service_unlink_all (api, unlink_all_completed);
  197. }
  198. static int32_t sig_diag_handler (int num, void *data)
  199. {
  200. corosync_state_dump ();
  201. logsys_log_rec_store (LOCALSTATEDIR "/lib/corosync/fdata");
  202. return 0;
  203. }
  204. static int32_t sig_exit_handler (int num, void *data)
  205. {
  206. corosync_service_unlink_all (api, unlink_all_completed);
  207. return 0;
  208. }
  209. static void sigsegv_handler (int num)
  210. {
  211. (void)signal (SIGSEGV, SIG_DFL);
  212. logsys_atexit();
  213. logsys_log_rec_store (LOCALSTATEDIR "/lib/corosync/fdata");
  214. raise (SIGSEGV);
  215. }
  216. static void sigabrt_handler (int num)
  217. {
  218. (void)signal (SIGABRT, SIG_DFL);
  219. logsys_atexit();
  220. logsys_log_rec_store (LOCALSTATEDIR "/lib/corosync/fdata");
  221. raise (SIGABRT);
  222. }
  223. #define LOCALHOST_IP inet_addr("127.0.0.1")
  224. static hdb_handle_t corosync_group_handle;
  225. static struct totempg_group corosync_group = {
  226. .group = "a",
  227. .group_len = 1
  228. };
  229. static void serialize_lock (void)
  230. {
  231. qb_thread_lock (serialize_lock_f);
  232. }
  233. static void serialize_unlock (void)
  234. {
  235. qb_thread_unlock (serialize_lock_f);
  236. }
  237. static void corosync_sync_completed (void)
  238. {
  239. log_printf (LOGSYS_LEVEL_NOTICE,
  240. "Completed service synchronization, ready to provide service.\n");
  241. sync_in_process = 0;
  242. cs_ipcs_sync_state_changed(sync_in_process);
  243. }
  244. static int corosync_sync_callbacks_retrieve (int sync_id,
  245. struct sync_callbacks *callbacks)
  246. {
  247. unsigned int ais_service_index;
  248. int res;
  249. for (ais_service_index = 0;
  250. ais_service_index < SERVICE_HANDLER_MAXIMUM_COUNT;
  251. ais_service_index++) {
  252. if (ais_service[ais_service_index] != NULL
  253. && (ais_service[ais_service_index]->sync_mode == CS_SYNC_V1
  254. || ais_service[ais_service_index]->sync_mode == CS_SYNC_V1_APIV2)) {
  255. if (ais_service_index == sync_id) {
  256. break;
  257. }
  258. }
  259. }
  260. /*
  261. * Try to load backwards compat sync engines
  262. */
  263. if (ais_service_index == SERVICE_HANDLER_MAXIMUM_COUNT) {
  264. res = evil_callbacks_load (sync_id, callbacks);
  265. return (res);
  266. }
  267. callbacks->name = ais_service[ais_service_index]->name;
  268. callbacks->sync_init_api.sync_init_v1 = ais_service[ais_service_index]->sync_init;
  269. callbacks->api_version = 1;
  270. if (ais_service[ais_service_index]->sync_mode == CS_SYNC_V1_APIV2) {
  271. callbacks->api_version = 2;
  272. }
  273. callbacks->sync_process = ais_service[ais_service_index]->sync_process;
  274. callbacks->sync_activate = ais_service[ais_service_index]->sync_activate;
  275. callbacks->sync_abort = ais_service[ais_service_index]->sync_abort;
  276. return (0);
  277. }
  278. static int corosync_sync_v2_callbacks_retrieve (
  279. int service_id,
  280. struct sync_callbacks *callbacks)
  281. {
  282. int res;
  283. if (minimum_sync_mode == CS_SYNC_V2 && service_id == CLM_SERVICE && ais_service[CLM_SERVICE] == NULL) {
  284. res = evil_callbacks_load (service_id, callbacks);
  285. return (res);
  286. }
  287. if (minimum_sync_mode == CS_SYNC_V2 && service_id == EVT_SERVICE && ais_service[EVT_SERVICE] == NULL) {
  288. res = evil_callbacks_load (service_id, callbacks);
  289. return (res);
  290. }
  291. if (ais_service[service_id] == NULL) {
  292. return (-1);
  293. }
  294. if (minimum_sync_mode == CS_SYNC_V1 && ais_service[service_id]->sync_mode != CS_SYNC_V2) {
  295. return (-1);
  296. }
  297. callbacks->name = ais_service[service_id]->name;
  298. callbacks->api_version = 1;
  299. if (ais_service[service_id]->sync_mode == CS_SYNC_V1_APIV2) {
  300. callbacks->api_version = 2;
  301. }
  302. callbacks->sync_init_api.sync_init_v1 = ais_service[service_id]->sync_init;
  303. callbacks->sync_process = ais_service[service_id]->sync_process;
  304. callbacks->sync_activate = ais_service[service_id]->sync_activate;
  305. callbacks->sync_abort = ais_service[service_id]->sync_abort;
  306. return (0);
  307. }
  308. static struct memb_ring_id corosync_ring_id;
  309. static void member_object_joined (unsigned int nodeid)
  310. {
  311. hdb_handle_t object_find_handle;
  312. hdb_handle_t object_node_handle;
  313. char * nodeint_str;
  314. char nodeid_str[64];
  315. unsigned int key_incr_dummy;
  316. snprintf (nodeid_str, 64, "%d", nodeid);
  317. objdb->object_find_create (
  318. object_memb_handle,
  319. nodeid_str,
  320. strlen (nodeid_str),
  321. &object_find_handle);
  322. if (objdb->object_find_next (object_find_handle,
  323. &object_node_handle) == 0) {
  324. objdb->object_key_increment (object_node_handle,
  325. "join_count", strlen("join_count"),
  326. &key_incr_dummy);
  327. objdb->object_key_replace (object_node_handle,
  328. "status", strlen("status"),
  329. "joined", strlen("joined"));
  330. } else {
  331. nodeint_str = (char*)api->totem_ifaces_print (nodeid);
  332. objdb->object_create (object_memb_handle,
  333. &object_node_handle,
  334. nodeid_str, strlen (nodeid_str));
  335. objdb->object_key_create_typed (object_node_handle,
  336. "ip",
  337. nodeint_str, strlen(nodeint_str),
  338. OBJDB_VALUETYPE_STRING);
  339. key_incr_dummy = 1;
  340. objdb->object_key_create_typed (object_node_handle,
  341. "join_count",
  342. &key_incr_dummy, sizeof (key_incr_dummy),
  343. OBJDB_VALUETYPE_UINT32);
  344. objdb->object_key_create_typed (object_node_handle,
  345. "status",
  346. "joined", strlen("joined"),
  347. OBJDB_VALUETYPE_STRING);
  348. }
  349. }
  350. static void member_object_left (unsigned int nodeid)
  351. {
  352. hdb_handle_t object_find_handle;
  353. hdb_handle_t object_node_handle;
  354. char nodeid_str[64];
  355. snprintf (nodeid_str, 64, "%u", nodeid);
  356. objdb->object_find_create (
  357. object_memb_handle,
  358. nodeid_str,
  359. strlen (nodeid_str),
  360. &object_find_handle);
  361. if (objdb->object_find_next (object_find_handle,
  362. &object_node_handle) == 0) {
  363. objdb->object_key_replace (object_node_handle,
  364. "status", strlen("status"),
  365. "left", strlen("left"));
  366. }
  367. }
  368. static void confchg_fn (
  369. enum totem_configuration_type configuration_type,
  370. const unsigned int *member_list, size_t member_list_entries,
  371. const unsigned int *left_list, size_t left_list_entries,
  372. const unsigned int *joined_list, size_t joined_list_entries,
  373. const struct memb_ring_id *ring_id)
  374. {
  375. int i;
  376. int abort_activate = 0;
  377. if (sync_in_process == 1) {
  378. abort_activate = 1;
  379. }
  380. sync_in_process = 1;
  381. cs_ipcs_sync_state_changed(sync_in_process);
  382. serialize_lock ();
  383. memcpy (&corosync_ring_id, ring_id, sizeof (struct memb_ring_id));
  384. for (i = 0; i < left_list_entries; i++) {
  385. member_object_left (left_list[i]);
  386. }
  387. for (i = 0; i < joined_list_entries; i++) {
  388. member_object_joined (joined_list[i]);
  389. }
  390. /*
  391. * Call configuration change for all services
  392. */
  393. for (i = 0; i < service_count; i++) {
  394. if (ais_service[i] && ais_service[i]->confchg_fn) {
  395. ais_service[i]->confchg_fn (configuration_type,
  396. member_list, member_list_entries,
  397. left_list, left_list_entries,
  398. joined_list, joined_list_entries, ring_id);
  399. }
  400. }
  401. serialize_unlock ();
  402. if (abort_activate) {
  403. sync_v2_abort ();
  404. }
  405. if (minimum_sync_mode == CS_SYNC_V2 && configuration_type == TOTEM_CONFIGURATION_TRANSITIONAL) {
  406. sync_v2_save_transitional (member_list, member_list_entries, ring_id);
  407. }
  408. if (minimum_sync_mode == CS_SYNC_V2 && configuration_type == TOTEM_CONFIGURATION_REGULAR) {
  409. sync_v2_start (member_list, member_list_entries, ring_id);
  410. }
  411. }
  412. static void priv_drop (void)
  413. {
  414. return; /* TODO: we are still not dropping privs */
  415. }
  416. static void corosync_tty_detach (void)
  417. {
  418. FILE *r;
  419. /*
  420. * Disconnect from TTY if this is not a debug run
  421. */
  422. switch (fork ()) {
  423. case -1:
  424. corosync_exit_error (AIS_DONE_FORK);
  425. break;
  426. case 0:
  427. /*
  428. * child which is disconnected, run this process
  429. */
  430. break;
  431. default:
  432. exit (0);
  433. break;
  434. }
  435. /* Create new session */
  436. (void)setsid();
  437. /*
  438. * Map stdin/out/err to /dev/null.
  439. */
  440. r = freopen("/dev/null", "r", stdin);
  441. if (r == NULL) {
  442. corosync_exit_error (AIS_DONE_STD_TO_NULL_REDIR);
  443. }
  444. r = freopen("/dev/null", "a", stderr);
  445. if (r == NULL) {
  446. corosync_exit_error (AIS_DONE_STD_TO_NULL_REDIR);
  447. }
  448. r = freopen("/dev/null", "a", stdout);
  449. if (r == NULL) {
  450. corosync_exit_error (AIS_DONE_STD_TO_NULL_REDIR);
  451. }
  452. }
  453. static void corosync_mlockall (void)
  454. {
  455. #if !defined(COROSYNC_BSD) || defined(COROSYNC_FREEBSD_GE_8)
  456. int res;
  457. #endif
  458. struct rlimit rlimit;
  459. rlimit.rlim_cur = RLIM_INFINITY;
  460. rlimit.rlim_max = RLIM_INFINITY;
  461. #ifndef COROSYNC_SOLARIS
  462. setrlimit (RLIMIT_MEMLOCK, &rlimit);
  463. #else
  464. setrlimit (RLIMIT_VMEM, &rlimit);
  465. #endif
  466. #if defined(COROSYNC_BSD) && !defined(COROSYNC_FREEBSD_GE_8)
  467. /* under FreeBSD < 8 a process with locked page cannot call dlopen
  468. * code disabled until FreeBSD bug i386/93396 was solved
  469. */
  470. log_printf (LOGSYS_LEVEL_WARNING, "Could not lock memory of service to avoid page faults\n");
  471. #else
  472. res = mlockall (MCL_CURRENT | MCL_FUTURE);
  473. if (res == -1) {
  474. LOGSYS_PERROR (errno, LOGSYS_LEVEL_WARNING,
  475. "Could not lock memory of service to avoid page faults");
  476. };
  477. #endif
  478. }
  479. static void corosync_totem_stats_updater (void *data)
  480. {
  481. totempg_stats_t * stats;
  482. uint32_t mtt_rx_token;
  483. uint32_t total_mtt_rx_token;
  484. uint32_t avg_backlog_calc;
  485. uint32_t total_backlog_calc;
  486. uint32_t avg_token_holdtime;
  487. uint32_t total_token_holdtime;
  488. int t, prev;
  489. int32_t token_count;
  490. uint32_t firewall_enabled_or_nic_failure;
  491. stats = api->totem_get_stats();
  492. objdb->object_key_replace (stats->hdr.handle,
  493. "msg_reserved", strlen("msg_reserved"),
  494. &stats->msg_reserved, sizeof (stats->msg_reserved));
  495. objdb->object_key_replace (stats->hdr.handle,
  496. "msg_queue_avail", strlen("msg_queue_avail"),
  497. &stats->msg_queue_avail, sizeof (stats->msg_queue_avail));
  498. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  499. "orf_token_tx", strlen("orf_token_tx"),
  500. &stats->mrp->srp->orf_token_tx, sizeof (stats->mrp->srp->orf_token_tx));
  501. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  502. "orf_token_rx", strlen("orf_token_rx"),
  503. &stats->mrp->srp->orf_token_rx, sizeof (stats->mrp->srp->orf_token_rx));
  504. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  505. "memb_merge_detect_tx", strlen("memb_merge_detect_tx"),
  506. &stats->mrp->srp->memb_merge_detect_tx, sizeof (stats->mrp->srp->memb_merge_detect_tx));
  507. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  508. "memb_merge_detect_rx", strlen("memb_merge_detect_rx"),
  509. &stats->mrp->srp->memb_merge_detect_rx, sizeof (stats->mrp->srp->memb_merge_detect_rx));
  510. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  511. "memb_join_tx", strlen("memb_join_tx"),
  512. &stats->mrp->srp->memb_join_tx, sizeof (stats->mrp->srp->memb_join_tx));
  513. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  514. "memb_join_rx", strlen("memb_join_rx"),
  515. &stats->mrp->srp->memb_join_rx, sizeof (stats->mrp->srp->memb_join_rx));
  516. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  517. "mcast_tx", strlen("mcast_tx"),
  518. &stats->mrp->srp->mcast_tx, sizeof (stats->mrp->srp->mcast_tx));
  519. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  520. "mcast_retx", strlen("mcast_retx"),
  521. &stats->mrp->srp->mcast_retx, sizeof (stats->mrp->srp->mcast_retx));
  522. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  523. "mcast_rx", strlen("mcast_rx"),
  524. &stats->mrp->srp->mcast_rx, sizeof (stats->mrp->srp->mcast_rx));
  525. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  526. "memb_commit_token_tx", strlen("memb_commit_token_tx"),
  527. &stats->mrp->srp->memb_commit_token_tx, sizeof (stats->mrp->srp->memb_commit_token_tx));
  528. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  529. "memb_commit_token_rx", strlen("memb_commit_token_rx"),
  530. &stats->mrp->srp->memb_commit_token_rx, sizeof (stats->mrp->srp->memb_commit_token_rx));
  531. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  532. "token_hold_cancel_tx", strlen("token_hold_cancel_tx"),
  533. &stats->mrp->srp->token_hold_cancel_tx, sizeof (stats->mrp->srp->token_hold_cancel_tx));
  534. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  535. "token_hold_cancel_rx", strlen("token_hold_cancel_rx"),
  536. &stats->mrp->srp->token_hold_cancel_rx, sizeof (stats->mrp->srp->token_hold_cancel_rx));
  537. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  538. "operational_entered", strlen("operational_entered"),
  539. &stats->mrp->srp->operational_entered, sizeof (stats->mrp->srp->operational_entered));
  540. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  541. "operational_token_lost", strlen("operational_token_lost"),
  542. &stats->mrp->srp->operational_token_lost, sizeof (stats->mrp->srp->operational_token_lost));
  543. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  544. "gather_entered", strlen("gather_entered"),
  545. &stats->mrp->srp->gather_entered, sizeof (stats->mrp->srp->gather_entered));
  546. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  547. "gather_token_lost", strlen("gather_token_lost"),
  548. &stats->mrp->srp->gather_token_lost, sizeof (stats->mrp->srp->gather_token_lost));
  549. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  550. "commit_entered", strlen("commit_entered"),
  551. &stats->mrp->srp->commit_entered, sizeof (stats->mrp->srp->commit_entered));
  552. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  553. "commit_token_lost", strlen("commit_token_lost"),
  554. &stats->mrp->srp->commit_token_lost, sizeof (stats->mrp->srp->commit_token_lost));
  555. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  556. "recovery_entered", strlen("recovery_entered"),
  557. &stats->mrp->srp->recovery_entered, sizeof (stats->mrp->srp->recovery_entered));
  558. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  559. "recovery_token_lost", strlen("recovery_token_lost"),
  560. &stats->mrp->srp->recovery_token_lost, sizeof (stats->mrp->srp->recovery_token_lost));
  561. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  562. "consensus_timeouts", strlen("consensus_timeouts"),
  563. &stats->mrp->srp->consensus_timeouts, sizeof (stats->mrp->srp->consensus_timeouts));
  564. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  565. "rx_msg_dropped", strlen("rx_msg_dropped"),
  566. &stats->mrp->srp->rx_msg_dropped, sizeof (stats->mrp->srp->rx_msg_dropped));
  567. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  568. "continuous_gather", strlen("continuous_gather"),
  569. &stats->mrp->srp->continuous_gather, sizeof (stats->mrp->srp->continuous_gather));
  570. firewall_enabled_or_nic_failure = (stats->mrp->srp->continuous_gather > MAX_NO_CONT_GATHER ? 1 : 0);
  571. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  572. "firewall_enabled_or_nic_failure", strlen("firewall_enabled_or_nic_failure"),
  573. &firewall_enabled_or_nic_failure, sizeof (firewall_enabled_or_nic_failure));
  574. total_mtt_rx_token = 0;
  575. total_token_holdtime = 0;
  576. total_backlog_calc = 0;
  577. token_count = 0;
  578. t = stats->mrp->srp->latest_token;
  579. while (1) {
  580. if (t == 0)
  581. prev = TOTEM_TOKEN_STATS_MAX - 1;
  582. else
  583. prev = t - 1;
  584. if (prev == stats->mrp->srp->earliest_token)
  585. break;
  586. /* if tx == 0, then dropped token (not ours) */
  587. if (stats->mrp->srp->token[t].tx != 0 ||
  588. (stats->mrp->srp->token[t].rx - stats->mrp->srp->token[prev].rx) > 0 ) {
  589. total_mtt_rx_token += (stats->mrp->srp->token[t].rx - stats->mrp->srp->token[prev].rx);
  590. total_token_holdtime += (stats->mrp->srp->token[t].tx - stats->mrp->srp->token[t].rx);
  591. total_backlog_calc += stats->mrp->srp->token[t].backlog_calc;
  592. token_count++;
  593. }
  594. t = prev;
  595. }
  596. if (token_count) {
  597. mtt_rx_token = (total_mtt_rx_token / token_count);
  598. avg_backlog_calc = (total_backlog_calc / token_count);
  599. avg_token_holdtime = (total_token_holdtime / token_count);
  600. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  601. "mtt_rx_token", strlen("mtt_rx_token"),
  602. &mtt_rx_token, sizeof (mtt_rx_token));
  603. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  604. "avg_token_workload", strlen("avg_token_workload"),
  605. &avg_token_holdtime, sizeof (avg_token_holdtime));
  606. objdb->object_key_replace (stats->mrp->srp->hdr.handle,
  607. "avg_backlog_calc", strlen("avg_backlog_calc"),
  608. &avg_backlog_calc, sizeof (avg_backlog_calc));
  609. }
  610. cs_ipcs_stats_update();
  611. api->timer_add_duration (1500 * MILLI_2_NANO_SECONDS, NULL,
  612. corosync_totem_stats_updater,
  613. &corosync_stats_timer_handle);
  614. }
  615. static void corosync_totem_stats_init (void)
  616. {
  617. totempg_stats_t * stats;
  618. hdb_handle_t object_find_handle;
  619. hdb_handle_t object_runtime_handle;
  620. hdb_handle_t object_totem_handle;
  621. uint32_t zero_32 = 0;
  622. uint64_t zero_64 = 0;
  623. stats = api->totem_get_stats();
  624. objdb->object_find_create (
  625. OBJECT_PARENT_HANDLE,
  626. "runtime",
  627. strlen ("runtime"),
  628. &object_find_handle);
  629. if (objdb->object_find_next (object_find_handle,
  630. &object_runtime_handle) == 0) {
  631. objdb->object_create (object_runtime_handle,
  632. &object_totem_handle,
  633. "totem", strlen ("totem"));
  634. objdb->object_create (object_totem_handle,
  635. &stats->hdr.handle,
  636. "pg", strlen ("pg"));
  637. objdb->object_create (stats->hdr.handle,
  638. &stats->mrp->hdr.handle,
  639. "mrp", strlen ("mrp"));
  640. objdb->object_create (stats->mrp->hdr.handle,
  641. &stats->mrp->srp->hdr.handle,
  642. "srp", strlen ("srp"));
  643. objdb->object_key_create_typed (stats->hdr.handle,
  644. "msg_reserved", &stats->msg_reserved,
  645. sizeof (stats->msg_reserved), OBJDB_VALUETYPE_UINT32);
  646. objdb->object_key_create_typed (stats->hdr.handle,
  647. "msg_queue_avail", &stats->msg_queue_avail,
  648. sizeof (stats->msg_queue_avail), OBJDB_VALUETYPE_UINT32);
  649. /* Members object */
  650. objdb->object_create (stats->mrp->srp->hdr.handle,
  651. &object_memb_handle,
  652. "members", strlen ("members"));
  653. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  654. "orf_token_tx", &stats->mrp->srp->orf_token_tx,
  655. sizeof (stats->mrp->srp->orf_token_tx), OBJDB_VALUETYPE_UINT64);
  656. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  657. "orf_token_rx", &stats->mrp->srp->orf_token_rx,
  658. sizeof (stats->mrp->srp->orf_token_rx), OBJDB_VALUETYPE_UINT64);
  659. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  660. "memb_merge_detect_tx", &stats->mrp->srp->memb_merge_detect_tx,
  661. sizeof (stats->mrp->srp->memb_merge_detect_tx), OBJDB_VALUETYPE_UINT64);
  662. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  663. "memb_merge_detect_rx", &stats->mrp->srp->memb_merge_detect_rx,
  664. sizeof (stats->mrp->srp->memb_merge_detect_rx), OBJDB_VALUETYPE_UINT64);
  665. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  666. "memb_join_tx", &stats->mrp->srp->memb_join_tx,
  667. sizeof (stats->mrp->srp->memb_join_tx), OBJDB_VALUETYPE_UINT64);
  668. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  669. "memb_join_rx", &stats->mrp->srp->memb_join_rx,
  670. sizeof (stats->mrp->srp->memb_join_rx), OBJDB_VALUETYPE_UINT64);
  671. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  672. "mcast_tx", &stats->mrp->srp->mcast_tx,
  673. sizeof (stats->mrp->srp->mcast_tx), OBJDB_VALUETYPE_UINT64);
  674. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  675. "mcast_retx", &stats->mrp->srp->mcast_retx,
  676. sizeof (stats->mrp->srp->mcast_retx), OBJDB_VALUETYPE_UINT64);
  677. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  678. "mcast_rx", &stats->mrp->srp->mcast_rx,
  679. sizeof (stats->mrp->srp->mcast_rx), OBJDB_VALUETYPE_UINT64);
  680. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  681. "memb_commit_token_tx", &stats->mrp->srp->memb_commit_token_tx,
  682. sizeof (stats->mrp->srp->memb_commit_token_tx), OBJDB_VALUETYPE_UINT64);
  683. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  684. "memb_commit_token_rx", &stats->mrp->srp->memb_commit_token_rx,
  685. sizeof (stats->mrp->srp->memb_commit_token_rx), OBJDB_VALUETYPE_UINT64);
  686. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  687. "token_hold_cancel_tx", &stats->mrp->srp->token_hold_cancel_tx,
  688. sizeof (stats->mrp->srp->token_hold_cancel_tx), OBJDB_VALUETYPE_UINT64);
  689. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  690. "token_hold_cancel_rx", &stats->mrp->srp->token_hold_cancel_rx,
  691. sizeof (stats->mrp->srp->token_hold_cancel_rx), OBJDB_VALUETYPE_UINT64);
  692. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  693. "operational_entered", &stats->mrp->srp->operational_entered,
  694. sizeof (stats->mrp->srp->operational_entered), OBJDB_VALUETYPE_UINT64);
  695. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  696. "operational_token_lost", &stats->mrp->srp->operational_token_lost,
  697. sizeof (stats->mrp->srp->operational_token_lost), OBJDB_VALUETYPE_UINT64);
  698. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  699. "gather_entered", &stats->mrp->srp->gather_entered,
  700. sizeof (stats->mrp->srp->gather_entered), OBJDB_VALUETYPE_UINT64);
  701. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  702. "gather_token_lost", &stats->mrp->srp->gather_token_lost,
  703. sizeof (stats->mrp->srp->gather_token_lost), OBJDB_VALUETYPE_UINT64);
  704. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  705. "commit_entered", &stats->mrp->srp->commit_entered,
  706. sizeof (stats->mrp->srp->commit_entered), OBJDB_VALUETYPE_UINT64);
  707. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  708. "commit_token_lost", &stats->mrp->srp->commit_token_lost,
  709. sizeof (stats->mrp->srp->commit_token_lost), OBJDB_VALUETYPE_UINT64);
  710. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  711. "recovery_entered", &stats->mrp->srp->recovery_entered,
  712. sizeof (stats->mrp->srp->recovery_entered), OBJDB_VALUETYPE_UINT64);
  713. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  714. "recovery_token_lost", &stats->mrp->srp->recovery_token_lost,
  715. sizeof (stats->mrp->srp->recovery_token_lost), OBJDB_VALUETYPE_UINT64);
  716. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  717. "consensus_timeouts", &stats->mrp->srp->consensus_timeouts,
  718. sizeof (stats->mrp->srp->consensus_timeouts), OBJDB_VALUETYPE_UINT64);
  719. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  720. "mtt_rx_token", &zero_32,
  721. sizeof (zero_32), OBJDB_VALUETYPE_UINT32);
  722. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  723. "avg_token_workload", &zero_32,
  724. sizeof (zero_32), OBJDB_VALUETYPE_UINT32);
  725. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  726. "avg_backlog_calc", &zero_32,
  727. sizeof (zero_32), OBJDB_VALUETYPE_UINT32);
  728. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  729. "rx_msg_dropped", &zero_64,
  730. sizeof (zero_64), OBJDB_VALUETYPE_UINT64);
  731. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  732. "continuous_gather", &zero_32,
  733. sizeof (zero_32), OBJDB_VALUETYPE_UINT32);
  734. objdb->object_key_create_typed (stats->mrp->srp->hdr.handle,
  735. "firewall_enabled_or_nic_failure", &zero_32,
  736. sizeof (zero_32), OBJDB_VALUETYPE_UINT32);
  737. }
  738. /* start stats timer */
  739. api->timer_add_duration (1500 * MILLI_2_NANO_SECONDS, NULL,
  740. corosync_totem_stats_updater,
  741. &corosync_stats_timer_handle);
  742. }
  743. static void deliver_fn (
  744. unsigned int nodeid,
  745. const void *msg,
  746. unsigned int msg_len,
  747. int endian_conversion_required)
  748. {
  749. const struct qb_ipc_request_header *header;
  750. int32_t service;
  751. int32_t fn_id;
  752. uint32_t id;
  753. uint32_t size;
  754. uint32_t key_incr_dummy;
  755. header = msg;
  756. if (endian_conversion_required) {
  757. id = swab32 (header->id);
  758. size = swab32 (header->size);
  759. } else {
  760. id = header->id;
  761. size = header->size;
  762. }
  763. /*
  764. * Call the proper executive handler
  765. */
  766. service = id >> 16;
  767. fn_id = id & 0xffff;
  768. serialize_lock();
  769. if (ais_service[service] == NULL && service == EVT_SERVICE) {
  770. evil_deliver_fn (nodeid, service, fn_id, msg,
  771. endian_conversion_required);
  772. }
  773. if (!ais_service[service]) {
  774. serialize_unlock();
  775. return;
  776. }
  777. if (fn_id >= ais_service[service]->exec_engine_count) {
  778. log_printf(LOGSYS_LEVEL_WARNING, "discarded unknown message %d for service %d (max id %d)",
  779. fn_id, service, ais_service[service]->exec_engine_count);
  780. serialize_unlock();
  781. return;
  782. }
  783. objdb->object_key_increment (service_stats_handle[service][fn_id],
  784. "rx", strlen("rx"),
  785. &key_incr_dummy);
  786. if (endian_conversion_required) {
  787. assert(ais_service[service]->exec_engine[fn_id].exec_endian_convert_fn != NULL);
  788. ais_service[service]->exec_engine[fn_id].exec_endian_convert_fn
  789. ((void *)msg);
  790. }
  791. ais_service[service]->exec_engine[fn_id].exec_handler_fn
  792. (msg, nodeid);
  793. serialize_unlock();
  794. }
  795. void main_get_config_modules(struct config_iface_ver0 ***modules, int *num)
  796. {
  797. *modules = config_modules;
  798. *num = num_config_modules;
  799. }
  800. int main_mcast (
  801. const struct iovec *iovec,
  802. unsigned int iov_len,
  803. unsigned int guarantee)
  804. {
  805. const struct qb_ipc_request_header *req = iovec->iov_base;
  806. int32_t service;
  807. int32_t fn_id;
  808. uint32_t key_incr_dummy;
  809. service = req->id >> 16;
  810. fn_id = req->id & 0xffff;
  811. if (ais_service[service]) {
  812. objdb->object_key_increment (service_stats_handle[service][fn_id],
  813. "tx", strlen("tx"), &key_incr_dummy);
  814. }
  815. return (totempg_groups_mcast_joined (corosync_group_handle, iovec, iov_len, guarantee));
  816. }
  817. static qb_loop_timer_handle recheck_the_q_level_timer;
  818. void corosync_recheck_the_q_level(void *data)
  819. {
  820. totempg_check_q_level(corosync_group_handle);
  821. if (cs_ipcs_q_level_get() == TOTEM_Q_LEVEL_CRITICAL) {
  822. qb_loop_timer_add(cs_poll_handle_get(), QB_LOOP_MED, 1*QB_TIME_NS_IN_MSEC,
  823. NULL, corosync_recheck_the_q_level, &recheck_the_q_level_timer);
  824. }
  825. }
  826. struct sending_allowed_private_data_struct {
  827. int reserved_msgs;
  828. };
  829. int corosync_sending_allowed (
  830. unsigned int service,
  831. unsigned int id,
  832. const void *msg,
  833. void *sending_allowed_private_data)
  834. {
  835. struct sending_allowed_private_data_struct *pd =
  836. (struct sending_allowed_private_data_struct *)sending_allowed_private_data;
  837. struct iovec reserve_iovec;
  838. struct qb_ipc_request_header *header = (struct qb_ipc_request_header *)msg;
  839. int sending_allowed;
  840. reserve_iovec.iov_base = (char *)header;
  841. reserve_iovec.iov_len = header->size;
  842. pd->reserved_msgs = totempg_groups_joined_reserve (
  843. corosync_group_handle,
  844. &reserve_iovec, 1);
  845. if (pd->reserved_msgs == -1) {
  846. return (-1);
  847. }
  848. sending_allowed = QB_FALSE;
  849. if (corosync_quorum_is_quorate() == 1 ||
  850. ais_service[service]->allow_inquorate == CS_LIB_ALLOW_INQUORATE) {
  851. // we are quorate
  852. // now check flow control
  853. if (ais_service[service]->lib_engine[id].flow_control == CS_LIB_FLOW_CONTROL_NOT_REQUIRED) {
  854. sending_allowed = QB_TRUE;
  855. } else if (pd->reserved_msgs && sync_in_process == 0) {
  856. sending_allowed = QB_TRUE;
  857. } else {
  858. log_printf(LOGSYS_LEVEL_NOTICE,
  859. "no tx: (have quorum) (FC req) reserved:%d sync:%d",
  860. pd->reserved_msgs, sync_in_process);
  861. }
  862. } else {
  863. log_printf(LOGSYS_LEVEL_NOTICE, "no tx: not quorate!");
  864. }
  865. /*
  866. sending_allowed =
  867. (corosync_quorum_is_quorate() == 1 ||
  868. ais_service[service]->allow_inquorate == CS_LIB_ALLOW_INQUORATE) &&
  869. ((ais_service[service]->lib_engine[id].flow_control == CS_LIB_FLOW_CONTROL_NOT_REQUIRED) ||
  870. ((ais_service[service]->lib_engine[id].flow_control == CS_LIB_FLOW_CONTROL_REQUIRED) &&
  871. (pd->reserved_msgs) &&
  872. (sync_in_process == 0)));
  873. */
  874. return (sending_allowed);
  875. }
  876. void corosync_sending_allowed_release (void *sending_allowed_private_data)
  877. {
  878. struct sending_allowed_private_data_struct *pd =
  879. (struct sending_allowed_private_data_struct *)sending_allowed_private_data;
  880. if (pd->reserved_msgs == -1) {
  881. return;
  882. }
  883. totempg_groups_joined_release (pd->reserved_msgs);
  884. }
  885. int message_source_is_local (const mar_message_source_t *source)
  886. {
  887. int ret = 0;
  888. assert (source != NULL);
  889. if (source->nodeid == totempg_my_nodeid_get ()) {
  890. ret = 1;
  891. }
  892. return ret;
  893. }
  894. void message_source_set (
  895. mar_message_source_t *source,
  896. void *conn)
  897. {
  898. assert ((source != NULL) && (conn != NULL));
  899. memset (source, 0, sizeof (mar_message_source_t));
  900. source->nodeid = totempg_my_nodeid_get ();
  901. source->conn = conn;
  902. }
  903. static void corosync_setscheduler (void)
  904. {
  905. #if defined(HAVE_PTHREAD_SETSCHEDPARAM) && defined(HAVE_SCHED_GET_PRIORITY_MAX) && defined(HAVE_SCHED_SETSCHEDULER)
  906. int res;
  907. sched_priority = sched_get_priority_max (SCHED_RR);
  908. if (sched_priority != -1) {
  909. global_sched_param.sched_priority = sched_priority;
  910. res = sched_setscheduler (0, SCHED_RR, &global_sched_param);
  911. if (res == -1) {
  912. LOGSYS_PERROR(errno, LOGSYS_LEVEL_WARNING,
  913. "Could not set SCHED_RR at priority %d",
  914. global_sched_param.sched_priority);
  915. global_sched_param.sched_priority = 0;
  916. logsys_thread_priority_set (SCHED_OTHER, NULL, 1);
  917. } else {
  918. /*
  919. * Turn on SCHED_RR in logsys system
  920. */
  921. res = logsys_thread_priority_set (SCHED_RR, &global_sched_param, 10);
  922. if (res == -1) {
  923. log_printf (LOGSYS_LEVEL_ERROR,
  924. "Could not set logsys thread priority."
  925. " Can't continue because of priority inversions.");
  926. corosync_exit_error (AIS_DONE_LOGSETUP);
  927. }
  928. }
  929. } else {
  930. LOGSYS_PERROR (errno, LOGSYS_LEVEL_WARNING,
  931. "Could not get maximum scheduler priority");
  932. sched_priority = 0;
  933. }
  934. #else
  935. log_printf(LOGSYS_LEVEL_WARNING,
  936. "The Platform is missing process priority setting features. Leaving at default.");
  937. #endif
  938. }
  939. static void fplay_key_change_notify_fn (
  940. object_change_type_t change_type,
  941. hdb_handle_t parent_object_handle,
  942. hdb_handle_t object_handle,
  943. const void *object_name_pt, size_t object_name_len,
  944. const void *key_name_pt, size_t key_len,
  945. const void *key_value_pt, size_t key_value_len,
  946. void *priv_data_pt)
  947. {
  948. if (key_len == strlen ("dump_flight_data") &&
  949. memcmp ("dump_flight_data", key_name_pt, key_len) == 0) {
  950. logsys_log_rec_store (LOCALSTATEDIR "/lib/corosync/fdata");
  951. }
  952. if (key_len == strlen ("dump_state") &&
  953. memcmp ("dump_state", key_name_pt, key_len) == 0) {
  954. corosync_state_dump ();
  955. }
  956. }
  957. static void corosync_fplay_control_init (void)
  958. {
  959. hdb_handle_t object_find_handle;
  960. hdb_handle_t object_runtime_handle;
  961. hdb_handle_t object_blackbox_handle;
  962. objdb->object_find_create (OBJECT_PARENT_HANDLE,
  963. "runtime", strlen ("runtime"),
  964. &object_find_handle);
  965. if (objdb->object_find_next (object_find_handle,
  966. &object_runtime_handle) != 0) {
  967. return;
  968. }
  969. objdb->object_create (object_runtime_handle,
  970. &object_blackbox_handle,
  971. "blackbox", strlen ("blackbox"));
  972. objdb->object_key_create_typed (object_blackbox_handle,
  973. "dump_flight_data", "no", strlen("no"),
  974. OBJDB_VALUETYPE_STRING);
  975. objdb->object_key_create_typed (object_blackbox_handle,
  976. "dump_state", "no", strlen("no"),
  977. OBJDB_VALUETYPE_STRING);
  978. objdb->object_track_start (object_blackbox_handle,
  979. OBJECT_TRACK_DEPTH_RECURSIVE,
  980. fplay_key_change_notify_fn,
  981. NULL, NULL, NULL, NULL);
  982. }
  983. static void main_service_ready (void)
  984. {
  985. int res;
  986. /*
  987. * This must occur after totempg is initialized because "this_ip" must be set
  988. */
  989. res = corosync_service_defaults_link_and_init (api);
  990. if (res == -1) {
  991. log_printf (LOGSYS_LEVEL_ERROR, "Could not initialize default services\n");
  992. corosync_exit_error (AIS_DONE_INIT_SERVICES);
  993. }
  994. evil_init (api);
  995. cs_ipcs_init();
  996. corosync_totem_stats_init ();
  997. corosync_fplay_control_init ();
  998. if (minimum_sync_mode == CS_SYNC_V2) {
  999. log_printf (LOGSYS_LEVEL_NOTICE, "Compatibility mode set to none. Using V2 of the synchronization engine.\n");
  1000. sync_v2_init (
  1001. corosync_sync_v2_callbacks_retrieve,
  1002. corosync_sync_completed);
  1003. } else
  1004. if (minimum_sync_mode == CS_SYNC_V1) {
  1005. log_printf (LOGSYS_LEVEL_NOTICE, "Compatibility mode set to whitetank. Using V1 and V2 of the synchronization engine.\n");
  1006. sync_register (
  1007. corosync_sync_callbacks_retrieve,
  1008. sync_v2_memb_list_determine,
  1009. sync_v2_memb_list_abort,
  1010. sync_v2_start);
  1011. sync_v2_init (
  1012. corosync_sync_v2_callbacks_retrieve,
  1013. corosync_sync_completed);
  1014. }
  1015. }
  1016. static enum e_ais_done corosync_flock (const char *lockfile, pid_t pid)
  1017. {
  1018. struct flock lock;
  1019. enum e_ais_done err;
  1020. char pid_s[17];
  1021. int fd_flag;
  1022. int lf;
  1023. err = AIS_DONE_EXIT;
  1024. lf = open (lockfile, O_WRONLY | O_CREAT, 0640);
  1025. if (lf == -1) {
  1026. log_printf (LOGSYS_LEVEL_ERROR, "Corosync Executive couldn't create lock file.\n");
  1027. return (AIS_DONE_AQUIRE_LOCK);
  1028. }
  1029. retry_fcntl:
  1030. lock.l_type = F_WRLCK;
  1031. lock.l_start = 0;
  1032. lock.l_whence = SEEK_SET;
  1033. lock.l_len = 0;
  1034. if (fcntl (lf, F_SETLK, &lock) == -1) {
  1035. switch (errno) {
  1036. case EINTR:
  1037. goto retry_fcntl;
  1038. break;
  1039. case EAGAIN:
  1040. case EACCES:
  1041. log_printf (LOGSYS_LEVEL_ERROR, "Another Corosync instance is already running.\n");
  1042. err = AIS_DONE_ALREADY_RUNNING;
  1043. goto error_close;
  1044. break;
  1045. default:
  1046. log_printf (LOGSYS_LEVEL_ERROR, "Corosync Executive couldn't aquire lock. Error was %s\n",
  1047. strerror(errno));
  1048. err = AIS_DONE_AQUIRE_LOCK;
  1049. goto error_close;
  1050. break;
  1051. }
  1052. }
  1053. if (ftruncate (lf, 0) == -1) {
  1054. log_printf (LOGSYS_LEVEL_ERROR, "Corosync Executive couldn't truncate lock file. Error was %s\n",
  1055. strerror (errno));
  1056. err = AIS_DONE_AQUIRE_LOCK;
  1057. goto error_close_unlink;
  1058. }
  1059. memset (pid_s, 0, sizeof (pid_s));
  1060. snprintf (pid_s, sizeof (pid_s) - 1, "%u\n", pid);
  1061. retry_write:
  1062. if (write (lf, pid_s, strlen (pid_s)) != strlen (pid_s)) {
  1063. if (errno == EINTR) {
  1064. goto retry_write;
  1065. } else {
  1066. log_printf (LOGSYS_LEVEL_ERROR, "Corosync Executive couldn't write pid to lock file. "
  1067. "Error was %s\n", strerror (errno));
  1068. err = AIS_DONE_AQUIRE_LOCK;
  1069. goto error_close_unlink;
  1070. }
  1071. }
  1072. if ((fd_flag = fcntl (lf, F_GETFD, 0)) == -1) {
  1073. log_printf (LOGSYS_LEVEL_ERROR, "Corosync Executive couldn't get close-on-exec flag from lock file. "
  1074. "Error was %s\n", strerror (errno));
  1075. err = AIS_DONE_AQUIRE_LOCK;
  1076. goto error_close_unlink;
  1077. }
  1078. fd_flag |= FD_CLOEXEC;
  1079. if (fcntl (lf, F_SETFD, fd_flag) == -1) {
  1080. log_printf (LOGSYS_LEVEL_ERROR, "Corosync Executive couldn't set close-on-exec flag to lock file. "
  1081. "Error was %s\n", strerror (errno));
  1082. err = AIS_DONE_AQUIRE_LOCK;
  1083. goto error_close_unlink;
  1084. }
  1085. return (err);
  1086. error_close_unlink:
  1087. unlink (lockfile);
  1088. error_close:
  1089. close (lf);
  1090. return (err);
  1091. }
  1092. int main (int argc, char **argv, char **envp)
  1093. {
  1094. const char *error_string;
  1095. struct totem_config totem_config;
  1096. hdb_handle_t objdb_handle;
  1097. hdb_handle_t config_handle;
  1098. unsigned int config_version = 0;
  1099. void *objdb_p;
  1100. struct config_iface_ver0 *config;
  1101. void *config_p;
  1102. const char *config_iface_init;
  1103. char *config_iface;
  1104. char *iface;
  1105. char *strtok_save_pt;
  1106. int res, ch;
  1107. int background, setprio;
  1108. struct stat stat_out;
  1109. char corosync_lib_dir[PATH_MAX];
  1110. hdb_handle_t object_runtime_handle;
  1111. enum e_ais_done flock_err;
  1112. serialize_lock_f = qb_thread_lock_create (QB_THREAD_LOCK_SHORT);
  1113. /* default configuration
  1114. */
  1115. background = 1;
  1116. setprio = 1;
  1117. while ((ch = getopt (argc, argv, "fpv")) != EOF) {
  1118. switch (ch) {
  1119. case 'f':
  1120. background = 0;
  1121. logsys_config_mode_set (NULL, LOGSYS_MODE_OUTPUT_STDERR|LOGSYS_MODE_THREADED|LOGSYS_MODE_FORK);
  1122. break;
  1123. case 'p':
  1124. setprio = 0;
  1125. break;
  1126. case 'v':
  1127. printf ("Corosync Cluster Engine, version '%s'\n", VERSION);
  1128. printf ("Copyright (c) 2006-2009 Red Hat, Inc.\n");
  1129. return EXIT_SUCCESS;
  1130. break;
  1131. default:
  1132. fprintf(stderr, \
  1133. "usage:\n"\
  1134. " -f : Start application in foreground.\n"\
  1135. " -p : Do not set process priority. \n"\
  1136. " -v : Display version and SVN revision of Corosync and exit.\n");
  1137. return EXIT_FAILURE;
  1138. }
  1139. }
  1140. /*
  1141. * Set round robin realtime scheduling with priority 99
  1142. * Lock all memory to avoid page faults which may interrupt
  1143. * application healthchecking
  1144. */
  1145. if (setprio) {
  1146. corosync_setscheduler ();
  1147. }
  1148. corosync_mlockall ();
  1149. log_printf (LOGSYS_LEVEL_NOTICE, "Corosync Cluster Engine ('%s'): started and ready to provide service.\n", VERSION);
  1150. log_printf (LOGSYS_LEVEL_INFO, "Corosync built-in features:" PACKAGE_FEATURES "\n");
  1151. corosync_poll_handle = qb_loop_create ();
  1152. qb_loop_signal_add(corosync_poll_handle, QB_LOOP_LOW,
  1153. SIGUSR2, NULL, sig_diag_handler, NULL);
  1154. qb_loop_signal_add(corosync_poll_handle, QB_LOOP_HIGH,
  1155. SIGINT, NULL, sig_exit_handler, NULL);
  1156. qb_loop_signal_add(corosync_poll_handle, QB_LOOP_HIGH,
  1157. SIGQUIT, NULL, sig_exit_handler, NULL);
  1158. qb_loop_signal_add(corosync_poll_handle, QB_LOOP_HIGH,
  1159. SIGTERM, NULL, sig_exit_handler, NULL);
  1160. (void)signal (SIGSEGV, sigsegv_handler);
  1161. (void)signal (SIGABRT, sigabrt_handler);
  1162. #if MSG_NOSIGNAL != 0
  1163. (void)signal (SIGPIPE, SIG_IGN);
  1164. #endif
  1165. /*
  1166. * Load the object database interface
  1167. */
  1168. res = lcr_ifact_reference (
  1169. &objdb_handle,
  1170. "objdb",
  1171. 0,
  1172. &objdb_p,
  1173. 0);
  1174. if (res == -1) {
  1175. log_printf (LOGSYS_LEVEL_ERROR, "Corosync Executive couldn't open configuration object database component.\n");
  1176. corosync_exit_error (AIS_DONE_OBJDB);
  1177. }
  1178. objdb = (struct objdb_iface_ver0 *)objdb_p;
  1179. objdb->objdb_init ();
  1180. /*
  1181. * Initialize the corosync_api_v1 definition
  1182. */
  1183. apidef_init (objdb);
  1184. api = apidef_get ();
  1185. num_config_modules = 0;
  1186. /*
  1187. * Bootstrap in the default configuration parser or use
  1188. * the corosync default built in parser if the configuration parser
  1189. * isn't overridden
  1190. */
  1191. config_iface_init = getenv("COROSYNC_DEFAULT_CONFIG_IFACE");
  1192. if (!config_iface_init) {
  1193. config_iface_init = "corosync_parser";
  1194. }
  1195. /* Make a copy so we can deface it with strtok */
  1196. if ((config_iface = strdup(config_iface_init)) == NULL) {
  1197. log_printf (LOGSYS_LEVEL_ERROR, "exhausted virtual memory");
  1198. corosync_exit_error (AIS_DONE_OBJDB);
  1199. }
  1200. iface = strtok_r(config_iface, ":", &strtok_save_pt);
  1201. while (iface)
  1202. {
  1203. res = lcr_ifact_reference (
  1204. &config_handle,
  1205. iface,
  1206. config_version,
  1207. &config_p,
  1208. 0);
  1209. config = (struct config_iface_ver0 *)config_p;
  1210. if (res == -1) {
  1211. log_printf (LOGSYS_LEVEL_ERROR, "Corosync Executive couldn't open configuration component '%s'\n", iface);
  1212. corosync_exit_error (AIS_DONE_MAINCONFIGREAD);
  1213. }
  1214. res = config->config_readconfig(objdb, &error_string);
  1215. if (res == -1) {
  1216. log_printf (LOGSYS_LEVEL_ERROR, "%s", error_string);
  1217. corosync_exit_error (AIS_DONE_MAINCONFIGREAD);
  1218. }
  1219. log_printf (LOGSYS_LEVEL_NOTICE, "%s", error_string);
  1220. config_modules[num_config_modules++] = config;
  1221. iface = strtok_r(NULL, ":", &strtok_save_pt);
  1222. }
  1223. free(config_iface);
  1224. res = corosync_main_config_read (objdb, &error_string);
  1225. if (res == -1) {
  1226. /*
  1227. * if we are here, we _must_ flush the logsys queue
  1228. * and try to inform that we couldn't read the config.
  1229. * this is a desperate attempt before certain death
  1230. * and there is no guarantee that we can print to stderr
  1231. * nor that logsys is sending the messages where we expect.
  1232. */
  1233. log_printf (LOGSYS_LEVEL_ERROR, "%s", error_string);
  1234. fprintf(stderr, "%s", error_string);
  1235. syslog (LOGSYS_LEVEL_ERROR, "%s", error_string);
  1236. corosync_exit_error (AIS_DONE_MAINCONFIGREAD);
  1237. }
  1238. /*
  1239. * Make sure required directory is present
  1240. */
  1241. sprintf (corosync_lib_dir, "%s/lib/corosync", LOCALSTATEDIR);
  1242. res = stat (corosync_lib_dir, &stat_out);
  1243. if ((res == -1) || (res == 0 && !S_ISDIR(stat_out.st_mode))) {
  1244. log_printf (LOGSYS_LEVEL_ERROR, "Required directory not present %s. Please create it.\n", corosync_lib_dir);
  1245. corosync_exit_error (AIS_DONE_DIR_NOT_PRESENT);
  1246. }
  1247. res = totem_config_read (objdb, &totem_config, &error_string);
  1248. if (res == -1) {
  1249. log_printf (LOGSYS_LEVEL_ERROR, "%s", error_string);
  1250. corosync_exit_error (AIS_DONE_MAINCONFIGREAD);
  1251. }
  1252. res = totem_config_keyread (objdb, &totem_config, &error_string);
  1253. if (res == -1) {
  1254. log_printf (LOGSYS_LEVEL_ERROR, "%s", error_string);
  1255. corosync_exit_error (AIS_DONE_MAINCONFIGREAD);
  1256. }
  1257. res = totem_config_validate (&totem_config, &error_string);
  1258. if (res == -1) {
  1259. log_printf (LOGSYS_LEVEL_ERROR, "%s", error_string);
  1260. corosync_exit_error (AIS_DONE_MAINCONFIGREAD);
  1261. }
  1262. totem_config.totem_logging_configuration = totem_logging_configuration;
  1263. totem_config.totem_logging_configuration.log_subsys_id =
  1264. _logsys_subsys_create ("TOTEM");
  1265. if (totem_config.totem_logging_configuration.log_subsys_id < 0) {
  1266. log_printf (LOGSYS_LEVEL_ERROR,
  1267. "Unable to initialize TOTEM logging subsystem\n");
  1268. corosync_exit_error (AIS_DONE_MAINCONFIGREAD);
  1269. }
  1270. totem_config.totem_logging_configuration.log_level_security = LOGSYS_LEVEL_WARNING;
  1271. totem_config.totem_logging_configuration.log_level_error = LOGSYS_LEVEL_ERROR;
  1272. totem_config.totem_logging_configuration.log_level_warning = LOGSYS_LEVEL_WARNING;
  1273. totem_config.totem_logging_configuration.log_level_notice = LOGSYS_LEVEL_NOTICE;
  1274. totem_config.totem_logging_configuration.log_level_debug = LOGSYS_LEVEL_DEBUG;
  1275. totem_config.totem_logging_configuration.log_printf = _logsys_log_printf;
  1276. res = corosync_main_config_compatibility_read (objdb,
  1277. &minimum_sync_mode,
  1278. &error_string);
  1279. if (res == -1) {
  1280. log_printf (LOGSYS_LEVEL_ERROR, "%s", error_string);
  1281. corosync_exit_error (AIS_DONE_MAINCONFIGREAD);
  1282. }
  1283. res = corosync_main_config_compatibility_read (objdb,
  1284. &minimum_sync_mode,
  1285. &error_string);
  1286. if (res == -1) {
  1287. log_printf (LOGSYS_LEVEL_ERROR, "%s", error_string);
  1288. corosync_exit_error (AIS_DONE_MAINCONFIGREAD);
  1289. }
  1290. /* create the main runtime object */
  1291. objdb->object_create (OBJECT_PARENT_HANDLE,
  1292. &object_runtime_handle,
  1293. "runtime", strlen ("runtime"));
  1294. /*
  1295. * Now we are fully initialized.
  1296. */
  1297. if (background) {
  1298. corosync_tty_detach ();
  1299. }
  1300. logsys_fork_completed();
  1301. if ((flock_err = corosync_flock (corosync_lock_file, getpid ())) != AIS_DONE_EXIT) {
  1302. corosync_exit_error (flock_err);
  1303. }
  1304. /*
  1305. * if totempg_initialize doesn't have root priveleges, it cannot
  1306. * bind to a specific interface. This only matters if
  1307. * there is more then one interface in a system, so
  1308. * in this case, only a warning is printed
  1309. */
  1310. /*
  1311. * Join multicast group and setup delivery
  1312. * and configuration change functions
  1313. */
  1314. totempg_initialize (
  1315. corosync_poll_handle,
  1316. &totem_config);
  1317. totempg_service_ready_register (
  1318. main_service_ready);
  1319. totempg_groups_initialize (
  1320. &corosync_group_handle,
  1321. deliver_fn,
  1322. confchg_fn);
  1323. totempg_groups_join (
  1324. corosync_group_handle,
  1325. &corosync_group,
  1326. 1);
  1327. /*
  1328. * Drop root privleges to user 'ais'
  1329. * TODO: Don't really need full root capabilities;
  1330. * needed capabilities are:
  1331. * CAP_NET_RAW (bindtodevice)
  1332. * CAP_SYS_NICE (setscheduler)
  1333. * CAP_IPC_LOCK (mlockall)
  1334. */
  1335. priv_drop ();
  1336. schedwrk_init (
  1337. serialize_lock,
  1338. serialize_unlock);
  1339. /*
  1340. * Start main processing loop
  1341. */
  1342. qb_loop_run (corosync_poll_handle);
  1343. /*
  1344. * Exit was requested
  1345. */
  1346. totempg_finalize ();
  1347. /*
  1348. * Remove pid lock file
  1349. */
  1350. unlink (corosync_lock_file);
  1351. corosync_exit_error (AIS_DONE_EXIT);
  1352. return EXIT_SUCCESS;
  1353. }