1*b1cdbd2cSJim Jagielski /************************************************************** 2*b1cdbd2cSJim Jagielski * 3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one 4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file 5*b1cdbd2cSJim Jagielski * distributed with this work for additional information 6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file 7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the 8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance 9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at 10*b1cdbd2cSJim Jagielski * 11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0 12*b1cdbd2cSJim Jagielski * 13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing, 14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an 15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the 17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations 18*b1cdbd2cSJim Jagielski * under the License. 19*b1cdbd2cSJim Jagielski * 20*b1cdbd2cSJim Jagielski *************************************************************/ 21*b1cdbd2cSJim Jagielski 22*b1cdbd2cSJim Jagielski 23*b1cdbd2cSJim Jagielski package com.sun.star.lib.connections.socket; 24*b1cdbd2cSJim Jagielski 25*b1cdbd2cSJim Jagielski 26*b1cdbd2cSJim Jagielski import java.io.BufferedInputStream; 27*b1cdbd2cSJim Jagielski import java.io.BufferedOutputStream; 28*b1cdbd2cSJim Jagielski import java.io.InputStream; 29*b1cdbd2cSJim Jagielski import java.io.IOException; 30*b1cdbd2cSJim Jagielski import java.io.OutputStream; 31*b1cdbd2cSJim Jagielski 32*b1cdbd2cSJim Jagielski import java.net.Socket; 33*b1cdbd2cSJim Jagielski 34*b1cdbd2cSJim Jagielski import java.util.Enumeration; 35*b1cdbd2cSJim Jagielski import java.util.Vector; 36*b1cdbd2cSJim Jagielski 37*b1cdbd2cSJim Jagielski 38*b1cdbd2cSJim Jagielski import com.sun.star.io.XStreamListener; 39*b1cdbd2cSJim Jagielski 40*b1cdbd2cSJim Jagielski import com.sun.star.connection.XConnection; 41*b1cdbd2cSJim Jagielski import com.sun.star.connection.XConnectionBroadcaster; 42*b1cdbd2cSJim Jagielski 43*b1cdbd2cSJim Jagielski /** 44*b1cdbd2cSJim Jagielski * The SocketConnection implements the <code>XConnection</code> interface 45*b1cdbd2cSJim Jagielski * and is uses by the <code>SocketConnector</code> and the <code>SocketAcceptor</code>. 46*b1cdbd2cSJim Jagielski * This class is not part of the provided <code>api</code>. 47*b1cdbd2cSJim Jagielski * <p> 48*b1cdbd2cSJim Jagielski * @version $Revision: 1.6 $ $ $Date: 2008-04-11 11:14:31 $ 49*b1cdbd2cSJim Jagielski * @author Kay Ramme 50*b1cdbd2cSJim Jagielski * @see com.sun.star.comp.connections.SocketAcceptor 51*b1cdbd2cSJim Jagielski * @see com.sun.star.comp.connections.SocketConnector 52*b1cdbd2cSJim Jagielski * @see com.sun.star.connections.XConnection 53*b1cdbd2cSJim Jagielski * @since UDK1.0 54*b1cdbd2cSJim Jagielski */ 55*b1cdbd2cSJim Jagielski public class SocketConnection implements XConnection, XConnectionBroadcaster { 56*b1cdbd2cSJim Jagielski /** 57*b1cdbd2cSJim Jagielski * When set to true, enables various debugging output. 58*b1cdbd2cSJim Jagielski */ 59*b1cdbd2cSJim Jagielski static public final boolean DEBUG = false; 60*b1cdbd2cSJim Jagielski 61*b1cdbd2cSJim Jagielski protected String _description; 62*b1cdbd2cSJim Jagielski protected Socket _socket; 63*b1cdbd2cSJim Jagielski protected InputStream _inputStream; 64*b1cdbd2cSJim Jagielski protected OutputStream _outputStream; 65*b1cdbd2cSJim Jagielski protected Vector _listeners; 66*b1cdbd2cSJim Jagielski protected boolean _firstRead; 67*b1cdbd2cSJim Jagielski 68*b1cdbd2cSJim Jagielski /** 69*b1cdbd2cSJim Jagielski * Constructs a new <code>SocketConnection</code>. 70*b1cdbd2cSJim Jagielski * <p> 71*b1cdbd2cSJim Jagielski * @param description the description of the connection 72*b1cdbd2cSJim Jagielski * @param socket the socket of the connection 73*b1cdbd2cSJim Jagielski */ SocketConnection(String description, Socket socket)74*b1cdbd2cSJim Jagielski public SocketConnection(String description, Socket socket) throws IOException { 75*b1cdbd2cSJim Jagielski if (DEBUG) System.err.println("##### " + getClass().getName() + " - instantiated " + description + " " + socket); 76*b1cdbd2cSJim Jagielski 77*b1cdbd2cSJim Jagielski _description = description 78*b1cdbd2cSJim Jagielski + ",localHost=" + socket.getLocalAddress().getHostName() 79*b1cdbd2cSJim Jagielski + ",localPort=" + socket.getLocalPort() 80*b1cdbd2cSJim Jagielski + ",peerHost=" + socket.getInetAddress().getHostName() 81*b1cdbd2cSJim Jagielski + ",peerPort=" + socket.getPort(); 82*b1cdbd2cSJim Jagielski 83*b1cdbd2cSJim Jagielski _socket = socket; 84*b1cdbd2cSJim Jagielski _inputStream = new BufferedInputStream(socket.getInputStream()); 85*b1cdbd2cSJim Jagielski _outputStream = new BufferedOutputStream(socket.getOutputStream()); 86*b1cdbd2cSJim Jagielski 87*b1cdbd2cSJim Jagielski _listeners = new Vector(); 88*b1cdbd2cSJim Jagielski _firstRead = true; 89*b1cdbd2cSJim Jagielski } 90*b1cdbd2cSJim Jagielski 91*b1cdbd2cSJim Jagielski 92*b1cdbd2cSJim Jagielski 93*b1cdbd2cSJim Jagielski addStreamListener(XStreamListener aListener )94*b1cdbd2cSJim Jagielski public void addStreamListener(XStreamListener aListener ) throws com.sun.star.uno.RuntimeException { 95*b1cdbd2cSJim Jagielski _listeners.addElement(aListener); 96*b1cdbd2cSJim Jagielski } 97*b1cdbd2cSJim Jagielski removeStreamListener(XStreamListener aListener )98*b1cdbd2cSJim Jagielski public void removeStreamListener(XStreamListener aListener ) throws com.sun.star.uno.RuntimeException { 99*b1cdbd2cSJim Jagielski _listeners.removeElement(aListener); 100*b1cdbd2cSJim Jagielski } 101*b1cdbd2cSJim Jagielski notifyListeners_open()102*b1cdbd2cSJim Jagielski private void notifyListeners_open() { 103*b1cdbd2cSJim Jagielski Enumeration elements = _listeners.elements(); 104*b1cdbd2cSJim Jagielski while(elements.hasMoreElements()) { 105*b1cdbd2cSJim Jagielski XStreamListener xStreamListener = (XStreamListener)elements.nextElement(); 106*b1cdbd2cSJim Jagielski xStreamListener.started(); 107*b1cdbd2cSJim Jagielski } 108*b1cdbd2cSJim Jagielski } 109*b1cdbd2cSJim Jagielski notifyListeners_close()110*b1cdbd2cSJim Jagielski private void notifyListeners_close() { 111*b1cdbd2cSJim Jagielski Enumeration elements = _listeners.elements(); 112*b1cdbd2cSJim Jagielski while(elements.hasMoreElements()) { 113*b1cdbd2cSJim Jagielski XStreamListener xStreamListener = (XStreamListener)elements.nextElement(); 114*b1cdbd2cSJim Jagielski xStreamListener.closed(); 115*b1cdbd2cSJim Jagielski } 116*b1cdbd2cSJim Jagielski } 117*b1cdbd2cSJim Jagielski notifyListeners_error(com.sun.star.uno.Exception exception)118*b1cdbd2cSJim Jagielski private void notifyListeners_error(com.sun.star.uno.Exception exception) { 119*b1cdbd2cSJim Jagielski Enumeration elements = _listeners.elements(); 120*b1cdbd2cSJim Jagielski while(elements.hasMoreElements()) { 121*b1cdbd2cSJim Jagielski XStreamListener xStreamListener = (XStreamListener)elements.nextElement(); 122*b1cdbd2cSJim Jagielski xStreamListener.error(exception); 123*b1cdbd2cSJim Jagielski } 124*b1cdbd2cSJim Jagielski } 125*b1cdbd2cSJim Jagielski 126*b1cdbd2cSJim Jagielski 127*b1cdbd2cSJim Jagielski /** 128*b1cdbd2cSJim Jagielski * Read the required number of bytes. 129*b1cdbd2cSJim Jagielski * <p> 130*b1cdbd2cSJim Jagielski * @return the number of bytes read 131*b1cdbd2cSJim Jagielski * @param aReadBytes the outparameter, where the bytes have to be placed 132*b1cdbd2cSJim Jagielski * @param nBytesToRead the number of bytes to read 133*b1cdbd2cSJim Jagielski * @see com.sun.star.connections.XConnection#read 134*b1cdbd2cSJim Jagielski */ read( byte[][] bytes, int nBytesToRead)135*b1cdbd2cSJim Jagielski public int read(/*OUT*/byte[][] bytes, int nBytesToRead) throws com.sun.star.io.IOException, com.sun.star.uno.RuntimeException { 136*b1cdbd2cSJim Jagielski if(_firstRead) { 137*b1cdbd2cSJim Jagielski _firstRead = false; 138*b1cdbd2cSJim Jagielski 139*b1cdbd2cSJim Jagielski notifyListeners_open(); 140*b1cdbd2cSJim Jagielski } 141*b1cdbd2cSJim Jagielski 142*b1cdbd2cSJim Jagielski String errMessage = null; 143*b1cdbd2cSJim Jagielski 144*b1cdbd2cSJim Jagielski int read_bytes = 0; 145*b1cdbd2cSJim Jagielski bytes[0] = new byte[nBytesToRead]; 146*b1cdbd2cSJim Jagielski 147*b1cdbd2cSJim Jagielski try { 148*b1cdbd2cSJim Jagielski int count ; 149*b1cdbd2cSJim Jagielski 150*b1cdbd2cSJim Jagielski do { 151*b1cdbd2cSJim Jagielski count = _inputStream.read(bytes[0], read_bytes, nBytesToRead - read_bytes); 152*b1cdbd2cSJim Jagielski if(count == -1) 153*b1cdbd2cSJim Jagielski errMessage = "EOF reached - " + getDescription(); 154*b1cdbd2cSJim Jagielski 155*b1cdbd2cSJim Jagielski read_bytes += count; 156*b1cdbd2cSJim Jagielski } 157*b1cdbd2cSJim Jagielski while(read_bytes >= 0 && read_bytes < nBytesToRead && count >= 0); 158*b1cdbd2cSJim Jagielski } 159*b1cdbd2cSJim Jagielski catch(IOException ioException) { 160*b1cdbd2cSJim Jagielski if(DEBUG) { 161*b1cdbd2cSJim Jagielski System.err.println("##### " + getClass().getName() + ".read - exception occurred:" + ioException); 162*b1cdbd2cSJim Jagielski ioException.printStackTrace(); 163*b1cdbd2cSJim Jagielski } 164*b1cdbd2cSJim Jagielski 165*b1cdbd2cSJim Jagielski errMessage = ioException.toString(); 166*b1cdbd2cSJim Jagielski } 167*b1cdbd2cSJim Jagielski 168*b1cdbd2cSJim Jagielski if(errMessage != null) { 169*b1cdbd2cSJim Jagielski com.sun.star.io.IOException unoIOException = new com.sun.star.io.IOException(errMessage); 170*b1cdbd2cSJim Jagielski notifyListeners_error(unoIOException); 171*b1cdbd2cSJim Jagielski 172*b1cdbd2cSJim Jagielski throw unoIOException; 173*b1cdbd2cSJim Jagielski } 174*b1cdbd2cSJim Jagielski 175*b1cdbd2cSJim Jagielski if (DEBUG) System.err.println("##### " + getClass().getName() + " - read byte:" + read_bytes + " " + bytes[0]); 176*b1cdbd2cSJim Jagielski 177*b1cdbd2cSJim Jagielski return read_bytes; 178*b1cdbd2cSJim Jagielski } 179*b1cdbd2cSJim Jagielski 180*b1cdbd2cSJim Jagielski /** 181*b1cdbd2cSJim Jagielski * Write bytes. 182*b1cdbd2cSJim Jagielski * <p> 183*b1cdbd2cSJim Jagielski * @param aData the bytes to write 184*b1cdbd2cSJim Jagielski * @see com.sun.star.connections.XConnection#write 185*b1cdbd2cSJim Jagielski */ write(byte aData[])186*b1cdbd2cSJim Jagielski public void write(byte aData[]) throws com.sun.star.io.IOException, com.sun.star.uno.RuntimeException { 187*b1cdbd2cSJim Jagielski try { 188*b1cdbd2cSJim Jagielski _outputStream.write(aData); 189*b1cdbd2cSJim Jagielski } 190*b1cdbd2cSJim Jagielski catch(IOException ioException) { 191*b1cdbd2cSJim Jagielski com.sun.star.io.IOException unoIOException = new com.sun.star.io.IOException(ioException.toString()); 192*b1cdbd2cSJim Jagielski notifyListeners_error(unoIOException); 193*b1cdbd2cSJim Jagielski 194*b1cdbd2cSJim Jagielski throw unoIOException; 195*b1cdbd2cSJim Jagielski } 196*b1cdbd2cSJim Jagielski 197*b1cdbd2cSJim Jagielski if (DEBUG) System.err.println("##### " + getClass().getName() + " - written bytes:" + aData + " " + aData.length); 198*b1cdbd2cSJim Jagielski } 199*b1cdbd2cSJim Jagielski 200*b1cdbd2cSJim Jagielski /** 201*b1cdbd2cSJim Jagielski * Flushes the buffer. 202*b1cdbd2cSJim Jagielski * <p> 203*b1cdbd2cSJim Jagielski * @see com.sun.star.connections.XConnection#flush 204*b1cdbd2cSJim Jagielski */ flush()205*b1cdbd2cSJim Jagielski public void flush() throws com.sun.star.io.IOException, com.sun.star.uno.RuntimeException { 206*b1cdbd2cSJim Jagielski try { 207*b1cdbd2cSJim Jagielski _outputStream.flush(); 208*b1cdbd2cSJim Jagielski } 209*b1cdbd2cSJim Jagielski catch(IOException ioException) { 210*b1cdbd2cSJim Jagielski com.sun.star.io.IOException unoIOException = new com.sun.star.io.IOException(ioException.toString()); 211*b1cdbd2cSJim Jagielski notifyListeners_error(unoIOException); 212*b1cdbd2cSJim Jagielski 213*b1cdbd2cSJim Jagielski throw unoIOException; 214*b1cdbd2cSJim Jagielski } 215*b1cdbd2cSJim Jagielski } 216*b1cdbd2cSJim Jagielski 217*b1cdbd2cSJim Jagielski /** 218*b1cdbd2cSJim Jagielski * Closes the connection. 219*b1cdbd2cSJim Jagielski * <p> 220*b1cdbd2cSJim Jagielski * @see com.sun.star.connections.XConnection#close 221*b1cdbd2cSJim Jagielski */ close()222*b1cdbd2cSJim Jagielski public void close() throws com.sun.star.io.IOException, com.sun.star.uno.RuntimeException { 223*b1cdbd2cSJim Jagielski try { 224*b1cdbd2cSJim Jagielski _socket.close(); 225*b1cdbd2cSJim Jagielski } 226*b1cdbd2cSJim Jagielski catch(IOException ioException) { 227*b1cdbd2cSJim Jagielski com.sun.star.io.IOException unoIOException = new com.sun.star.io.IOException(ioException.toString()); 228*b1cdbd2cSJim Jagielski notifyListeners_error(unoIOException); 229*b1cdbd2cSJim Jagielski 230*b1cdbd2cSJim Jagielski throw unoIOException; 231*b1cdbd2cSJim Jagielski } 232*b1cdbd2cSJim Jagielski if (DEBUG) System.err.println("##### " + getClass().getName() + " - socket closed"); 233*b1cdbd2cSJim Jagielski 234*b1cdbd2cSJim Jagielski notifyListeners_close(); 235*b1cdbd2cSJim Jagielski } 236*b1cdbd2cSJim Jagielski 237*b1cdbd2cSJim Jagielski /** 238*b1cdbd2cSJim Jagielski * Gives a description of the connection. 239*b1cdbd2cSJim Jagielski * <p> 240*b1cdbd2cSJim Jagielski * @return the description 241*b1cdbd2cSJim Jagielski * @see com.sun.star.connections.XConnection#getDescription 242*b1cdbd2cSJim Jagielski */ getDescription()243*b1cdbd2cSJim Jagielski public String getDescription() throws com.sun.star.uno.RuntimeException { 244*b1cdbd2cSJim Jagielski return _description; 245*b1cdbd2cSJim Jagielski } 246*b1cdbd2cSJim Jagielski 247*b1cdbd2cSJim Jagielski } 248*b1cdbd2cSJim Jagielski 249