- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
我有一个程序可以将缓冲区复制到文件,mmap 将它们返回,然后检查它们的内容。多个线程可以处理同一个文件。偶尔,我在阅读时收到 SIGBUS,但只是在负载下。
映射是 MAP_PRIVATE 和 MAP_POPULATE。通过 SIGBUS 的崩溃发生在 mmap 成功之后,我不明白,因为使用了 MAP_POPULATE。
这是一个完整的示例(在/tmp/buf_* 下创建文件并用零填充),使用 OpenMP 创建更多负载和并发写入:
// Program to check for unexpected SIGBUS
// gcc -std=c99 -fopenmp -g -O3 -o mmap_manymany mmap_manymany.c
#include <assert.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/mman.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
#define NBUFS 64
const char bufs[NBUFS][65536] = {{0}};
const char zeros[65536] = {0};
int main()
{
int count = 0;
while ( 1 )
{
void *mappings[ 1000 ] = {NULL};
#pragma omp parallel for
for ( int i = 0; i < 1000; ++i )
{
// Prepare filename
int bufIdx = i % NBUFS;
char path[ 128 ] = { 0 };
sprintf( path, "/tmp/buf_%0d", bufIdx );
// Write full buffer
int outFd = -1;
#pragma omp critical
{
remove( path );
outFd = open( path, O_EXCL | O_CREAT | O_WRONLY | O_TRUNC, 0644 );
}
assert( outFd != -1 );
ssize_t size = write( outFd, bufs[bufIdx], 65536 );
assert( size == 65536 );
close( outFd );
// Map it to memory
int inFd = open( path, O_RDONLY );
if ( inFd == -1 )
continue; // Deleted by other thread. Nevermind
mappings[i] = mmap( NULL, 65536, PROT_READ, MAP_PRIVATE | MAP_POPULATE, inFd, 0 );
assert( mappings[i] != MAP_FAILED );
close( inFd );
// Read data immediately. Creates occasional SIGBUS but only under load.
int v = memcmp( mappings[i], zeros, 65536 );
assert( v == 0 );
}
// Clean up
for ( int i = 0; i < 1000; ++i )
munmap( mappings[ i ], 65536 );
printf( "count: %d\n", ++count );
}
}
我没有断言触发,但程序总是在 SIGBUS 几秒钟后崩溃。
最佳答案
对于您当前的程序,线程 0 可能会创建 /tmp/buf_0
,写入并关闭它。然后线程 1 删除并创建 /tmp/buf_0
,但在线程 1 写入它之前,线程 0 打开、映射并从 /tmp/buf_0
读取 - 因此尝试访问尚未包含 64 kiB 数据的文件。你得到一个 SIGBUS
。
为避免该问题,只需使用 omp_get_thread_num()
而不是 bufIdx
为每个线程创建唯一的文件/和 bufs
。
关于c - 从 mmap-ed 内存中进行有效读取会在负载下产生 SIGBUS。为什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44542852/
我遇到了一个奇怪的问题。我有这个: $(document).ready(function () {
我正在编写一个程序,它从列表中读取一些 ID,从中找出不同的 URL,然后将图像保存到我的 C: 驱动器中。 如果我在浏览器中导航到图像 URL,它们就会起作用。此外,如果我尝试从不同的服务器获取图像
我编写了一个 REST WCF RIA Silverlight 4.0 兼容服务,我可以从 javascript + jQuery.1.4.2.js + JSON2.js(当然,还可以从 .NET 4
我很确定这个网站实际上还没有得到回答。一劳永逸地,与 32 位有符号整数范围内的数字字符串匹配的最小正则表达式是什么,范围是 -2147483648至 2147483647 . 我必须使用正则表达式进
我有两个data.table;我想从那些与键匹配的元素中随机分配一个元素。我现在这样做的方式相当慢。 让我们具体点;这是一些示例数据: dt1<-data.table(id=sample(letter
我已经安装了 celery 、RabitMQ 和花。我可以浏览到花港。我有以下简单的工作人员,我可以将其附加到 celery 并从 python 程序调用: # -*- coding: utf-8 -
我正在使用 ScalaCheck 在 ScalaTest 中进行一些基于属性的测试。假设我想测试一个函数,f(x: Double): Double仅针对 x >= 0.0 定义的, 并返回 NaN对于
我想检查文件是否具有有效的 IMAGE_DOS_SIGNATURE (MZ) function isMZ(FileName : String) : boolean; var Signature: W
在 Herbert Schildt 的“Java:完整引用,第 9 版”中,有一个让我有点困惑的例子。它的关键点我无法理解可以概括为以下代码: class Test { public stat
我在工作中查看了一些代码,发现了一些我以前没有遇到过的东西: for (; ;) { // Some code here break; } 我们一直调用包含这个的函数,我最近才进去看看它是
在 Herbert Schildt 的“Java:完整引用,第 9 版”中,有一个让我有点困惑的例子。它的关键点我无法理解可以概括为以下代码: class Test { public stat
我试图编写一个函数,获取 2D 点矩阵和概率 p 并以概率 p 更改或交换每个点坐标 所以我问了一个question我试图使用二进制序列作为特定矩阵 swap_matrix=[[0,1],[1,0]]
这个问题在这里已经有了答案: Using / or \\ for folder paths in C# (5 个答案) 关闭 7 年前。 我在某个Class1中有这个功能: public v
PostgreSQL 10.4 我有一张 table : Column | Type ------------------------- id | integer| title
我正在 Postgresql 中编写一个函数,它将返回一些针对特定时区(输入)计算的指标。 示例结果: 主要问题是这只是一个指标。我需要从其他表中获取其他 9 个指标。 对于实现此目标的更简洁的方法有
我需要在 python 中模拟超几何分布(用于不替换采样元素的花哨词)。 设置:有一个装满人口许多弹珠的袋子。弹珠有两种类型,红色和绿色(在以下实现中,弹珠表示为 True 和 False)。从袋子中
我正在使用 MaterializeCSS 框架并动态填充文本输入。我遇到的一个问题是,在我关注该字段之前,valid 和 invalid css 类不会添加到我的字段中。 即使我调用 M.update
是否有重叠 2 个 div 的有效方法。 我有以下内容,但无法让它们重叠。 #top-border{width:100%; height:60px; background:url(image.jpg)
我希望你们中的一位能向我解释为什么编译器要求我在编译单元中重新定义一个静态固定长度数组,尽管我已经在头文件中这样做了。这是一个例子: 我的类.h: #ifndef MYCLASS_H #define
我正在使用旧线程发布试图解决相同问题的新代码。什么是安全 pickle ? this? socks .py from socket import socket from socket import A
我是一名优秀的程序员,十分优秀!