ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/filter/FilterMain.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/filter/FilterMain.java (file contents):
Revision 1.17 by ajm, Wed Dec 13 15:47:26 2000 UTC vs.
Revision 1.18 by tdb, Fri Jan 12 00:45:25 2001 UTC

#	Line 72 | Line 72 | public class FilterMain implements uk.ac.ukc.iscream.u
72		// get parent
73		Filter parentFilter = FilterHelper.narrow(_refman.getCORBARef("iscream.Filter." + parentFilterName));
74
75	+	// setup a queue
76	+	Queue queue = new Queue();
77	+
78	+	// Start a filter thread
79	+	_logger.write(toString(), Logger.SYSINIT, "starting Filter Thread / Queue consumer");
80	+	FilterThread filterThread = new FilterThread(queue, parentFilter);
81	+	filterThread.start();
82	+
83		// FilterServant start (for inbound child filter data)
84		_logger.write(toString(), Logger.DEBUG, "starting Filter Child -> Parent link for upstream parent - " + parentFilterName);
85	<	FilterServant filterServant = new FilterServant(parentFilter, TCPListenPort, UDPListenPort);
85	>	FilterServant filterServant = new FilterServant(TCPListenPort, UDPListenPort, queue);
86		_refman.bindToOrb(filterServant, "iscream.Filter." + FilterMain.NAME);
87
88		// UDL Reader start (for inbound host data)
89		_logger.write(toString(), Logger.SYSINIT, "starting Filter UDP listener");
90	<	UDPReader udpReader = new UDPReader(UDPListenPort, parentFilter);
90	>	UDPReader udpReader = new UDPReader(UDPListenPort, queue);
91		udpReader.start();
92
93		// TCP Reader start (for heartbeats)
94		_logger.write(toString(), Logger.SYSINIT, "starting Filter TCP listener");
95	<	TCPReader tcpReader = new TCPReader(TCPListenPort, parentFilter);
95	>	TCPReader tcpReader = new TCPReader(TCPListenPort, queue);
96		tcpReader.start();
97
98		_logger.write(toString(), Logger.SYSINIT, "started");

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines