boost/interprocess
2
0
Fork 0
mirror of https://github.com/boostorg/interprocess.git synced 2026-01-19 04:12:13 +00:00
Code Issues Projects Releases Wiki Activity

Massive but simple changes:

Browse Source 
- Removed all tabs
- Changed all Doxygen @cond/@endcond tags with preprocessor sections, as Doxygen still has some problems when parsing this code. This also makes unmatched Doxygen sections a compilation error, which is easier to detect.
This commit is contained in:
Ion Gaztañaga
2014-07-30 11:46:32 +02:00
parent 36713fbe07
commit ad1b7f301c
220 changed files with 19267 additions and 19271 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
test/message_queue_test.cpp
View File

@@ -165,15 +165,15 @@ bool test_serialize_db()
//through mq2 to the second buffer
while(1){
//Send a fragment of buffer1 through mq1
std::size_t bytes_to_send = MaxMsgSize < (db_origin.get_size() - sent) ?
std::size_t bytes_to_send = MaxMsgSize < (db_origin.get_size() - sent) ?
MaxMsgSize : (db_origin.get_size() - sent);
mq1.send( &static_cast<char*>(db_origin.get_address())[sent]
, bytes_to_send
, 0);
sent += bytes_to_send;
//Receive the fragment through mq2 to buffer_destiny
mq2.receive( &buffer_destiny[total_recvd]
, BufferSize - recvd
mq2.receive( &buffer_destiny[total_recvd]
, BufferSize - recvd
, recvd
, priority);
total_recvd += recvd;
@@ -208,8 +208,8 @@ bool test_serialize_db()
}
//Now let's compare all db values
MyMap::size_type num_elements = map1->size();
for(std::size_t i = 0; i < num_elements; ++i){
MyMap::size_type num_elements = map1->size();
for(std::size_t i = 0; i < num_elements; ++i){
if((*map1)[i] != (*map2)[i]){
return false;
}
@@ -286,26 +286,26 @@ static const int MULTI_THREAD_COUNT = 10;
static void multisend()
{
char buff;
for (int i = 0; i < MULTI_NUM_MSG_PER_SENDER; i++) {
global_queue->send(&buff, 1, 0);
}
global_queue->send(&buff, 0, 0);
//std::cout<<"writer thread complete"<<std::endl;
char buff;
for (int i = 0; i < MULTI_NUM_MSG_PER_SENDER; i++) {
global_queue->send(&buff, 1, 0);
}
global_queue->send(&buff, 0, 0);
//std::cout<<"writer thread complete"<<std::endl;
}
static void multireceive()
{
char buff;
size_t size;
char buff;
size_t size;
int received_msgs = 0;
unsigned int priority;
do {
global_queue->receive(&buff, 1, size, priority);
unsigned int priority;
do {
global_queue->receive(&buff, 1, size, priority);
++received_msgs;
} while (size > 0);
} while (size > 0);
--received_msgs;
//std::cout << "reader thread complete, read msgs: " << received_msgs << std::endl;
//std::cout << "reader thread complete, read msgs: " << received_msgs << std::endl;
}
@@ -313,35 +313,35 @@ bool test_multi_sender_receiver()
{
bool ret = true;
//std::cout << "Testing multi-sender / multi-receiver " << std::endl;
try {
boost::interprocess::message_queue::remove(test::get_process_id_name());
boost::interprocess::message_queue mq
try {
boost::interprocess::message_queue::remove(test::get_process_id_name());
boost::interprocess::message_queue mq
(boost::interprocess::open_or_create, test::get_process_id_name(), MULTI_QUEUE_SIZE, 1);
global_queue = &mq;
std::vector<boost::interprocess::ipcdetail::OS_thread_t> threads(MULTI_THREAD_COUNT*2);
//Launch senders receiver thread
for (int i = 0; i < MULTI_THREAD_COUNT; i++) {
for (int i = 0; i < MULTI_THREAD_COUNT; i++) {
boost::interprocess::ipcdetail::thread_launch
(threads[i], &multisend);
}
}
for (int i = 0; i < MULTI_THREAD_COUNT; i++) {
for (int i = 0; i < MULTI_THREAD_COUNT; i++) {
boost::interprocess::ipcdetail::thread_launch
(threads[MULTI_THREAD_COUNT+i], &multireceive);
}
}
for (int i = 0; i < MULTI_THREAD_COUNT*2; i++) {
for (int i = 0; i < MULTI_THREAD_COUNT*2; i++) {
boost::interprocess::ipcdetail::thread_join(threads[i]);
//std::cout << "Joined thread " << i << std::endl;
}
}
}
}
catch (std::exception &e) {
std::cout << "error " << e.what() << std::endl;
std::cout << "error " << e.what() << std::endl;
ret = false;
}
}
boost::interprocess::message_queue::remove(test::get_process_id_name());
return ret;
return ret;
}