mirror of
https://github.com/facebook/sapling.git
synced 2024-10-09 08:18:15 +03:00
e9e0539cc1
Summary: We want to remove filepeer as part of removing server logic in the client. To start with, let's disable it by default and only enable it in tests that need it. The next step will be to update those tests. Reviewed By: quark-zju Differential Revision: D30977765 fbshipit-source-id: c56016f017e894a15bf43fb7a8d3a0a417663ad9
226 lines
6.3 KiB
Perl
226 lines
6.3 KiB
Perl
#chg-compatible
|
|
$ setconfig experimental.allowfilepeer=True
|
|
|
|
#require unix-permissions no-root no-windows
|
|
|
|
Prepare
|
|
|
|
$ hg init a
|
|
$ echo a > a/a
|
|
$ hg -R a ci -A -m a
|
|
adding a
|
|
|
|
$ hg clone a b
|
|
updating to branch default
|
|
1 files updated, 0 files merged, 0 files removed, 0 files unresolved
|
|
|
|
Test that raising an exception in the release function doesn't cause the lock to choke
|
|
|
|
$ cat > testlock.py << EOF
|
|
> from edenscm.mercurial import error, registrar
|
|
>
|
|
> cmdtable = {}
|
|
> command = registrar.command(cmdtable)
|
|
>
|
|
> def acquiretestlock(repo, releaseexc):
|
|
> def unlock():
|
|
> if releaseexc:
|
|
> raise error.Abort('expected release exception')
|
|
> l = repo._lock(repo.localvfs, 'testlock', False, unlock, None, 'test lock')
|
|
> return l
|
|
>
|
|
> @command('testlockexc')
|
|
> def testlockexc(ui, repo):
|
|
> testlock = acquiretestlock(repo, True)
|
|
> try:
|
|
> testlock.release()
|
|
> finally:
|
|
> try:
|
|
> testlock = acquiretestlock(repo, False)
|
|
> except error.LockHeld:
|
|
> raise error.Abort('lockfile on disk even after releasing!')
|
|
> testlock.release()
|
|
> EOF
|
|
$ cat >> $HGRCPATH << EOF
|
|
> [extensions]
|
|
> testlock=$TESTTMP/testlock.py
|
|
> EOF
|
|
|
|
$ hg -R b testlockexc
|
|
abort: expected release exception
|
|
[255]
|
|
|
|
One process waiting for another for a significant period of time (longer than the default threshold). Warning should be shown.
|
|
|
|
$ cat > hooks.py << EOF
|
|
> import time
|
|
> def sleeplong(**x): time.sleep(3.1)
|
|
> def sleepshort(**x): time.sleep(0.1)
|
|
> EOF
|
|
$ echo b > b/b
|
|
$ hg -R b ci -A -m b --config hooks.precommit="python:`pwd`/hooks.py:sleeplong" > stdout &
|
|
$ hg -R b up -q --config hooks.pre-update="python:`pwd`/hooks.py:sleepshort" \
|
|
> > preup-stdout 2>preup-stderr
|
|
$ wait
|
|
$ cat preup-stdout
|
|
$ cat preup-stderr
|
|
waiting for lock on working directory of b held by process '*' on host '*' (glob)
|
|
(hint: run 'hg debugprocesstree *' to see related processes) (glob)
|
|
got lock after * seconds (glob)
|
|
$ cat stdout
|
|
adding b
|
|
|
|
One process waiting for another for short period of time. No warning.
|
|
|
|
$ cat > hooks.py << EOF
|
|
> import time
|
|
> def sleepone(**x): time.sleep(1)
|
|
> def sleephalf(**x): time.sleep(0.5)
|
|
> EOF
|
|
$ echo b > b/c
|
|
$ hg -R b ci -A -m b --config hooks.precommit="python:`pwd`/hooks.py:sleepone" > stdout &
|
|
$ hg -R b up -q --config hooks.pre-update="python:`pwd`/hooks.py:sleephalf" \
|
|
> > preup-stdout 2>preup-stderr
|
|
$ wait
|
|
$ cat preup-stdout
|
|
$ cat preup-stderr
|
|
$ cat stdout
|
|
adding c
|
|
|
|
On processs waiting on another, warning after a long time.
|
|
|
|
$ echo b > b/d
|
|
$ hg -R b ci -A -m b --config hooks.precommit="python:`pwd`/hooks.py:sleepone" > stdout &
|
|
$ hg -R b up -q --config hooks.pre-update="python:`pwd`/hooks.py:sleephalf" \
|
|
> --config ui.timeout.warn=250 \
|
|
> > preup-stdout 2>preup-stderr
|
|
$ wait
|
|
$ cat preup-stdout
|
|
$ cat preup-stderr
|
|
$ cat stdout
|
|
adding d
|
|
|
|
On processs waiting on another, warning disabled.
|
|
|
|
$ echo b > b/e
|
|
$ hg -R b ci -A -m b --config hooks.precommit="python:`pwd`/hooks.py:sleepone" > stdout &
|
|
$ hg -R b up -q --config hooks.pre-update="python:`pwd`/hooks.py:sleephalf" \
|
|
> --config ui.timeout.warn=-1 \
|
|
> > preup-stdout 2>preup-stderr
|
|
$ wait
|
|
$ cat preup-stdout
|
|
$ cat preup-stderr
|
|
$ cat stdout
|
|
adding e
|
|
|
|
check we still print debug output
|
|
|
|
On processs waiting on another, warning after a long time (debug output on)
|
|
|
|
$ echo b > b/f
|
|
$ hg -R b ci -A -m b --config hooks.precommit="python:`pwd`/hooks.py:sleepone" > stdout &
|
|
$ hg -R b up --config hooks.pre-update="python:`pwd`/hooks.py:sleephalf" \
|
|
> --config ui.timeout.warn=250 --debug\
|
|
> > preup-stdout 2>preup-stderr
|
|
$ wait
|
|
$ cat preup-stdout
|
|
calling hook pre-update: hghook_pre-update.sleephalf
|
|
0 files updated, 0 files merged, 0 files removed, 0 files unresolved
|
|
$ cat preup-stderr
|
|
locker is still running (full unique id: '*') (glob)
|
|
waiting for lock on working directory of b held by process '*' on host * (glob)
|
|
(hint: run * to see related processes) (glob)
|
|
got lock after * seconds (glob)
|
|
$ cat stdout
|
|
adding f
|
|
|
|
On processs waiting on another, warning disabled, (debug output on)
|
|
|
|
$ echo b > b/g
|
|
$ hg -R b ci -A -m b --config hooks.precommit="python:`pwd`/hooks.py:sleepone" > stdout &
|
|
$ hg -R b up --config hooks.pre-update="python:`pwd`/hooks.py:sleephalf" \
|
|
> --config ui.timeout.warn=-1 --debug\
|
|
> > preup-stdout 2>preup-stderr
|
|
$ wait
|
|
$ cat preup-stdout
|
|
calling hook pre-update: hghook_pre-update.sleephalf
|
|
0 files updated, 0 files merged, 0 files removed, 0 files unresolved
|
|
$ cat preup-stderr
|
|
locker is still running (full unique id: '*') (glob)
|
|
waiting for lock on working directory of b held by process '*' on host * (glob)
|
|
(hint: run * to see related processes) (glob)
|
|
got lock after * seconds (glob)
|
|
$ cat stdout
|
|
adding g
|
|
|
|
#if windows
|
|
Pushing to a local read-only repo that can't be locked
|
|
|
|
$ chmod 100 a/.hg/store
|
|
|
|
$ hg -R b push a
|
|
pushing to a
|
|
searching for changes
|
|
abort: could not lock repository a: Permission denied
|
|
[255]
|
|
|
|
$ chmod 700 a/.hg/store
|
|
|
|
Having an empty lock file
|
|
$ cd a
|
|
$ touch .hg/wlock
|
|
$ hg backout # a command which always acquires a lock
|
|
abort: malformed lock file ($TESTTMP/a/.hg/wlock)
|
|
(run hg debuglocks)
|
|
[255]
|
|
$ rm .hg/wlock
|
|
|
|
Having an undolog lock file
|
|
$ mkdir .hg/undolog && touch .hg/undolog/lock
|
|
$ hg debuglocks
|
|
lock: free
|
|
wlock: free
|
|
undolog/lock: malformed
|
|
prefetchlock: free
|
|
infinitepushbackup.lock: free
|
|
[1]
|
|
$ hg debuglocks --force-undolog-lock
|
|
$ hg debuglocks
|
|
lock: free
|
|
wlock: free
|
|
undolog/lock: free
|
|
prefetchlock: free
|
|
infinitepushbackup.lock: free
|
|
|
|
#else
|
|
|
|
Having an empty lock file
|
|
$ cd a
|
|
$ touch .hg/wlock
|
|
$ hg backout # a command which always acquires a lock
|
|
abort: please specify a revision to backout
|
|
[255]
|
|
|
|
Non-symlink stale lock is removed automatically.
|
|
|
|
Having an empty undolog lock file
|
|
$ mkdir .hg/undolog && touch .hg/undolog/lock
|
|
$ hg debuglocks
|
|
lock: free
|
|
wlock: free
|
|
undolog/lock: free
|
|
prefetchlock: free
|
|
infinitepushbackup.lock: free
|
|
$ hg debuglocks --force-undolog-lock
|
|
abort: cannot force release lock on POSIX
|
|
[255]
|
|
$ hg debuglocks
|
|
lock: free
|
|
wlock: free
|
|
undolog/lock: free
|
|
prefetchlock: free
|
|
infinitepushbackup.lock: free
|
|
#endif
|
|
|
|
$ cd ..
|