From 763cfe0a19ce46b64bc637b65352006526eff37c Mon Sep 17 00:00:00 2001 From: dianshi Date: Wed, 1 Apr 2020 16:37:19 +0000 Subject: Initial commit --- PIPET-1.xcodeproj/project.pbxproj | 30 +++++ PIPET-1/main.c | 276 +++++++++++++++++++++++++++++++++++++- PIPET-1/pipet_view.c | 92 +++++++++++++ PIPET-1/pipet_view.h | 42 ++++++ 4 files changed, 438 insertions(+), 2 deletions(-) create mode 100644 PIPET-1/pipet_view.c create mode 100644 PIPET-1/pipet_view.h diff --git a/PIPET-1.xcodeproj/project.pbxproj b/PIPET-1.xcodeproj/project.pbxproj index b6e3f57..7c1c6d5 100644 --- a/PIPET-1.xcodeproj/project.pbxproj +++ b/PIPET-1.xcodeproj/project.pbxproj @@ -8,6 +8,8 @@ /* Begin PBXBuildFile section */ A94B89502434F70400B7DC09 /* main.c in Sources */ = {isa = PBXBuildFile; fileRef = A94B894F2434F70400B7DC09 /* main.c */; }; + A94B89582434F73800B7DC09 /* pipet_view.c in Sources */ = {isa = PBXBuildFile; fileRef = A94B89572434F73800B7DC09 /* pipet_view.c */; }; + A94B895D2434F76800B7DC09 /* SDL2.framework in Frameworks */ = {isa = PBXBuildFile; fileRef = A94B895C2434F76800B7DC09 /* SDL2.framework */; }; /* End PBXBuildFile section */ /* Begin PBXCopyFilesBuildPhase section */ @@ -25,6 +27,11 @@ /* Begin PBXFileReference section */ A94B894C2434F70400B7DC09 /* PIPET-1 */ = {isa = PBXFileReference; explicitFileType = "compiled.mach-o.executable"; includeInIndex = 0; path = "PIPET-1"; sourceTree = BUILT_PRODUCTS_DIR; }; A94B894F2434F70400B7DC09 /* main.c */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.c; path = main.c; sourceTree = ""; }; + A94B89562434F73800B7DC09 /* pipet_view.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = pipet_view.h; sourceTree = ""; }; + A94B89572434F73800B7DC09 /* pipet_view.c */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.c; path = pipet_view.c; sourceTree = ""; }; + A94B895A2434F75400B7DC09 /* Library */ = {isa = PBXFileReference; lastKnownFileType = folder; name = Library; path = ../../../../../Library; sourceTree = ""; }; + A94B895C2434F76800B7DC09 /* SDL2.framework */ = {isa = PBXFileReference; lastKnownFileType = wrapper.framework; name = SDL2.framework; path = ../../../../../Library/Frameworks/SDL2.framework; sourceTree = ""; }; + A94B895E2434F77C00B7DC09 /* SDL2_ttf.framework */ = {isa = PBXFileReference; lastKnownFileType = wrapper.framework; name = SDL2_ttf.framework; path = ../../../../../Library/Frameworks/SDL2_ttf.framework; sourceTree = ""; }; /* End PBXFileReference section */ /* Begin PBXFrameworksBuildPhase section */ @@ -32,6 +39,7 @@ isa = PBXFrameworksBuildPhase; buildActionMask = 2147483647; files = ( + A94B895D2434F76800B7DC09 /* SDL2.framework in Frameworks */, ); runOnlyForDeploymentPostprocessing = 0; }; @@ -43,6 +51,7 @@ children = ( A94B894E2434F70400B7DC09 /* PIPET-1 */, A94B894D2434F70400B7DC09 /* Products */, + A94B89592434F75400B7DC09 /* Frameworks */, ); sourceTree = ""; }; @@ -57,11 +66,23 @@ A94B894E2434F70400B7DC09 /* PIPET-1 */ = { isa = PBXGroup; children = ( + A94B89572434F73800B7DC09 /* pipet_view.c */, + A94B89562434F73800B7DC09 /* pipet_view.h */, A94B894F2434F70400B7DC09 /* main.c */, ); path = "PIPET-1"; sourceTree = ""; }; + A94B89592434F75400B7DC09 /* Frameworks */ = { + isa = PBXGroup; + children = ( + A94B895E2434F77C00B7DC09 /* SDL2_ttf.framework */, + A94B895C2434F76800B7DC09 /* SDL2.framework */, + A94B895A2434F75400B7DC09 /* Library */, + ); + name = Frameworks; + sourceTree = ""; + }; /* End PBXGroup section */ /* Begin PBXNativeTarget section */ @@ -120,6 +141,7 @@ buildActionMask = 2147483647; files = ( A94B89502434F70400B7DC09 /* main.c in Sources */, + A94B89582434F73800B7DC09 /* pipet_view.c in Sources */, ); runOnlyForDeploymentPostprocessing = 0; }; @@ -239,6 +261,10 @@ isa = XCBuildConfiguration; buildSettings = { CODE_SIGN_STYLE = Automatic; + FRAMEWORK_SEARCH_PATHS = ( + "$(inherited)", + "$(LOCAL_LIBRARY_DIR)/Frameworks", + ); PRODUCT_NAME = "$(TARGET_NAME)"; }; name = Debug; @@ -247,6 +273,10 @@ isa = XCBuildConfiguration; buildSettings = { CODE_SIGN_STYLE = Automatic; + FRAMEWORK_SEARCH_PATHS = ( + "$(inherited)", + "$(LOCAL_LIBRARY_DIR)/Frameworks", + ); PRODUCT_NAME = "$(TARGET_NAME)"; }; name = Release; diff --git a/PIPET-1/main.c b/PIPET-1/main.c index ff09eb6..45c9b43 100644 --- a/PIPET-1/main.c +++ b/PIPET-1/main.c @@ -2,14 +2,286 @@ // main.c // PIPET-1 // -// Created by dianshi on 4/1/20. +// Created by dianshi on 3/28/20. // Copyright © 2020 dianshi. All rights reserved. // #include +#include +#include +#include +#include +#include +#include +#include +#include + +#include +#include + +#include "pipet_view.h" + +#define SCREEN_WIDTH 200 +#define SCREEN_HEIGHT 100 + + +typedef struct { + int f_output; //show statistics of pipe + int f_stopzero; //stop if 0 bytes in input + int f_nowriteout; // dont write to output + int f_graphmode; //show graph +} pipet_params; + +typedef struct { + uint64_t cnt_in; + uint64_t prev_cnt_in; + uint64_t cnt_out; +} pipet_stats; + +typedef struct { + int fd_in; + int fd_out; + pipet_stats *ps; +} thread_params; + +//global_params +static pipet_params g_params; +static pipet_stats g_stats; +static pipet_view g_view; +static int quit=0; +static SDL_Window *window = NULL; +static SDL_Renderer *renderer = NULL; + + +void helper(char *progname) +{ + printf("Usage: %s [OPTS]\n\n" + "-o show output stats\n" + "-s stop if there is 0 bytes in read\n" + "-n dont ouput input data\n" + "-g graphical interface\n" + "Version: 0.0.2 \n" + "\n" + , progname); +} + +void sig_handler(int signo) +{ + switch(signo) + { + case SIGINT: + printf("Catch SIGINT Exit\n"); + if (g_params.f_output) + { + printf("Data in %d bytes Data out %d bytes",g_stats.cnt_in,g_stats.cnt_out); + } + default: + printf("Unknown signal %d\n",signo); + } + exit(0); +} + +void *thread_pipe(void *param) +{ + thread_params *tp = (thread_params *)param; + int cur_read=-1; + int cur_write=-1; + const uint64_t BUF_SZ=1024*4; + uint8_t buf[BUF_SZ]; + + + printf("Start thread\n"); + + while (quit == 0) + { + cur_read = read(tp->fd_in,buf, BUF_SZ); + if (g_params.f_stopzero) + { + if (cur_read < 1) + { + quit = 1; + break; + } + } + g_stats.cnt_in += cur_read;// printf("Read %d\n", cur_read); + + if (!g_params.f_nowriteout) + { + cur_write = write(tp->fd_out, buf, cur_read); + g_stats.cnt_out += cur_write; + } + } + + //exit(0); + pthread_exit(NULL); + +} int main(int argc, const char * argv[]) { + int c; + int rc; + + int fd_stdin=-1,fd_stdout=-1; + int cur_read,cur_write; + int prev_val=0; + + pthread_t thread; + SDL_Event event; + + const uint64_t BUF_SZ=1024*4; + uint8_t buf[BUF_SZ]; + + thread_params tp; + // insert code here... - printf("Hello, World!\n"); + + memset(&g_params,0,sizeof(pipet_params)); + memset(&g_stats,0,sizeof(pipet_stats)); + memset(&g_view,0,sizeof(pipet_view)); + memset(&tp,0,sizeof(thread_params)); + + + pv_init(&g_view, 200, SCREEN_WIDTH, SCREEN_HEIGHT); + + fd_stdin = fileno(stdin); + fd_stdout = fileno(stdout); + + //int flags = fcntl(fd_stdin, F_GETFL, 0); + //fcntl(fd_stdin, F_SETFL, flags | O_NONBLOCK); + + + if (signal(SIGINT,sig_handler) == SIG_ERR) + { + printf("cannot register signal handler\n"); + exit(1); + } + + //process arguments + while ((c = getopt(argc, argv, "osng")) != -1) + { + switch (c) + { + case 'o': + g_params.f_output = 1; + break; + case 's': + g_params.f_stopzero = 1; + break; + case 'n': + g_params.f_nowriteout = 1; + break; + case 'g': + g_params.f_graphmode = 1; + break; + default: + helper(argv[0]); + exit(1); + } + } + + if ( argc < 2 ) + { + helper(argv[0]); + exit(1); + } + + //start graph + if (g_params.f_graphmode) + { + printf("Start thread\n"); + SDL_Init(SDL_INIT_VIDEO); + window = SDL_CreateWindow("PIPET-1", SDL_WINDOWPOS_UNDEFINED, SDL_WINDOWPOS_UNDEFINED, SCREEN_WIDTH, SCREEN_HEIGHT, SDL_WINDOW_SHOWN|SDL_WINDOW_OPENGL); + renderer = SDL_CreateRenderer(window, -1, SDL_RENDERER_ACCELERATED); + SDL_SetRenderDrawColor(renderer, 0xff, 0x99, 0x99, 0x99); + + + //int rc = pthread_create(&thread, NULL, thread_graph, NULL); + //if (rc) + { + // printf("Cannot start thread\n"); + } + } + + tp.fd_in = dup(fd_stdin); + tp.fd_out = dup(fd_stdout); + + rc = pthread_create(&thread, NULL, thread_pipe, &tp); + if (rc) + { + printf("Cannot lunch pipe thread\n"); + } + + //main loop + int i=0; + while (quit == 0) + { + i+=10; + /* + //printf("!!!\n"); + cur_read = read(fd_stdin,buf, BUF_SZ); + if (g_params.f_stopzero) + { + if (cur_read < 1) + { + quit = 1; + break; + } + } + g_stats.cnt_in += cur_read;// printf("Read %d\n", cur_read); + + if (!g_params.f_nowriteout) + { + cur_write = write(fd_stdout, buf, cur_read); + g_stats.cnt_out += cur_write; + } + */ + + //sdl thread for now its here + if (g_params.f_graphmode) + { + //printf("SDL loop\n"); + + while (SDL_PollEvent(&event)) + { + + switch (event.type) + { + case SDL_QUIT: + { + quit = 1; + break; + } + //case SDL_KE + } + + //sleep(1); + } + SDL_SetRenderDrawColor(renderer, 0, 0, 0, 0); + SDL_RenderClear(renderer); + pv_render(&g_view, renderer); + SDL_RenderPresent(renderer); + + pv_add_dot(&g_view, g_stats.cnt_in-g_stats.prev_cnt_in); + g_stats.prev_cnt_in = g_stats.cnt_in; + + } + sleep(1); + + } + + if (g_params.f_output) + { + printf("Data in %d bytes Data out %d bytes\n", g_stats.cnt_in, g_stats.cnt_out); + } + + if (g_params.f_graphmode) + { + SDL_DestroyRenderer(renderer); + SDL_DestroyWindow(window); + SDL_Quit(); + } + + //pthread_join(&thread,NULL); + //pthread_exit(NULL); return 0; } diff --git a/PIPET-1/pipet_view.c b/PIPET-1/pipet_view.c new file mode 100644 index 0000000..2bb1380 --- /dev/null +++ b/PIPET-1/pipet_view.c @@ -0,0 +1,92 @@ +// +// pipet_view.c +// PIPET-1 +// +// Created by dianshi on 3/28/20. +// Copyright © 2020 dianshi. All rights reserved. +// + +#include "pipet_view.h" + +int pv_init(pipet_view *pv, int32_t max_dots, int32_t w, int32_t h) +{ + pv->dots_size = max_dots; + + pv->dots = malloc(sizeof(uint64_t)*max_dots); + memset(pv->dots,0,sizeof(uint64_t)*max_dots); + + pv->dots_relative = malloc(sizeof(float)*max_dots); + memset(pv->dots_relative,0,sizeof(float)*max_dots); + + pv->width = w; + pv->height = h; + pv->cur_dot = 0; + + return 0; +} + +int pv_set_color(pipet_view *pv, int32_t color) +{ + pv->color = color; + + return 0; +} + +int pv_add_dot(pipet_view *pv, uint64_t val) +{ + int i=0; + float f = 0.0f; + + pv->dots[pv->cur_dot] = val; + pv->cur_dot = (pv->cur_dot+1)%pv->dots_size; + + if (val > pv->max_dot_value) + { + pv->max_dot_value = val; + //printf("New max value %d\n",val); + } + + for (i=0;idots_size;i++) + { + f = 1.0f*pv->dots[i]/pv->max_dot_value; + + //pv->dots_relative[i] = (uint8_t)(f*255); + pv->dots_relative[i] = f; + //printf("%.3f %f (%d-%d) ",f, pv->dots_relative[i], pv->dots[i], pv->max_dot_value); + + } + printf("Max:%d K Val:%d K \n",pv->max_dot_value/1024,val/1024); + + return 0; +} + + +int pv_destroy(pipet_view *pv) +{ + free(pv->dots); + free(pv->dots_relative); + return 0; +} + +int pv_draw_texture(pipet_view *pv, SDL_Renderer *renderer, int x, int y) +{ + SDL_SetRenderDrawColor(renderer, 255, 0, 0, 255); + SDL_RenderDrawPoint(renderer,x,y); + return 0; +} + + +int pv_render(pipet_view *pv, SDL_Renderer *renderer) +{ + int i; + float f=1.0f*pv->width/pv->dots_size; + float fx = 0.0f; + + for (i=0;iwidth;i++) + { + fx+=f; + pv_draw_texture(pv, renderer, fx, (pv->height-pv->height*pv->dots_relative[i]-1)); + } + + return 0; +} diff --git a/PIPET-1/pipet_view.h b/PIPET-1/pipet_view.h new file mode 100644 index 0000000..1685ac1 --- /dev/null +++ b/PIPET-1/pipet_view.h @@ -0,0 +1,42 @@ +// +// pipet_view.h +// PIPET-1 +// +// Created by dianshi on 3/28/20. +// Copyright © 2020 dianshi. All rights reserved. +// + +#ifndef pipet_view_h +#define pipet_view_h + +#include +#include +#include + +#include + +typedef struct pipet_view { + int32_t width; + int32_t height; + int32_t delay; + int32_t color; //rgb + int64_t max_dot_value; + int64_t last_max_dot; + float *dots_relative; //buf of dots values relative + uint64_t *dots; + int32_t cur_dot; + int32_t dots_size; +} pipet_view; + +int pv_init(pipet_view *pv, int32_t max_dots, int32_t w, int32_t h); +int pv_set_color(pipet_view *pv, int32_t color); +int pv_add_dot(pipet_view *pv, uint64_t val); +int pv_destroy(pipet_view *pv); + + +int pv_draw_texture(pipet_view *pv, SDL_Renderer *renderer, int x, int y); +int pv_render(pipet_view *pv, SDL_Renderer *renderer); + + + +#endif /* pipet_view_h */ -- cgit v1.2.3