2323BENCH_BMEM char msg [MAX_MSG ];
2424BENCH_BMEM char data_bench [MESSAGE_SIZE ];
2525
26- BENCH_DMEM struct k_pipe * test_pipes [] = {& PIPE_SMALLBUFF , & PIPE_BIGBUFF };
26+ BENCH_DMEM struct k_pipe * test_pipes [] = {& PIPE_NOBUFF , & PIPE_SMALLBUFF , & PIPE_BIGBUFF };
2727BENCH_BMEM char sline [SLINE_LEN + 1 ];
2828
2929/*
@@ -70,6 +70,7 @@ K_MBOX_DEFINE(MAILB1);
7070
7171K_MUTEX_DEFINE (DEMO_MUTEX );
7272
73+ K_PIPE_DEFINE (PIPE_NOBUFF , 0 , 4 );
7374K_PIPE_DEFINE (PIPE_SMALLBUFF , 256 , 4 );
7475K_PIPE_DEFINE (PIPE_BIGBUFF , 4096 , 4 );
7576
@@ -187,7 +188,7 @@ int main(void)
187188 k_thread_access_grant (& recv_thread , & DEMOQX1 , & DEMOQX4 , & DEMOQX192 ,
188189 & MB_COMM , & CH_COMM , & SEM0 , & SEM1 , & SEM2 , & SEM3 ,
189190 & SEM4 , & STARTRCV , & DEMO_MUTEX ,
190- & PIPE_SMALLBUFF , & PIPE_BIGBUFF );
191+ & PIPE_NOBUFF , & PIPE_SMALLBUFF , & PIPE_BIGBUFF );
191192
192193 k_thread_start (& recv_thread );
193194 k_thread_start (& test_thread );
@@ -211,7 +212,7 @@ int main(void)
211212 k_thread_access_grant (& test_thread , & DEMOQX1 , & DEMOQX4 , & DEMOQX192 ,
212213 & MB_COMM , & CH_COMM , & SEM0 , & SEM1 , & SEM2 , & SEM3 ,
213214 & SEM4 , & STARTRCV , & DEMO_MUTEX ,
214- & PIPE_SMALLBUFF , & PIPE_BIGBUFF );
215+ & PIPE_NOBUFF , & PIPE_SMALLBUFF , & PIPE_BIGBUFF );
215216
216217 k_thread_start (& recv_thread );
217218 k_thread_start (& test_thread );
@@ -235,11 +236,11 @@ int main(void)
235236 k_thread_access_grant (& test_thread , & DEMOQX1 , & DEMOQX4 , & DEMOQX192 ,
236237 & MB_COMM , & CH_COMM , & SEM0 , & SEM1 , & SEM2 , & SEM3 ,
237238 & SEM4 , & STARTRCV , & DEMO_MUTEX ,
238- & PIPE_SMALLBUFF , & PIPE_BIGBUFF );
239+ & PIPE_NOBUFF , & PIPE_SMALLBUFF , & PIPE_BIGBUFF );
239240 k_thread_access_grant (& recv_thread , & DEMOQX1 , & DEMOQX4 , & DEMOQX192 ,
240241 & MB_COMM , & CH_COMM , & SEM0 , & SEM1 , & SEM2 , & SEM3 ,
241242 & SEM4 , & STARTRCV , & DEMO_MUTEX ,
242- & PIPE_SMALLBUFF , & PIPE_BIGBUFF );
243+ & PIPE_NOBUFF , & PIPE_SMALLBUFF , & PIPE_BIGBUFF );
243244
244245 k_thread_start (& recv_thread );
245246 k_thread_start (& test_thread );
0 commit comments