001: /*
002: License $Id: UDPListener.java,v 1.4 2003/09/13 04:59:56 hendriks73 Exp $
003:
004: Copyright (c) 2001-2005 tagtraum industries.
005:
006: LGPL
007: ====
008:
009: jo! is free software; you can redistribute it and/or
010: modify it under the terms of the GNU Lesser General Public
011: License as published by the Free Software Foundation; either
012: version 2.1 of the License, or (at your option) any later version.
013:
014: jo! is distributed in the hope that it will be useful,
015: but WITHOUT ANY WARRANTY; without even the implied warranty of
016: MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
017: Lesser General Public License for more details.
018:
019: You should have received a copy of the GNU Lesser General Public
020: License along with this library; if not, write to the Free Software
021: Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
022:
023: For LGPL see <http://www.fsf.org/copyleft/lesser.txt>
024:
025:
026: Sun license
027: ===========
028:
029: This release contains software by Sun Microsystems. Therefore
030: the following conditions have to be met, too. They apply to the
031: files
032:
033: - lib/mail.jar
034: - lib/activation.jar
035: - lib/jsse.jar
036: - lib/jcert.jar
037: - lib/jaxp.jar
038: - lib/crimson.jar
039: - lib/servlet.jar
040: - lib/jnet.jar
041: - lib/jaas.jar
042: - lib/jaasmod.jar
043:
044: contained in this release.
045:
046: a. Licensee may not modify the Java Platform
047: Interface (JPI, identified as classes contained within the javax
048: package or any subpackages of the javax package), by creating additional
049: classes within the JPI or otherwise causing the addition to or modification
050: of the classes in the JPI. In the event that Licensee creates any
051: Java-related API and distribute such API to others for applet or
052: application development, you must promptly publish broadly, an accurate
053: specification for such API for free use by all developers of Java-based
054: software.
055:
056: b. Software is confidential copyrighted information of Sun and
057: title to all copies is retained by Sun and/or its licensors. Licensee
058: shall not modify, decompile, disassemble, decrypt, extract, or otherwise
059: reverse engineer Software. Software may not be leased, assigned, or
060: sublicensed, in whole or in part. Software is not designed or intended
061: for use in on-line control of aircraft, air traffic, aircraft navigation
062: or aircraft communications; or in the design, construction, operation or
063: maintenance of any nuclear facility. Licensee warrants that it will not
064: use or redistribute the Software for such purposes.
065:
066: c. Software is provided "AS IS," without a warranty
067: of any kind. ALL EXPRESS OR IMPLIED REPRESENTATIONS AND WARRANTIES,
068: INCLUDING ANY IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS FOR A
069: PARTICULAR PURPOSE OR NON-INFRINGEMENT, ARE HEREBY EXCLUDED.
070:
071: d. This License is effective until terminated. Licensee may
072: terminate this License at any time by destroying all copies of Software.
073: This License will terminate immediately without notice from Sun if Licensee
074: fails to comply with any provision of this License. Upon such termination,
075: Licensee must destroy all copies of Software.
076:
077: e. Software, including technical data, is subject to U.S.
078: export control laws, including the U.S. Export Administration Act and its
079: associated regulations, and may be subject to export or import regulations
080: in other countries. Licensee agrees to comply strictly with all such
081: regulations and acknowledges that it has the responsibility to obtain
082: licenses to export, re-export, or import Software. Software may not be
083: downloaded, or otherwise exported or re-exported (i) into, or to a national
084: or resident of, Cuba, Iraq, Iran, North Korea, Libya, Sudan, Syria or any
085: country to which the U.S. has embargoed goods; or (ii) to anyone on the
086: U.S. Treasury Department's list of Specially Designated Nations or the U.S.
087: Commerce Department's Table of Denial Orders.
088:
089:
090: Feedback
091: ========
092:
093: We encourage your feedback and suggestions and want to use your feedback to
094: improve the Software. Send all such feedback to:
095: <feedback@tagtraum.com>
096:
097: For more information on tagtraum industries and jo!
098: please see <http://www.tagtraum.com/>.
099:
100:
101: */
102: package com.tagtraum.framework.server;
103:
104: import com.tagtraum.framework.log.C_Log;
105: import com.tagtraum.framework.log.Log;
106:
107: import java.io.IOException;
108: import java.io.InterruptedIOException;
109: import java.net.DatagramPacket;
110: import java.net.DatagramSocket;
111: import java.net.SocketException;
112:
113: /**
114: * Prototype of a {@link I_UDPListener}.
115: *
116: * @author <a href="mailto:hs@tagtraum.com">Hendrik Schreiber</a>
117: * @version 1.1beta1 $Id: UDPListener.java,v 1.4 2003/09/13 04:59:56 hendriks73 Exp $
118: */
119: public class UDPListener extends Listener implements Runnable {
120:
121: /**
122: * Source-Version
123: */
124: public static String vcid = "$Id: UDPListener.java,v 1.4 2003/09/13 04:59:56 hendriks73 Exp $";
125:
126: /**
127: * DatagramSocket.
128: */
129: protected DatagramSocket myDatagramSocket = null;
130:
131: /**
132: * ReceiveBufferSize. Default = 256.
133: */
134: protected int myReceiveBufferSize = 256;
135:
136: /**
137: * Closes the <code>DatagramSocket</code>, if it is set.
138: */
139: public void close() throws IOException {
140: if (myDatagramSocket != null) {
141: myDatagramSocket.close();
142:
143: myDatagramSocket = null;
144: }
145: }
146:
147: /**
148: * Binds the <code>DatagramSocket</code> to the set <code>InetAddress</code>.
149: *
150: * @see I_Listener#setPort(int)
151: * @see I_Listener#setBindAddress(InetAddress)
152: */
153: protected synchronized void bind() throws IOException,
154: ServerException {
155: if (Log.getLog(myService.getName()).isLog(C_Log.METHOD)) {
156: Log.getLog(myService.getName()).log(
157: "Trying to bind server to " + myBindAddress + ":"
158: + myPort, C_Log.METHOD);
159: }
160:
161: myDatagramSocket = new DatagramSocket(myPort, myBindAddress);
162:
163: // Blocking-Timeout setzen
164: myDatagramSocket.setSoTimeout(getSoTimeout());
165:
166: if (Log.getLog(myService.getName()).isLog(C_Log.MODULE)) {
167: Log.getLog(myService.getName()).log("Listening...",
168: C_Log.MODULE);
169: }
170: }
171:
172: /**
173: * Contains the listenting loop.
174: * For each connection {@link Service#getHandler()} is called.
175: * Then the {@link I_UDPHandler#handlePacket(DatagramPacket)} method
176: * is called with the current <code>DatagramPacket</code>.
177: */
178: public void run() {
179: try {
180: I_UDPHandler aHandler;
181:
182: while (!stopped) {
183: byte[] buf = new byte[myReceiveBufferSize];
184: DatagramPacket aPacket = new DatagramPacket(buf,
185: buf.length);
186:
187: try {
188: myDatagramSocket.receive(aPacket);
189:
190: aHandler = (I_UDPHandler) myService.getHandler();
191:
192: aHandler.handlePacket(aPacket);
193: } catch (HandlerException he) {
194: if (Log.getLog(myService.getName()).isLog(
195: C_Log.ERROR)) {
196: Log.getLog(myService.getName()).log(
197: he.getThrowable(), C_Log.ERROR);
198: }
199: } catch (InterruptedIOException ie) {
200: handleSoTimeout();
201: } catch (SocketException se) {
202: if (!stopped && Log.isLog(myService.getName())) {
203: Log.getLog(myService.getName()).log(
204: se.getMessage());
205: }
206: }
207: }
208: } catch (IOException ioe) {
209: if (Log.getLog(myService.getName()).isLog(C_Log.ERROR)) {
210: Log.getLog(myService.getName()).log(ioe, C_Log.ERROR);
211: }
212:
213: throw new ServerRuntimeException(ioe);
214: } finally {
215: stopped = true;
216:
217: try {
218: close();
219: } catch (IOException ioe) {
220: if (Log.isLog(myService.getName())) {
221: Log.getLog(myService.getName()).log(ioe);
222: }
223:
224: throw new ServerRuntimeException(
225: "Failed to close socket.", ioe);
226: }
227: }
228: }
229:
230: /**
231: * Indicates whether this <code>Listener</code> is already bound
232: * to a port/address.
233: *
234: * @return <code>true</code> or <code>false</code>
235: */
236: public boolean isBound() {
237: return myDatagramSocket != null;
238: }
239:
240: }
|