Форум программистов [Powered by Invision Power Board]

Код

   public void run() {
        try {
            sc = (SocketConnection) Connector.open("socket://" + FHost + ":" + FPort);
            sc.setSocketOption(sc.KEEPALIVE, 1);
            sc.setSocketOption(sc.RCVBUF, 16384);
        } catch (Exception e) { /*e.printStackTrace();*/ Stop(); return; }
        if (sc == null) return;
        try {
            is = sc.openInputStream();
            os = sc.openOutputStream();
        } catch (Exception e) { e.printStackTrace(); }
        try {
            FSender = new TCPSender(os);
            FSender.Wait();
        } catch (Exception e) { e.printStackTrace(); }
        FActive = true;
        int i = 0, k = 0;
        try {

            // added  
            tmrPing.enable(); // ping ON 
            ping = 0;
            // comment for disable pings

            while (FActive) {
                i = 0; k = 0;
                for (int a = 0; a < 4; a++) {
                    i = is.read();
                    if (i==-1) throw new DisconnectException();
                    k = k + ( i << ( 8 * (3 - a) ) );
                }
                if (( k < 1)|(k>16384)) throw new DisconnectException();
                byte[] x = new byte[k];
                is.read(x);

                // added
                if ((x.length == 1) && (x[0] == '!')) { // pong answer - "!"
                    ping--;
                    x = null;
                    continue;
                }

                Incoming = wuc.WinToUnicode(x);
                buffer.addElement(Incoming);
                MainMidlet.GetDisplay().flashBacklight(0);

                x = null;

                try { Thread.sleep(250); } catch (Exception e) {}
            }
        }
        catch (InterruptedIOException iioe) { Stop(); }
        catch (DisconnectException de) { Stop(); }
        catch(Exception e) { Stop(); e.printStackTrace(); }
    }