KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > drftpd > slaveselection > filter > MaxbandwidthFilter


1 /*
2  * This file is part of DrFTPD, Distributed FTP Daemon.
3  *
4  * DrFTPD is free software; you can redistribute it and/or modify
5  * it under the terms of the GNU General Public License as published by
6  * the Free Software Foundation; either version 2 of the License, or
7  * (at your option) any later version.
8  *
9  * DrFTPD is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12  * GNU General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License
15  * along with DrFTPD; if not, write to the Free Software
16  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17  */
18 package org.drftpd.slaveselection.filter;
19
20 import java.net.InetAddress JavaDoc;
21 import java.rmi.RemoteException JavaDoc;
22 import java.util.Iterator JavaDoc;
23 import java.util.Properties JavaDoc;
24
25 import net.sf.drftpd.Bytes;
26 import net.sf.drftpd.NoAvailableSlaveException;
27 import net.sf.drftpd.master.config.FtpConfig;
28 import net.sf.drftpd.master.usermanager.User;
29 import net.sf.drftpd.remotefile.LinkedRemoteFileInterface;
30 import net.sf.drftpd.slave.SlaveStatus;
31
32 import org.apache.log4j.Logger;
33
34 /**
35  * @author zubov
36  */
37 public class MaxbandwidthFilter extends Filter {
38     private static final Logger logger =
39         Logger.getLogger(MaxbandwidthFilter.class);
40
41     private long _maxBandwidth;
42
43     public MaxbandwidthFilter(FilterChain ssm, int i, Properties JavaDoc p) {
44         _maxBandwidth =
45             Bytes.parseBytes(FtpConfig.getProperty(p, i + ".maxbandwidth"));
46     }
47
48     public void process(
49         ScoreChart scorechart,
50         User user,
51         InetAddress JavaDoc peer,
52         char direction,
53         LinkedRemoteFileInterface dir)
54         throws NoAvailableSlaveException {
55         for (Iterator JavaDoc iter = scorechart.getSlaveScores().iterator();
56             iter.hasNext();
57             ) {
58             ScoreChart.SlaveScore slavescore =
59                 (ScoreChart.SlaveScore) iter.next();
60             SlaveStatus status;
61             try {
62                 status = slavescore.getRSlave().getStatus();
63             } catch (Exception JavaDoc e) {
64                 if (e instanceof RemoteException JavaDoc) {
65                     slavescore.getRSlave().handleRemoteException(
66                         (RemoteException JavaDoc) e);
67                 }
68                 iter.remove();
69                 logger.debug("removed " + slavescore.getRSlave().getName() + " because of exception", e);
70                 continue;
71             }
72             if (status.getThroughputDirection(direction) > _maxBandwidth) {
73                 logger.debug("removed " + slavescore.getRSlave().getName());
74                 iter.remove();
75             }
76         }
77     }
78 }
Popular Tags