← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/lock.py

  • Committer: Martin Pool
  • Date: 2005-07-12 01:44:23 UTC
  • Revision ID: mbp@sourcefrog.net-20050712014423-1d95eb47ce7ab510
- add simple test case for bzr status

- show_status takes to_file argument

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/lock.py
52
52
                raise
53
53
 
54
54
            # maybe this is an old branch (before may 2005)
55
 
            mutter("trying to create missing branch lock %r", filename)
 
55
            mutter("trying to create missing branch lock %r" % filename)
56
56
            
57
57
            self.f = open(filename, 'wb')
58
58
            return self.f
84
84
        f = None
85
85
 
86
86
        def unlock(self):
87
 
            fcntl.lockf(self.f, fcntl.LOCK_UN)
 
87
            fcntl.flock(self.f, fcntl.LOCK_UN)
88
88
            self.f.close()
89
89
            del self.f 
90
90
 
92
92
    class _fcntl_WriteLock(_fcntl_FileLock):
93
93
        def __init__(self, filename):
94
94
            try:
95
 
                fcntl.lockf(self._open(filename, 'wb'), fcntl.LOCK_EX)
 
95
                fcntl.flock(self._open(filename, 'wb'), fcntl.LOCK_EX)
96
96
            except Exception, e:
97
97
                raise LockError(e)
98
98
 
100
100
    class _fcntl_ReadLock(_fcntl_FileLock):
101
101
        def __init__(self, filename):
102
102
            try:
103
 
                fcntl.lockf(self._open(filename, 'rb'), fcntl.LOCK_SH)
 
103
                fcntl.flock(self._open(filename, 'rb'), fcntl.LOCK_SH)
104
104
            except Exception, e:
105
105
                raise LockError(e)
106
106
 
112
112
        import win32con, win32file, pywintypes
113
113
 
114
114
 
115
 
        LOCK_SH = 0 # the default
116
 
        LOCK_EX = win32con.LOCKFILE_EXCLUSIVE_LOCK
117
 
        LOCK_NB = win32con.LOCKFILE_FAIL_IMMEDIATELY
 
115
        #LOCK_SH = 0 # the default
 
116
        #LOCK_EX = win32con.LOCKFILE_EXCLUSIVE_LOCK
 
117
        #LOCK_NB = win32con.LOCKFILE_FAIL_IMMEDIATELY
118
118
 
119
119
        class _w32c_FileLock(_base_Lock):
120
120
            def _lock(self, filename, openmode, lockmode):
139
139
 
140
140
        class _w32c_ReadLock(_w32c_FileLock):
141
141
            def __init__(self, filename):
142
 
                _w32c_FileLock._lock(self, filename, 'rb',
143
 
                                     LOCK_NB)
 
142
                _w32c_FileLock._lock(self, filename, 'rb', 0)
144
143
 
145
144
        class _w32c_WriteLock(_w32c_FileLock):
146
145
            def __init__(self, filename):
147
146
                _w32c_FileLock._lock(self, filename, 'wb',
148
 
                                     LOCK_EX + LOCK_NB)
 
147
                                     win32con.LOCKFILE_EXCLUSIVE_LOCK)
149
148
 
150
149
 
151
150
 
169
168
                LOCK_NB = 4
170
169
                def unlock(self):
171
170
                    _msvc_unlock(self.f)
172
 
                    self.f.close()
173
 
                    self.f = None
174
171
 
175
172
 
176
173
            class _msvc_ReadLock(_msvc_FileLock):
201
198
                        fpos = os.lseek(fn, 0,0)
202
199
                        os.lseek(fn, 0,0)
203
200
 
204
 
                    if flags & _msvc_FileLock.LOCK_SH:
205
 
                        if flags & _msvc_FileLock.LOCK_NB:
 
201
                    if flags & self.LOCK_SH:
 
202
                        if flags & self.LOCK_NB:
206
203
                            lock_mode = msvcrt.LK_NBLCK
207
204
                        else:
208
205
                            lock_mode = msvcrt.LK_LOCK
209
 
                    elif flags & _msvc_FileLock.LOCK_EX:
210
 
                        if flags & _msvc_FileLock.LOCK_NB:
 
206
                    elif flags & self.LOCK_EX:
 
207
                        if flags & self.LOCK_NB:
211
208
                            lock_mode = msvcrt.LK_NBRLCK
212
209
                        else:
213
210
                            lock_mode = msvcrt.LK_RLCK