文档章节

父子进程通过mmap进行通信

kuerant
 kuerant
发布于 2014/06/18 17:10
字数 466
阅读 300
收藏 6

本来打算使用pipe进行父子进程之间的数据交互(应用场景是父进程向多个子进程分发数据,子进程进行处理);但是担心pipe的性能,转而使用mmap实现。

废话少叙,上代码。

#include <stdio.h>
#include <sys/types.h>
#include <signal.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/mman.h>
#include <fcntl.h>

#define SHMFILE "shm.data"

typedef struct cell_t {
    int state;
    #define CELL_READY  1
    #define CELL_CLEAR  0
    int size;
    char    data[64];
} cell_t;

int main(void) {
    signal( SIGCHLD, SIG_IGN );
    
    int i, ret = 0;
    int fd = open(SHMFILE, O_CREAT | O_RDWR | O_TRUNC, 0600);
    if ( fd < 0 ) {
        fprintf(stderr, "fail to open %s -- %s\n", SHMFILE, strerror(errno));
        return  2;
    }
    int n_cells = 8;
    int shm_size = sizeof(cell_t) * n_cells;
    off_t off = lseek(fd, shm_size, SEEK_END);
    if ( off != (off_t)shm_size ) {
        fprintf(stderr, "fail to seek %s (got:%ld want:%d) -- %s\n", SHMFILE, off, shm_size, strerror(errno));
        return  3;
    }
    ret = write(fd, "", 1);
    if ( ret < 0 ) {
        fprintf(stderr, "fail to write %s -- %s\n", SHMFILE, strerror(errno));
        return  5;
    }

    cell_t* cell = (cell_t *) mmap(NULL, shm_size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
    if ( cell == NULL ) {
        fprintf(stderr, "fail to mmap %s -- %s\n", SHMFILE, strerror(errno));
        return  7;
    }
    for (i=0; i<n_cells; i++) {
        memset( cell + i, 0, sizeof(cell_t) );
    }
    int id = 3;
    int pid = fork();
    if (pid < 0) {
        fprintf(stderr, "fail to fork child -- %s\n", strerror(errno));
        return  1;
    }
    else if (pid == 0) {
        // child process
        pid = getpid();
        fprintf(stdout, "\tC#%d I am here ...\n", pid);
        
        cell_t* c = &cell[id];
        
        for ( i=0; i<5; i++ ) {
            if ( c->state == CELL_READY ) {
                fprintf(stdout, "\tC#%d size=%d data='%s'\n", pid, c->size, c->data);
                c->state = CELL_CLEAR;
                break;
            }
            sleep(1);
        }
        fprintf(stdout, "\tC#%d byebye\n", pid);

        munmap(cell, shm_size);
        close(fd);
        exit(0);
    }

    pid = getpid();
    fprintf(stdout, "P#%d I am here ...\n", pid);
    sleep(1);
    {
        cell_t* c = &cell[id];
        char*   data = "Hello,World.";
        c->size = strlen(data);
        memmove( c->data, data, c->size );
        c->state = CELL_READY;
        fprintf(stdout, "P#%d cell->state=%d\n", pid, c->state);
        sleep(5);
        fprintf(stdout, "P#%d cell->state=%d\n", pid, c->state);
    }
    fprintf(stdout, "P#%d byebye\n", pid);

    munmap(cell, shm_size);
    close(fd);
    return  0;
}

© 著作权归作者所有

共有 人打赏支持
上一篇: 2015 年度计划
下一篇: sqlite rpm spec
kuerant
粉丝 9
博文 54
码字总数 12892
作品 0
通州
私信 提问
Linux进程间通信—— 内存映射

Linux环境进程间通信(五): 共享内存(上) 共享内存可以说是最有用的进程间通信方式,也是最快的IPC形式。两个不同进程A、B共享内存的意思是,同一块物理内存被映射到进程A、B各自的进程地...

li_wen01
2017/07/29
0
0
Linux内存管理之mmap详解

一. mmap系统调用 1. mmap系统调用 mmap将一个文件或者其它对象映射进内存。文件被映射到多个页上,如果文件的大小不是所有页的大小之和,最后一个页不被使用的空间将会清零。munmap执行相反...

zhangyujsj
2016/03/12
52
0
Linux进程间通信源码剖析,共享内存(mmap)

来自:http://blog.csdn.net/dancing999/archive/2008/01/13/2042473.aspx 范例1:两个进程通过映射普通文件实现共享内存通信 范例1包含两个子程序:map_normalfile1.c及map_normalfile2.c。...

长平狐
2012/06/12
483
0
linux内存管理——mmap函数详解

mmap函数是unix/linux下的系统调用。 当存在客户-服务程序中复制文件时候,其数据流如下,要经历四次数据复制,开销很大。 如果采用共享内存的方式,那么将大大优化IO操作,数据流变成了如下...

闪亮的蛤蟆
04/20
0
0
Bryce1010的操作系统课程设计

1.作业调度 2.磁盘调度 常见的磁盘调度算法大致分为以下5类: FCFS、SSTF、SCAN、CSCAN、FSCAN 程序实现了上述5类调度算法。 其中,当前磁道和要求服务的磁道均由系统随机产生。 程序入口是m...

Fire_to_cheat_
2017/12/23
0
0

没有更多内容

加载失败,请刷新页面

加载更多

java框架学习日志-7(静态代理和JDK代理)

静态代理 我们平时去餐厅吃饭,不是直接告诉厨师做什么菜的,而是先告诉服务员点什么菜,然后由服务员传到给厨师,相当于服务员是厨师的代理,我们通过代理让厨师炒菜,这就是代理模式。代理...

白话
今天
21
0
Flink Window

1.Flink窗口 Window Assigner分配器。 窗口可以是时间驱动的(Time Window,例如:每30秒钟),也可以是数据驱动的(Count Window,例如:每一百个元素)。 一种经典的窗口分类可以分成: 翻...

满小茂
今天
17
0
my.ini

1

architect刘源源
今天
15
0
docker dns

There is a opensource application that solves this issue, it's called DNS Proxy Server It's a DNS server that solves containers hostnames, if could not found a hostname that mat......

kut
今天
15
0
寻找数学的广度——《这才是数学》读书笔记2700字

寻找数学的广度——《这才是数学》读书笔记2700字: 文|程哲。数学学习方式之广:国内外数学教育方面的专家,进行了很多种不同的数学学习方式尝试,如数学绘本、数学游戏、数学实验、数学步道...

原创小博客
今天
27
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部