mirror of https://github.com/yandex/odyssey.git
odyssey: fix machinarium stat tests
This commit is contained in:
parent
de824a3373
commit
366f9b5312
|
@ -8,16 +8,18 @@ machinarium_test_config(void)
|
||||||
{
|
{
|
||||||
machinarium_set_pool_size(1);
|
machinarium_set_pool_size(1);
|
||||||
machinarium_init();
|
machinarium_init();
|
||||||
int count_machine = 0;
|
uint64_t count_machine = 0;
|
||||||
int count_coroutine = 0;
|
uint64_t count_coroutine = 0;
|
||||||
int count_coroutine_cache = 0;
|
uint64_t count_coroutine_cache = 0;
|
||||||
int msg_allocated = 0;
|
uint64_t msg_allocated = 0;
|
||||||
int msg_cache_count = 0;
|
uint64_t msg_cache_count = 0;
|
||||||
int msg_cache_size = 0;
|
uint64_t msg_cache_gc_count = 0;
|
||||||
|
uint64_t msg_cache_size = 0;
|
||||||
machinarium_stat(&count_machine, &count_coroutine,
|
machinarium_stat(&count_machine, &count_coroutine,
|
||||||
&count_coroutine_cache,
|
&count_coroutine_cache,
|
||||||
&msg_allocated,
|
&msg_allocated,
|
||||||
&msg_cache_count,
|
&msg_cache_count,
|
||||||
|
&msg_cache_gc_count,
|
||||||
&msg_cache_size);
|
&msg_cache_size);
|
||||||
test(count_machine == 1);
|
test(count_machine == 1);
|
||||||
machinarium_free();
|
machinarium_free();
|
||||||
|
|
|
@ -15,12 +15,13 @@ machinarium_test_stat(void)
|
||||||
{
|
{
|
||||||
machinarium_init();
|
machinarium_init();
|
||||||
|
|
||||||
int count_machine = 0;
|
uint64_t count_machine = 0;
|
||||||
int count_coroutine = 0;
|
uint64_t count_coroutine = 0;
|
||||||
int count_coroutine_cache = 0;
|
uint64_t count_coroutine_cache = 0;
|
||||||
int msg_allocated = 0;
|
uint64_t msg_allocated = 0;
|
||||||
int msg_cache_count = 0;
|
uint64_t msg_cache_count = 0;
|
||||||
int msg_cache_size = 0;
|
uint64_t msg_cache_gc_count = 0;
|
||||||
|
uint64_t msg_cache_size = 0;
|
||||||
|
|
||||||
|
|
||||||
for (;;) {
|
for (;;) {
|
||||||
|
@ -28,6 +29,7 @@ machinarium_test_stat(void)
|
||||||
&count_coroutine_cache,
|
&count_coroutine_cache,
|
||||||
&msg_allocated,
|
&msg_allocated,
|
||||||
&msg_cache_count,
|
&msg_cache_count,
|
||||||
|
&msg_cache_gc_count,
|
||||||
&msg_cache_size);
|
&msg_cache_size);
|
||||||
test(count_machine == 3); /* thread pool */
|
test(count_machine == 3); /* thread pool */
|
||||||
test(count_coroutine_cache == 0);
|
test(count_coroutine_cache == 0);
|
||||||
|
@ -47,6 +49,7 @@ machinarium_test_stat(void)
|
||||||
&count_coroutine_cache,
|
&count_coroutine_cache,
|
||||||
&msg_allocated,
|
&msg_allocated,
|
||||||
&msg_cache_count,
|
&msg_cache_count,
|
||||||
|
&msg_cache_gc_count,
|
||||||
&msg_cache_size);
|
&msg_cache_size);
|
||||||
test(count_machine == 3 + 1);
|
test(count_machine == 3 + 1);
|
||||||
test(count_coroutine_cache == 0);
|
test(count_coroutine_cache == 0);
|
||||||
|
@ -66,6 +69,7 @@ machinarium_test_stat(void)
|
||||||
&count_coroutine_cache,
|
&count_coroutine_cache,
|
||||||
&msg_allocated,
|
&msg_allocated,
|
||||||
&msg_cache_count,
|
&msg_cache_count,
|
||||||
|
&msg_cache_gc_count,
|
||||||
&msg_cache_size);
|
&msg_cache_size);
|
||||||
test(count_machine == 3)
|
test(count_machine == 3)
|
||||||
if (count_coroutine != 3) {
|
if (count_coroutine != 3) {
|
||||||
|
|
Loading…
Reference in New Issue