blob: 6a0b47ca87f0c9bedfe6d56bdd9cc6f00af55b8d [file] [edit]
/* SPDX-License-Identifier: GPL-2.0 */
#ifndef _FSM_H_
#define _FSM_H_
#include <linux/kernel.h>
#include <linux/types.h>
#include <linux/timer.h>
#include <linux/time.h>
#include <linux/slab.h>
#include <linux/sched.h>
#include <linux/string.h>
#include <linux/atomic.h>
/*
* Define this to get debugging messages.
*/
#define FSM_DEBUG 0
/*
* Define this to get debugging massages for
* timer handling.
*/
#define FSM_TIMER_DEBUG 0
/*
* Define these to record a history of
* Events/Statechanges and print it if a
* action_function is not found.
*/
#define FSM_DEBUG_HISTORY 0
#define FSM_HISTORY_SIZE 40
struct fsm_instance_t;
/*
* Definition of an action function, called by a FSM
*/
typedef void (*fsm_function_t)(struct fsm_instance_t *, int, void *);
/*
* Internal jump table for a FSM
*/
typedef struct {
fsm_function_t *jumpmatrix;
int nr_events;
int nr_states;
const char **event_names;
const char **state_names;
} fsm;
#if FSM_DEBUG_HISTORY
/*
* Element of State/Event history used for debugging.
*/
typedef struct {
int state;
int event;
} fsm_history;
#endif
/*
* Representation of a FSM
*/
typedef struct fsm_instance_t {
fsm *f;
atomic_t state;
char name[16];
void *userdata;
int userint;
wait_queue_head_t wait_q;
#if FSM_DEBUG_HISTORY
int history_index;
int history_size;
fsm_history history[FSM_HISTORY_SIZE];
#endif
} fsm_instance;
/*
* Description of a state-event combination
*/
typedef struct {
int cond_state;
int cond_event;
fsm_function_t function;
} fsm_node;
/*
* Description of a FSM Timer.
*/
typedef struct {
fsm_instance *fi;
struct timer_list tl;
int expire_event;
void *event_arg;
} fsm_timer;
/**
* init_fsm - Creates a finite state machine
* @name: Name of this instance for logging purposes
* @state_names: Array of names for all states for logging purposes
* @event_names: Array of names for all events for logging purposes
* @nr_states: Number of states for this instance
* @nr_events: Number of events for this instance
* @tmpl: Pointer to fsm_node array describing this FSM
* @tmpl_len: Number of entries in the tmpl array
* @order: GFP flags for memory allocation (e.g. GFP_KERNEL)
*
* Allocates and initializes a finite state machine instance with the
* specified states, events, and transition table.
*
* Return: Pointer to initialized FSM instance, or NULL on failure
*/
fsm_instance *init_fsm(char *name, const char **state_names,
const char **event_names, int nr_states,
int nr_events, const fsm_node *tmpl,
int tmpl_len, gfp_t order);
/**
* kfree_fsm - Releases a finite state machine
* @fi: Pointer to FSM instance, previously created with init_fsm()
*
* Frees all memory associated with the FSM instance.
*/
void kfree_fsm(fsm_instance *fi);
#if FSM_DEBUG_HISTORY
void fsm_print_history(fsm_instance *fi);
void fsm_record_history(fsm_instance *fi, int state, int event);
#endif
/**
* fsm_event - Emits an event to a finite state machine
* @fi: Pointer to FSM which should receive the event
* @event: The event to be delivered
* @arg: Generic argument, passed to the action function
*
* If an action function is defined for the current state/event
* combination, that function is called with the provided arguments.
*
* Return:
* * 0 - Success, action function was called
* * 1 - State/event out of range, or no action function defined
*/
static inline int
fsm_event(fsm_instance *fi, int event, void *arg)
{
fsm_function_t r;
int state = atomic_read(&fi->state);
if ((state >= fi->f->nr_states) ||
(event >= fi->f->nr_events) ) {
printk(KERN_ERR "fsm(%s): Invalid state st(%ld/%ld) ev(%d/%ld)\n",
fi->name, (long)state,(long)fi->f->nr_states, event,
(long)fi->f->nr_events);
#if FSM_DEBUG_HISTORY
fsm_print_history(fi);
#endif
return 1;
}
r = fi->f->jumpmatrix[fi->f->nr_states * event + state];
if (r) {
#if FSM_DEBUG
printk(KERN_DEBUG "fsm(%s): state %s event %s\n",
fi->name, fi->f->state_names[state],
fi->f->event_names[event]);
#endif
#if FSM_DEBUG_HISTORY
fsm_record_history(fi, state, event);
#endif
r(fi, event, arg);
return 0;
} else {
#if FSM_DEBUG || FSM_DEBUG_HISTORY
printk(KERN_DEBUG "fsm(%s): no function for event %s in state %s\n",
fi->name, fi->f->event_names[event],
fi->f->state_names[state]);
#endif
#if FSM_DEBUG_HISTORY
fsm_print_history(fi);
#endif
return !0;
}
}
/**
* fsm_newstate - Modifies the state of a finite state machine
* @fi: Pointer to FSM
* @newstate: The new state for this FSM
*
* This does not trigger an event or call an action function.
* Wakes up any processes waiting on the FSM's wait queue.
*/
static inline void
fsm_newstate(fsm_instance *fi, int newstate)
{
atomic_set(&fi->state,newstate);
#if FSM_DEBUG_HISTORY
fsm_record_history(fi, newstate, -1);
#endif
#if FSM_DEBUG
printk(KERN_DEBUG "fsm(%s): New state %s\n", fi->name,
fi->f->state_names[newstate]);
#endif
wake_up(&fi->wait_q);
}
/**
* fsm_getstate - Retrieves the current state of a finite state machine
* @fi: Pointer to FSM
*
* Return: Current state number
*/
static inline int
fsm_getstate(fsm_instance *fi)
{
return atomic_read(&fi->state);
}
/**
* fsm_getstate_str - Retrieves the name of the current FSM state
* @fi: Pointer to FSM
*
* Return: State name string, or "Invalid" if state is out of range
*/
const char *fsm_getstate_str(fsm_instance *fi);
/**
* fsm_settimer - Initializes a timer for a finite state machine
* @fi: Pointer to FSM
* @this: The timer to be initialized
*
* Prepares an fsm_timer for usage with fsm_addtimer().
*/
void fsm_settimer(fsm_instance *fi, fsm_timer *this);
/**
* fsm_deltimer - Clears a pending timer of an FSM instance
* @timer: The timer to clear
*
* Stops and removes the timer. Safe to call on an inactive timer.
*/
void fsm_deltimer(fsm_timer *timer);
/**
* fsm_addtimer - Adds and starts a timer for an FSM instance
* @timer: The timer to be added (timer->fi must point to the FSM instance)
* @millisec: Duration in milliseconds after which the timer expires
* @event: Event to trigger when timer expires
* @arg: Generic argument provided to the event handler
*
* Starts a timer that will trigger the specified event after the given
* duration. The timer must have been initialized with fsm_settimer().
*
* Return: Always returns 0
*/
int fsm_addtimer(fsm_timer *timer, int millisec, int event, void *arg);
/**
* fsm_modtimer - Modifies a timer of a finite state machine
* @timer: The timer to modify
* @millisec: New duration in milliseconds after which the timer expires
* @event: Event to trigger when timer expires
* @arg: Generic argument provided to the event handler
*
* Stops the existing timer and restarts it with new parameters.
*/
void fsm_modtimer(fsm_timer *timer, int millisec, int event, void *arg);
#endif /* _FSM_H_ */