Python fcntl не заблокирован, как ожидалось

Question

В операционной системе на базе Debian (Ubuntu, Debian Squeeze) я использую fttnt(), чтобы заблокировать файл. Как я понимаю из того, что я читал, fnctl.flock блокирует файл таким образом, что будет вызываться исключение, если другой клиент хочет заблокировать один и тот же файл.

Я построил маленький пример, который я бы ожидать, чтобы бросить excepiton, так как я первый заблокировать файл, а затем, сразу же после того, как я стараюсь, чтобы заблокировать его снова:

#!/usr/bin/env python 
# -*- coding: utf-8 -*- 
import fcntl 
fcntl.flock(open('/tmp/locktest', 'r'), fcntl.LOCK_EX) 
try: 
    fcntl.flock(open('/tmp/locktest', 'r'), fcntl.LOCK_EX | fcntl.LOCK_NB) 
except IOError: 
    print("can't immediately write-lock the file ($!), blocking ...") 
else: 
    print("No error") 

Но пример просто печатает «Нет ошибки».

Если я разделяю этот код на два клиента, работающих одновременно (одна блокировка, а затем ожидание, другая попытка блокировки после первой блокировки уже активна), я получаю такое же поведение - никакого эффекта вообще.

Какое объяснение этого поведения?

EDIT:

Изменения по просьбе nightcracker, эта версия также не печатает "Нет ошибки", хотя я бы не стал ожидать, что:

#!/usr/bin/env python 
# -*- coding: utf-8 -*- 
import fcntl 
import time 
fcntl.flock(open('/tmp/locktest', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB) 
try: 
    fcntl.flock(open('/tmp/locktest', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB) 
except IOError: 
    print("can't immediately write-lock the file ($!), blocking ...") 
else: 
    print("No error") 

Answer 1

Получено. Ошибка в моем сценарии является то, что я создаю новый дескриптор файла при каждом вызове:

fcntl.flock(open('/tmp/locktest', 'r'), fcntl.LOCK_EX | fcntl.LOCK_NB) 
(...) 
fcntl.flock(open('/tmp/locktest', 'r'), fcntl.LOCK_EX | fcntl.LOCK_NB) 

Вместо этого я должен назначить объект файла в переменную и не пытаться блокировать:

f = open('/tmp/locktest', 'r') 
fcntl.flock(f, fcntl.LOCK_EX | fcntl.LOCK_NB) 
(...) 
fcntl.flock(f, fcntl.LOCK_EX | fcntl.LOCK_NB) 

Чем Я также получаю исключение, которое хотел увидеть: IOError: [Errno 11] Resource temporarily unavailable.Теперь я должен думать о том, в каких случаях имеет смысл использовать fcntl.

Answer 2

Есть два уловы. Согласно documentation:

1. Когда операция LOCK_SH или LOCK_EX, он также может быть побитовое ORed с LOCK_NB, чтобы избежать блокировки на блокировку приобретения. Если используется LOCK_NB, и блокировка не может быть получена, то будет поднят IOError, и исключение будет иметь атрибут errno, установленный на EACCES или EAGAIN (в зависимости от операционной системы, для переносимости, проверьте оба значения).

   Вы забыли установить LOCK_NB.

2. По крайней мере в некоторых системах LOCK_EX может быть использован только если дескриптор файла ссылается на файл открыт для записи.

   У вас есть файл, открытый для чтения, который может не поддерживать LOCK_EX в вашей системе.

Answer 3

Необходимо передать в дескриптор файла (доступный путем вызова метода fileno() объекта файла). Код ниже бросает IOError, когда один и тот же код запускается в отдельном интерпретаторе.

>>> import fcntl 
>>> thefile = open('/tmp/testfile') 
>>> fd = thefile.fileno() 
>>> fcntl.flock(fd, fcntl.LOCK_EX | fcntl.LOCK_NB) 

Answer 4

Старый пост, но если кто-то находит его, я получаю такое поведение:

>>> fcntl.flock(open('test.flock', 'w'), fcntl.LOCK_EX) 
>>> fcntl.flock(open('test.flock', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB) 
# That didn't throw an exception 

>>> f = open('test.flock', 'w') 
>>> fcntl.flock(f, fcntl.LOCK_EX) 
>>> fcntl.flock(open('test.flock', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB) 
Traceback (most recent call last): 
    File "<stdin>", line 1, in <module> 
IOError: [Errno 35] Resource temporarily unavailable 
>>> f.close() 
>>> fcntl.flock(open('test.flock', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB) 
# No exception 

Похоже, что в первом случае, файл закрывается после первой строки, предположительно потому, что объектный файл недоступен , Закрытие файла освобождает блокировку.

Answer 5

я мастерил та же проблема ... Я решил, что держит открытый файл в отдельной переменной:

не будет работать:

fcntl.lockf(open('/tmp/locktest', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB) 

Работы:

lockfile = open('/tmp/locktest', 'w') 
fcntl.lockf(lockfile, fcntl.LOCK_EX | fcntl.LOCK_NB) 

Я думаю, что первый не работает, потому что открыт файл сбор мусора, закрыт и блокировка выпущена.

Answer 6

Try:

global f 
f = open('/tmp/locktest', 'r') 

Когда файл закрывается замок исчезнет.