direct/test-framework/stress_tests/stress_tester/message_buffer.c

   1 /*
   2  * YAFFS: Yet another FFS. A NAND-flash specific file system.
   3  *
   4  * Copyright (C) 2002-2018 Aleph One Ltd.
   5  *
   6  * Created by Timothy Manning <timothy@yaffs.net>
   7  *
   8  * This program is free software; you can redistribute it and/or modify
   9  * it under the terms of the GNU General Public License version 2 as
  10  * published by the Free Software Foundation.
  11  */
  12
  13 /*
  14  * message_buffer.c contains code for a message buffer .
  15  */
  16
  17 #include "message_buffer.h"
  18
  19 void append_to_buffer(buffer *p_Buffer, char *message,char message_level,char print){
  20         /*wrapper function for add_to_buffer_root_function*/
  21         add_to_buffer_root_function(p_Buffer,message, message_level,APPEND_MESSAGE,print);
  22 }
  23
  24 void add_to_buffer(buffer *p_Buffer, char *message,char message_level,char print){
  25         /*wrapper function for add_to_buffer_root_function*/
  26         add_to_buffer_root_function(p_Buffer,message, message_level,DO_NOT_APPEND_MESSAGE,print);
  27 }
  28
  29 void add_int_to_buffer(buffer *p_Buffer, int num,char message_level,char print){
  30         char message[20];
  31         sprintf(message, "%d",num);
  32         add_to_buffer_root_function(p_Buffer,message, message_level,DO_NOT_APPEND_MESSAGE,print);
  33 }
  34
  35 void append_int_to_buffer(buffer *p_Buffer, int num,char message_level,char print){
  36         char message[20];
  37         sprintf(message, "%d",num);
  38         add_to_buffer_root_function(p_Buffer,message, message_level,APPEND_MESSAGE,print);
  39 }
  40
  41
  42 void add_to_buffer_root_function(buffer *p_Buffer, char *message,char message_level,char append,char print){
  43         FILE *log_handle;
  44
  45         if (append==APPEND_MESSAGE){    /* append current message*/
  46                 strncat(p_Buffer->message[p_Buffer->head],message,BUFFER_MESSAGE_LENGTH);
  47         }
  48         else {
  49
  50                 /*move the head up one. the head always points at the last written data*/
  51                 p_Buffer->head++;
  52
  53                 /*printf("p_Buffer->tail=%d\n",p_Buffer->tail);*/
  54                 /*printf("p_Buffer->head=%d\n",p_Buffer->head);*/
  55                 if (p_Buffer->head >=BUFFER_SIZE-1) {
  56                         /*printf("buffer overflow\n");*/
  57                         p_Buffer->head -= (BUFFER_SIZE-1);      /*wrap the head around the buffer*/
  58                         /*printf("new p_Buffer->head=%d\n",p_Buffer->head);*/
  59                 }
  60                 /*if the buffer is full then delete last entry by moving the tail*/
  61                 if (p_Buffer->head==p_Buffer->tail){
  62                         /*printf("moving buffer tail from %d to ",p_Buffer->tail);*/
  63                         p_Buffer->tail++;
  64                         if (p_Buffer->tail >=BUFFER_SIZE) p_Buffer->tail -= BUFFER_SIZE;/*wrap the tail around the buffer*/
  65                         /*printf("%d\n",p_Buffer->tail);*/
  66
  67                 }
  68
  69                 p_Buffer->message_level[p_Buffer->head]=message_level; /*copy the message level*/
  70                 strncpy(p_Buffer->message[p_Buffer->head],message,BUFFER_MESSAGE_LENGTH); /*copy the message*/
  71                 /*printf("copied %s into p_Buffer->message[p_Buffer->head]: %s\n",message,p_Buffer->message[p_Buffer->head]);
  72                 printf("extra %s\n",p_Buffer->message[p_Buffer->head]);*/
  73         }
  74         if ((p_Buffer->message_level[p_Buffer->head]<=DEBUG_LEVEL)&& (print==PRINT)){
  75                 /*printf("printing buffer 1\n");
  76                 // the print buffer function is not working this is just a quick fix
  77                 print_buffer(p_Buffer,1); //if the debug level is higher enough then print the new message
  78                 */
  79                 printf("%s\n",p_Buffer->message[p_Buffer->head]);
  80                 log_handle=fopen(LOG_FILE,"a");
  81                 if (log_handle!=NULL){
  82                         fputs(p_Buffer->message[p_Buffer->head],log_handle);
  83                         fputs("\n",log_handle);
  84                         fclose(log_handle);
  85                 }
  86         }
  87 }
  88
  89
  90
  91 void print_buffer(buffer *p_Buffer, int number_of_messages_to_print){
  92         int x=0;
  93         int i=0;
  94         printf("print buffer\n");
  95         printf("buffer head:%d\n",p_Buffer->head);
  96         printf("buffer tail:%d\n",p_Buffer->tail);
  97
  98         if (number_of_messages_to_print==PRINT_ALL) number_of_messages_to_print=BUFFER_SIZE;
  99 //      printf("number_of_messages_to_print=%d\n",number_of_messages_to_print);
 100         for (i=0,x=0; (x>=p_Buffer->tail) && (i<number_of_messages_to_print); i++, x--){
 101 //              printf("printing buffer\n");
 102 //              printf("x:%d\n",x);
 103                 if (x<0) x = BUFFER_SIZE-1;             /*wrap x around buffer*/
 104                 printf("%s\n",p_Buffer->message[p_Buffer->head]);
 105                 printf("printed buffer\n");
 106         }
 107
 108 }
 109
 110
 111