diff --git a/cib/io.c b/cib/io.c

index e2873a8..4e2b24a 100644

--- a/cib/io.c

+++ b/cib/io.c

@@ -254,9 +254,7 @@ readCibXmlFile(const char *dir, const char *file, gboolean discard_status)

     if (cib_writes_enabled && use_valgrind) {

         if (crm_is_true(use_valgrind) || strstr(use_valgrind, "cib")) {

             cib_writes_enabled = FALSE;

-            crm_err("*********************************************************");

             crm_err("*** Disabling disk writes to avoid confusing Valgrind ***");

-            crm_err("*********************************************************");

         }

     }

diff --git a/crmd/crmd_lrm.h b/crmd/crmd_lrm.h

index 81a53c5..78432df 100644

--- a/crmd/crmd_lrm.h

+++ b/crmd/crmd_lrm.h

@@ -37,6 +37,8 @@ typedef struct resource_history_s {

     GHashTable *stop_params;

 } rsc_history_t;

+void history_free(gpointer data);

+

 /* TDOD - Replace this with lrmd_event_data_t */

 struct recurring_op_s {

     int call_id;

diff --git a/crmd/lrm.c b/crmd/lrm.c

index 062f769..418e7cf 100644

--- a/crmd/lrm.c

+++ b/crmd/lrm.c

@@ -103,6 +103,80 @@ copy_meta_keys(gpointer key, gpointer value, gpointer user_data)

     }

 }

+/*

+ * \internal

+ * \brief Remove a recurring operation from a resource's history

+ *

+ * \param[in,out] history  Resource history to modify

+ * \param[in]     op       Operation to remove

+ *

+ * \return TRUE if the operation was found and removed, FALSE otherwise

+ */

+static gboolean

+history_remove_recurring_op(rsc_history_t *history, const lrmd_event_data_t *op)

+{

+    GList *iter;

+

+    for (iter = history->recurring_op_list; iter != NULL; iter = iter->next) {

+        lrmd_event_data_t *existing = iter->data;

+

+        if ((op->interval == existing->interval)

+            && crm_str_eq(op->rsc_id, existing->rsc_id, TRUE)

+            && safe_str_eq(op->op_type, existing->op_type)) {

+

+            history->recurring_op_list = g_list_delete_link(history->recurring_op_list, iter);

+            lrmd_free_event(existing);

+            return TRUE;

+        }

+    }

+    return FALSE;

+}

+

+/*

+ * \internal

+ * \brief Free all recurring operations in resource history

+ *

+ * \param[in,out] history  Resource history to modify

+ */

+static void

+history_free_recurring_ops(rsc_history_t *history)

+{

+    GList *iter;

+

+    for (iter = history->recurring_op_list; iter != NULL; iter = iter->next) {

+        lrmd_free_event(iter->data);

+    }

+    g_list_free(history->recurring_op_list);

+    history->recurring_op_list = NULL;

+}

+

+/*

+ * \internal

+ * \brief Free resource history

+ *

+ * \param[in,out] history  Resource history to free

+ */

+void

+history_free(gpointer data)

+{

+    rsc_history_t *history = (rsc_history_t*)data;

+

+    if (history->stop_params) {

+        g_hash_table_destroy(history->stop_params);

+    }

+

+    /* Don't need to free history->rsc.id because it's set to history->id */

+    free(history->rsc.type);

+    free(history->rsc.class);

+    free(history->rsc.provider);

+

+    lrmd_free_event(history->failed);

+    lrmd_free_event(history->last);

+    free(history->id);

+    history_free_recurring_ops(history);

+    free(history);

+}

+

 static void

 update_history_cache(lrm_state_t * lrm_state, lrmd_rsc_info_t * rsc, lrmd_event_data_t * op)

 {

@@ -145,25 +219,10 @@ update_history_cache(lrm_state_t * lrm_state, lrmd_rsc_info_t * rsc, lrmd_event_

     target_rc = rsc_op_expected_rc(op);

     if (op->op_status == PCMK_LRM_OP_CANCELLED) {

         if (op->interval > 0) {

-            GList *gIter, *gIterNext;

-

             crm_trace("Removing cancelled recurring op: %s_%s_%d", op->rsc_id, op->op_type,

                       op->interval);

-

-            for (gIter = entry->recurring_op_list; gIter != NULL; gIter = gIterNext) {

-                lrmd_event_data_t *existing = gIter->data;

-

-                gIterNext = gIter->next;

-

-                if (crm_str_eq(op->rsc_id, existing->rsc_id, TRUE)

-                    && safe_str_eq(op->op_type, existing->op_type)

-                    && op->interval == existing->interval) {

-                    lrmd_free_event(existing);

-                    entry->recurring_op_list = g_list_delete_link(entry->recurring_op_list, gIter);

-                }

-            }

+            history_remove_recurring_op(entry, op);

             return;

-

         } else {

             crm_trace("Skipping %s_%s_%d rc=%d, status=%d", op->rsc_id, op->op_type, op->interval,

                       op->rc, op->op_status);

@@ -201,32 +260,17 @@ update_history_cache(lrm_state_t * lrm_state, lrmd_rsc_info_t * rsc, lrmd_event_

     }

     if (op->interval > 0) {

-        GListPtr iter = NULL;

-

-        for(iter = entry->recurring_op_list; iter; iter = iter->next) {

-            lrmd_event_data_t *o = iter->data;

-

-            /* op->rsc_id is implied */

-            if(op->interval == o->interval && strcmp(op->op_type, o->op_type) == 0) {

-                crm_trace("Removing existing recurring op entry: %s_%s_%d", op->rsc_id, op->op_type, op->interval);

-                entry->recurring_op_list = g_list_remove(entry->recurring_op_list, o);

-                break;

-            }

-        }

+        /* Ensure there are no duplicates */

+        history_remove_recurring_op(entry, op);

         crm_trace("Adding recurring op: %s_%s_%d", op->rsc_id, op->op_type, op->interval);

         entry->recurring_op_list = g_list_prepend(entry->recurring_op_list, lrmd_copy_event(op));

     } else if (entry->recurring_op_list && safe_str_eq(op->op_type, RSC_STATUS) == FALSE) {

-        GList *gIter = entry->recurring_op_list;

-

         crm_trace("Dropping %d recurring ops because of: %s_%s_%d",

-                  g_list_length(gIter), op->rsc_id, op->op_type, op->interval);

-        for (; gIter != NULL; gIter = gIter->next) {

-            lrmd_free_event(gIter->data);

-        }

-        g_list_free(entry->recurring_op_list);

-        entry->recurring_op_list = NULL;

+                  g_list_length(entry->recurring_op_list), op->rsc_id,

+                  op->op_type, op->interval);

+        history_free_recurring_ops(entry);

     }

 }

diff --git a/crmd/lrm_state.c b/crmd/lrm_state.c

index 374c806..162ad03 100644

--- a/crmd/lrm_state.c

+++ b/crmd/lrm_state.c

@@ -32,24 +32,6 @@ int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg);

 void lrmd_internal_set_proxy_callback(lrmd_t * lrmd, void *userdata, void (*callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg));

 static void

-history_cache_destroy(gpointer data)

-{

-    rsc_history_t *entry = data;

-

-    if (entry->stop_params) {

-        g_hash_table_destroy(entry->stop_params);

-    }

-

-    free(entry->rsc.type);

-    free(entry->rsc.class);

-    free(entry->rsc.provider);

-

-    lrmd_free_event(entry->failed);

-    lrmd_free_event(entry->last);

-    free(entry->id);

-    free(entry);

-}

-static void

 free_rsc_info(gpointer value)

 {

     lrmd_rsc_info_t *rsc_info = value;

@@ -155,7 +137,7 @@ lrm_state_create(const char *node_name)

                                                g_str_equal, g_hash_destroy_str, free_recurring_op);

     state->resource_history = g_hash_table_new_full(crm_str_hash,

-                                                    g_str_equal, NULL, history_cache_destroy);

+                                                    g_str_equal, NULL, history_free);

     g_hash_table_insert(lrm_state_table, (char *)state->node_name, state);

     return state;

diff --git a/cts/CM_ais.py b/cts/CM_ais.py

index 44f91cd..a34f9b1 100644

--- a/cts/CM_ais.py

+++ b/cts/CM_ais.py

@@ -49,42 +49,46 @@ class crm_ais(crm_lha):

     def NodeUUID(self, node):

         return node

-    def ais_components(self):

+    def ais_components(self, extra={}):

         complist = []

         if not len(self.fullcomplist.keys()):

             for c in ["cib", "lrmd", "crmd", "attrd" ]:

-               self.fullcomplist[c] = Process(

-                   self, c, 

-                   pats = self.templates.get_component(self.name, c),

-                   badnews_ignore = self.templates.get_component(self.name, "%s-ignore"%c),

-                   common_ignore = self.templates.get_component(self.name, "common-ignore"))

-

-               self.fullcomplist["pengine"] = Process(

-                   self, "pengine", 

-                   dc_pats = self.templates.get_component(self.name, "pengine"),

-                   badnews_ignore = self.templates.get_component(self.name, "pengine-ignore"),

-                   common_ignore = self.templates.get_component(self.name, "common-ignore"))

-

-               self.fullcomplist["stonith-ng"] = Process(

-                   self, "stonith-ng", process="stonithd", 

-                   pats = self.templates.get_component(self.name, "stonith"),

-                   badnews_ignore = self.templates.get_component(self.name, "stonith-ignore"),

-                   common_ignore = self.templates.get_component(self.name, "common-ignore"))

-

+                self.fullcomplist[c] = Process(

+                    self, c, 

+                    pats = self.templates.get_component(self.name, c),

+                    badnews_ignore = self.templates.get_component(self.name, "%s-ignore" % c),

+                    common_ignore = self.templates.get_component(self.name, "common-ignore"))

+

+            # pengine uses dc_pats instead of pats

+            self.fullcomplist["pengine"] = Process(

+                self, "pengine", 

+                dc_pats = self.templates.get_component(self.name, "pengine"),

+                badnews_ignore = self.templates.get_component(self.name, "pengine-ignore"),

+                common_ignore = self.templates.get_component(self.name, "common-ignore"))

+

+            # stonith-ng's process name is different from its component name

+            self.fullcomplist["stonith-ng"] = Process(

+                self, "stonith-ng", process="stonithd", 

+                pats = self.templates.get_component(self.name, "stonith"),

+                badnews_ignore = self.templates.get_component(self.name, "stonith-ignore"),

+                common_ignore = self.templates.get_component(self.name, "common-ignore"))

+

+            # add (or replace) any extra components passed in

+            self.fullcomplist.update(extra)

+

+        # Processes running under valgrind can't be shot with "killall -9 processname",

+        # so don't include them in the returned list

         vgrind = self.Env["valgrind-procs"].split()

         for key in self.fullcomplist.keys():

             if self.Env["valgrind-tests"]:

-               if key in vgrind:

-               # Processes running under valgrind can't be shot with "killall -9 processname"

+                if key in vgrind:

                     self.log("Filtering %s from the component list as it is being profiled by valgrind" % key)

                     continue

             if key == "stonith-ng" and not self.Env["DoFencing"]:

                 continue

-

             complist.append(self.fullcomplist[key])

-        #self.complist = [ fullcomplist["pengine"] ]

         return complist

@@ -100,17 +104,14 @@ class crm_cs_v0(crm_ais):

         crm_ais.__init__(self, Environment, randseed=randseed, name=name)

     def Components(self):

-        self.ais_components()

-        c = "corosync"

-

-        self.fullcomplist[c] = Process(

-            self, c, 

-            pats = self.templates.get_component(self.name, c),

-            badnews_ignore = self.templates.get_component(self.name, "%s-ignore"%c),

+        extra = {}

+        extra["corosync"] = Process(

+            self, "corosync", 

+            pats = self.templates.get_component(self.name, "corosync"),

+            badnews_ignore = self.templates.get_component(self.name, "corosync-ignore"),

             common_ignore = self.templates.get_component(self.name, "common-ignore")

         )

-

-        return self.ais_components()

+        return self.ais_components(extra=extra)

 class crm_cs_v1(crm_cs_v0):

diff --git a/cts/environment.py b/cts/environment.py

index a3399c3..61d4211 100644

--- a/cts/environment.py

+++ b/cts/environment.py

@@ -59,7 +59,7 @@ class Environment:

         self["stonith-params"] = "hostlist=all,livedangerously=yes"

         self["loop-minutes"] = 60

         self["valgrind-prefix"] = None

-        self["valgrind-procs"] = "cib crmd attrd pengine stonith-ng"

+        self["valgrind-procs"] = "attrd cib crmd lrmd pengine stonith-ng"

         self["valgrind-opts"] = """--leak-check=full --show-reachable=yes --trace-children=no --num-callers=25 --gen-suppressions=all --suppressions="""+CTSvars.CTS_home+"""/cts.supp"""

         self["experimental-tests"] = 0

@@ -578,6 +578,10 @@ class Environment:

             elif args[i] == "--valgrind-tests":

                 self["valgrind-tests"] = 1

+            elif args[i] == "--valgrind-procs":

+                self["valgrind-procs"] = args[i+1]

+                skipthis = 1

+

             elif args[i] == "--no-loop-tests":

                 self["loop-tests"] = 0

diff --git a/cts/patterns.py b/cts/patterns.py

index 1bc05a6..493b690 100644

--- a/cts/patterns.py

+++ b/cts/patterns.py

@@ -7,7 +7,9 @@ class BasePatterns:

     def __init__(self, name):

         self.name = name

         patternvariants[name] = self

-        self.ignore = []

+        self.ignore = [

+            "avoid confusing Valgrind",

+        ]

         self.BadNews = []

         self.components = {}

         self.commands = {

@@ -140,7 +142,7 @@ class crm_lha(BasePatterns):

                 r"Parameters to .* changed",

             ]

-        self.ignore = [

+        self.ignore = self.ignore + [

                 r"(ERROR|error):.*\s+assert\s+at\s+crm_glib_handler:"

                 "(ERROR|error): Message hist queue is filling up",

                 "stonithd.*CRIT: external_hostlist:.*'vmware gethosts' returned an empty hostlist",

@@ -177,7 +179,7 @@ class crm_cs_v0(BasePatterns):

             "Pat:PacemakerUp"  : "%s\W.*pacemakerd.*Starting Pacemaker",

         })

-        self.ignore = [

+        self.ignore = self.ignore + [

             r"crm_mon:",

             r"crmadmin:",

             r"update_trace_data",

diff --git a/extra/ansible/docker/group_vars/all b/extra/ansible/docker/group_vars/all

new file mode 100644

index 0000000..935e88a

--- /dev/null

+++ b/extra/ansible/docker/group_vars/all

@@ -0,0 +1,5 @@

+max: 4

+prefix: ansible-pcmk

+base_image: centos:centos7

+subnet: 172.17.200

+pacemaker_authkey: this_is_very_insecure

\ No newline at end of file

diff --git a/extra/ansible/docker/hosts b/extra/ansible/docker/hosts

new file mode 100644

index 0000000..5b0fb71

--- /dev/null

+++ b/extra/ansible/docker/hosts

@@ -0,0 +1,7 @@

+[controllers]

+oss-uk-1.clusterlabs.org

+

+[containers]

+ansible-1

+ansible-2

+ansible-3

diff --git a/extra/ansible/docker/roles/docker-host/files/docker-enter b/extra/ansible/docker/roles/docker-host/files/docker-enter

new file mode 100644

index 0000000..04c4822

--- /dev/null

+++ b/extra/ansible/docker/roles/docker-host/files/docker-enter

@@ -0,0 +1,29 @@

+#! /bin/sh -e

+

+case "$1" in

+  -h|--help)

+    echo "Usage: docker-enter CONTAINER [COMMAND]"

+    exit 0

+    ;;

+esac

+

+if [ $(id -ru) -ne 0 ]; then

+  echo "You have to be root."

+  exit 1

+fi

+

+if [ $# -eq 0 ]; then

+  echo "Usage: docker-enter CONTAINER [COMMAND]"

+  exit 1

+fi

+

+container=$1; shift

+PID=$(docker inspect --format {{.State.Pid}} "$container")

+

+if [ $# -ne 0 ]; then

+   nsenter --target $PID --mount --uts --ipc --net --pid -- $*

+   exit $?

+fi

+

+nsenter --target $PID --mount --uts --ipc --net --pid

+exit 0

diff --git a/extra/ansible/docker/roles/docker-host/files/fence_docker_cts b/extra/ansible/docker/roles/docker-host/files/fence_docker_cts

new file mode 100644

index 0000000..6d6f025

--- /dev/null

+++ b/extra/ansible/docker/roles/docker-host/files/fence_docker_cts

@@ -0,0 +1,202 @@

+#!/bin/bash

+#

+# Copyright (c) 2014 David Vossel <dvossel@redhat.com>

+#					All Rights Reserved.

+#

+# This program is free software; you can redistribute it and/or modify

+# it under the terms of version 2 of the GNU General Public License as

+# published by the Free Software Foundation.

+#

+# This program is distributed in the hope that it would be useful, but

+# WITHOUT ANY WARRANTY; without even the implied warranty of

+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

+#

+# Further, this software is distributed without any warranty that it is

+# free of the rightful claim of any third person regarding infringement

+# or the like.  Any license provided herein, whether implied or

+# otherwise, applies only to this software file.  Patent licenses, if

+# any, provided herein do not apply to combinations of this program with

+# other software, or any other product whatsoever.

+#

+# You should have received a copy of the GNU General Public License

+# along with this program; if not, write the Free Software Foundation,

+# Inc., 59 Temple Place - Suite 330, Boston MA 02111-1307, USA.

+#

+#######################################################################

+

+port=""

+action="list"		 # Default fence action

+

+function usage()

+{

+cat <

+`basename $0` - A fencing agent for docker containers for testing purposes

+ 

+Usage: `basename $0` -o|--action [-n|--port] [options]

+Options:

+ -h, --help 		This text

+ -V, --version		Version information

+ 

+Commands:

+ -o, --action		Action to perform: on|off|reboot|status|monitor

+ -n, --port 		The name of a container to control/check

+

+EOF

+	exit 0;

+}

+

+function metadata()

+{

+cat <

+

+<resource-agent name="fence_docker_cts" shortdesc="docker fencing agent for testing purposes" >

+	<longdesc>

+		fence_docker_cts fences docker containers for testing purposes.

+	</longdesc>

+	<parameters>

+	<parameter name="action" unique="1" required="0">

+		<getopt mixed="-o, --action=[action]" />

+		<content type="string" default="reboot" />

+		<shortdesc lang="en">Fencing Action</shortdesc>

+	</parameter>

+	<parameter name="port" unique="1" required="0">

+		<getopt mixed="-n, --port=[port]" />

+		<content type="string" />

+		<shortdesc lang="en">The name/id of docker container to control/check</shortdesc>

+	</parameter>

+	</parameters>

+	<actions>

+	<action name="on" />

+	<action name="off" />

+	<action name="reboot" />

+	<action name="status" />

+	<action name="list" />

+	<action name="monitor" />

+	<action name="metadata" />

+	</actions>

+</resource-agent>

+EOF

+	exit 0;

+}

+

+function docker_log() {

+	if ! [ "$action" = "list" ]; then

+		printf "$*\n" 1>&2

+	fi

+}

+

+# stdin option processing

+if [ -z $1 ]; then

+	# If there are no command line args, look for options from stdin

+	while read line; do

+		for word in $(echo "$line"); do

+			case $word in 

+			option=*|action=*) action=`echo $word | sed s/.*=//`;;

+			port=*)			port=`echo $word | sed s/.*=//`;;

+			node=*)			port=`echo $word | sed s/.*=//`;;

+			nodename=*)			port=`echo $word | sed s/.*=//`;;

+			--);;

+			*) docker_log "Invalid command: $word";;

+			esac

+		done

+	done

+fi

+

+# Command line option processing

+while true ; do

+	if [ -z "$1" ]; then

+		break;

+	fi

+	case "$1" in

+	-o|--action|--option) action=$2;	shift; shift;;

+	-n|--port)			port=$2;	  shift; shift;;

+	-V|--version) echo "1.0.0"; exit 0;;

+	--help|-h) 

+		usage;

+		exit 0;;

+	--) shift ; break ;;

+	*) docker_log "Unknown option: $1. See --help for details."; exit 1;;

+	esac

+done

+

+action=`echo $action | tr 'A-Z' 'a-z'`

+case $action in

+	hostlist|list) action=list;;

+	stat|status)   action=status;;

+	restart|reboot|reset)  action=reboot;;

+	poweron|on)	action=start;;

+	poweroff|off)  action=stop;;

+esac

+

+function fence_done() 

+{

+	if [ $1 -eq 0 ]; then

+		docker_log "Operation $action (port=$port) passed"

+	else

+		docker_log "Operation $action (port=$port) failed: $1"

+	fi

+	if [ -z "$returnfile" ]; then

+		rm -f $returnfile

+	fi

+	if [ -z "$helperscript" ]; then

+		rm -f $helperscript

+	fi

+	exit $1

+}

+

+case $action in 

+	metadata) metadata;;

+esac

+

+returnfile=$(mktemp /tmp/fence_docker_cts_returnfileXXXX)

+returnstring=""

+helper_script=$(mktemp /tmp/fence_docker_cts_helperXXXX)

+

+exec_action()

+{

+	echo "#!/bin/bash" > $helper_script

+	echo "sleep 10000" >> $helper_script

+	chmod 755 $helper_script

+	src="$(uname -n)"

+

+	$helper_script "$src" "$action" "$returnfile" "$port" > /dev/null 2>&1 &

+	pid=$!

+	docker_log "waiting on pid $pid"

+	wait $pid > /dev/null 2>&1

+	returnstring=$(cat $returnfile)

+

+	if [ -z "$returnstring" ]; then

+		docker_log "fencing daemon did not respond"

+		fence_done 1

+	fi

+

+	if [ "$returnstring" == "fail" ]; then

+		docker_log "fencing daemon failed to execute action [$action on port $port]"

+		fence_done 1

+	fi

+

+	return 0

+}

+

+exec_action

+case $action in 

+	list)

+		cat $returnfile

+		fence_done 0

+		;;

+

+	status)

+		# 0 if container is on

+		# 1 if container can not be contacted or unknown

+		# 2 if container is off

+		if [ "$returnstring" = "true" ]; then

+			fence_done 0

+		else 

+			fence_done 2

+		fi

+		;;

+	monitor|stop|start|reboot) : ;;

+	*) docker_log "Unknown action: $action"; fence_done 1;;

+esac

+

+fence_done $?

diff --git a/extra/ansible/docker/roles/docker-host/files/launch.sh b/extra/ansible/docker/roles/docker-host/files/launch.sh

new file mode 100644

index 0000000..66bebf4

--- /dev/null

+++ b/extra/ansible/docker/roles/docker-host/files/launch.sh

@@ -0,0 +1,4 @@

+#!/bin/bash

+while true; do

+	sleep 1

+done

diff --git a/extra/ansible/docker/roles/docker-host/files/pcmk_remote_start b/extra/ansible/docker/roles/docker-host/files/pcmk_remote_start

new file mode 100644

index 0000000..1bf0320

--- /dev/null

+++ b/extra/ansible/docker/roles/docker-host/files/pcmk_remote_start

@@ -0,0 +1,18 @@

+#!/bin/bash

+/usr/sbin/ip_start

+pid=$(pidof pacemaker_remoted)

+if [ "$?" -ne 0 ];  then

+	mkdir -p /var/run

+

+	export PCMK_debugfile=$pcmklogs

+	(pacemaker_remoted &) & > /dev/null 2>&1

+	sleep 5

+

+	pid=$(pidof pacemaker_remoted)

+	if [ "$?" -ne 0 ]; then

+		echo "startup of pacemaker failed"

+		exit 1

+	fi

+	echo "$pid" > /var/run/pacemaker_remoted.pid

+fi

+exit 0

diff --git a/extra/ansible/docker/roles/docker-host/files/pcmk_remote_stop b/extra/ansible/docker/roles/docker-host/files/pcmk_remote_stop

new file mode 100644

index 0000000..074cd59

--- /dev/null

+++ b/extra/ansible/docker/roles/docker-host/files/pcmk_remote_stop

@@ -0,0 +1,36 @@

+#!/bin/bash

+status()

+{

+	pid=$(pidof $1 2>/dev/null)

+	rtrn=$?

+	if [ $rtrn -ne 0 ]; then

+		echo "$1 is stopped"

+	else

+		echo "$1 (pid $pid) is running..."

+	fi

+	return $rtrn

+}

+stop()

+{

+	desc="Pacemaker Remote"

+	prog=$1

+	shutdown_prog=$prog

+

+	if status $shutdown_prog > /dev/null 2>&1; then

+	    kill -TERM $(pidof $prog) > /dev/null 2>&1

+

+	    while status $prog > /dev/null 2>&1; do

+		sleep 1

+		echo -n "."

+	    done

+	else

+	    echo -n "$desc is already stopped"

+	fi

+

+	rm -f /var/lock/subsystem/pacemaker

+	rm -f /var/run/${prog}.pid

+	killall -q -9 'crmd stonithd attrd cib lrmd pacemakerd pacemaker_remoted'

+}

+

+stop "pacemaker_remoted"

+exit 0

diff --git a/extra/ansible/docker/roles/docker-host/files/pcmk_start b/extra/ansible/docker/roles/docker-host/files/pcmk_start

new file mode 100644

index 0000000..d8b2ba8

--- /dev/null

+++ b/extra/ansible/docker/roles/docker-host/files/pcmk_start