Here's an example. mmshare writes lines from its STDIN to an mmap'd file, and mmlisten waits for that, then prints them. You have to be a bit careful how you write to the file; writing more than one machine word isn't atomic. So these programs divide the file up into segments, and use the first byte as a segment identifier which can be read and written to atomically.
#!/usr/bin/perl use warnings; use strict; use Sys::Mmap; use constant SEGMENT_SIZE => 256; use constant MAX_SEGMENTS => 8192/SEGMENT_SIZE; my $file = shift; my $mmap; if (! -f $file) { die "'$file' is not a regular file\n"; } open(F, "+< $file") or die "Couldn't open '$file': $!\n"; mmap($mmap, 0, PROT_READ|PROT_WRITE, MAP_SHARED, F) or die "mmap error: $!\n"; my $segment = 0; while (<>) { if (length > (SEGMENT_SIZE-1)) { warn "Line too long\n"; next; } $segment = ($segment + 1 ) % MAX_SEGMENTS; substr($mmap,1+SEGMENT_SIZE*$segment,1)=chr(length); substr($mmap,2+SEGMENT_SIZE*$segment,length)=$_; substr($mmap,0,1)=chr($segment); }
mmlisten:
#!/usr/bin/perl use warnings; use strict; use Sys::Mmap; use constant SEGMENT_SIZE => 256; use constant MAX_SEGMENTS => 8192/SEGMENT_SIZE; my $file = shift; my $mmap; if (! -f $file) { die "'$file' is not a regular file\n"; } open(F, "< $file") or die "Couldn't open '$file': $!\n"; mmap($mmap, 0, PROT_READ, MAP_SHARED, F) or die "mmap error: $!\n"; my $last_seg = -1; while (1) { my $segment = ord(substr($mmap,0,1)); next if ($segment == $last_seg); my $len = ord(substr($mmap,1+SEGMENT_SIZE*$segment,1)); my $line = substr($mmap,2+SEGMENT_SIZE*$segment,$len); print $line; $last_seg = $segment; }
To use them, first create an empty file to mmap:
then run mmlisten mm in one window, and mmshare mm in another. As you type lines into mmshare, they should show up in the mmlisten window.dd if=/dev/zero bs=1 count=8192 of=mm
Update: To answer Aristotle's question, AFAIK there's no way to share an anonymous mmap region between unrelated processes.
To answer leriksen's question, it's actually sharing the memory backed by the file, just as in some OS's all real memory is backed by swap (Solaris, IIRC). Changes are available immediately, at least as immediately as with any other shared memory scheme. It does periodically write the data out to disk, but changes are visible before it's written out.
In reply to Re: Mmap question
by sgifford
in thread Mmap question
by zentara
| For: | Use: | ||
| & | & | ||
| < | < | ||
| > | > | ||
| [ | [ | ||
| ] | ] |