// -*- tab-width: 4; Mode: C++; c-basic-offset: 4; indent-tabs-mode: t -*- // Code to Write and Read packets from DataFlash log memory // Code to interact with the user to dump or erase logs #define HEAD_BYTE1 0xA3 // Decimal 163 #define HEAD_BYTE2 0x95 // Decimal 149 #define END_BYTE 0xBA // Decimal 186 // These are function definitions so the Menu can be constructed before the functions // are defined below. Order matters to the compiler. static int8_t print_log_menu(uint8_t argc, const Menu::arg *argv); static int8_t dump_log(uint8_t argc, const Menu::arg *argv); static int8_t erase_logs(uint8_t argc, const Menu::arg *argv); static int8_t select_logs(uint8_t argc, const Menu::arg *argv); // This is the help function // PSTR is an AVR macro to read strings from flash memory // printf_P is a version of print_f that reads from flash memory static int8_t help_log(uint8_t argc, const Menu::arg *argv) { Serial.printf_P(PSTR("\n" "Commands:\n" " dump dump log \n" " erase erase all logs\n" " enable |all enable logging or everything\n" " disable |all disable logging or everything\n" "\n")); } // Creates a constant array of structs representing menu options // and stores them in Flash memory, not RAM. // User enters the string in the console to call the functions on the right. // See class Menu in AP_Coommon for implementation details const struct Menu::command log_menu_commands[] PROGMEM = { {"dump", dump_log}, {"erase", erase_logs}, {"enable", select_logs}, {"disable", select_logs}, {"help", help_log} }; // A Macro to create the Menu MENU2(log_menu, "Log", log_menu_commands, print_log_menu); static bool print_log_menu(void) { int log_start; int log_end; byte last_log_num = get_num_logs(); Serial.printf_P(PSTR("logs enabled: ")); if (0 == g.log_bitmask) { Serial.printf_P(PSTR("none")); } else { // Macro to make the following code a bit easier on the eye. // Pass it the capitalised name of the log option, as defined // in defines.h but without the LOG_ prefix. It will check for // the bit being set and print the name of the log option to suit. #define PLOG(_s) if (g.log_bitmask & LOGBIT_ ## _s) Serial.printf_P(PSTR(" %S"), PSTR(#_s)) PLOG(ATTITUDE_FAST); PLOG(ATTITUDE_MED); PLOG(GPS); PLOG(PM); PLOG(CTUN); PLOG(NTUN); PLOG(MODE); PLOG(RAW); PLOG(CMD); PLOG(CURRENT); #undef PLOG } Serial.println(); if (last_log_num == 0) { Serial.printf_P(PSTR("\nNo logs available for download\n")); } else { Serial.printf_P(PSTR("\n%d logs available for download\n"), last_log_num); for(int i=1;i last_log_num)) { Serial.printf_P(PSTR("bad log number\n")); return(-1); } get_log_boundaries(last_log_num, dump_log, dump_log_start, dump_log_end); Serial.printf_P(PSTR("Dumping Log number %d, start page %d, end page %d\n"), dump_log, dump_log_start, dump_log_end); Log_Read(dump_log_start, dump_log_end); Serial.printf_P(PSTR("Log read complete\n")); } static int8_t erase_logs(uint8_t argc, const Menu::arg *argv) { for(int i = 10 ; i > 0; i--) { Serial.printf_P(PSTR("ATTENTION - Erasing log in %d seconds. Power off now to save log! \n"), i); delay(1000); } Serial.printf_P(PSTR("\nErasing log...\n")); for(int j = 1; j < 4096; j++) DataFlash.PageErase(j); DataFlash.StartWrite(1); DataFlash.WriteByte(HEAD_BYTE1); DataFlash.WriteByte(HEAD_BYTE2); DataFlash.WriteByte(LOG_INDEX_MSG); DataFlash.WriteByte(0); DataFlash.WriteByte(END_BYTE); Serial.printf_P(PSTR("\nLog erased.\n")); } static int8_t select_logs(uint8_t argc, const Menu::arg *argv) { uint16_t bits; if (argc != 2) { Serial.printf_P(PSTR("missing log type\n")); return(-1); } bits = 0; // Macro to make the following code a bit easier on the eye. // Pass it the capitalised name of the log option, as defined // in defines.h but without the LOG_ prefix. It will check for // that name as the argument to the command, and set the bit in // bits accordingly. // if (!strcasecmp_P(argv[1].str, PSTR("all"))) { bits = ~(bits = 0); } else { #define TARG(_s) if (!strcasecmp_P(argv[1].str, PSTR(#_s))) bits |= LOGBIT_ ## _s TARG(ATTITUDE_FAST); TARG(ATTITUDE_MED); TARG(GPS); TARG(PM); TARG(CTUN); TARG(NTUN); TARG(MODE); TARG(RAW); TARG(CMD); TARG(CURRENT); #undef TARG } if (!strcasecmp_P(argv[0].str, PSTR("enable"))) { g.log_bitmask.set_and_save(g.log_bitmask | bits); } else { g.log_bitmask.set_and_save(g.log_bitmask & ~bits); } return(0); } int8_t process_logs(uint8_t argc, const Menu::arg *argv) { log_menu.run(); } byte get_num_logs(void) { int page = 1; byte data; byte log_step = 0; DataFlash.StartRead(1); while (page == 1) { data = DataFlash.ReadByte(); switch(log_step) //This is a state machine to read the packets { case 0: if(data==HEAD_BYTE1) // Head byte 1 log_step++; break; case 1: if(data==HEAD_BYTE2) // Head byte 2 log_step++; else log_step = 0; break; case 2: if(data==LOG_INDEX_MSG){ byte num_logs = DataFlash.ReadByte(); return num_logs; } else { log_step=0; // Restart, we have a problem... } break; } page = DataFlash.GetPage(); } return 0; } void start_new_log(byte num_existing_logs) { int page; int start_pages[50] = {0,0,0}; int end_pages[50] = {0,0,0}; byte data; if(num_existing_logs > 0) { for(int i=0;i 0) start_pages[num_existing_logs] = end_pages[num_existing_logs - 1] + 1; else start_pages[0] = 2; num_existing_logs++; DataFlash.StartWrite(1); DataFlash.WriteByte(HEAD_BYTE1); DataFlash.WriteByte(HEAD_BYTE2); DataFlash.WriteByte(LOG_INDEX_MSG); DataFlash.WriteByte(num_existing_logs); for(int i=0;i Logs full - logging discontinued"); } } void get_log_boundaries(byte num_logs, byte log_num, int & start_page, int & end_page) { int page = 1; byte data; byte log_step = 0; DataFlash.StartRead(1); while (page = 1) { data = DataFlash.ReadByte(); switch(log_step) //This is a state machine to read the packets { case 0: if(data==HEAD_BYTE1) // Head byte 1 log_step++; break; case 1: if(data==HEAD_BYTE2) // Head byte 2 log_step++; else log_step = 0; break; case 2: if(data==LOG_INDEX_MSG){ byte num_logs = DataFlash.ReadByte(); for(int i=0;i 1) { look_page = (top_page + bottom_page) / 2; DataFlash.StartRead(look_page); check = DataFlash.ReadLong(); if(check == 0xFFFFFFFF) top_page = look_page; else bottom_page = look_page; } return top_page; } // Write an attitude packet. Total length : 10 bytes void Log_Write_Attitude(int log_roll, int log_pitch, uint16_t log_yaw) { DataFlash.WriteByte(HEAD_BYTE1); DataFlash.WriteByte(HEAD_BYTE2); DataFlash.WriteByte(LOG_ATTITUDE_MSG); DataFlash.WriteInt(log_roll); DataFlash.WriteInt(log_pitch); DataFlash.WriteInt(log_yaw); DataFlash.WriteByte(END_BYTE); } // Write a performance monitoring packet. Total length : 19 bytes void Log_Write_Performance() { DataFlash.WriteByte(HEAD_BYTE1); DataFlash.WriteByte(HEAD_BYTE2); DataFlash.WriteByte(LOG_PERFORMANCE_MSG); DataFlash.WriteLong(millis()- perf_mon_timer); DataFlash.WriteInt(mainLoop_count); DataFlash.WriteInt(G_Dt_max); DataFlash.WriteByte(dcm.gyro_sat_count); DataFlash.WriteByte(imu.adc_constraints); DataFlash.WriteByte(dcm.renorm_sqrt_count); DataFlash.WriteByte(dcm.renorm_blowup_count); DataFlash.WriteByte(gps_fix_count); DataFlash.WriteInt((int)(dcm.get_health() * 1000)); DataFlash.WriteByte(END_BYTE); } // Write a command processing packet. Total length : 19 bytes //void Log_Write_Cmd(byte num, byte id, byte p1, long alt, long lat, long lng) void Log_Write_Cmd(byte num, struct Location *wp) { DataFlash.WriteByte(HEAD_BYTE1); DataFlash.WriteByte(HEAD_BYTE2); DataFlash.WriteByte(LOG_CMD_MSG); DataFlash.WriteByte(num); DataFlash.WriteByte(wp->id); DataFlash.WriteByte(wp->p1); DataFlash.WriteLong(wp->alt); DataFlash.WriteLong(wp->lat); DataFlash.WriteLong(wp->lng); DataFlash.WriteByte(END_BYTE); } void Log_Write_Startup(byte type) { DataFlash.WriteByte(HEAD_BYTE1); DataFlash.WriteByte(HEAD_BYTE2); DataFlash.WriteByte(LOG_STARTUP_MSG); DataFlash.WriteByte(type); DataFlash.WriteByte(g.waypoint_total); DataFlash.WriteByte(END_BYTE); // create a location struct to hold the temp Waypoints for printing struct Location cmd = get_wp_with_index(0); Log_Write_Cmd(0, &cmd); for (int i=1; i7) logvar = DataFlash.ReadInt(); else logvar = DataFlash.ReadByte(); //if(y > 7) logvar = logvar/1000.f; Serial.print(logvar); Serial.print(comma); } Serial.println(" "); } // Read a command processing packet void Log_Read_Cmd() { byte logvarb; long logvarl; Serial.print("CMD:"); for(int i=1;i<4;i++) { logvarb = DataFlash.ReadByte(); Serial.print(logvarb,DEC); Serial.print(comma); } for(int i=1;i<4;i++) { logvarl = DataFlash.ReadLong(); Serial.print(logvarl,DEC); Serial.print(comma); } Serial.println(" "); } void Log_Read_Startup() { byte logbyte = DataFlash.ReadByte(); if (logbyte == TYPE_AIRSTART_MSG) Serial.print("AIR START - "); else if (logbyte == TYPE_GROUNDSTART_MSG) Serial.print("GROUND START - "); else Serial.print("UNKNOWN STARTUP TYPE -"); Serial.print(DataFlash.ReadByte(), DEC); Serial.println(" commands in memory"); } // Read an attitude packet void Log_Read_Attitude() { int log_roll; int log_pitch; uint16_t log_yaw; log_roll = DataFlash.ReadInt(); log_pitch = DataFlash.ReadInt(); log_yaw = (uint16_t)DataFlash.ReadInt(); Serial.print("ATT:"); Serial.print(log_roll); Serial.print(comma); Serial.print(log_pitch); Serial.print(comma); Serial.print(log_yaw); Serial.println(); } // Read a mode packet void Log_Read_Mode() { Serial.print("MOD:"); Serial.println(flight_mode_strings[DataFlash.ReadByte()]); } // Read a GPS packet void Log_Read_GPS() { Serial.print("GPS:"); Serial.print(DataFlash.ReadLong()); // Time Serial.print(comma); Serial.print((int)DataFlash.ReadByte()); // Fix Serial.print(comma); Serial.print((int)DataFlash.ReadByte()); // Num of Sats Serial.print(comma); Serial.print((float)DataFlash.ReadLong()/t7, 7); // Lattitude Serial.print(comma); Serial.print((float)DataFlash.ReadLong()/t7, 7); // Longitude Serial.print(comma); Serial.print((float)DataFlash.ReadLong()/100.0); // Baro/gps altitude mix Serial.print(comma); Serial.print((float)DataFlash.ReadLong()/100.0); // GPS altitude Serial.print(comma); Serial.print((float)DataFlash.ReadLong()/100.0); // Ground Speed Serial.print(comma); Serial.println((float)DataFlash.ReadLong()/100.0); // Ground Course } // Read a raw accel/gyro packet void Log_Read_Raw() { float logvar; Serial.print("RAW:"); for (int y=0;y<6;y++) { logvar = (float)DataFlash.ReadLong()/t7; Serial.print(logvar); Serial.print(comma); } Serial.println(" "); } // Read the DataFlash log memory : Packet Parser void Log_Read(int start_page, int end_page) { byte data; byte log_step=0; int packet_count=0; int page = start_page; DataFlash.StartRead(start_page); while (page < end_page && page != -1) { data = DataFlash.ReadByte(); switch(log_step) //This is a state machine to read the packets { case 0: if(data==HEAD_BYTE1) // Head byte 1 log_step++; break; case 1: if(data==HEAD_BYTE2) // Head byte 2 log_step++; else log_step = 0; break; case 2: if(data==LOG_ATTITUDE_MSG){ Log_Read_Attitude(); log_step++; }else if(data==LOG_MODE_MSG){ Log_Read_Mode(); log_step++; }else if(data==LOG_CONTROL_TUNING_MSG){ Log_Read_Control_Tuning(); log_step++; }else if(data==LOG_NAV_TUNING_MSG){ Log_Read_Nav_Tuning(); log_step++; }else if(data==LOG_PERFORMANCE_MSG){ Log_Read_Performance(); log_step++; }else if(data==LOG_RAW_MSG){ Log_Read_Raw(); log_step++; }else if(data==LOG_CMD_MSG){ Log_Read_Cmd(); log_step++; }else if(data==LOG_CURRENT_MSG){ Log_Read_Current(); log_step++; }else if(data==LOG_STARTUP_MSG){ Log_Read_Startup(); log_step++; }else { if(data == LOG_GPS_MSG){ Log_Read_GPS(); log_step++; } else { Serial.print("Error Reading Packet: "); Serial.print(packet_count); log_step = 0; // Restart, we have a problem... } } break; case 3: if(data==END_BYTE){ packet_count++; }else{ Serial.print("Error Reading END_BYTE "); Serial.println(data,DEC); } log_step=0; // Restart sequence: new packet... break; } page = DataFlash.GetPage(); } Serial.print("Number of packets read: "); Serial.println(packet_count); }