200010030
/
iPDC-suite
mirror of https://github.com/karthikmurakonda/iPDC-suite.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Compare commits

base: 200010030:4ce18420acc81f124d340acf83fabd3b994c3d7b
Branches Tags
200010030:master
200010030:testing-kmeans
200010030:kmeans
..
compare: 200010030:efdc4d6a6c0fa93db4e78003bb0681b85e3fe727
Branches Tags
200010030:master
200010030:testing-kmeans
200010030:kmeans

No commits in common. "4ce18420acc81f124d340acf83fabd3b994c3d7b" and "efdc4d6a6c0fa93db4e78003bb0681b85e3fe727" have entirely different histories.
4ce18420ac ... efdc4d6a6c

18 changed files with 244 additions and 771 deletions
Show Stats Expand all files Collapse all files

9
iPDC/inc/Attack_detect.h Normal file
View File

@ -0,0 +1,9 @@
/* pavan changes */
#include <gtk/gtk.h>
/* variables declared of attack_detect function */
/* function declared */
gboolean attack_detect_freq(struct data_frame *df);
gboolean attack_detect_vol(struct data_frame *df);
gboolean attack_detect_freq_vol(struct data_frame *df);
/* pavan changes */

30
iPDC/inc/Dynamic_time_warping.h
View File

@ -1,33 +1,5 @@
/* -----------------------------------------------------------------------------
* Dynamic_time_warping.h
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
/*pavan changes*/
int DTWfreqDistance(struct data_frame *df); int DTWfreqDistance(struct data_frame *df);
int DTWvolDistance(struct data_frame *df); int DTWvolDistance(struct data_frame *df);

34
iPDC/inc/Event_detect.h
View File

@ -1,34 +0,0 @@
/* -----------------------------------------------------------------------------
* Event_detect.h
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include <gtk/gtk.h>
gboolean attack_detect_freq(struct data_frame *df);
gboolean attack_detect_vol(struct data_frame *df);
gboolean attack_detect_freq_vol(struct data_frame *df);

37
iPDC/inc/Kmeans.h
View File

@ -1,33 +1,10 @@
/* ----------------------------------------------------------------------------- /*Pavan Changes*/
* Kmeans.h
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include <gtk/gtk.h> #include <gtk/gtk.h>
// intial variables
//function declaration
gboolean kmeans(struct data_frame *df); gboolean kmeans(struct data_frame *df);
/*Pavan Changes*/

30
iPDC/inc/Kmeans2.h
View File

@ -1,33 +1,3 @@
/* -----------------------------------------------------------------------------
* Kmeans2.h
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
int *getRandoms(int lower, int upper, int count); int *getRandoms(int lower, int upper, int count);
long double distance(struct Point *A, struct Point *B); long double distance(struct Point *A, struct Point *B);
bool Kmeans2(struct data_frame *df); bool Kmeans2(struct data_frame *df);

36
iPDC/inc/data_vis.h
View File

@ -1,39 +1,8 @@
/* -----------------------------------------------------------------------------
* data_vis.h
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include<gtk/gtk.h> #include<gtk/gtk.h>
#include<osm-gps-map.h> #include<osm-gps-map.h>
#include "livechart.h" #include "livechart.h"
typedef struct typedef struct{
{
OsmGpsMap *util_map; OsmGpsMap *util_map;
GdkPixbuf *g_red_image; GdkPixbuf *g_red_image;
GdkPixbuf *g_green_image; GdkPixbuf *g_green_image;
@ -41,8 +10,7 @@ typedef struct
int current_selection; int current_selection;
} myParameters; } myParameters;
struct vis_data struct vis_data{
{
int id; int id;
float lat; float lat;
float lon; float lon;

32
iPDC/inc/utility_tools.h
View File

@ -1,33 +1,3 @@
/* -----------------------------------------------------------------------------
* utility_tools.h
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include <stdio.h> #include <stdio.h>
#include<gtk/gtk.h> #include<gtk/gtk.h>
#include "osm-gps-map.h" #include "osm-gps-map.h"
@ -83,4 +53,6 @@ int curr_measurement;
int algorithm; int algorithm;
int dimmension; int dimmension;
void utility_tools(GtkButton *but, gpointer udata); void utility_tools(GtkButton *but, gpointer udata);

0
iPDC/testing_files/kmeans.csv → iPDC/kmeans.csv
View File

0
iPDC/testing_files/kmeans.txt → iPDC/kmeans.txt
View File

0
iPDC/testing_files/plot_kmeans1.py → iPDC/plot_kmeans1.py
View File

0
iPDC/testing_files/plot_kmeans2.py → iPDC/plot_kmeans2.py
View File

0
iPDC/testing_files/points.csv → iPDC/points.csv
View File

Can't render this file because it is too large.

58
iPDC/src/Event_detect.c → iPDC/src/Attack_detect.c
View File

@ -1,42 +1,12 @@
/* ----------------------------------------------------------------------------- /* pavan changes */
* Event_detect.c
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include <time.h> #include <time.h>
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
#include <gtk/gtk.h> #include <gtk/gtk.h>
#include <math.h> #include <math.h>
#include "parser.h" #include "parser.h"
#include "Event_detect.h" #include "Attack_detect.h"
/*Used in maintaining Nodes for all PMUS*/
struct freqlist struct freqlist
{ {
int idcode; int idcode;
@ -45,7 +15,6 @@ struct freqlist
struct freqlist *next; struct freqlist *next;
}; };
/*Used in maintaining Nodes for all PMUS*/
struct vollist struct vollist
{ {
int idcode; int idcode;
@ -57,13 +26,6 @@ struct vollist
struct freqlist *head = NULL; struct freqlist *head = NULL;
struct vollist *headvol = NULL; struct vollist *headvol = NULL;
/**
* @brief It is used to check event detection using Basic appraoch using freq
* called in data_vis.c
*
* @param df data frame
* @return gboolean
*/
gboolean attack_detect_freq(struct data_frame *df) gboolean attack_detect_freq(struct data_frame *df)
{ {
if (head == NULL) if (head == NULL)
@ -133,13 +95,6 @@ gboolean attack_detect_freq(struct data_frame *df)
} }
} }
/**
* @brief It is used to check event detection using Basic appraoch using voltage
* called in data_vis.c
*
* @param df data frame
* @return gboolean
*/
gboolean attack_detect_vol(struct data_frame *df) gboolean attack_detect_vol(struct data_frame *df)
{ {
float CURR_vol; float CURR_vol;
@ -239,14 +194,9 @@ gboolean attack_detect_vol(struct data_frame *df)
} }
} }
/**
* @brief It is used to check event detection using Basic appraoch using voltage and frequency
* called in data_vis.c
*
* @param df data frame
* @return gboolean
*/
gboolean attack_detect_freq_vol(struct data_frame *df) gboolean attack_detect_freq_vol(struct data_frame *df)
{ {
return attack_detect_freq(df) && attack_detect_vol(df); return attack_detect_freq(df) && attack_detect_vol(df);
} }
/* pavan changes */

49
iPDC/src/Dynamic_time_warping.c
View File

@ -1,31 +1,3 @@
/* -----------------------------------------------------------------------------
* Dynamic_time_warping.c
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include "parser.h" #include "parser.h"
#include <stdio.h> #include <stdio.h>
#include <math.h> #include <math.h>
@ -60,13 +32,6 @@ struct DTWvollist
struct DTWfreqlist *dtwhead = NULL; struct DTWfreqlist *dtwhead = NULL;
struct DTWvollist *dtwheadvol = NULL; struct DTWvollist *dtwheadvol = NULL;
/**
* @brief It is used to check event detection using Dynamic Time Warping using frequency
* called in data_vis.c
*
* @param df data frame
* @return int
*/
int DTWfreqDistance(struct data_frame *df) int DTWfreqDistance(struct data_frame *df)
{ {
if (dtwhead == NULL) if (dtwhead == NULL)
@ -193,13 +158,6 @@ int DTWfreqDistance(struct data_frame *df)
} }
} }
/**
* @brief It is used to check event detection using Dynamic Time Warping using voltage
* called in data_vis.c
*
* @param df data frame
* @return int
*/
int DTWvolDistance(struct data_frame *df) int DTWvolDistance(struct data_frame *df)
{ {
if (dtwheadvol == NULL) if (dtwheadvol == NULL)
@ -356,13 +314,6 @@ int DTWvolDistance(struct data_frame *df)
} }
} }
/**
* @brief It is used to check event detection using Dynamic Time Warping using frequency and voltage
* called in data_vis.c
*
* @param df data frame
* @return int
*/
int DTWfreqvolDistance(struct data_frame *df) int DTWfreqvolDistance(struct data_frame *df)
{ {
return DTWfreqDistance(df) && DTWfreqvolDistance(df); return DTWfreqDistance(df) && DTWfreqvolDistance(df);

39
iPDC/src/Kmeans.c
View File

@ -1,32 +1,4 @@
/* ----------------------------------------------------------------------------- /*Pavan Changes*/
* Kmeans.c
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include "parser.h" #include "parser.h"
#include <stdlib.h> #include <stdlib.h>
@ -50,13 +22,6 @@ struct kmeans1
struct kmeans1 *headk = NULL; struct kmeans1 *headk = NULL;
/**
* @brief It is used to check event detection using Kmeans clustering using frequency
* called in data_vis.c
*
* @param df data frame
* @return gboolean
*/
gboolean kmeans(struct data_frame *df) gboolean kmeans(struct data_frame *df)
{ {
if (headk == NULL) if (headk == NULL)
@ -134,3 +99,5 @@ gboolean kmeans(struct data_frame *df)
} }
} }
} }
/*Pavan Changes*/

52
iPDC/src/Kmeans2.c
View File

@ -1,33 +1,3 @@
/* -----------------------------------------------------------------------------
* Kmeans2.c
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include "parser.h" #include "parser.h"
#include <stdlib.h> #include <stdlib.h>
#include <stdio.h> #include <stdio.h>
@ -36,7 +6,6 @@
#include <string.h> #include <string.h>
#include <stdbool.h> #include <stdbool.h>
/*Used for storing points*/
struct Point struct Point
{ {
long double x, y; // coordinates long double x, y; // coordinates
@ -44,7 +13,6 @@ struct Point
long double minDist; // default infinite dist to nearest cluster long double minDist; // default infinite dist to nearest cluster
}; };
/*used for storing centroid of clusters formed*/
struct centroid struct centroid
{ {
long double x, y; long double x, y;
@ -52,7 +20,6 @@ struct centroid
unsigned long long int count; unsigned long long int count;
}; };
/*used to maintain nodes for all PMUs*/
struct Kmeans2 struct Kmeans2
{ {
int idcode; int idcode;
@ -67,23 +34,11 @@ struct Kmeans2
struct Kmeans2 *head_of_kmeans2 = NULL; struct Kmeans2 *head_of_kmeans2 = NULL;
/**
* @brief It finds data between point A and B
*
* @param A,B
* @return long double
*/
long double distance(struct Point *A, struct Point *B) long double distance(struct Point *A, struct Point *B)
{ {
return (((A->x - B->x) * (A->x - B->x)) + ((A->y - B->y) * (A->y - B->y))); return (((A->x - B->x) * (A->x - B->x)) + ((A->y - B->y) * (A->y - B->y)));
} }
/**
* @brief It finds data between centroid A and point B
*
* @param A,B
* @return long double
*/
long double distance2(struct centroid *A, struct Point *B) long double distance2(struct centroid *A, struct Point *B)
{ {
return (((A->x - B->x) * (A->x - B->x)) + ((A->y - B->y) * (A->y - B->y))); return (((A->x - B->x) * (A->x - B->x)) + ((A->y - B->y) * (A->y - B->y)));
@ -124,13 +79,6 @@ int *getRandoms(int lower, int upper, int count)
} }
} }
/**
* @brief It is used to check event detection using Kmeans clustering using voltage and frequency
* called in data_vis.c
*
* @param df data frame
* @return bool
*/
bool Kmeans2(struct data_frame *df) bool Kmeans2(struct data_frame *df)
{ {
if (head_of_kmeans2 == NULL) if (head_of_kmeans2 == NULL)

219
iPDC/src/data_vis.c
View File

@ -1,33 +1,3 @@
/* -----------------------------------------------------------------------------
* data_vis.c
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include <stdlib.h> #include <stdlib.h>
#include <stdio.h> #include <stdio.h>
#include <stdbool.h> #include <stdbool.h>
@ -38,7 +8,7 @@
#include "data_vis.h" #include "data_vis.h"
#include "parser.h" #include "parser.h"
#include "osm-gps-map.h" #include "osm-gps-map.h"
#include "Event_detect.h" #include "Attack_detect.h"
#include "Kmeans.h" #include "Kmeans.h"
#include "Dynamic_time_warping.h" #include "Dynamic_time_warping.h"
#include "connections.h" #include "connections.h"
@ -46,17 +16,10 @@
#include "utility_tools.h" #include "utility_tools.h"
#include "Kmeans2.h" #include "Kmeans2.h"
int loops = 0; int loops = 0;
/** gboolean update_vis(gpointer* pars){
* @brief It is used to update the data in the GUI.
* called in utility_tools.c with the help of g_timeout_add()
*
* @param pars
* @return gboolean
*/
gboolean update_vis(gpointer *pars)
{
int match=0,id, cfg_match=0; int match=0,id, cfg_match=0;
myParameters* parameters = (myParameters*) pars; myParameters* parameters = (myParameters*) pars;
struct cfg_frame* temp_cfg; struct cfg_frame* temp_cfg;
@ -66,8 +29,7 @@ gboolean update_vis(gpointer *pars)
struct Lower_Layer_Details *LLptr; struct Lower_Layer_Details *LLptr;
struct vis_data *vis_ptr; struct vis_data *vis_ptr;
if (df == NULL) if (df == NULL){
{
pthread_mutex_unlock(&mutex_on_TSB); pthread_mutex_unlock(&mutex_on_TSB);
return TRUE; return TRUE;
} }
@ -75,40 +37,32 @@ gboolean update_vis(gpointer *pars)
int i = 0, k = 0; int i = 0, k = 0;
float freq,vol_magnitude,angle, dfreq; float freq,vol_magnitude,angle, dfreq;
unsigned char freq_fmt, anal_fmt, phas_fmt, polar_fmt; unsigned char freq_fmt, anal_fmt, phas_fmt, polar_fmt;
while (df != NULL) while (df!=NULL){
{
float lat; float lat;
float lon; float lon;
loops++; loops++;
id = to_intconvertor(df->idcode); id = to_intconvertor(df->idcode);
pthread_mutex_lock(&mutex_cfg); pthread_mutex_lock(&mutex_cfg);
temp_cfg = cfgfirst; temp_cfg = cfgfirst;
while (temp_cfg != NULL) while(temp_cfg != NULL){
{ if(id == to_intconvertor(temp_cfg->idcode)){
if (id == to_intconvertor(temp_cfg->idcode))
{
cfg_match = 1; cfg_match = 1;
freq_fmt = temp_cfg->pmu[0]->fmt->freq; freq_fmt = temp_cfg->pmu[0]->fmt->freq;
anal_fmt = temp_cfg->pmu[0]->fmt->analog; anal_fmt = temp_cfg->pmu[0]->fmt->analog;
phas_fmt = temp_cfg->pmu[0]->fmt->phasor; phas_fmt = temp_cfg->pmu[0]->fmt->phasor;
polar_fmt = temp_cfg->pmu[0]->fmt->polar; polar_fmt = temp_cfg->pmu[0]->fmt->polar;
break; break;
} } else {
else
{
temp_cfg = temp_cfg->cfgnext; temp_cfg = temp_cfg->cfgnext;
} }
} }
pthread_mutex_unlock(&mutex_cfg); pthread_mutex_unlock(&mutex_cfg);
// get data from df. // get data from df.
if (freq_fmt == '1') if(freq_fmt == '1'){
{
freq = decode_ieee_single(df->dpmu[i]->freq); freq = decode_ieee_single(df->dpmu[i]->freq);
printf("freq = %f\n",freq); printf("freq = %f\n",freq);
} }else{
else
{
freq = to_intconvertor(df->dpmu[i]->freq)*1e-3+50; freq = to_intconvertor(df->dpmu[i]->freq)*1e-3+50;
printf("freq = %f\n",freq); printf("freq = %f\n",freq);
} }
@ -122,10 +76,8 @@ gboolean update_vis(gpointer *pars)
vis_ptr = vis_data_head; vis_ptr = vis_data_head;
match = 0; match = 0;
while (vis_ptr != NULL) while(vis_ptr != NULL){
{ if(vis_ptr->id == id){
if (vis_ptr->id == id)
{
match = 1; match = 1;
break; break;
} }
@ -139,136 +91,78 @@ gboolean update_vis(gpointer *pars)
live_chart_serie_add(vis_ptr->serie_vol, vol_magnitude); live_chart_serie_add(vis_ptr->serie_vol, vol_magnitude);
live_chart_serie_add(vis_ptr->serie_dfreq, dfreq); live_chart_serie_add(vis_ptr->serie_dfreq, dfreq);
if (match == 1 && cfg_match == 1) if(match == 1 && cfg_match == 1){
{ if(vis_ptr->last_image != 0){
if (vis_ptr->last_image != 0)
{
osm_gps_map_image_remove(parameters->util_map, vis_ptr->last_image); osm_gps_map_image_remove(parameters->util_map, vis_ptr->last_image);
} }
if (curr_measurement == 0) if(curr_measurement == 0){
{ if(vol_magnitude > 65600 || vol_magnitude < 65300){
if (vol_magnitude > 65600 || vol_magnitude < 65300)
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map, lat, lon, parameters->g_red_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map, lat, lon, parameters->g_red_image);
} }else{
else
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map, lat, lon, parameters->g_green_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map, lat, lon, parameters->g_green_image);
} }
}else if(curr_measurement == 1){
if (freq > 50.3){
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
}else{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
} }
else if (curr_measurement == 1) }else if(curr_measurement == 2){
{ if (dfreq < 0.5){
if (freq > 50.3) vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
{ }else{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
}
}else if(curr_measurement == 3){
if(algorithm==0 && dimmension == 0){
if (!attack_detect_freq(df)){
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
}else{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
} }
else }else if (algorithm==0 && dimmension == 1){
{ if (!attack_detect_vol(df)){
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
} }else{
}
else if (curr_measurement == 2)
{
if (dfreq < 0.5)
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
} }
else }else if (algorithm==0 && dimmension == 2){
{ if (!attack_detect_freq_vol(df)){
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
} }else{
}
else if (curr_measurement == 3)
{
if (algorithm == 0 && dimmension == 0)
{
if (!attack_detect_freq(df))
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map, lat, lon, parameters->g_red_image);
}
else
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
} }
} }else if (algorithm==1 && dimmension == 0){
else if (algorithm == 0 && dimmension == 1) if(!kmeans(df)){
{
if (!attack_detect_vol(df))
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
} }else{
else
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
} }
} }else if (algorithm==1 && dimmension == 1){
else if (algorithm == 0 && dimmension == 2)
{ }else if (algorithm==1 && dimmension == 2){
if (!attack_detect_freq_vol(df)) if(!Kmeans2(df)){
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
} }else{
else
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
} }
} }else if (algorithm==2 && dimmension == 0){
else if (algorithm == 1 && dimmension == 0) if(!DTWfreqDistance(df)){
{
if (!kmeans(df))
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
} }else{
else
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
} }
} }else if (algorithm==2 && dimmension == 1){
else if (algorithm == 1 && dimmension == 1) if(!DTWvolDistance(df)){
{
}
else if (algorithm == 1 && dimmension == 2)
{
if (!Kmeans2(df))
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
} }else{
else
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
} }
} }else if (algorithm==2 && dimmension == 2){
else if (algorithm == 2 && dimmension == 0) if(!DTWfreqvolDistance(df)){
{
if (!DTWfreqDistance(df))
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_red_image);
} }else{
else
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map, lat, lon, parameters->g_green_image);
}
}
else if (algorithm == 2 && dimmension == 1)
{
if (!DTWvolDistance(df))
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map, lat, lon, parameters->g_red_image);
}
else
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map, lat, lon, parameters->g_green_image);
}
}
else if (algorithm == 2 && dimmension == 2)
{
if (!DTWfreqvolDistance(df))
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map, lat, lon, parameters->g_red_image);
}
else
{
vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image); vis_ptr->last_image = osm_gps_map_image_add(parameters->util_map,lat, lon, parameters->g_green_image);
} }
} }
@ -282,3 +176,4 @@ gboolean update_vis(gpointer *pars)
gtk_widget_queue_draw(GTK_WIDGET(parameters->util_map)); gtk_widget_queue_draw(GTK_WIDGET(parameters->util_map));
return TRUE; return TRUE;
} }

110
iPDC/src/utility_tools.c
View File

@ -1,33 +1,3 @@
/* -----------------------------------------------------------------------------
* utility_tools.c
*
* iPDC - Phasor Data Concentrator
*
* Copyright (C) 2022-2023 Nitesh Pandit
* Copyright (C) 2022-2023 Kedar V. Khandeparkar
* Copyright (C) 2022-2023 Pavan Kumar V Patil
* Copyright (C) 2022-2023 Karthik Murakonda
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Authors:
* M V Karthik <karthik.murakonda14@gmail.com>
* Pavan Kumar V Patil <pavanvpatil01@gmail.com>
*
* ----------------------------------------------------------------------------- */
#include <gtk/gtk.h> #include <gtk/gtk.h>
#include "align_sort.h" #include "align_sort.h"
#include "parser.h" #include "parser.h"
@ -44,21 +14,11 @@
#define GREY_IMAGE "/usr/local/share/iPDC/grey.png" #define GREY_IMAGE "/usr/local/share/iPDC/grey.png"
#define PINK_IMAGE "/usr/local/share/iPDC/pink.png" #define PINK_IMAGE "/usr/local/share/iPDC/pink.png"
/**
* @brief Get the Index Color object
*
* @param index
* @return GdkRGBA
* @note This function is used to get the color of the index mathematicallly
* by using the index value.
*
*/
GdkRGBA getIndexColor(int index) GdkRGBA getIndexColor(int index){
{
GdkRGBA color; GdkRGBA color;
switch (index) // get the color from the index mathematically
{ switch(index){
case 0: case 0:
color.red = 1.0; color.red = 1.0;
color.green = 0.0; color.green = 0.0;
@ -153,18 +113,14 @@ GdkRGBA getIndexColor(int index)
return color; return color;
} }
void on_window_destroy(GtkWidget *widget, gpointer data) void on_window_destroy(GtkWidget *widget, gpointer data)
{ {
g_source_remove(GPOINTER_TO_UINT(data)); g_source_remove(GPOINTER_TO_UINT(data));
gtk_main_quit(); gtk_main_quit();
} }
/** // on clicking the button voltage
* @brief handles the voltage magnitude button click event
*
* @param but
* @param udata
*/
void on_voltage_clicked(GtkButton *but, gpointer udata) void on_voltage_clicked(GtkButton *but, gpointer udata)
{ {
curr_measurement = 0; curr_measurement = 0;
@ -196,12 +152,7 @@ void on_voltage_clicked(GtkButton *but, gpointer udata)
printf("Voltage\n"); printf("Voltage\n");
} }
/** // on clicking the button frequency
* @brief handles the frequency magnitude button click event
*
* @param but : button
* @param udata : user data
*/
void on_frequency_clicked(GtkButton *but, gpointer udata) void on_frequency_clicked(GtkButton *but, gpointer udata)
{ {
curr_measurement = 1; curr_measurement = 1;
@ -222,6 +173,7 @@ void on_frequency_clicked(GtkButton *but, gpointer udata)
gtk_widget_hide(utdata->graph_layoutdfreq); gtk_widget_hide(utdata->graph_layoutdfreq);
gtk_widget_hide(utdata->graph_layoutvol); gtk_widget_hide(utdata->graph_layoutvol);
gtk_widget_hide(utdata->algorithm); gtk_widget_hide(utdata->algorithm);
gtk_widget_hide(utdata->dimmension); gtk_widget_hide(utdata->dimmension);
gtk_widget_hide(utdata->algo_label); gtk_widget_hide(utdata->algo_label);
@ -234,12 +186,7 @@ void on_frequency_clicked(GtkButton *but, gpointer udata)
printf("Frequency\n"); printf("Frequency\n");
} }
/** // on clicking the button dfreq
* @brief handles the frequency derivative button click event
*
* @param but : button
* @param udata : user data
*/
void on_dfreq_clicked(GtkButton *but, gpointer udata) void on_dfreq_clicked(GtkButton *but, gpointer udata)
{ {
curr_measurement = 2; curr_measurement = 2;
@ -260,6 +207,7 @@ void on_dfreq_clicked(GtkButton *but, gpointer udata)
gtk_widget_hide(utdata->swvol); gtk_widget_hide(utdata->swvol);
gtk_widget_hide(utdata->swfreq); gtk_widget_hide(utdata->swfreq);
gtk_widget_hide(utdata->algorithm); gtk_widget_hide(utdata->algorithm);
gtk_widget_hide(utdata->dimmension); gtk_widget_hide(utdata->dimmension);
gtk_widget_hide(utdata->algo_label); gtk_widget_hide(utdata->algo_label);
@ -272,12 +220,7 @@ void on_dfreq_clicked(GtkButton *but, gpointer udata)
printf("dfreq\n"); printf("dfreq\n");
} }
/** // on clicking the button attack_detection
* @brief handles the attack detection button click event
*
* @param but : button
* @param udata : user data
*/
void on_attack_detection_clicked(GtkButton *but, gpointer udata) void on_attack_detection_clicked(GtkButton *but, gpointer udata)
{ {
curr_measurement = 3; curr_measurement = 3;
@ -308,24 +251,12 @@ void on_attack_detection_clicked(GtkButton *but, gpointer udata)
printf("Attack Detection\n"); printf("Attack Detection\n");
} }
/**
* @brief Set the algo variable to the selected algorithm
*
* @param combo : combo box
* @param udata : user data
*/
void set_algo(GtkComboBox *combo, gpointer udata) void set_algo(GtkComboBox *combo, gpointer udata)
{ {
algorithm = gtk_combo_box_get_active(combo); algorithm = gtk_combo_box_get_active(combo);
printf("Algorithm: %d\n", algorithm); printf("Algorithm: %d\n", algorithm);
} }
/**
* @brief Set the dimm variable to the selected dimmension
*
* @param combo : combo box
* @param udata : user data
*/
void set_dimm(GtkComboBox *combo, gpointer udata) void set_dimm(GtkComboBox *combo, gpointer udata)
{ {
dimmension = gtk_combo_box_get_active(combo); dimmension = gtk_combo_box_get_active(combo);
@ -333,13 +264,9 @@ void set_dimm(GtkComboBox *combo, gpointer udata)
printf("dimmension = %d\n", dimmension); printf("dimmension = %d\n", dimmension);
} }
/**
* @brief Main function for the utility tools window sets up the window and all the widgets
* and connects the signals to the callbacks. // Initializes utility tools window.
*
* @param but : button
* @param udata : user data
*/
void utility_tools(GtkButton *but, gpointer udata) void utility_tools(GtkButton *but, gpointer udata)
{ {
GdkPixbuf *g_red_image; GdkPixbuf *g_red_image;
@ -395,6 +322,7 @@ void utility_tools(GtkButton *but, gpointer udata)
gtk_widget_set_visible(utdata->graph_layoutfreq, FALSE); gtk_widget_set_visible(utdata->graph_layoutfreq, FALSE);
gtk_widget_set_visible(utdata->graph_layoutdfreq, FALSE); gtk_widget_set_visible(utdata->graph_layoutdfreq, FALSE);
g_signal_connect(utdata->voltage, "clicked", G_CALLBACK(on_voltage_clicked), NULL); g_signal_connect(utdata->voltage, "clicked", G_CALLBACK(on_voltage_clicked), NULL);
g_signal_connect(utdata->frequency, "clicked", G_CALLBACK(on_frequency_clicked), NULL); g_signal_connect(utdata->frequency, "clicked", G_CALLBACK(on_frequency_clicked), NULL);
g_signal_connect(utdata->dfreq, "clicked", G_CALLBACK(on_dfreq_clicked), NULL); g_signal_connect(utdata->dfreq, "clicked", G_CALLBACK(on_dfreq_clicked), NULL);
@ -422,6 +350,7 @@ void utility_tools(GtkButton *but, gpointer udata)
gtk_container_add(utdata->map_layout, GTK_WIDGET(utdata->util_map)); gtk_container_add(utdata->map_layout, GTK_WIDGET(utdata->util_map));
LiveChartConfig *config_vol = live_chart_config_new(); LiveChartConfig *config_vol = live_chart_config_new();
live_chart_yaxis_set_unit(config_vol->y_axis, "V"); live_chart_yaxis_set_unit(config_vol->y_axis, "V");
live_chart_xaxis_set_tick_interval(config_vol->x_axis, 20); live_chart_xaxis_set_tick_interval(config_vol->x_axis, 20);
@ -440,6 +369,7 @@ void utility_tools(GtkButton *but, gpointer udata)
LiveChartChart *chart_freq = live_chart_chart_new(config_freq); LiveChartChart *chart_freq = live_chart_chart_new(config_freq);
LiveChartConfig *config_dfreq = live_chart_config_new(); LiveChartConfig *config_dfreq = live_chart_config_new();
live_chart_yaxis_set_unit(config_dfreq->y_axis, "mHz"); live_chart_yaxis_set_unit(config_dfreq->y_axis, "mHz");
live_chart_xaxis_set_tick_interval(config_dfreq->x_axis, 20); live_chart_xaxis_set_tick_interval(config_dfreq->x_axis, 20);
@ -466,6 +396,7 @@ void utility_tools(GtkButton *but, gpointer udata)
// declare tooltip // declare tooltip
gchar *tooltiptext; gchar *tooltiptext;
// iterate through the cfg frame and find the corresponding cfg frame // iterate through the cfg frame and find the corresponding cfg frame
while (temp_cfg != NULL) while (temp_cfg != NULL)
{ {
@ -522,13 +453,10 @@ void utility_tools(GtkButton *but, gpointer udata)
temp_visptr->next = NULL; temp_visptr->next = NULL;
guint pid = g_timeout_add(20, (GSourceFunc)update_vis, data); guint pid = g_timeout_add(20, (GSourceFunc)update_vis, data);
if (index > 0) if(index>0){
{
centroid_latitude /= (index); centroid_latitude /= (index);
centroid_longitude /= (index); centroid_longitude /= (index);
} }else{
else
{
centroid_latitude = 15; centroid_latitude = 15;
centroid_longitude = 74; centroid_longitude = 74;
} }