plugin_flowview/flowview_cleanup.php at develop · Cacti/plugin_flowview · GitHub

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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
#!/usr/bin/env php
<?php
/*
 +-------------------------------------------------------------------------+
 | Copyright (C) 2004-2026 The Cacti Group |
 | |
 | 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. |
 +-------------------------------------------------------------------------+
 | Cacti: The Complete RRDTool-based Graphing Solution |
 +-------------------------------------------------------------------------+
 | This code is designed, written, and maintained by the Cacti Group. See |
 | about.php and/or the AUTHORS file for specific developer information. |
 +-------------------------------------------------------------------------+
 | http://www.cacti.net/ |
 +-------------------------------------------------------------------------+
*/

chdir('../../');
include('./include/cli_check.php');
include_once('./plugins/flowview/functions.php');
include_once('./plugins/flowview/setup.php');
include_once('./plugins/flowview/database.php');

flowview_connect();

ini_set('max_execution_time', '0');

/* process calling arguments */
$parms = $_SERVER['argv'];
array_shift($parms);

$proceed = false;

if (cacti_sizeof($parms)) {
foreach($parmsas$parameter) {
if (strpos($parameter, '=')) {
list($arg, $value) = explode('=', $parameter, 2);
 } else {
$arg = $parameter;
$value = '';
 }

switch ($arg) {
case'--proceed':
$proceed = true;
break;
case'--version':
case'-V':
case'-v':
display_version();
exit(0);
case'--help':
case'-H':
case'-h':
display_help();
exit(0);
default:
print'ERROR: Invalid Parameter ' . $parameter . PHP_EOL . PHP_EOL;
display_help();
exit(1);
 }
	}
}

if ($proceed == false) {
print"WARNING: This utility is meant for development purposes only. It will kill and cleanup parallel queries." . PHP_EOL;
print"Use the --proceed option if you wish to do so.". PHP_EOL;
exit(1);
}

print"NOTE: Check for Lingering Processes" . PHP_EOL;

$processes = db_fetch_assoc_prepared('SELECT * FROM processes
	WHERE tasktype = ?
	AND taskname LIKE "db_%"
	ORDER BY taskname',
array('flowview'));

if (cacti_sizeof($processes)) {
foreach($processesas$p) {
print"WARNING: Cleaning Process with Task Name:{$p['taskname']} and PID:{$p['pid']}" . PHP_EOL;

posix_kill($p['pid'], SIGINT);

db_execute_prepared('DELETE FROM processes WHERE id = ?', array($p['id']));
	}
}

print"NOTE: Check for Lingering Map Tables" . PHP_EOL;

$parallel_tables = flowview_db_fetch_assoc('SELECT TABLE_NAME, TABLE_COLLATION
	FROM information_schema.TABLES
	WHERE TABLE_NAME LIKE "parallel_database_query_map%"
	ORDER BY TABLE_NAME DESC');

if (cacti_sizeof($parallel_tables)) {
foreach($parallel_tablesas$t) {
print"WARNING: Dropping Table {$t['TABLE_NAME']}" . PHP_EOL;
flowview_db_execute("DROP TABLE {$t['TABLE_NAME']}");
	}
}

print"NOTE: Purging Parallel Query Cache and Orphaned Shards" . PHP_EOL;
flowview_db_execute_prepared('TRUNCATE TABLE parallel_database_query');
flowview_db_execute_prepared('TRUNCATE TABLE parallel_database_query_shard');
flowview_db_execute_prepared('TRUNCATE TABLE parallel_database_query_shard_cache');

exit(0);

/* display_version - displays version information */
functiondisplay_version() {
$info = plugin_flowview_version();
$version = $info['version'];

print"Cacti Flowview Cleanup Parallel Queries, Version $version, " . COPYRIGHT_YEARS . PHP_EOL;
}

/* display_help - displays the usage of the function */
functiondisplay_help () {
display_version();

printPHP_EOL . 'usage: flowview_cleanup.php [--proceed]' . PHP_EOL . PHP_EOL;
print'A command line version of the Cacti Flowview parallel query cleanup. You must execute' . PHP_EOL;
print'this command as a super user to execute the cleanup.' . PHP_EOL;
print'You must use the --proceed option.' . PHP_EOL . PHP_EOL;
print'This tool is to be used by developers who wish to reset their database.' . PHP_EOL;
}