android-vnc

// // Copyright (C) 2010 Michael A. MacDonald // Copyright (C) 2004 Horizon Wimba. All Rights Reserved. // Copyright (C) 2001-2003 HorizonLive.com, Inc. All Rights Reserved. // Copyright (C) 2001,2002 Constantin Kaplinsky. All Rights Reserved. // Copyright (C) 2000 Tridia Corporation. All Rights Reserved. // Copyright (C) 1999 AT&T Laboratories Cambridge. All Rights Reserved. // // This is free software; you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by // the Free Software Foundation; either version 2 of the License, or // (at your option) any later version. // // This software is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // You should have received a copy of the GNU General Public License // along with this software; if not, write to the Free Software // Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, // USA. // // // VncCanvas is a subclass of android.view.SurfaceView which draws a VNC // desktop on it. // package android.androidVNC; import java.io.IOException; import java.util.zip.Inflater; import android.app.ProgressDialog; import android.content.Context; import android.content.DialogInterface; import android.graphics.Color; import android.graphics.Paint; import android.graphics.Rect; import android.graphics.Paint.Style; import android.os.Handler; import android.util.AttributeSet; import android.util.Log; import android.view.Display; import android.view.KeyEvent; import android.view.MotionEvent; import android.widget.ImageView; import android.widget.Toast; import com.antlersoft.android.bc.BCFactory; public class VncCanvas extends ImageView { private final static String TAG = "VncCanvas"; private final static boolean LOCAL_LOGV = true; AbstractScaling scaling; // Available to activity int mouseX, mouseY; // Connection parameters ConnectionBean connection; // Runtime control flags private boolean maintainConnection = true; private boolean showDesktopInfo = true; private boolean repaintsEnabled = true; /** * Use camera button as meta key for right mouse button */ boolean cameraButtonDown = false; // Keep track when a seeming key press was the result of a menu shortcut int lastKeyDown; boolean afterMenu; // Color Model settings private COLORMODEL pendingColorModel = COLORMODEL.C24bit; private COLORMODEL colorModel = null; private int bytesPerPixel = 0; private int[] colorPalette = null; // VNC protocol connection public RfbProto rfb; // Internal bitmap data AbstractBitmapData bitmapData; public Handler handler = new Handler(); // VNC Encoding parameters private boolean useCopyRect = false; // TODO CopyRect is not working private int preferredEncoding = -1; // Unimplemented VNC encoding parameters private boolean requestCursorUpdates = false; private boolean ignoreCursorUpdates = true; // Unimplemented TIGHT encoding parameters private int compressLevel = -1; private int jpegQuality = -1; // Used to determine if encoding update is necessary private int[] encodingsSaved = new int[20]; private int nEncodingsSaved = 0; // ZRLE encoder's data. private byte[] zrleBuf; private int[] zrleTilePixels; private ZlibInStream zrleInStream; // Zlib encoder's data. private byte[] zlibBuf; private Inflater zlibInflater; private MouseScrollRunnable scrollRunnable; private Paint handleRREPaint; /** * Position of the top left portion of the <i>visible</i> part of the screen, in * full-frame coordinates */ int absoluteXPosition = 0, absoluteYPosition = 0; /** * Constructor used by the inflation apparatus * @param context */ public VncCanvas(final Context context, AttributeSet attrs) { super(context, attrs); scrollRunnable = new MouseScrollRunnable(); handleRREPaint = new Paint(); handleRREPaint.setStyle(Style.FILL); } /** * Create a view showing a VNC connection * @param context Containing context (activity) * @param bean Connection settings * @param setModes Callback to run on UI thread after connection is set up */ void initializeVncCanvas(ConnectionBean bean, final Runnable setModes) { connection = bean; this.pendingColorModel = COLORMODEL.valueOf(bean.getColorModel()); // Startup the RFB thread with a nifty progess dialog final ProgressDialog pd = ProgressDialog.show(getContext(), "Connecting...", "Establishing handshake.\nPlease wait...", true, true, new DialogInterface.OnCancelListener() { @Override public void onCancel(DialogInterface dialog) { closeConnection(); handler.post(new Runnable() { public void run() { Utils.showErrorMessage(getContext(), "VNC connection aborted!"); } }); } }); final Display display = pd.getWindow().getWindowManager().getDefaultDisplay(); Thread t = new Thread() { public void run() { try { connectAndAuthenticate(connection.getUserName(),connection.getPassword()); doProtocolInitialisation(display.getWidth(), display.getHeight()); handler.post(new Runnable() { public void run() { pd.setMessage("Downloading first frame.\nPlease wait..."); } }); processNormalProtocol(getContext(), pd, setModes); } catch (Throwable e) { if (maintainConnection) { Log.e(TAG, e.toString()); e.printStackTrace(); // Ensure we dismiss the progress dialog // before we fatal error finish if (pd.isShowing()) pd.dismiss(); if (e instanceof OutOfMemoryError) { // TODO Not sure if this will happen but... // figure out how to gracefully notify the user // Instantiating an alert dialog here doesn't work // because we are out of memory. :( } else { String error = "VNC connection failed!"; if (e.getMessage() != null && (e.getMessage().indexOf("authentication") > -1)) { error = "VNC authentication failed!"; } final String error_ = error + "<br>" + e.getLocalizedMessage(); handler.post(new Runnable() { public void run() { Utils.showFatalErrorMessage(getContext(), error_); } }); } } } } }; t.start(); } void connectAndAuthenticate(String us,String pw) throws Exception { Log.i(TAG, "Connecting to " + connection.getAddress() + ", port " + connection.getPort() + "..."); rfb = new RfbProto(connection.getAddress(), connection.getPort()); if (LOCAL_LOGV) Log.v(TAG, "Connected to server"); // <RepeaterMagic> if (connection.getUseRepeater() && connection.getRepeaterId() != null && connection.getRepeaterId().length()>0) { Log.i(TAG, "Negotiating repeater/proxy connection"); byte[] protocolMsg = new byte[12]; rfb.is.read(protocolMsg); byte[] buffer = new byte[250]; System.arraycopy(connection.getRepeaterId().getBytes(), 0, buffer, 0, connection.getRepeaterId().length()); rfb.os.write(buffer); } // </RepeaterMagic> rfb.readVersionMsg(); Log.i(TAG, "RFB server supports protocol version " + rfb.serverMajor + "." + rfb.serverMinor); rfb.writeVersionMsg(); Log.i(TAG, "Using RFB protocol version " + rfb.clientMajor + "." + rfb.clientMinor); int bitPref=0; if(connection.getUserName().length()>0) bitPref|=1; Log.d("debug","bitPref="+bitPref); int secType = rfb.negotiateSecurity(bitPref); int authType; if (secType == RfbProto.SecTypeTight) { rfb.initCapabilities(); rfb.setupTunneling(); authType = rfb.negotiateAuthenticationTight(); } else if (secType == RfbProto.SecTypeUltra34) { rfb.prepareDH(); authType = RfbProto.AuthUltra; } else { authType = secType; } switch (authType) { case RfbProto.AuthNone: Log.i(TAG, "No authentication needed"); rfb.authenticateNone(); break; case RfbProto.AuthVNC: Log.i(