From 9710824c31c7e3b41d482e68ae790b46dc0513bb Mon Sep 17 00:00:00 2001
From: "carey.xu" <carey.xuhan@huawei.com>
Date: Tue, 1 Mar 2016 17:50:10 +0800
Subject: maker mariadb playbook reentrant

JIRA: COMPASS-329

Change-Id: I02680fe271f3896dc901a67c043570449fd3d64e
Signei-off-by: carey.xu <carey.xuhan@huawei.com>
Signed-off-by: carey.xu <carey.xuhan@huawei.com>
---
 .../roles/database/tasks/mariadb_cluster.yml       | 52 ++++++++++++++++++++--
 1 file changed, 48 insertions(+), 4 deletions(-)

(limited to 'deploy/adapters/ansible/roles/database/tasks/mariadb_cluster.yml')

diff --git a/deploy/adapters/ansible/roles/database/tasks/mariadb_cluster.yml b/deploy/adapters/ansible/roles/database/tasks/mariadb_cluster.yml
index 84704fa4..8fdb1437 100644
--- a/deploy/adapters/ansible/roles/database/tasks/mariadb_cluster.yml
+++ b/deploy/adapters/ansible/roles/database/tasks/mariadb_cluster.yml
@@ -7,8 +7,52 @@
 # http://www.apache.org/licenses/LICENSE-2.0
 ##############################################################################
 ---
-- include: mariadb_cluster_debian.yml
-  when: ansible_os_family == "Debian"
+- name: get cluster status
+  shell: mysql --silent --skip-column-names -e 'SHOW STATUS LIKE "wsrep_evs_state"'|awk '{print $2}'
+  register: cluster_status
+  when:
+    - inventory_hostname == haproxy_hosts.keys()[0]
 
-- include: mariadb_cluster_redhat.yml
-  when: ansible_os_family == "RedHat"
+- name: start first node to create new cluster
+  service:
+    name: mysql
+    state: restarted
+    enabled: yes
+    args: "--wsrep-new-cluster"
+  when: |
+    inventory_hostname == haproxy_hosts.keys()[0]
+    and not cluster_status.stdout | search("OPERATIONAL")
+
+- name: wait for cluster ready
+  shell: mysql --silent --skip-column-names -e 'SHOW STATUS LIKE "wsrep_evs_state"'|awk '{print $2}'
+  register: cluster_status
+  until: cluster_status|success
+  failed_when: not cluster_status.stdout | search("OPERATIONAL")
+  retries: 10
+  delay: 3
+  when: |
+    inventory_hostname == haproxy_hosts.keys()[0]
+    and not cluster_status.stdout | search("OPERATIONAL")
+
+- name: if I in the cluster nodes
+  shell: mysql --silent --skip-column-names -e 'SHOW STATUS LIKE "wsrep_incoming_addresses"'|awk '{print $2}'
+  register: cluster_nodes
+  changed_when: false
+
+- name: restart other nodes and join cluster
+  service:
+    name: mysql
+    state: restarted
+    enabled: yes
+  when: |
+    inventory_hostname != haproxy_hosts.keys()[0]
+    and not cluster_nodes.stdout | search("{{ internal_ip }}")
+
+- name: restart first nodes
+  service:
+    name: mysql
+    state: restarted
+  when: |
+    (inventory_hostname == haproxy_hosts.keys()[0]
+    and haproxy_hosts|length > 1
+    and not cluster_nodes.stdout | search('{{ internal_ip }}'))
-- 
cgit 1.2.3-korg