Rooba
/
odyssey
mirror of https://github.com/yandex/odyssey.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

machinarium: update benchmarks

This commit is contained in:
Dmitry Simonenko 2018-02-05 15:49:23 +03:00
parent 9024153a6d
commit dfb7963b4d
4 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.gitignore vendored
View File

@ -4,5 +4,5 @@
sources/build.h
benchmark/benchmark_csw
benchmark/benchmark_channel
benchmark/benchmark_queue
benchmark/benchmark_channel_shared
tests/machinarium_test

2
benchmark/benchmark_channel.c
View File

@ -41,7 +41,7 @@ benchmark_runner(void *arg)
printf("benchmark started.\n");
machine_channel_t *channel;
channel = machine_channel_create();
channel = machine_channel_create(0);
int r = machine_coroutine_create(benchmark_reader, channel);
int w = machine_coroutine_create(benchmark_writer, channel);

18
benchmark/benchmark_queue.c → benchmark/benchmark_channel_shared.c
View File

@ -12,10 +12,10 @@ static int ops = 0;
static void
benchmark_reader(void *arg)
{
machine_queue_t *q = arg;
machine_channel_t *q = arg;
while (machine_active()) {
machine_msg_t *msg;
msg = machine_queue_get(q, UINT32_MAX);
msg = machine_channel_read(q, UINT32_MAX);
if (msg)
machine_msg_free(msg);
ops++;
@ -25,11 +25,11 @@ benchmark_reader(void *arg)
static void
benchmark_writer(void *arg)
{
machine_queue_t *q = arg;
machine_channel_t *q = arg;
while (machine_active()) {
machine_msg_t *msg;
msg = machine_msg_create(0, 0);
machine_queue_put(q, msg);
machine_channel_write(q, msg);
ops++;
machine_sleep(0);
}
@ -40,8 +40,8 @@ benchmark_runner(void *arg)
{
printf("benchmark started.\n");
machine_queue_t *q;
q = machine_queue_create();
machine_channel_t *q;
q = machine_channel_create(1);
int r = machine_coroutine_create(benchmark_reader, q);
int w = machine_coroutine_create(benchmark_writer, q);
@ -52,17 +52,17 @@ benchmark_runner(void *arg)
machine_join(r);
machine_join(w);
machine_queue_free(q);
machine_channel_free(q);
printf("done.\n");
printf("queue operations %d in 1 sec.\n", ops);
printf("channel operations %d in 1 sec.\n", ops);
}
int
main(int argc, char *argv[])
{
machinarium_init();
int id = machine_create("benchmark_queue", benchmark_runner, NULL);
int id = machine_create("benchmark_channel", benchmark_runner, NULL);
machine_wait(id);
machinarium_free();
return 0;

6
benchmark/makefile
View File

@ -3,13 +3,13 @@ RM = rm
CFLAGS = -I. -Wall -g -O3 -I../sources
LFLAGS_LIB = ../sources/libmachinarium.a -pthread -lssl -lcrypto
LFLAGS = $(LFLAGS_LIB)
EXAMPLES = benchmark_csw benchmark_channel benchmark_queue
EXAMPLES = benchmark_csw benchmark_channel benchmark_channel_shared
all: clean $(EXAMPLES)
benchmark_csw:
$(CC) $(CFLAGS) benchmark_csw.c $(LFLAGS) -o benchmark_csw
benchmark_channel:
$(CC) $(CFLAGS) benchmark_channel.c $(LFLAGS) -o benchmark_channel
benchmark_queue:
$(CC) $(CFLAGS) benchmark_queue.c $(LFLAGS) -o benchmark_queue
benchmark_channel_shared:
$(CC) $(CFLAGS) benchmark_channel_shared.c $(LFLAGS) -o benchmark_channel_shared
clean:
$(RM) -f $(EXAMPLES)