-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathaddFilter2.php
85 lines (72 loc) · 2.13 KB
/
addFilter2.php
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
<?
require("sessionCheck.php");
require("config.php");
?>
<html>
<?
print $pageStyle;
$INDEX=$_POST["index"];
$FILTER_ID=$_POST["filter_id"];
$CI=$_POST["ci"];
$VLAN_TCI=$_POST["vlan_tci"];
$VLAN_TCI_MASK=$_POST["vlan_tci_mask"];
$ETH_TYPE=$_POST["eth_type"];
$ETH_TYPE_MASK=$_POST["eth_type_mask"];
$ETH_SRC=$_POST["eth_src"];
$ETH_SRC_MASK=$_POST["eth_src_mask"];
$ETH_DST=$_POST["eth_dst"];
$ETH_DST_MASK=$_POST["eth_dst_mask"];
$IP_PROTO=$_POST["ip_proto"];
$IP_SRC=$_POST["ip_src"];
$IP_SRC_MASK=$_POST["ip_src_mask"];
$IP_DST=$_POST["ip_dst"];
$IP_DST_MASK=$_POST["ip_dst_mask"];
$SRC_PORT=$_POST["src_port"];
$SRC_PORT_MASK=$_POST["src_port_mask"];
$DST_PORT=$_POST["dst_port"];
$DST_PORT_MASK=$_POST["dst_port_mask"];
$DESTADDR=$_POST["destaddr"];
$TYPE=$_POST["stream_type"];
$CAPLEN=$_POST["caplen"];
$MAMPid=$_POST["mp"];
$filt="$MAMPid"."_filterlist";
$query="INSERT INTO $filt SET filter_id='$FILTER_ID', ind='$INDEX',
CI_ID='$CI',VLAN_TCI='$VLAN_TCI',VLAN_TCI_MASK='$VLAN_TCI_MASK',
ETH_TYPE='$ETH_TYPE',ETH_TYPE_MASK='$ETH_TYPE_MASK',
ETH_SRC='$ETH_SRC',ETH_SRC_MASK='$ETH_SRC_MASK',
ETH_DST='$ETH_DST',ETH_DST_MASK='$ETH_DST_MASK',
IP_PROTO='$IP_PROTO',
IP_SRC='$IP_SRC',IP_SRC_MASK='$IP_SRC_MASK',
IP_DST='$IP_DST',IP_DST_MASK='$IP_DST_MASK',
SRC_PORT='$SRC_PORT',SRC_PORT_MASK='$SRC_PORT_MASK',
DST_PORT='$DST_PORT',DST_PORT_MASK='$DST_PORT_MASK',
DESTADDR='$DESTADDR', TYPE='$TYPE', CAPLEN='$CAPLEN'";
$result=mysqli_query ($query);
if(!$result) {
print "sq: $query <br>\n";
print "Mysql Problems: " . mysqli_error() . "<br>\n";
return;
}
$query="SELECT * FROM measurementpoints WHERE MAMPid='$MAMPid'";
$result=mysqli_query ($query);
if(!$result) {
print "sq: $query <br>\n";
print "Mysql Problems: " . mysqli_error() . "<br>\n";
return;
}
$row = mysqli_fetch_array($result);
$IP=$row["ip"];
$port=$row["port"];
$type=3;
$message=$FILTER_ID;
$message=sprintf("%s%s",pack("N",$type),$message);
print "Contacting ctrl $IP:$port <h1>$type -- $message</h1>\n";
$fp = fsockopen("udp://$IP", $port, $errno, $errstr);
if (!$fp) {
echo "ERROR: $errno - $errstr<br />\n";
} else {
fwrite($fp, $message);
fclose($fp);
}
?>
</body></html>