disruptor c++ implementation for IPC (arbitrary length of data)
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
tests
.gitignore
LICENSE
README.md
atomic_print.hpp
common_def.hpp
elapsed_time.hpp
ring_buffer.hpp
ring_buffer_on_shmem.cpp
ring_buffer_on_shmem.hpp
shared_mem_manager.cpp
shared_mem_manager.hpp
wait_strategy.hpp

README.md

disruptorCpp-IPC for arbitrary length of data

slightly modified version of disruptorCpp-IPC

inter thread test

cd tests/inter_thread 
make clean all
./inter_thread_test 

inter process test

cd tests/inter_process 
make -f make_procucer.mk clean all
make -f make_consumer.mk clean all

//whenever you change number of cunsumer, producer or memory size, 
//clear shared memory first.
//ipcrm -M 0x000e1740
//ipcrm -M 0x0001e240

//run 2 consumer, then 1 producer 
./consumer 0 
./consumer 1
./producer
//make sure reset shared memory running 'ipcrm -M your_shmkey' if you have changed buffer size or number of producers/consumers.