【问题标题】:C - Multiple processes writing to the same log fileC - 多个进程写入同一个日志文件
【发布时间】:2019-07-27 02:14:42
【问题描述】:

我有一个非常简单的 C 套接字服务器:主进程正在侦听特定端口。当新请求到达时,调用 fork():子进程进入一个名为 dosomething() 的函数,向客户端返回响应,将所有内容记录在文本文件中,然后终止。这是一个简化的视图:

void dosomething(int socketFd)
{
    /* ... */
    //Reads the request and sends a response
    writetolog("[INFO] Request accepted. Sent response message -> ", buffer);
    /* ... */
}

这是日志功能:

void writetolog(char* logString1, char* logString2)
{
    /* ... */
    //Prepends date and time, and formats everything nicely into a single char[]
    if ((logFd = open("SocketServer.log", O_CREAT | O_WRONLY | O_APPEND, 0644)) >= 0) {
        write(logFd, logBuffer, strlen(logBuffer));
        close(logFd);
    }
}

现在,我的问题是:由于该服务器(理论上)能够同时处理多个请求(因此,多个进程可能想要在日志中写入一些内容),我是否必须为日志引入任何同步(锁定)逻辑文件?

鉴于“关键部分”是单个 write() 调用: 由于操作系统调度,同一文件描述符上的多个 write() 调用是否可以“混合”?这是真正的风险吗? 例如:

Process1 wants to write "ABC"
Process2 wants to write "123"
Result: "AB1C23"

我尝试在同一时间窗口内从三个不同的客户端发送数千个请求。日志文件每次都正确写入,根本没有“混合”。我可以断定 write() 系统调用是原子的,至少在 POSIX 兼容系统中是这样吗?

额外问题:假设日志记录函数使用两个 write() 调用而不是一个。同步机制不应该再是可选的了,因为我想确保执行这两个调用而不会被另一个进程中断。在这种情况下我应该使用的最简单的锁定对象是什么?互斥就够了吗?

【问题讨论】:

  • write 系统调用不保证写入所有请求的字节。返回值告诉您它实际 写入了多少字节(最多为您指定的数字)。我不知道它可能会变小的所有条件,但如果输出设备空间不足,就会发生这种情况。这并不能真正回答您的问题,但值得了解。
  • 我的期望(可能完全合理,也可能不完全合理)是,只要每个进程进行一次写入调用以添加消息,交错就不应该有问题。 O_APPEND 标志很重要。您可能要考虑是否最好打开文件一次(在分叉之前)然后让孩子使用相同的打开文件描述(但每个都有自己的打开文件描述符 - 如果需要,请重新阅读 read() 规范刷新您对差异的记忆)。

标签: c concurrency locking fork mutex


【解决方案1】:

:“我必须为日志文件引入任何同步(锁定)逻辑吗?”

A:是的。同时写入同一个文件会产生竞争条件和不良行为。

Q:“鉴于“关键部分”是单个 write() 调用:由于操作系统调度,同一文件描述符上的多个 write() 调用是否可以“混合”?是这真的有风险吗?”

A:是的,你的例子可以发生。

要改进您的代码,请打开日志文件一次,并跟踪文件描述符。在writetolog 中使用互斥锁。

我写了一个新版本的writetolog,支持多参数(比如printf):

检查Share condition variable & mutex between processes: does mutex have to locked before? 的 pthread_mutex_t _mutex_log_file 初始化

#MAX_LEN_LOG_ENTRY 1024

// _log_fd is a file descriptor previously opened

void writetolog (char *fmt, ...)
{
    va_list ap;
    char   msg[MAX_LEN_LOG_ENTRY];

    va_start(ap, fmt);
    vsnprintf(msg, MAX_LEN_LOG_ENTRY - 1, fmt, ap);
    va_end(ap);

    pthread_mutex_lock (&_mutex_log_file);

    fprintf (_log_fd, "[ LOG ] %s\n", msg);
    fflush(_log_fd);

    pthread_mutex_unlock (&_mutex_log_file);
}

writetolog 的调用示例:

writetolog("Testing log function: %s %s %s", "hello", "world", "good");

【讨论】:

  • 由于这里使用了fork,所以锁是跨进程的。在这种情况下,以下链接中互斥锁的使用可能会更全面。 stackoverflow.com/questions/20325146/…
  • 这很有趣,谢谢大家。那么,为了让所有进程共享互斥锁,我是否必须在 main() 函数之外声明它(并在分叉之前对其进行初始化)?
  • @kleewan 您可以在父进程的主进程中或在父进程之外(全局)声明它,但初始化应该在分叉之前(在父进程中)。
  • @HoracioGoetendia Mutex 不会为子进程共享,所以这不起作用。它必须在共享内存中。
猜你喜欢
  • 1970-01-01
  • 2016-12-07
  • 1970-01-01
  • 1970-01-01
  • 2012-10-26
  • 1970-01-01
  • 2012-09-22
  • 1970-01-01
  • 2012-12-30
相关资源
最近更新 更多