eventengine.java

监控大型网络的软件。能够自动发现拓扑结构

				for (Iterator handlerIt = eventHandlerList.iterator(); handlerIt.hasNext();) {
					EventHandler eh = (EventHandler) handlerIt.next();
					Log.d("EVENTQ_MONITOR_TASK", "RUN", "Found handler: " + eh.getClass().getName());
					Database.beginTransaction();
					try {
						eh.handle(devDB, e, cfmt.getConfigParser() );

					} catch (Exception exp) {
						Log.e("EVENTQ_MONITOR_TASK", "RUN", "Got Exception from handler: " + eh.getClass().getName() + " Msg: " + exp.getMessage());
						exp.printStackTrace(System.err);

						// Rollback any database changes
						Database.rollback();
					}
					Database.commit();

				}
			}

			Log.d("EVENTQ_MONITOR_TASK", "RUN", "Processed " + eventCnt + " events in this session");

		} catch (SQLException e) {
			// Now we are in trouble
			Log.e("EVENTQ_MONITOR_TASK", "RUN", "SQLException when fetching from eventq: " + e.getMessage());
			e.printStackTrace(System.err);
		}
	}



/*

1673

BEGIN;
INSERT INTO eventq (source,target,netboxid,eventtypeid,state,severity) VALUES ('pping','getDeviceData',1022,'notification','x',0);
INSERT INTO eventqvar (eventqid,var,val) VALUES ((SELECT eventqid FROM eventq WHERE target='getDeviceData' AND netboxid=1022),'command','runNetbox');
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,eventtypeid,state,severity) VALUES ('pping','getDeviceData','notification','x',0);
INSERT INTO eventqvar (eventqid,var,val) VALUES ((SELECT eventqid FROM eventq WHERE target='getDeviceData'),'command','updateFromDB');
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,subid,eventtypeid,state,severity) VALUES ('eventEngine','eventEngine',65432,'notification','x',0);
INSERT INTO eventqvar (eventqid,var,val) VALUES ((SELECT eventqid FROM eventq WHERE subid=65432),'command','updateFromDB');
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,subid,eventtypeid,state,severity) VALUES ('eventEngine','eventEngine',76543,'notification','x',0);
INSERT INTO eventqvar (eventqid,var,val) VALUES ((SELECT eventqid FROM eventq WHERE subid=76543),'command','dumpDeviceList');
COMMIT;


// Down
sit-sby6-936-h.ntnu.no
sit-sby6-936-h2.ntnu.no (shadow)
BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'sit-sby6-936-h.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'sit-sby6-936-h.ntnu.no'),'boxState','s',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'sit-sby6-936-h2.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'sit-sby6-936-h2.ntnu.no'),'boxState','s',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'sit-sby6-936-h.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'sit-sby6-936-h.ntnu.no'),'boxState','e',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'sit-sby6-936-h2.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'sit-sby6-936-h2.ntnu.no'),'boxState','e',100);
COMMIT;

-- kjemi-369-sw.ntnu.no + wlan-s63-369-ap.wlan.ntnu.no
BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'kjemi-369-sw.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'kjemi-369-sw.ntnu.no'),'boxState','s',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'bygg-stud-369-h.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'bygg-stud-369-h.ntnu.no'),'boxState','s',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'wlan-s63-369-ap.wlan.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'wlan-s63-369-ap.wlan.ntnu.no'),'boxState','s',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'kjemi-369-sw.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'kjemi-369-sw.ntnu.no'),'boxState','e',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'bygg-stud-369-h.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'bygg-stud-369-h.ntnu.no'),'boxState','e',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'wlan-s63-369-ap.wlan.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname LIKE 'wlan-s63-369-ap.wlan.ntnu.no'),'boxState','e',100);
COMMIT;

--voll-sby-980-h
BEGIN;
INSERT INTO eventq (source,target,deviceid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'voll-sby-980-h.%'),'boxState','s',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 'voll-sby-980-h.%'),'boxState','e',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 't971-6.itea.ntnu.no'),'boxState','s',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname LIKE 't971-6.itea.ntnu.no'),'boxState','e',100);
COMMIT;


--test modul
BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname='bib-stud-407-h.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname='bib-stud-407-h.ntnu.no'),'boxState','s',100);

INSERT INTO eventq (source,target,deviceid,netboxid,subid,eventtypeid,state,severity) VALUES ('moduleMon','eventEngine',(SELECT deviceid FROM module WHERE netboxid=(SELECT netboxid FROM netbox WHERE sysname LIKE 'bib-stud-407-h.ntnu.no') ORDER BY module DESC LIMIT 1),(SELECT netboxid FROM netbox WHERE sysname LIKE 'bib-stud-407-h.ntnu.no'),(SELECT moduleid FROM module WHERE netboxid=(SELECT netboxid FROM netbox WHERE sysname LIKE 'bib-stud-407-h.ntnu.no') ORDER BY module ASC LIMIT 1),'moduleState','s',100);


COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,subid,eventtypeid,state,severity) VALUES ('moduleMon','eventEngine',(SELECT deviceid FROM module WHERE netboxid=(SELECT netboxid FROM netbox WHERE sysname LIKE 'bib-stud-407-h.ntnu.no') ORDER BY module DESC LIMIT 1),(SELECT netboxid FROM netbox WHERE sysname LIKE 'bib-stud-407-h.ntnu.no'),(SELECT moduleid FROM module WHERE netboxid=(SELECT netboxid FROM netbox WHERE sysname LIKE 'bib-stud-407-h.ntnu.no') ORDER BY module ASC LIMIT 1),'moduleState','e',100);

INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',(SELECT deviceid FROM netbox WHERE sysname='bib-stud-407-h.ntnu.no'),(SELECT netboxid FROM netbox WHERE sysname='bib-stud-407-h.ntnu.no'),'boxState','e',100);

COMMIT;

--kjemi-384-sw
BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',75,75,'boxState','e',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',724,394,'boxState','e',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',725,395,'boxState','e',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',761,396,'boxState','e',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',75,75,'boxState','s',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',724,394,'boxState','s',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',725,395,'boxState','s',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',761,396,'boxState','s',100);
COMMIT;


--tekno-sw
BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',1643,627,'boxState','e',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',9953,827,'boxState','e',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',9956,829,'boxState','e',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',1643,627,'boxState','s',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',9953,827,'boxState','s',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',9956,829,'boxState','s',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',348,347,'boxState','s',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',48977,1912,'boxState','s',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',348,347,'boxState','e',100);
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',48977,1912,'boxState','e',100);
COMMIT;




BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',1,1,'boxState','t',100);
INSERT INTO eventqvar (eventqid,var,val) VALUES ((SELECT eventq_eventqid_seq.last_value),'pl','100');
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',1,1,'boxState','f',100);
COMMIT;

- tekno-sw is going down...

BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',534,533,'boxState','s',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,netboxid,eventtypeid,state,severity) VALUES ('pping','eventEngine',534,533,'boxState','e',100);
COMMIT;

- mask-stud-368-h2 is going down...

BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',1253,1253,'boxState','s',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',1253,1253,'boxState','e',100);
COMMIT;

- Prøv noe enkelt, voll-sby-980-h (238) står i skygge for voll-sw (237)

BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',238,238,'boxState','s',100);
COMMIT;
BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',237,237,'boxState','s',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',238,238,'boxState','e',100);
COMMIT;
BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',237,237,'boxState','e',100);
COMMIT;



- sb-351-sw


- Hva gjøres i tilfellet der man har f.eks to like etterfølgende info-events, skal event engine ignorere den siste?
- Hva gjøres for tilstandsfulle events som aldri oppheves (f.eks en linkDown event der kabelen kobles over på annen port)?
- Skal transienter rapporteres, dvs. boxDown og boxUp i rask rekkefølge?
- Hvordan skal coldStart og warmStart behandles?
- linkState events går ikke til alertq/alerthist
- Dersom en boks går ned, skal moduleDown rapporteres til alertq, evt. med skygge?

---
Algoritmen for down|shadow sjekker ikke om en ruter er nåbar hvis alt er oppe, dvs.
har ikke topologiavlederen funnet all info så vil boksen alltid være i skygge uansett.
---

BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',1,1,'info','t',100);
INSERT INTO eventqvar (eventqid,var,val) VALUES ((SELECT eventq_eventqid_seq.last_value),'pl','100');
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',1,1,'info','f',100);
COMMIT;

BEGIN;
INSERT INTO eventq (source,target,deviceid,boksid,eventtypeid,state,severity) VALUES ('pping','eventEngine',1,1,'info','x',100);
INSERT INTO eventqvar (eventqid,var,val) VALUES ((SELECT eventq_eventqid_seq.last_value),'pl','100');
COMMIT;








*/

}



/*
DeviceDB:
	Device findBySysname(String s)
	Device findByDeviceid(int deviceid)

Device:
	down()
	up()
	isUp()

Box extends Device

Nettel extends Box
	linkDown(String mp)
	linkUp(String mp)
	warmStart()
	coldStart()

Gw extends Nettel
	cpuThresholdExceeded()
	memThresholdExceeded()

Sw extends Nettel
	backplaneThresholdExceeded()

Server extends Device
	serviceDown(String serviceid)
	serviceUp(String serviceid)

WWWServer extends Server
*/