/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/lockdir.py

  • Committer: John Arbash Meinel
  • Date: 2009-12-22 16:28:47 UTC
  • mto: This revision was merged to the branch mainline in revision 4922.
  • Revision ID: john@arbash-meinel.com-20091222162847-tvnsc69to4l4uf5r
Implement a permute_for_extension helper.

Use it for all of the 'simple' extension permutations.
It basically permutes all tests in the current module, by setting TestCase.module.
Which works well for most of our extension tests. Some had more advanced
handling of permutations (extra permutations, custom vars, etc.)

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/lockdir.py
1
 
# Copyright (C) 2006-2010 Canonical Ltd
 
1
# Copyright (C) 2006, 2007, 2008, 2009 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
242
242
        # incorrect.  It's possible some other servers or filesystems will
243
243
        # have a similar bug allowing someone to think they got the lock
244
244
        # when it's already held.
245
 
        #
246
 
        # See <https://bugs.edge.launchpad.net/bzr/+bug/498378> for one case.
247
 
        #
248
 
        # Strictly the check is unnecessary and a waste of time for most
249
 
        # people, but probably worth trapping if something is wrong.
250
245
        info = self.peek()
251
246
        self._trace("after locking, info=%r", info)
252
 
        if info is None:
253
 
            raise LockFailed(self, "lock was renamed into place, but "
254
 
                "now is missing!")
255
 
        if info.get('nonce') != self.nonce:
 
247
        if info['nonce'] != self.nonce:
256
248
            self._trace("rename succeeded, "
257
249
                "but lock is still held by someone else")
258
250
            raise LockContention(self)
430
422
    def peek(self):
431
423
        """Check if the lock is held by anyone.
432
424
 
433
 
        If it is held, this returns the lock info structure as a dict
 
425
        If it is held, this returns the lock info structure as a rio Stanza,
434
426
        which contains some information about the current lock holder.
435
427
        Otherwise returns None.
436
428
        """
459
451
        return s.to_string()
460
452
 
461
453
    def _parse_info(self, info_bytes):
462
 
        stanza = rio.read_stanza(osutils.split_lines(info_bytes))
463
 
        if stanza is None:
464
 
            # see bug 185013; we fairly often end up with the info file being
465
 
            # empty after an interruption; we could log a message here but
466
 
            # there may not be much we can say
467
 
            return {}
468
 
        else:
469
 
            return stanza.as_dict()
 
454
        # TODO: Handle if info_bytes is empty
 
455
        return rio.read_stanza(osutils.split_lines(info_bytes)).as_dict()
470
456
 
471
457
    def attempt_lock(self):
472
458
        """Take the lock; fail if it's already held.
540
526
                    deadline_str = time.strftime('%H:%M:%S',
541
527
                                                 time.localtime(deadline))
542
528
                lock_url = self.transport.abspath(self.path)
543
 
                # See <https://bugs.edge.launchpad.net/bzr/+bug/250451>
544
 
                # the URL here is sometimes not one that is useful to the
545
 
                # user, perhaps being wrapped in a lp-%d or chroot decorator,
546
 
                # especially if this error is issued from the server.
547
529
                self._report_function('%s %s\n'
548
 
                    '%s\n' # held by
549
 
                    '%s\n' # locked ... ago
550
 
                    'Will continue to try until %s, unless '
551
 
                    'you press Ctrl-C.\n'
552
 
                    'See "bzr help break-lock" for more.',
553
 
                    start,
554
 
                    formatted_info[0],
555
 
                    formatted_info[1],
556
 
                    formatted_info[2],
557
 
                    deadline_str,
558
 
                    )
 
530
                                      '%s\n' # held by
 
531
                                      '%s\n' # locked ... ago
 
532
                                      'Will continue to try until %s, unless '
 
533
                                      'you press Ctrl-C\n'
 
534
                                      'If you\'re sure that it\'s not being '
 
535
                                      'modified, use bzr break-lock %s',
 
536
                                      start,
 
537
                                      formatted_info[0],
 
538
                                      formatted_info[1],
 
539
                                      formatted_info[2],
 
540
                                      deadline_str,
 
541
                                      lock_url)
559
542
 
560
543
            if (max_attempts is not None) and (attempt_count >= max_attempts):
561
544
                self._trace("exceeded %d attempts")
617
600
    def _format_lock_info(self, info):
618
601
        """Turn the contents of peek() into something for the user"""
619
602
        lock_url = self.transport.abspath(self.path)
620
 
        start_time = info.get('start_time')
621
 
        if start_time is None:
622
 
            time_ago = '(unknown)'
623
 
        else:
624
 
            time_ago = format_delta(time.time() - int(info['start_time']))
 
603
        delta = time.time() - int(info['start_time'])
625
604
        return [
626
605
            'lock %s' % (lock_url,),
627
 
            'held by %s on host %s [process #%s]' %
628
 
                tuple([info.get(x, '<unknown>') for x in ['user', 'hostname', 'pid']]),
629
 
            'locked %s' % (time_ago,),
 
606
            'held by %(user)s on host %(hostname)s [process #%(pid)s]' % info,
 
607
            'locked %s' % (format_delta(delta),),
630
608
            ]
631
609
 
632
610
    def validate_token(self, token):