Pacemaker 対応ログメッセージ変換機能。
Heartbeat-2.1.4 用 hb-logconv(*) のPacemaker 1.0.x + Corosync スタック対応版。
(*) http://sourceforge.jp/projects/linux-ha/releases/?package_id=10282
| Revision | 02abf5567b14e60704fb1d22c0dc8c55d2a8f6ac (tree) |
|---|---|
| Time | 2013-04-03 16:44:57 |
| Author | Yoshihiko SATO <satoyoshi@inte...> |
| Commiter | Yoshihiko SATO |
ノード状態ログ変更に伴う対応(MsgNo.6-1, 6-2)
pm_logconv.conf (diff)
pm_logconv.py (diff)| @@ -53,8 +53,8 @@ | ||
| 53 | 53 | ## |
| 54 | 54 | #MsgNo.6-1, 6-2 |
| 55 | 55 | [Node status updated] |
| 56 | -pattern_lost=crmd,info:,ais_status_callback:,status:,is now lost | |
| 57 | -pattern_member=crmd,info:,ais_status_callback:,status:,is now member | |
| 56 | +pattern_lost=crmd,info:,peer_update_callback:,is now lost | |
| 57 | +pattern_member=crmd,info:,peer_update_callback:,is now member | |
| 58 | 58 | func=node_status_updated |
| 59 | 59 | |
| 60 | 60 | #MsgNo.6-3 |
| @@ -2516,16 +2516,15 @@ | ||
| 2516 | 2516 | Convert log message which means Node status updated. |
| 2517 | 2517 | |
| 2518 | 2518 | MsgNo.6-1) |
| 2519 | - Jan 19 13:15:00 x3650a crmd: [27020]: info: ais_status_callback: status: x3650b is now lost (was member) | |
| 2519 | + Apr 3 14:25:20 pm01 crmd[15994]: info: peer_update_callback: pm02 is now lost (was member) | |
| 2520 | 2520 | MsgNo.6-2) |
| 2521 | - Jan 19 13:22:09 x3650a crmd: [27020]: info: ais_status_callback: status: x3650b is now member (was lost) | |
| 2522 | - Jan 19 13:44:25 x3650a crmd: [27020]: info: ais_status_callback: status: x3650b is now member | |
| 2521 | + Apr 3 14:26:44 pm01 crmd[15994]: info: peer_update_callback: pm02 is now member (was lost) | |
| 2523 | 2522 | ''' |
| 2524 | 2523 | def node_status_updated(self, outputobj, logelm, lconvfrm): |
| 2525 | 2524 | try: |
| 2526 | 2525 | wordlist = logelm.halogmsg.split() |
| 2527 | - nodename = wordlist[2] | |
| 2528 | - status = wordlist[5] | |
| 2526 | + nodename = wordlist[1] | |
| 2527 | + status = wordlist[4] | |
| 2529 | 2528 | except: |
| 2530 | 2529 | return CONV_PARSE_ERROR |
| 2531 | 2530 | if self.is_empty(nodename, status): |
Fork