corosync.aug 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120
  1. (* Process /etc/corosync/corosync.conf *)
  2. (* The lens is based on the corosync.conf(5) man page *)
  3. module Corosync =
  4. autoload xfm
  5. let comment = Util.comment
  6. let empty = Util.empty
  7. let dels = Util.del_str
  8. let eol = Util.eol
  9. let ws = del /[ \t]+/ " "
  10. let wsc = del /:[ \t]+/ ": "
  11. let indent = del /[ \t]*/ ""
  12. (* We require that braces are always followed by a newline *)
  13. let obr = del /\{([ \t]*)\n/ "{\n"
  14. let cbr = del /[ \t]*}[ \t]*\n/ "}\n"
  15. let ikey (k:regexp) = indent . key k
  16. let section (n:regexp) (b:lens) =
  17. [ ikey n . ws . obr . (b|empty|comment)* . cbr ]
  18. let kv (k:regexp) (v:regexp) =
  19. [ ikey k . wsc . store v . eol ]
  20. (* FIXME: it would be much more concise to write *)
  21. (* [ key k . ws . (bare | quoted) ] *)
  22. (* but the typechecker trips over that *)
  23. let qstr (k:regexp) =
  24. let delq = del /['"]/ "\"" in
  25. let bare = del /["']?/ "" . store /[^"' \t\n]+/ . del /["']?/ "" in
  26. let quoted = delq . store /.*[ \t].*/ . delq in
  27. [ ikey k . wsc . bare . eol ]
  28. |[ ikey k . wsc . quoted . eol ]
  29. (* The compatibility option *)
  30. let compatibility = kv "compatibility" /whitetank|none/
  31. (* A integer subsection *)
  32. let interface =
  33. let setting =
  34. kv "ringnumber" Rx.integer
  35. |kv "mcastport" Rx.integer
  36. |qstr /bindnetaddr|mcastaddr/ in
  37. section "interface" setting
  38. (* The totem section *)
  39. let totem =
  40. let setting =
  41. kv "clear_node_high_bit" /yes|no/
  42. |kv "rrp_mode" /none|active|passive/
  43. |kv "vsftype" /none|ykd/
  44. |kv "secauth" /on|off/
  45. |kv "transport" /udp|iba/
  46. |kv "version" Rx.integer
  47. |kv "nodeid" Rx.integer
  48. |kv "threads" Rx.integer
  49. |kv "netmtu" Rx.integer
  50. |kv "token" Rx.integer
  51. |kv "token_retransmit" Rx.integer
  52. |kv "hold" Rx.integer
  53. |kv "token_retransmits_before_loss_const" Rx.integer
  54. |kv "join" Rx.integer
  55. |kv "send_join" Rx.integer
  56. |kv "consensus" Rx.integer
  57. |kv "merge" Rx.integer
  58. |kv "downcheck" Rx.integer
  59. |kv "fail_to_recv_const" Rx.integer
  60. |kv "seqno_unchanged_const" Rx.integer
  61. |kv "heartbeat_failures_allowed" Rx.integer
  62. |kv "max_network_delay" Rx.integer
  63. |kv "max_messages" Rx.integer
  64. |kv "window_size" Rx.integer
  65. |kv "rrp_problem_count_timeout" Rx.integer
  66. |kv "rrp_problem_count_threshold" Rx.integer
  67. |kv "rrp_token_expired_timeout" Rx.integer
  68. |interface in
  69. section "totem" setting
  70. let common_logging =
  71. kv "to_syslog" /yes|no|on|off/
  72. |kv "to_stderr" /yes|no|on|off/
  73. |kv "to_logfile" /yes|no|on|off/
  74. |kv "debug" /yes|no|on|off/
  75. |kv "logfile_priority" /alert|crit|debug|emerg|err|info|notice|warning/
  76. |kv "syslog_priority" /alert|crit|debug|emerg|err|info|notice|warning/
  77. |kv "syslog_facility" /daemon|local0|local1|local2|local3|local4|local5|local6|local7/
  78. |qstr /logfile|tags/
  79. (* A logger_subsys subsection *)
  80. let logger_subsys =
  81. let setting =
  82. qstr /subsys/
  83. |common_logging in
  84. section "logger_subsys" setting
  85. (* The logging section *)
  86. let logging =
  87. let setting =
  88. kv "fileline" /yes|no|on|off/
  89. |kv "function_name" /yes|no|on|off/
  90. |kv "timestamp" /yes|no|on|off/
  91. |common_logging
  92. |logger_subsys in
  93. section "logging" setting
  94. (* The amf section *)
  95. let amf =
  96. let setting =
  97. kv "mode" /enabled|disabled/ in
  98. section "amf" setting
  99. let lns = (comment|empty|compatibility|totem|logging|amf)*
  100. let xfm = transform lns (incl "/etc/corosync/corosync.conf")