logger.c 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  1. #include <stdio.h>
  2. #include <stdarg.h>
  3. #include "bsp/bsp.h"
  4. #include "logger.h"
  5. #include "os/os_task.h"
  6. static uint32_t level_data[2];
  7. static char log_cache[128];
  8. //static co_queue_t log_queue = NULL;
  9. int can_fputc(char c);
  10. #if 0
  11. static void log_co_task(void *args) {
  12. log_chan_t log_v;
  13. while(1) {
  14. if (queue_get(log_queue, &log_v)){
  15. if (log_v.id != 1) {
  16. sys_debug("%d: %d\n", log_v.id, log_v.value);
  17. }else {
  18. extern void shark_uart_write_log(char *buffer);
  19. char buffer[128] = {0};
  20. sprintf(buffer, "$%d;", log_v.value);
  21. shark_uart_write_log(buffer);
  22. }
  23. }
  24. co_task_yield();
  25. }
  26. }
  27. void log_start_task(void) {
  28. log_queue = queue_create(5000, sizeof(log_chan_t));
  29. co_task_create(log_co_task, NULL, 512);
  30. }
  31. #endif
  32. void log_chan_value(u16 id, s32 value) {
  33. }
  34. static int _get_level(int mod){
  35. int index = mod_bit_start(mod)/(32+1);
  36. mod = mod_bit_start(mod) % 32;
  37. return (level_data[index] >> mod) & LEVEL_MASK;
  38. }
  39. void set_log_level(int mod, int l){
  40. int index = mod_bit_start(mod)/(32+1);
  41. mod = mod_bit_start(mod) % 32;
  42. level_data[index] = (level_data[index] & (~(LEVEL_MASK<<mod))) | ((l & LEVEL_MASK)<<mod);
  43. }
  44. static void log_out(char *fmt, va_list args){
  45. int len = vsnprintf(log_cache, sizeof(log_cache), fmt, args);
  46. for (int i = 0; i < len; i++) {
  47. can_fputc(log_cache[i]);
  48. }
  49. }
  50. void log_debug(int mod, char *fmt, ...){
  51. if (_get_level(mod) >= L_debug){
  52. va_list args;
  53. va_start(args, fmt);
  54. log_out(fmt, args);
  55. va_end(args);
  56. }
  57. }
  58. void log_warning(int mod, char *fmt, ...){
  59. if (_get_level(mod) >= L_warning){
  60. va_list args;
  61. va_start(args, fmt);
  62. log_out(fmt, args);
  63. va_end(args);
  64. }
  65. }
  66. void log_error(int mod, char *fmt, ...){
  67. if (_get_level(mod) >= L_error){
  68. va_list args;
  69. va_start(args, fmt);
  70. log_out(fmt, args);
  71. va_end(args);
  72. }
  73. }
  74. static char log_buffer[8];
  75. static int log_index = 0;
  76. int can_fputc(char c){
  77. can_id_t frame_id;
  78. frame_id.id=0;
  79. frame_id.src = CAN_MY_ADDRESS;
  80. frame_id.type = ptype_indicater;
  81. if (c == '\n'){ //don't send '\n'
  82. if (log_index != 0){
  83. frame_id.dest = 0x72;
  84. shark_can0_send_message(frame_id.id, log_buffer, log_index);
  85. }
  86. log_index = 0;
  87. }else if (log_index == sizeof(log_buffer)){
  88. frame_id.dest = 0x70;
  89. shark_can0_send_message(frame_id.id, log_buffer, log_index);
  90. log_index = 0;
  91. log_buffer[log_index++] = c;
  92. }else{
  93. log_buffer[log_index++] = c;
  94. }
  95. return 1;
  96. }