aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Embedded_SW/Embedded/Modules/Control/MillisecTask.h
blob: 064302685b52d0e883c9e5a8fdf1da2df1052008 (plain) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

/*
 * MillisecTask.h
 *
 *  Created on: 15 ���� 2018
 *      Author: shlomo
 */

#ifndef MODULES_CONTROL_MILLISECTASK_H_
#define MODULES_CONTROL_MILLISECTASK_H_

#include "drivers/adc_sampling/adc.h"
#include "control.h"
#include "drivers/Motors/Motor.h"
#include "drivers/Heater/TemperatureSensor.h"

typedef  uint32_t (* MSecFptr)(uint32_t deviceID, uint32_t ReadValue);
int32_t MillisecWriteToMotor(TimerMotors_t MotorId, unsigned long Data, int Length, MSecFptr Callback);
int32_t MillisecMoveScrew(unsigned long Data, int Length, MSecFptr Callback);
int32_t MillisecSetScrewSpeed(unsigned long Data, int Length, MSecFptr Callback);
int32_t MillisecSetMotorSpeed(TimerMotors_t MotorId, unsigned long Data, int Length, MSecFptr Callback);
int32_t MillisecReadFromMotor(TimerMotors_t MotorId, unsigned long Data, int Length, MSecFptr Callback);
int MillisecFlushMsgQ(TimerMotors_t MotorId);

int32_t MillisecReadFromTempSensor(uint32_t TempSensorId, MSecFptr Callback);
int MillisecFlushMsgQ(TimerMotors_t MotorId);
/*
uint32_t getMotorStatusData(int MotorId);
uint32_t getMotorSpeedData(int MotorId);
uint32_t getTemperatureSensorData(int SensorId);
uint32_t getADCData(int DeviceId);
*/
float getSensorSpeedData(void);
uint32_t getDrawerFansStatus(void);
uint32_t getSystemFansStatus(void);
uint8_t getGasReading(void);

void MillisecInit(void);
void MillisecStop(void);
void MillisecStart(void);

#ifdef HUNDRED_MICROSECONDS_DANCER_READ
void SaveLogData(void);
void MillisecLogInit(void);
void MillisecLogClose(void);

#endif


extern bool watchdogCriticalAlarm;

extern Task_Handle Millisecond_Task_Handle;
#endif /* MODULES_CONTROL_MILLISECTASK_H_ */
generated by cgit v1.3.1 (git 2.54.0) at 2026-07-24 17:12:26 +0000
ass="w"> System.Collections.Concurrent; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Diagnostics; using System.IO; using System.Linq; using System.Reflection; using System.Runtime.CompilerServices; using System.Text; using System.Threading; using System.Threading.Tasks; namespace Tango.Logging { /// <summary> /// Represents a helper class for logging information and errors. /// </summary> public class LogManager { private List<ILogger> _loggers; private ConcurrentQueue<LogItemBase> _logs; private Thread _loggingThread; private bool _isStarted; /// <summary> /// Occurs when a new log as been received. /// </summary> public event EventHandler<LogItemBase> NewLog; /// <summary> /// Gets the registered loggers. /// </summary> public List<ILogger> RegisteredLoggers { get { return _loggers.ToList(); } } private static LogManager _default; /// <summary> /// Gets the default log manager instance. /// </summary> public static LogManager Default { get { if (_default == null) { _default = new LogManager(); } return _default; } } /// <summary> /// Gets or sets a value indicating whether to propagate logs instantly (Warning - not thread safe). /// </summary> public bool OverrideQueue { get; set; } /// <summary> /// Initializes the <see cref="LogManager"/> class. /// </summary> public LogManager() { _loggers = new List<ILogger>(); _logs = new ConcurrentQueue<LogItemBase>(); Categories = new List<LogCategory>(); Categories.Add(LogCategory.Critical); Categories.Add(LogCategory.Error); Categories.Add(LogCategory.Info); Categories.Add(LogCategory.Warning); } /// <summary> /// Gets or sets the logging categories filter. /// </summary> public List<LogCategory> Categories { get; private set; } /// <summary> /// Registers a logger. /// </summary> /// <param name="logger">The logger.</param> public void RegisterLogger(ILogger logger) { if (logger != null && !_loggers.Contains(logger)) { _loggers.Add(logger); } } /// <summary> /// Unregisters a logger. /// </summary> /// <param name="logger">The logger.</param> public void UnregisterLogger(ILogger logger) { if (logger != null && _loggers.Contains(logger)) { _loggers.Remove(logger); } } /// <summary> /// Add new exception log item. /// </summary> /// <param name="e">Exception.</param> /// <param name="description">Error description.</param> public Exception Log(Exception e, String description = null, [CallerMemberName] string caller = null, [CallerFilePath] string file = null, [CallerLineNumber] int lineNumber = 0) { return Log(e, LogCategory.Error, description, caller, file, lineNumber); } /// <summary> /// Add new exception log item. /// </summary> /// <param name="e">Exception.</param> /// <param name="description">Error description.</param> public Exception Log(Exception e, LogCategory category, String description = null, [CallerMemberName] string caller = null, [CallerFilePath] string file = null, [CallerLineNumber] int lineNumber = 0) { if (!Categories.Contains(category)) return e; ExceptionLogItem log = new ExceptionLogItem(); log.CallerMethodName = caller; log.CallerFile = file; log.CallerLineNumber = lineNumber; log.TimeStamp = DateTime.Now; log.Exception = e; log.Category = category; log.Description = description != null ? description : e.ToString(); if (!OverrideQueue) { AppendLog(log); } else { AppendLogInstantly(log); } return e; } /// <summary> /// Add new exception log item. /// </summary> /// <param name="e">Exception.</param> /// <param name="description">Error description.</param> public Exception LogFormat(Exception e, String description, object argument, [CallerMemberName] string caller = null, [CallerFilePath] string file = null, [CallerLineNumber] int lineNumber = 0) { return Log(e, LogCategory.Error, String.Format(description, argument), caller, file, lineNumber); } /// <summary> /// Add new message log item. /// </summary> /// <param name="message">Message.</param> public String LogFormat(String message, object argument, [CallerMemberName] string caller = null, [CallerFilePath] string file = null, [CallerLineNumber] int lineNumber = 0) { return Log(String.Format(message, argument), LogCategory.Info, null, caller, file, lineNumber); } /// <summary> /// Add new message log item. /// </summary> /// <param name="message">Message.</param> public String Log(String message, [CallerMemberName] string caller = null, [CallerFilePath] string file = null, [CallerLineNumber] int lineNumber = 0) { return Log(message, LogCategory.Info, null, caller, file, lineNumber); } /// <summary> /// Add new message log item. /// </summary> /// <param name="message">Message.</param> public String Log(String message, LogCategory category, [CallerMemberName] string caller = null, [CallerFilePath] string file = null, [CallerLineNumber] int lineNumber = 0) { return Log(message, category, null, caller, file, lineNumber); } /// <summary> /// Add new message log item. /// </summary> /// <param name="message">Message.</param> public String Log(String message, LogCategory category, Object logObject, [CallerMemberName] string caller = null, [CallerFilePath] string file = null, [CallerLineNumber] int lineNumber = 0) { if (!Categories.Contains(category)) return message; MessageLogItem log = new MessageLogItem(); log.CallerMethodName = caller; log.CallerFile = file; log.CallerLineNumber = lineNumber; log.TimeStamp = DateTime.Now; log.Category = category; log.Message = message; log.LogObject = logObject; if (!OverrideQueue) { AppendLog(log); } else { AppendLogInstantly(log); } return message; } /// <summary> /// Add new message log item. /// </summary> /// <param name="message">Message.</param> public void Log(MessageLogItem log) { log.TimeStamp = DateTime.Now; AppendLog(log); } /// <summary> /// Appends the log. /// </summary> /// <param name="log">The log.</param> private void AppendLog(LogItemBase log) { if (log != null) { _loggers.Where(x => x.Enabled && x.Immediate).ToList().ForEach(x => x.OnLog(log)); } _logs.Enqueue(log); StartLoggingThread(); } /// <summary> /// Starts the logging thread. /// </summary> private void StartLoggingThread() { if (!_isStarted) { _isStarted = true; _loggingThread = new Thread(LoggingThreadMethod); _loggingThread.IsBackground = true; _loggingThread.Start(); } } /// <summary> /// Loggings thread method. /// </summary> //[DebuggerStepThrough] //[DebuggerHidden] private void LoggingThreadMethod() { while (_isStarted) { while (_logs.Count > 0) { LogItemBase log; if (_logs.TryDequeue(out log)) { if (log != null) { _loggers.Where(x => x.Enabled && !x.Immediate).ToList().ForEach(x => x.OnLog(log)); NewLog?.Invoke(this, log); } } } Thread.Sleep(10); } } /// <summary> /// Appends the log instantly. /// </summary> /// <param name="log">The log.</param> [DebuggerStepThrough] [DebuggerHidden] private void AppendLogInstantly(LogItemBase log) { bool wroteLog = false; while (!wroteLog) { try { _loggers.Where(x => x.Enabled).ToList().ForEach(x => x.OnLog(log)); wroteLog = true; } catch { Thread.Sleep(5); } } } } }
generated by cgit v1.3.1 (git 2.54.0) at 2026-07-24 17:12:26 +0000