diff --git a/rhodecode/tests/test_concurency.py b/rhodecode/tests/_test_concurency.py
old mode 100755
new mode 100644
copy from rhodecode/tests/test_concurency.py
copy to rhodecode/tests/_test_concurency.py
--- a/rhodecode/tests/test_concurency.py
+++ b/rhodecode/tests/_test_concurency.py
@@ -6,7 +6,8 @@
     Test suite for making push/pull operations
 
     :created_on: Dec 30, 2010
-    :copyright: (C) 2009-2011 Marcin Kuzminski <marcin@python-works.com>
+    :author: marcink
+    :copyright: (C) 2010-2012 Marcin Kuzminski <marcin@python-works.com>
     :license: GPLv3, see COPYING for more details.
 """
 # This program is free software: you can redistribute it and/or modify
@@ -53,7 +54,8 @@ add_cache(conf)
 
 USER = 'test_admin'
 PASS = 'test12'
-HOST = '127.0.0.1:5000'
+HOST = 'hg.local'
+METHOD = 'pull'
 DEBUG = True
 log = logging.getLogger(__name__)
 
@@ -80,7 +82,7 @@ class Command(object):
 def get_session():
     engine = engine_from_config(conf, 'sqlalchemy.db1.')
     init_model(engine)
-    sa = meta.Session()
+    sa = meta.Session
     return sa
 
 
@@ -153,9 +155,12 @@ def get_anonymous_access():
 #==============================================================================
 # TESTS
 #==============================================================================
-def test_clone_with_credentials(no_errors=False, repo=HG_REPO):
+def test_clone_with_credentials(no_errors=False, repo=HG_REPO, method=METHOD,
+                                seq=None):
     cwd = path = jn(TESTS_TMP_PATH, repo)
 
+    if seq == None:
+        seq = _RandomNameSequence().next()
 
     try:
         shutil.rmtree(path, ignore_errors=True)
@@ -164,26 +169,43 @@ def test_clone_with_credentials(no_error
     except OSError:
         raise
 
-
-    clone_url = 'http://%(user)s:%(pass)s@%(host)s/%(cloned_repo)s %(dest)s' % \
+    clone_url = 'http://%(user)s:%(pass)s@%(host)s/%(cloned_repo)s' % \
                   {'user':USER,
                    'pass':PASS,
                    'host':HOST,
-                   'cloned_repo':repo,
-                   'dest':path + _RandomNameSequence().next()}
+                   'cloned_repo':repo, }
 
-    stdout, stderr = Command(cwd).execute('hg clone', clone_url)
+    dest = path + seq
+    if method == 'pull':
+        stdout, stderr = Command(cwd).execute('hg', method, '--cwd', dest, clone_url)
+    else:
+        stdout, stderr = Command(cwd).execute('hg', method, clone_url, dest)
 
-    if no_errors is False:
-        assert """adding file changes""" in stdout, 'no messages about cloning'
-        assert """abort""" not in stderr , 'got error from clone'
+        if no_errors is False:
+            assert """adding file changes""" in stdout, 'no messages about cloning'
+            assert """abort""" not in stderr , 'got error from clone'
 
 if __name__ == '__main__':
     try:
         create_test_user(force=False)
+        seq = None
+        import time
 
-        for i in range(int(sys.argv[2])):
-            test_clone_with_credentials(repo=sys.argv[1])
+        try:
+            METHOD = sys.argv[3]
+        except:
+            pass
 
+        if METHOD == 'pull':
+            seq = _RandomNameSequence().next()
+            test_clone_with_credentials(repo=sys.argv[1], method='clone',
+                                        seq=seq)
+        s = time.time()
+        for i in range(1, int(sys.argv[2]) + 1):
+            print 'take', i
+            test_clone_with_credentials(repo=sys.argv[1], method=METHOD,
+                                        seq=seq)
+        print 'time taken %.3f' % (time.time() - s)
     except Exception, e:
+        raise
         sys.exit('stop on %s' % e)