From: Sage Weil <sage@redhat.com>
Date: Thu, 26 Mar 2015 23:51:56 +0000 (-0700)
Subject: tasks/watch_notify_same_primary: wait for watch before notify
X-Git-Tag: v10.2.6~165^2^2~521^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=bafe87a8e51cdedad84ac6ea8ecd6504a7d9dd2e;p=ceph.git

tasks/watch_notify_same_primary: wait for watch before notify

Make sure watch is done registering and ready before sending the
notifies.

Fixes: #10634
Signed-off-by: Sage Weil <sage@redhat.com>
---

diff --git a/tasks/watch_notify_same_primary.py b/tasks/watch_notify_same_primary.py
index b83a7a97235..168b6bb6c30 100644
--- a/tasks/watch_notify_same_primary.py
+++ b/tasks/watch_notify_same_primary.py
@@ -7,6 +7,7 @@ import contextlib
 import logging
 
 from teuthology.orchestra import run
+from teuthology.contextutil import safe_while
 
 log = logging.getLogger(__name__)
 
@@ -57,7 +58,7 @@ def task(ctx, config):
                 obj(n),
                 "/etc/resolv.conf"],
             logger=log.getChild('watch.{id}'.format(id=n)))
-        return remote.run(
+        proc = remote.run(
             args = [
                 "rados",
                 "-p", pool,
@@ -67,7 +68,28 @@ def task(ctx, config):
             stdout=StringIO(),
             stderr=StringIO(),
             wait=False)
-    watches = [start_watch(i) for i in range(20)]
+        return proc
+
+    num = 20
+
+    watches = [start_watch(i) for i in range(num)]
+
+    # wait for them all to register
+    for i in range(num):
+        with safe_while() as proceed:
+            while proceed():
+                proc = remote.run(
+                    args = [
+                        "rados",
+                        "-p", pool,
+                        "listwatchers",
+                        obj(i)],
+                    stdout=StringIO())
+                lines = proc.stdout.getvalue()
+                num_watchers = lines.count('watcher=')
+                log.info('i see %d watchers for %s', num_watchers, obj(i))
+                if num_watchers >= 1:
+                    break
 
     def notify(n, msg):
         remote.run(