class MySQL_Slave < Property
      attr_reader :basedir, :mysqld_datadir, :mysqld_port, :mysqld_server_id, :mysqld_log_bin, :ebs_volume, :ebs_device

      def initialize
        super()
        @max_instances = 5

        # ▽ _wakame-common.sh ここから
        @template = ConfigurationTemplate::MySQLSlaveTemplate.new()
        @basedir = '/home/wakame/mysql'

        @mysqld_server_id = nil

        @mysqld_port = 3307
        @mysqld_datadir = File.expand_path('data-slave', @basedir)

        @ebs_volume = 'vol-12ac437b'  # master volume_id
        @ebs_device = '/dev/sdn'      # slave mount point
        @ebs_mount_option = 'noatime'

        @mysqld_master_host = nil
        @mysqld_master_user = 'wakame-repl'
        @mysqld_master_pass = 'wakame-slave'
        @mysqld_master_port = 3306
        @mysqld_master_datadir = File.expand_path('data', @basedir)
        # △ _wakame-common.sh ここまで

        @duplicable = true
      end

      # in wakame-master
      def before_start(svc, action)
        agent_ip = svc.agent.agent_ip
        Wakame.log.debug("#{svc.agent}")
        Wakame.log.debug("mysql_slave.agent.agent_ip = #{agent_ip}")

        # ▽wakame-ebs-mysql-master-make-snapshot.sh ここから
        # directory
        command = "ssh -i #{Wakame.config.ssh_private_key} -o \"StrictHostKeyChecking no\" -o \"UserKnownHostsFile #{Wakame.config.ssh_known_hosts}\" root@#{agent_ip} \"[ -d #{@mysqld_datadir} ] || mkdir -p #{@mys
qld_datadir}\""
        Wakame.log.debug(command)
        system(command)

        # /dev/ebs_device
        command = "ssh -i #{Wakame.config.ssh_private_key} -o \"StrictHostKeyChecking no\" -o \"UserKnownHostsFile #{Wakame.config.ssh_known_hosts}\" root@#{agent_ip} \"[ -b #{@ebs_device} ]\""
        Wakame.log.debug(command)
        system(command)
        if $? == 0
          Wakame.log.debug("The EBS volume(slave) device is not ready to attach: #{@ebs_device}")
          return
        end

        vm_manipulator = VmManipulator.create
        volume_map = vm_manipulator.describe_volume(@ebs_volume)
        Wakame.log.debug("describe_volume(#{@ebs_volume}): #{volume_map.inspect}")
        if volume_map['status'] == 'in-use'
          # Nothin to be done
        else
          Wakame.log.debug("The EBS volume(slave) is not ready to attach: #{@ebs_volume}")
          return
        end


        @mysqld_master_host = svc.cluster.fetch_mysql_master_ip
        Wakame.log.debug("mysqld_master_host = #{@mysqld_master_host}")
        system("echo show master status | /usr/bin/mysql -h#{@mysqld_master_host} -P#{@mysqld_master_port} -u#{@mysqld_master_user}  -p#{@mysqld_master_pass}")
        if $? != 0
          raise "Can't connect mysql master: #{@mysqld_master_host}:#{@mysqld_master_port}"
        end

        system("echo 'FLUSH TABLES WITH READ LOCK;' | /usr/bin/mysql -h#{@mysqld_master_host} -P#{@mysqld_master_port} -u#{@mysqld_master_user}  -p#{@mysqld_master_pass} -s")
        master_status = `echo show master status | /usr/bin/mysql -h#{@mysqld_master_host} -P#{@mysqld_master_port} -u#{@mysqld_master_user}  -p#{@mysqld_master_pass} -s`.to_s.split(/\t/)[0..1]

        # mysql/data/master.info
        master_infos = []
        master_infos << 14
        master_infos << master_status[0]
        master_infos << master_status[1]
        master_infos << @mysqld_master_host
        master_infos << @mysqld_master_user
        master_infos << @mysqld_master_pass
        master_infos << @mysqld_master_port
        master_infos << 60
        master_infos << 0
        master_infos << ""
        master_infos << ""
        master_infos << ""
        master_infos << ""
        master_infos << ""
        master_infos << ""

        tmp_output_basedir = File.expand_path(Wakame.gen_id, "/tmp")
        FileUtils.mkdir_p tmp_output_basedir
        master_info = File.expand_path('master.info', tmp_output_basedir)
        file = File.new(master_info, "w")
        file.puts(master_infos.join("\n"))
        file.chmod(0664)
        file.close

        3.times do |i|
          system("/bin/sync")
          sleep 1.0
        end

        # scp master:$datadir/master.info slave:$datadir/master.info
        command = "scp -i #{Wakame.config.ssh_private_key} -o \"StrictHostKeyChecking no\" -o \"UserKnownHostsFile #{Wakame.config.ssh_known_hosts}\" #{master_info} root@#{@mysqld_master_host}:#{@mysqld_master_dat
adir}/"
        Wakame.log.debug(command)
        system(command)

        # ssh slave chown mysql:mysql $datadir/master.info
        command = "ssh -i #{Wakame.config.ssh_private_key} -o \"StrictHostKeyChecking no\" -o \"UserKnownHostsFile #{Wakame.config.ssh_known_hosts}\" root@#{@mysqld_master_host} chown mysql:mysql #{@mysqld_master_
datadir}/master.info"
        Wakame.log.debug(command)
        system(command)

        # sync
        3.times do |i|
          command = "ssh -i #{Wakame.config.ssh_private_key} -o \"StrictHostKeyChecking no\" -o \"UserKnownHostsFile #{Wakame.config.ssh_known_hosts}\" root@#{@mysqld_master_host} /bin/sync"
          system(command)
          sleep 1.0
        end

        FileUtils.rm_rf tmp_output_basedir

        # 2. snapshot
        Wakame.log.debug("create_snapshot (#{@ebs_volume})")
        snapshot_map = vm_manipulator.create_snapshot(@ebs_volume)
        16.times do |i|
          Wakame.log.debug("describe_snapshot(#{snapshot_map.snapshotId}) ... #{i}")
          snapshot_map = vm_manipulator.describe_snapshot(snapshot_map["snapshotId"])
          if snapshot_map["status"] == "completed"
            break
          end
          sleep 1.0
        end
        if snapshot_map["status"] != "completed"
          raise "#{snapshot_map.snapshotId} status is #{snapshot_map.status}"
        end

        # 3. unlock mysql-master
        system("echo 'UNLOCK TABLES;' | /usr/bin/mysql -h#{@mysqld_master_host} -P#{@mysqld_master_port} -u#{@mysqld_master_user}  -p#{@mysqld_master_pass}")

        # create volume /dev/xxxx
        Wakame.log.debug("create_volume_from_snapshot(#{volume_map.availabilityZone}, #{snapshot_map.snapshotId})")
        created_volume_from_snapshot_map = vm_manipulator.create_volume_from_snapshot(volume_map["availabilityZone"], snapshot_map["snapshotId"])
        volume_from_snapshot_map = created_volume_from_snapshot_map
        16.times do |i|
          Wakame.log.debug("describe_snapshot(#{snapshot_map.snapshotId}) ... #{i}")
          volume_from_snapshot_map = vm_manipulator.describe_snapshot(snapshot_map["snapshotId"])
          if volume_from_snapshot_map["status"] == "completed"
            break
          end
          sleep 1.0
        end
        if volume_from_snapshot_map["status"] != "completed"
          raise "#{volume_from_snapshot_map.snapshotId} status is #{volume_from_snapshot_map.status}"
        end
        # △wakame-ebs-mysql-master-make-snapshot.sh ここまで

        # ▽wakame-ebs-mysql-slave-restore.sh(1) ここから
        # attach volume
        attach_volume_map = vm_manipulator.attach_volume(svc.agent.agent_id, created_volume_from_snapshot_map["volumeId"], @ebs_device)
        16.times do |i|
          Wakame.log.debug("describe_volume(#{attach_volume_map.volumeId}) ... #{i}")
          attach_volume_map = vm_manipulator.describe_volume(created_volume_from_snapshot_map["volumeId"])
          if attach_volume_map["status"] == "in-use"
            break
          end
          sleep 1.0
        end
        if attach_volume_map["status"] != "in-use"
          raise "#{attach_volume_map.volumeId} status is #{attach_volume_map.status}"
        end
        # △wakame-ebs-mysql-slave-restore.sh(1) ここまで
      end

      # in wakame-agent
      def start
        # ▽wakame-ebs-mysql-slave-restore.sh(2) ここから
        mount_point_dev=`df "#{@mysqld_datadir}" | awk 'NR==2 {print $1}'`
        if mount_point_dev != @ebs_device
          # sync
          3.times do |i|
            system("/bin/sync")
            sleep 1.0
          end

          Wakame.log.debug("Mounting EBS volume: #{@ebs_device} as #{@mysqld_datadir} (with option: #{@ebs_mount_option})")
          system("/bin/mount -o #{@ebs_mount_option} #{@ebs_device} #{@mysqld_datadir}")
          # sync
          3.times do |i|
            system("/bin/sync")
            sleep 1.0
          end
        end
        system(Wakame.config.root + "/config/init.d/mysql-slave start")
        # △wakame-ebs-mysql-slave-restore.sh(2) ここまで
      end

    end

    class WebCluster < ServiceCluster
      def initialize(master, &blk)
        super(master) {
        # サービスの定義を追加
        add_service(Apache_WWW.new)
        add_service(Apache_APP.new)
        add_service(Apache_LB.new)
        add_service(MySQL_Master.new)
        add_service(MySQL_Slave.new)

        # 依存関係の指定
        set_dependency(Apache_WWW, Apache_LB)
        set_dependency(Apache_APP, Apache_LB)
        set_dependency(MySQL_Master, Apache_APP)
        set_dependency(MySQL_Master, MySQL_Slave)
      end
    end