- LEAK_DETECTIVE activated
- memory leak in event_queue_t fixed
This commit is contained in:
@@ -280,6 +280,7 @@ static status_t add_absolute(private_event_queue_t *this, job_t *job, timeval_t
|
|||||||
status = iterator->has_next(iterator,&has_next);
|
status = iterator->has_next(iterator,&has_next);
|
||||||
if (status != SUCCESS)
|
if (status != SUCCESS)
|
||||||
{
|
{
|
||||||
|
iterator->destroy(iterator);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -296,7 +297,6 @@ static status_t add_absolute(private_event_queue_t *this, job_t *job, timeval_t
|
|||||||
{
|
{
|
||||||
/* my event has to be fired before the current event in list */
|
/* my event has to be fired before the current event in list */
|
||||||
status = this->list->insert_before(this->list,current_list_element,event);
|
status = this->list->insert_before(this->list,current_list_element,event);
|
||||||
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -306,6 +306,7 @@ static status_t add_absolute(private_event_queue_t *this, job_t *job, timeval_t
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
iterator->destroy(iterator);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -30,7 +30,7 @@
|
|||||||
/**
|
/**
|
||||||
* Number of different times to insert per thread
|
* Number of different times to insert per thread
|
||||||
*/
|
*/
|
||||||
#define EVENT_QUEUE_TIMES 10
|
#define EVENT_QUEUE_TIMES 5
|
||||||
/**
|
/**
|
||||||
* Number of entries per time per thread
|
* Number of entries per time per thread
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -104,7 +104,7 @@ void test_job_queue(tester_t *tester)
|
|||||||
test_infos.tester = tester;
|
test_infos.tester = tester;
|
||||||
test_infos.job_queue = job_queue;
|
test_infos.job_queue = job_queue;
|
||||||
test_infos.insert_item_count = 10000;
|
test_infos.insert_item_count = 10000;
|
||||||
test_infos.remove_item_count = 10000;
|
test_infos.remove_item_count = 50000;
|
||||||
|
|
||||||
|
|
||||||
desired_value = test_infos.insert_item_count * sender_count -
|
desired_value = test_infos.insert_item_count * sender_count -
|
||||||
@@ -130,9 +130,9 @@ void test_job_queue(tester_t *tester)
|
|||||||
pthread_join(receiver_threads[i], NULL);
|
pthread_join(receiver_threads[i], NULL);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/* the job-queue has to have disered_value count entries! */
|
/* the job-queue has to have disered_value count entries! */
|
||||||
tester->assert_true(tester,(job_queue->get_count(job_queue,&value) == SUCCESS), "get count call check");
|
tester->assert_true(tester,(job_queue->get_count(job_queue,&value) == SUCCESS), "get count call check");
|
||||||
tester->assert_true(tester,(value == desired_value), "get count value check");
|
tester->assert_true(tester,(value == desired_value), "get count value check");
|
||||||
|
|
||||||
tester->assert_true(tester,(job_queue->destroy(job_queue) == SUCCESS), "destroy call check");
|
tester->assert_true(tester,(job_queue->destroy(job_queue) == SUCCESS), "destroy call check");
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -33,7 +33,7 @@
|
|||||||
/**
|
/**
|
||||||
* Number of packets to send by sender-thread
|
* Number of packets to send by sender-thread
|
||||||
*/
|
*/
|
||||||
#define NUMBER_OF_PACKETS_TO_SEND 400
|
#define NUMBER_OF_PACKETS_TO_SEND 50
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Port to send the packets to
|
* Port to send the packets to
|
||||||
|
|||||||
Reference in New Issue
Block a user