From: Bastian Dehn Date: Sun, 15 May 2022 16:36:11 +0000 (+0200) Subject: change: seperate file outputbuffer X-Git-Url: https://gitweb.hhaalo.de/?a=commitdiff_plain;h=fb5fe4d4d5cb7e1dbc0292be75adfcb52178b06c;p=ringbuffer.git change: seperate file outputbuffer --- diff --git a/CMakeLists.txt b/CMakeLists.txt index a6737e6..aad8cd7 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -2,5 +2,5 @@ cmake_minimum_required(VERSION 3.18.4) project(ringbuffer) -add_executable(ringbuffer demo.c ringbuffer.c readbuffer.c) +add_executable(ringbuffer demo.c ringbuffer.c readbuffer.c outputbuffer.c) target_link_libraries(ringbuffer pthread) diff --git a/demo.c b/demo.c index 165a8b9..ea2df9f 100644 --- a/demo.c +++ b/demo.c @@ -1,32 +1,9 @@ #include #include -#include #include "readbuffer.h" +#include "outputbuffer.h" #include "ringbuffer.h" -#define maxvalues 1000000 - -void waitDstBuffer(ringbuffer *buf) -{ - while (buf->count == 0 && !buf->finish) { - usleep(100); - } -} - -void *outValues(void *buf) -{ - ringbuffer *buffer = (ringbuffer*) buf; - - for (int i = 0; i < maxvalues; i++) { - waitDstBuffer(buffer); - printf("get: Head: %d, Tail %d, Count: %d, Value: %d\n", - buffer->head, - buffer->tail, - buffer->count, - getValue(buffer)); - } -} - int main() { pthread_t readthread; diff --git a/outputbuffer.c b/outputbuffer.c new file mode 100644 index 0000000..0e90e77 --- /dev/null +++ b/outputbuffer.c @@ -0,0 +1,26 @@ +#include +#include +#include "outputbuffer.h" + +#define maxvalues 1000000 + +void waitDstBuffer(ringbuffer *buf) +{ + while (buf->count == 0 && !buf->finish) { + usleep(100); + } +} + +void *outValues(void *buf) +{ + ringbuffer *buffer = (ringbuffer*) buf; + + for (int i = 0; i < maxvalues; i++) { + waitDstBuffer(buffer); + printf("get: Head: %d, Tail %d, Count: %d, Value: %d\n", + buffer->head, + buffer->tail, + buffer->count, + getValue(buffer)); + } +} diff --git a/outputbuffer.h b/outputbuffer.h new file mode 100644 index 0000000..8b70a55 --- /dev/null +++ b/outputbuffer.h @@ -0,0 +1,8 @@ +#ifndef OUTPUTBUFFER_H +#define OUTPUTBUFFER_H +#include "ringbuffer.h" + +void waitDstBuffer(ringbuffer *buf); +void *outValues(void *buf); + +#endif