ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/PacketSorter.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/PacketSorter.java (file contents):
Revision 1.16 by tdb, Wed Mar 14 23:25:29 2001 UTC vs.
Revision 1.17 by tdb, Fri Mar 16 16:11:31 2001 UTC

# Line 38 | Line 38 | class PacketSorter extends Thread {
38          // set the Thread name
39          setName("clientinterface.PacketSorter");
40          
41 <        _queue = new Queue();
41 >        ConfigurationProxy cp = ConfigurationProxy.getInstance();
42 >        String configName = "ClientInterface";
43 >        
44 >        // see if this Queue needs a size limit
45 >        try {
46 >            int queueSizeLimit = Integer.parseInt(cp.getProperty(configName, "Queue.SizeLimit"));
47 >            String queueRemoveAlgorithm = cp.getProperty(configName, "Queue.RemoveAlgorithm");
48 >            int algorithm = StringUtils.getStringPos(queueRemoveAlgorithm, Queue.algorithms);
49 >            if(algorithm != -1) {
50 >                _logger.write(toString(), Logger.DEBUG, "Starting Queue with size limit of "+queueSizeLimit+", using remove algorithm "+queueRemoveAlgorithm);
51 >                // we have valid values, so lets start it.
52 >                _queue = new Queue(queueSizeLimit, algorithm);
53 >            }
54 >            else {
55 >                _logger.write(toString(), Logger.WARNING, "Bad Queue Algorithm configuration, not known: "+queueRemoveAlgorithm);
56 >                // just don't activate a limit
57 >                _queue = new Queue();
58 >            }
59 >            
60 >        } catch (PropertyNotFoundException e) {
61 >            _logger.write(toString(), Logger.DEBUG, "Optional config not set: "+e);
62 >            // just don't activate a limit
63 >            _queue = new Queue();
64 >        } catch (NumberFormatException e) {
65 >            _logger.write(toString(), Logger.WARNING, "Bad Queue SizeLimit configuration: "+e);
66 >            // just don't activate a limit
67 >            _queue = new Queue();
68 >        }
69 >        
70          // startup a monitor on this queue
71          try {
72              // try to get the interval, if this fails, we won't start up the monitor
73 <            ConfigurationProxy cp = ConfigurationProxy.getInstance();
46 <            int queueMonitorInterval = Integer.parseInt(cp.getProperty("ClientInterface", "Queue.MonitorInterval"));
73 >            int queueMonitorInterval = Integer.parseInt(cp.getProperty(configName, "Queue.MonitorInterval"));
74              String queueName = _name + " PacketSorterQueue";
75              _queue.startMonitor(queueMonitorInterval*1000, queueName);
76          } catch (PropertyNotFoundException e) {

Diff Legend

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