1 /**
2 * Copyright (c) 2012, University of Konstanz, Distributed Systems Group All rights reserved.
3 *
4 * Redistribution and use in source and binary forms, with or without modification, are permitted provided that the
5 * following conditions are met: * Redistributions of source code must retain the above copyright notice, this list of
6 * conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright notice,
7 * this list of conditions and the following disclaimer in the documentation and/or other materials provided with the
8 * distribution. * Neither the name of the University of Konstanz nor the names of its contributors may be used to
9 * endorse or promote products derived from this software without specific prior written permission.
10 *
11 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
12 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
13 * DISCLAIMED. IN NO EVENT SHALL <COPYRIGHT HOLDER> BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,
14 * OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
15 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
16 * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,
17 * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
18 */
19 package org.jscsi.initiator.taskbalancer;
20
21
22 import java.util.concurrent.LinkedBlockingQueue;
23
24 import org.jscsi.exception.NoSuchConnectionException;
25 import org.jscsi.initiator.connection.Connection;
26
27
28 /**
29 * <h1>SimpleLoadBalancer</h1>
30 * <p/>
31 * This simple load balancer distribute only the work to the first connection.
32 *
33 * @author Volker Wildi
34 */
35 public final class SimpleTaskBalancer extends AbstractTaskBalancer {
36
37 // --------------------------------------------------------------------------
38 // --------------------------------------------------------------------------
39 /**
40 * Constructor to create a <code>SimpleLoadBalancer</code> instance.
41 *
42 * @param initConnections The list with all opened connections.
43 */
44 public SimpleTaskBalancer (final LinkedBlockingQueue<Connection> initConnections) {
45
46 super(initConnections);
47 }
48
49 // --------------------------------------------------------------------------
50 // --------------------------------------------------------------------------
51
52 /** {@inheritDoc} */
53 @Override
54 public Connection getConnection () throws NoSuchConnectionException {
55
56 Connection retConnection;
57 try {
58 retConnection = freeConnections.take();
59 return retConnection;
60
61 } catch (InterruptedException e) {
62 e.printStackTrace();
63 return null;
64 }
65 }
66 // --------------------------------------------------------------------------
67 // --------------------------------------------------------------------------
68 // --------------------------------------------------------------------------
69 // --------------------------------------------------------------------------
70
71 }