c - linux fcntl文件锁定超时

Question

标准 Linux fcntl调用不提供超时选项。我正在考虑用信号实现超时锁定。

这里是阻塞锁的描述:

---

F_SETLKW

此命令等同于 F_SETLK，除了如果共享锁或排他锁被其他锁阻塞，线程将等待直到请求得到满足。 如果在 fcntl() 等待区域时接收到要捕获的信号，fcntl() 将被中断。 从信号处理程序返回时，fcntl() 将返回 -1 和错误号设置为[EINTR]，不进行锁操作。

---

那么我需要用什么样的信号来表示锁要被中断呢？而且由于我的进程中有多个线程在运行，我只想中断这个阻塞文件锁的IO线程，其他线程不应该受到影响，但是信号是进程级的，我不确定如何处理这种情况。

添加:

我已经使用信号编写了一个简单的实现。

int main(int argc, char **argv) {
  std::string lock_path = "a.lck";

  int fd = open(lock_path.c_str(), O_CREAT | O_RDWR, S_IRWXU | S_IRWXG | S_IRWXO);

  if (argc > 1) {
    signal(SIGALRM, [](int sig) {});
    std::thread([](pthread_t tid, unsigned int seconds) {
      sleep(seconds);
      pthread_kill(tid, SIGALRM);
    }, pthread_self(), 3).detach();
    int ret = file_rwlock(fd, F_SETLKW, F_WRLCK);

    if (ret == -1) std::cout << "FAIL to acquire lock after waiting 3s!" << std::endl;

  } else {
    file_rwlock(fd, F_SETLKW, F_WRLCK);
    while (1);
  }

  return 0;
}

通过运行 ./main 然后是 ./main a，我希望第一个进程永远持有锁，第二个进程尝试获取锁并在之后中断3s，但第二个进程刚刚终止。

有人能告诉我我的代码有什么问题吗？

Answer 1

So what kind of signal I need to use to indicate the lock to beinterrupted?

最明显的信号选择是 SIGUSR1 或 SIGUSR2。提供这些是为了满足用户定义的目的。

还有 SIGALRM，如果您使用产生此类信号的计时器来进行计时，这将是很自然的，并且即使以编程方式生成它也有意义，只要您不将其用于其他目的。

And since there're multiple threads running in myprocess, I only want to interrupt this IO thread who is blokcing forthe file lock, other threads should not be affected, but signal isprocess-level, I'm not sure how to handle this situation.

您可以通过 pthread_kill() 函数向多线程进程中的选定线程传递信号。这也适用于多个线程同时等待锁的情况。

使用常规 kill()，您还可以选择让所有线程阻塞所选信号 (sigprocmask())，然后让线程进行锁定尝试立即解锁它。 When the chosen signal is delivered to the process, a thread that is not presently blocking it will receive it, if any such thread is available.

示例实现

这假设已经设置了一个信号处理程序来处理所选信号(它不需要做任何事情)，并且可以通过符号 LOCK_TIMER_SIGNAL 获得要使用的信号编号.它提供了所需的超时行为作为围绕 fcntl() 的包装函数，使用问题中描述的命令 F_SETLKW。

#define _POSIX_C_SOURCE 200809L
#define _GNU_SOURCE

#include <unistd.h>
#include <signal.h>
#include <time.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/syscall.h>

#if (__GLIBC__ < 2) || (__GLIBC__ == 2 && __GLIBC_MINOR__ < 30)
// glibc prior to 2.30 does not provide a wrapper 
// function for this syscall:    
static pid_t gettid(void) {
    return syscall(SYS_gettid);
}
#endif

/**
 * Attempt to acquire an fcntl() lock, with timeout
 *
 * fd: an open file descriptor identifying the file to lock
 * lock_info: a pointer to a struct flock describing the wanted lock operation
 * to_secs: a time_t representing the amount of time to wait before timing out
 */    
int try_lock(int fd, struct flock *lock_info, time_t to_secs) {
    int result;
    timer_t timer;

    result = timer_create(CLOCK_MONOTONIC,
            & (struct sigevent) {
                .sigev_notify = SIGEV_THREAD_ID,
                ._sigev_un = { ._tid = gettid() },
                // note: gettid() conceivably can fail
                .sigev_signo = LOCK_TIMER_SIGNAL },
            &timer);
    // detect and handle errors ...

    result = timer_settime(timer, 0,
            & (struct itimerspec) { .it_value = { .tv_sec = to_secs } },
            NULL);

    result = fcntl(fd, F_SETLKW, lock_info);
    // detect and handle errors (other than EINTR) ...
    // on EINTR, may want to check that the timer in fact expired

    result = timer_delete(timer);
    // detect and handle errors ...

    return result;
}

这符合我的预期。

注意事项:

• 信号处置是进程范围的属性，而不是每个线程的属性，因此您需要在整个程序中协调信号的使用。在这种情况下，try_lock 函数本身修改其所选信号的配置是没有用的(而且可能是危险的)。
• timer_* 接口(interface)提供 POSIX 间隔计时器，但指定特定线程接收来自此类计时器的信号的规定是 Linux 特定的。
• 在 Linux 上，您需要为 timer_* 函数链接 -lrt。
• 以上解决了 Glibc 的 struct sigevent 不符合其自己的文档(至少在相对较旧的版本 2.17 中)这一事实。文档声称 struct sigevent 有一个成员 sigev_notify_thread_id，但实际上它没有。相反，它有一个未记录的 union 体，其中包含相应的成员，并且它提供了一个宏来弥补差异——但该宏在指定的初始值设定项中不能用作成员指定符。
• fcntl 锁在每个进程的基础上运行。因此，同一进程的不同线程不能通过这种锁相互排斥。此外，同一进程的不同线程可以修改通过其他线程获得的 fcntl() 锁，无需任何特殊努力或任何线程通知。
• 您可以考虑为此目的创建和维护每线程静态计时器，而不是在每次调用时创建然后销毁一个新计时器。
• 注意 fcntl() 将返回 EINTR 如果被任何 不终止线程的信号中断。因此，您可能希望使用一个信号处理程序来设置一个肯定的每线程标志，您可以通过该标志验证是否收到了实际的计时器信号，以便在它被不同的信号中断时重试锁定。
• 由您来确保线程不会因为某些其他原因接收到所选信号，或者通过其他方式确认在使用 EINTR 锁定失败的情况下时间实际上已到期.