/*
* This file is part of the LibreOffice project.
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*
* This file incorporates work covered by the following license notice:
*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed
* with this work for additional information regarding copyright
* ownership. The ASF licenses this file to you under the Apache
* License, Version 2.0 (the "License"); you may not use this file
* except in compliance with the License. You may obtain a copy of
* the License at http://www.apache.org/licenses/LICENSE-2.0 .
*/
package com.sun.star.lib.connections.pipe;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.StringTokenizer;
import com.sun.star.connection.XConnection;
import com.sun.star.connection.XConnectionBroadcaster;
import com.sun.star.io.XStreamListener;
import com.sun.star.lib.util.NativeLibraryLoader;
/**
* The PipeConnection implements the XConnection
interface
* and is uses by the PipeConnector
and the PipeAcceptor
.
* This class is not part of the provided api
.
*
* @author Kay Ramme
* @see com.sun.star.comp.connections.PipeAcceptor
* @see com.sun.star.comp.connections.PipeConnector
* @see com.sun.star.connections.XConnection
* @since UDK1.0
*/
public class PipeConnection implements XConnection, XConnectionBroadcaster {
/**
* When set to true, enables various debugging output.
*/
static public final boolean DEBUG = false;
static {
// load shared library for JNI code
NativeLibraryLoader.loadLibrary(PipeConnection.class.getClassLoader(), "jpipe");
}
protected String _aDescription;
protected long _nPipeHandle;
protected ArrayList
* @param description the description of the connection
* @param pipe the pipe of the connection
*/
public PipeConnection(String description)
throws IOException
{
if (DEBUG) System.err.println("##### " + getClass().getName() + " - instantiated " + description );
_aListeners = new ArrayList
* @return the number of bytes read
* @param aReadBytes the outparameter, where the bytes have to be placed
* @param nBytesToRead the number of bytes to read
* @see com.sun.star.connections.XConnection#read
*/
public int read(/*OUT*/byte[][] bytes, int nBytesToRead)
throws com.sun.star.io.IOException, com.sun.star.uno.RuntimeException
{
if(_bFirstRead) {
_bFirstRead = false;
notifyListeners_open();
}
return readJNI( bytes, nBytesToRead );
}
/**
* Write bytes.
*
* @param aData the bytes to write
* @see com.sun.star.connections.XConnection#write
*/
public void write(byte aData[])
throws com.sun.star.io.IOException, com.sun.star.uno.RuntimeException
{
writeJNI( aData );
}
/**
* Flushes the buffer.
*
* @see com.sun.star.connections.XConnection#flush
*/
public void flush()
throws com.sun.star.io.IOException, com.sun.star.uno.RuntimeException
{
flushJNI();
}
/**
* Closes the connection.
*
* @see com.sun.star.connections.XConnection#close
*/
public void close()
throws com.sun.star.io.IOException, com.sun.star.uno.RuntimeException
{
if (DEBUG) System.out.print( "PipeConnection::close() " );
closeJNI();
notifyListeners_close();
if (DEBUG) System.out.println( "done" );
}
/**
* Gives a description of the connection.
*
* @return the description
* @see com.sun.star.connections.XConnection#getDescription
*/
public String getDescription() throws com.sun.star.uno.RuntimeException {
return _aDescription;
}
}
PipeConnection
.
*