Added matching table for executed commands

1 files changed, 267 insertions, 0 deletions

diff --git a/tbl_qcmd.h b/tbl_qcmd.h
new file mode 100644
index 0000000..4052812
--- /dev/null
+++ b/tbl_qcmd.h
@@ -0,0 +1,267 @@
+#ifndef __TBL_QCMD_H
+#define __TBL_QCMD_H
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <mqueue.h>
+#include <string.h>
+
+#define EXEC_CURRENT 0  //executes in current thread
+#define EXEC_SEPERATE 1 //executes in seperate thread
+
+/*
+Fields:
+*/
+typedef struct tble_exec
+{
+	int id;
+	char *name; /*module name, can be used just for note*/
+	char *cmd; /*command name*/
+	int type;
+} tble_exec;
+
+/*
+list of registed commands
+Fields:
+*/
+typedef struct tbl_exec
+{
+	int size;
+	int max_size;
+	tble_exec **reg_cmd;
+} tbl_exec;
+
+#define QCMD_NONE 0    //nothing happening with this command
+#define QCMD_TIMEOUT 1 //command running to long without result
+#define QCMD_DONE 2    //comand finsihed execution
+#define QCMD_RUNNING 3 //command still in execution state
+#define QCMD_PREPARE 4 //something need to be done before make it to run
+
+/*
+Fields:
+*/
+typedef struct tble_qcmd 
+{
+	int id;
+	int timestamp; //when command started to execute
+	int state;     //command execution state
+	int timeout;   //timeout time for command
+	char *cmd;     //cmd name
+	char *param;   //params
+	mqd_t out_q;
+	mqd_t in_q;
+	int idx_exec;  //table unique id of executor, check if still there ;]
+} tble_qcmd;
+
+/*
+table of commands executing
+Fields:
+*/
+typedef struct tbl_qcmd 
+{
+	int size;
+	int max_size;
+	tble_qcmd **cmd; /*list of command executing and waiting for replay*/
+} tbl_qcmd;
+
+/*
+use this structure to give params to command execution thread
+Fields:
+*/
+typedef struct tble_cmd_param
+{
+	int id;
+	mqd_t out_q;
+	char *cmd;
+	char *param;
+} tble_cmd_param;
+
+/*
+Fields:
+*/
+typedef struct tble_cmd_resp
+{
+	int id;
+	int type;
+	int ret_code;
+	char *resp;
+} tble_cmd_resp;
+
+/*
+create exec command
+Input:
+Output:
+	!NULL  - if everything whent ok
+	NULL   - if there was some kind of mistake
+*/
+tble_exec *tbl_exec_c();
+
+/*
+create array where to put commands
+Input:
+	size - size of array that will be created
+Output:
+	!NULL  - if everything whent ok
+	NULL   - if there was some kind of mistake
+*/
+tbl_exec *tbl_exec_list_c(int size);
+
+/*
+add new command to array
+Input:
+	tbl - table of executed commands
+	cmd - command that shoule be added
+Output:
+	0  - if everything whent ok
+	-1 - if there was some kind of mistake
+*/
+int tbl_exec_add(tbl_exec *tbl, tble_exec *cmd);
+
+/*
+search for command in da list
+Input:
+	tbl - table of executed commands
+	cmd - command name to search in the list
+Output:
+	>=0  - if everything whent ok
+	-1   - if there was some kind of mistake
+*/
+int tbl_exec_in_s(tbl_exec *tbl, char *cmd);
+
+/*
+if command is found then return pointer to it
+if you passs pointer further then if its will be freed
+or deleted from the list your programm will segfault
+so enjoy ;]
+Input:
+	tbl - table of executed commands
+	cmd - command name to search in the list
+Output:
+	>=0  - if everything whent ok
+	-1   - if there was some kind of mistake
+*/
+tble_exec *tbl_exec_search_cmd(tbl_exec *tbl, char *cmd);
+
+/*
+print all entries in table
+Input:
+	tbl - table of executed commands
+Output:
+	>=0  - if everything whent ok
+	-1   - if there was some kind of mistake
+*/
+int tbl_exec_print(tbl_exec *tbl);
+
+
+/*
+create qcmd commands
+Input:
+Output:
+	!NULL  - if everything whent ok
+	NULL   - if there was some kind of mistake
+*/
+tble_qcmd *tbl_qcmd_c();
+
+/*
+create array for executed commands
+Input:
+Output:
+	!NULL  - if everything whent ok
+	NULL   - if there was some kind of mistake
+*/
+tbl_qcmd* tbl_qcmd_list_c(int size);
+
+/*
+add info from executor to command
+Input:
+	tbl - array of executed commands
+	cmd - command to be added to execution list
+Output:
+	0  - if everything whent ok
+	-1 - if there was some kind of mistake
+*/
+int tbl_qcmd_set_exec(tble_qcmd *qcmd, tble_exec *exec);
+
+/*
+add command to executed array
+Input:
+	tbl - array of executed commands
+	cmd - command to be added to execution list
+Output:
+	0  - if everything whent ok
+	-1 - if there was some kind of mistake
+*/
+int tbl_qcmd_add(tbl_qcmd *tbl, tble_qcmd *qcmd);
+/*
+check if there any event on commands
+Input:
+
+Output:
+	>=0  - if everything whent ok, returns index in the table (ret-1)
+	-1  - if there was some kind of mistake, or nothing happened
+*/
+int tbl_qcmd_chk(tbl_qcmd *tbl);  
+
+/*
+delete command from the list
+Input:
+	tbl - array of executed commands
+	idx - index in array that should be removed
+Output:
+	0  - if everything whent ok
+	-1 - if there was some kind of mistake
+*/
+int tbl_qcmd_del(tbl_qcmd *tbl, int idx); 
+
+/*
+if there is response then try to match response and return code to 
+executed command requester
+Input:
+	tbl  - array of executed cmds
+	resp - response recieved, match it to table values
+Output:
+	0  - if everything whent ok
+	-1 - if there was some kind of mistake
+*/
+int tbl_qcmd_resp(tbl_qcmd *tbl, tble_cmd_resp *resp); 
+
+/*
+create cmd param
+Input:
+Output:
+	!NULL  - if everything whent ok
+	NULL   - if there was some kind of mistake
+*/
+tble_cmd_param* tbl_cmd_param_c();
+
+/*
+create cmd param
+Input:
+Output:
+	0  - if everything whent ok
+	-1 - if there was some kind of mistake
+*/
+int tbl_cmd_param_set(tble_cmd_param *cmd_param, tble_qcmd *cmd);
+
+char *alloc_new_str_s(char *str, size_t size);
+char *alloc_new_str(char *str);
+
+/*mvar things*/
+//shitty macro
+#define MVAR_ALLOC_STRC(VNAME,VTYPE,VRET)\
+VTYPE *VNAME;\
+VNAME=malloc(sizeof(VTYPE));\
+if ((VNAME)==NULL){\
+VRET\
+}\
+memset(VNAME,0,sizeof(VTYPE));
+
+#define MVAR_ALLOC_ARR(VNAME,VTYPE,VSZ,VRET)\
+VTYPE *VNAME;\
+VNAME=malloc(sizeof(VTYPE)*(VSZ));\
+if ((VNAME)==NULL){\
+VRET\
+}\
+memset(VNAME,0,sizeof(VTYPE)*(VSZ));
+
+#endif