diff options
| author | Alan Conway <aconway@apache.org> | 2010-01-19 16:13:06 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2010-01-19 16:13:06 +0000 |
| commit | 1536ce288de7228869278baf795ff869aa255c85 (patch) | |
| tree | df8d1526564dbe8b80c1b35566818b2134673aea /cpp/src/tests/cluster_test.cpp | |
| parent | b5225ba70eced1130194a237d1673304875912eb (diff) | |
| download | qpid-python-1536ce288de7228869278baf795ff869aa255c85.tar.gz | |
Fix intermittent test error: cluster_test.cpp(1108): error in "testRelease": check browse(c3, "q", 5) == expected failed [ != m_1 m_2 m_3 m_4 m_5 ]
This was a test issue, not a broker issue. What seems to have been happening:
- start broker b0 & send messages.
- fork broker b1
- line 1103 (lqSub.release(...)); executes against b0 _before_ b1 connects for update lqSub.release(lqSub.getUnaccepted());
- line 1108 browse() executes during the update.
- update takes > 0.5 secs for some reason, browse times out.
The fix is a synchronous flush in browse() which will wait for the broker to be responsive before trying to get the messages.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@900829 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/cluster_test.cpp')
| -rw-r--r-- | cpp/src/tests/cluster_test.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/cpp/src/tests/cluster_test.cpp b/cpp/src/tests/cluster_test.cpp index 33f23aa5b3..bb1c014b99 100644 --- a/cpp/src/tests/cluster_test.cpp +++ b/cpp/src/tests/cluster_test.cpp @@ -157,6 +157,7 @@ vector<string> browse(Client& c, const string& q, int n) { ); LocalQueue lq; c.subs.subscribe(lq, q, browseSettings); + c.session.messageFlush(q); vector<string> result; for (int i = 0; i < n; ++i) { Message m; |