//// Copyright 2002 Nokia Corporation.//// THIS SOURCE CODE IS PROVIDED 'AS IS', WITH NO WARRANTIES WHATSOEVER,// EXPRESS OR IMPLIED, INCLUDING ANY WARRANTY OF MERCHANTABILITY, FITNESS// FOR ANY PARTICULAR PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE// OR TRADE PRACTICE, RELATING TO THE SOURCE CODE OR ANY WARRANTY OTHERWISE// ARISING OUT OF ANY PROPOSAL, SPECIFICATION, OR SAMPLE AND WITH NO// OBLIGATION OF NOKIA TO PROVIDE THE LICENSEE WITH ANY MAINTENANCE OR// SUPPORT. FURTHERMORE, NOKIA MAKES NO WARRANTY THAT EXERCISE OF THE// RIGHTS GRANTED HEREUNDER DOES NOT INFRINGE OR MAY NOT CAUSE INFRINGEMENT// OF ANY PATENT OR OTHER INTELLECTUAL PROPERTY RIGHTS OWNED OR CONTROLLED// BY THIRD PARTIES//// Furthermore, information provided in this source code is preliminary,// and may be changed substantially prior to final release. Nokia Corporation// retains the right to make changes to this source code at any time,// without notice. This source code is provided for informational// purposes only.//// Nokia and Nokia Connecting People are registered trademarks of Nokia// Corporation. Java and all Java-based marks are trademarks or registered// trademarks of Sun Microsystems, Inc. Other product and company names// mentioned herein may be trademarks or trade names of their respective owners.//// A non-exclusive, non-transferable, worldwide, limited license is hereby// granted to the Licensee to download, print, reproduce and modify the// source code. The licensee has the right to market, sell, distribute and// make available the source code in original or modified form only when// incorporated into the programs developed by the Licensee. No other// license, express or implied, by estoppel or otherwise, to any other// intellectual property rights is granted herein.//import java.io.*;import java.util.*;abstract class SmsHandler    implements Runnable{    protected final Vector outgoingTextMessages = new Vector();    protected IncomingTextMessageListener incomingListener;    protected OutgoingTextMessageListener outgoingListener;    protected String port = null;    protected volatile boolean aborting = false;    protected volatile int incomingMessagesPending = 0;    protected SmsHandler()    {    }    void init(IncomingTextMessageListener incomingListener,        OutgoingTextMessageListener outgoingListener,        String port)    {        this.incomingListener = incomingListener;        this.outgoingListener = outgoingListener;        this.port = port;        // If we are able to open the server mode connection,        // then start the thread that does listening + sending.        if (openServerModeConnection())        {            Thread t = new Thread(this);            t.start();        }    }    public void run()    {        while (!aborting)        {            // 1. Wait if there is nothing to send or receive.            synchronized (this)            {                if ((outgoingTextMessages.size() == 0) &&                    (incomingMessagesPending == 0))                {                    try                    {                        wait(); // releases lock                    }                    catch (InterruptedException e)                    {                    }                }            }            if (aborting)            {                break;            }            // 2. If there are any outgoing messages on the queue, then send one.            while (outgoingTextMessages.size() > 0)            {                OutgoingTextMessage outgoing =                    (OutgoingTextMessage) outgoingTextMessages.firstElement();                doSend(outgoing);                outgoingTextMessages.removeElementAt(0);            }            // 3. If there is an incoming message pending, then read it.            while (incomingMessagesPending > 0)            {                doReceive();                synchronized (this)                {                    incomingMessagesPending--;                }            }        }    }    protected abstract boolean openServerModeConnection();    protected abstract void doSend(OutgoingTextMessage outgoing);    protected abstract void doReceive();    void sendMessage(String[] addrs, String content)    {        for (int i = 0; i < addrs.length; i++)        {            if (addrs[i] != null)            {                OutgoingTextMessage outgoing =                    new OutgoingTextMessage(addrs[i], content);                outgoingTextMessages.addElement(outgoing);            }        }        synchronized (this)        {            notify(); // wake up the sending thread        }    }    void abort()    {        // Set the state to 'aborting'.        aborting = true;        synchronized (this)        {            notify(); // wake up the SmsHandler thread, to kill it        }    }}