streamCTRL.h

Go to the documentation of this file.

#ifndef _STREAMCTRL_H
#define _STREAMCTRL_H


/* =============================================================================================== */
/* =============================================================================================== */
/*                                        HEADER FILES                                             */
/* =============================================================================================== */
/* =============================================================================================== */


// #include <string.h>
// #include <stdlib.h>
// #include <stdio.h>
// #include <sys/file.h>
// #include <malloc.h>
// #include <sys/mman.h> // mmap()

// #include <time.h>
// #include <signal.h>

#include <stdint.h>    // int_fast8_t
#include <unistd.h>    // getpid()
// #include <sys/types.h>

// #include <sys/stat.h>
// #include <sys/types.h>


// #include <ncurses.h>
// #include <fcntl.h> 
// #include <ctype.h>

// #include <dirent.h>

// #include <wchar.h>
// #include <locale.h>
// #include <errno.h>

// #include <pthread.h>

/* =============================================================================================== */
/* =============================================================================================== */
/*                                      DEFINES, MACROS                                            */
/* =============================================================================================== */
/* =============================================================================================== */

#define STRINGLENMAX  32

#define streamNBID_MAX 10000
#define streamOpenNBpid_MAX 100
#define nameNBchar 100
#define PIDnameStringLen 12



/* =============================================================================================== */
/* =============================================================================================== */
/*                                  GLOBAL DATA DECLARATION                                        */
/* =============================================================================================== */
/* =============================================================================================== */



typedef struct
{
    char sname[nameNBchar];      // stream name

    long ID;
    
    int SymLink;
    char linkname[nameNBchar];   // if stream is sym link, resolve link name

    pid_t streamOpenPID[streamOpenNBpid_MAX];
    int streamOpenPID_cnt;
    int streamOpenPID_cnt1;                       // number of processes accessing stream
    int streamOpenPID_status;

    int datatype;

    double updatevalue; // higher value = more actively recent updates [Hz]
    double updatevalue_frozen;

    long long cnt0; // used to check if cnt0 has changed
    long deltacnt0;
    
} STREAMINFO;



typedef struct
{
    int twaitus; // sleep time between scans
    double dtscan; // measured time interval between scans [s]
        
    int loop;   // 1 : loop     0 : exit
    long loopcnt;
    
    int filter;           // 1 if applying filter to name
    char namefilter[STRINGLENMAX];
    
    int WriteFlistToFile; // 1 if output to file
    
    STREAMINFO *sinfo;
    long NBstream;
    int fuserUpdate;
    int fuserUpdate0;
    int sindexscan;
    char **PIDtable; // stores names of PIDs
    
} STREAMINFOPROC;






/* =============================================================================================== */
/* =============================================================================================== */
/*                                    FUNCTIONS SOURCE CODE                                        */
/* =============================================================================================== */
/* =============================================================================================== */




#ifdef __cplusplus
extern "C" {
#endif



int get_process_name_by_pid(const int pid, char *pname);

int streamCTRL_CatchSignals();

void *streamCTRL_scan(void* thptr);

errno_t streamCTRL_CTRLscreen();


long image_ID_from_images(IMAGE* images, const char *name);

long image_get_first_ID_available_from_images(IMAGE* images);


#ifdef __cplusplus
}
#endif

#endif // _STREAMCTRL_H