01: /*
02: *
03: * Copyright (c) 2007, Sun Microsystems, Inc.
04: *
05: * All rights reserved.
06: *
07: * Redistribution and use in source and binary forms, with or without
08: * modification, are permitted provided that the following conditions
09: * are met:
10: *
11: * * Redistributions of source code must retain the above copyright
12: * notice, this list of conditions and the following disclaimer.
13: * * Redistributions in binary form must reproduce the above copyright
14: * notice, this list of conditions and the following disclaimer in the
15: * documentation and/or other materials provided with the distribution.
16: * * Neither the name of Sun Microsystems nor the names of its contributors
17: * may be used to endorse or promote products derived from this software
18: * without specific prior written permission.
19: *
20: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
21: * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
22: * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
23: * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
24: * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
25: * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
26: * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
27: * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
28: * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
29: * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
30: * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
31: */
32: package datagram;
33:
34: import java.io.*;
35:
36: import javax.microedition.io.*;
37: import javax.microedition.lcdui.*;
38: import javax.microedition.midlet.*;
39:
40: public class Sender extends Thread {
41: private DatagramConnection dc;
42: private String address;
43: private String message;
44:
45: public Sender(DatagramConnection dc) {
46: this .dc = dc;
47: start();
48: }
49:
50: public synchronized void send(String addr, String msg) {
51: address = addr;
52: message = msg;
53: notify();
54: }
55:
56: public synchronized void run() {
57: while (true) {
58: // If no client to deal, wait until one connects
59: if (message == null) {
60: try {
61: wait();
62: } catch (InterruptedException e) {
63: }
64: }
65:
66: try {
67: byte[] bytes = message.getBytes();
68: Datagram dg = null;
69:
70: // Are we a sender thread for the client ? If so then there's
71: // no address parameter
72: if (address == null) {
73: dg = dc.newDatagram(bytes, bytes.length);
74: } else {
75: dg = dc.newDatagram(bytes, bytes.length, address);
76: }
77:
78: dc.send(dg);
79: } catch (Exception ioe) {
80: ioe.printStackTrace();
81: }
82:
83: // Completed client handling, return handler to pool and
84: // mark for wait
85: message = null;
86: }
87: }
88: }
|