01: /*
02: * This file is part of DrFTPD, Distributed FTP Daemon.
03: *
04: * DrFTPD is free software; you can redistribute it and/or modify
05: * it under the terms of the GNU General Public License as published by
06: * the Free Software Foundation; either version 2 of the License, or
07: * (at your option) any later version.
08: *
09: * 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;
21: import java.util.Properties;
22:
23: import net.sf.drftpd.NoAvailableSlaveException;
24: import net.sf.drftpd.mirroring.Job;
25: import net.sf.drftpd.mirroring.JobManager;
26:
27: import org.drftpd.GlobalContext;
28: import org.drftpd.master.RemoteSlave;
29: import org.drftpd.remotefile.LinkedRemoteFileInterface;
30: import org.drftpd.usermanager.User;
31:
32: /**
33: * @author mog
34: * @version $Id: MaxUploadsPerSlaveJob.java 879 2004-12-29 03:39:22Z mog $
35: */
36: public class MaxUploadsPerSlaveJob extends Filter {
37: private GlobalContext _gctx;
38:
39: public MaxUploadsPerSlaveJob(FilterChain fc, int i, Properties p) {
40: _gctx = fc.getGlobalContext();
41: }
42:
43: public MaxUploadsPerSlaveJob(GlobalContext gctx) {
44: _gctx = gctx;
45: }
46:
47: public void process(ScoreChart scorechart, User user,
48: InetAddress peer, char direction,
49: LinkedRemoteFileInterface dir, RemoteSlave sourceSlave)
50: throws NoAvailableSlaveException {
51: process(scorechart, sourceSlave);
52: }
53:
54: public void process(ScoreChart scorechart, RemoteSlave sourceSlave) {
55: if (sourceSlave == null)
56: return;
57: JobManager jm = _gctx.getJobManager();
58: for (Job job : jm.getAllJobsFromQueue()) {
59: synchronized (job) {
60: if (job.isTransferring()) {
61: if (job.getSourceSlave().equals(sourceSlave))
62: scorechart.removeSlaveScore(job
63: .getDestinationSlave());
64: }
65: }
66: }
67: }
68: }
|