com.highqsoft.corbafileserver

Class SocketWriter

java.lang.Object

java.lang.Thread

com.highqsoft.corbafileserver.SocketWriter

All Implemented Interfaces:

java.lang.Runnable

public class SocketWriter
extends java.lang.Thread

The socket writer.
Here is a code snip that shows the way to use this class. It is the same code as used by the static receive method.

 SocketWriter writer = null;
 try {
    writer = new SocketWriter(file, port, Helper.DEFAULT_SOCKET_TIMEOUT);
 } catch (Throwable t) {
    String host = InetAddress.getLocalHost().getHostName();
    throw new ConnectException("Socket connection to " + host + ":" + port
          + " refused");
 }
 if (writer != null) {
    String host = InetAddress.getLocalHost().getHostName();
 
    try {
       writer.start();
       server.getBySocket(aoSession, name, host, port);
       writer.join();
    } catch (Throwable ttt) {
       ttt.printStackTrace();
    }
 
    Throwable t = writer.getThrowable();
    if (t != null) {
       if (t instanceof FileNotFoundException) {
          throw (FileNotFoundException) t;
       } else {
          throw (IOException) t;
       }
    }
 
    writer.close();
 }
 

Since:

$Date: 2017/04/06 13:28:53 $

Version:

$Revision: 1.20 $

Author:

Andreas Hofmann

See Also:

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected int	bufSize
protected java.net.Socket	client
static int	DEFAULT_BUFSIZE The default buffer size is 100000.
static int	DEFAULT_PORT The default port number is 11011.
protected java.lang.Throwable	error
protected java.io.File	file
static java.lang.Object	ID
protected java.net.ServerSocket	serverSocket
protected int	timeout

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
SocketWriter(java.io.File file, int timeout) Write the given file to socket with default portnumber (11011) and default buffersize (100000).
SocketWriter(java.io.File file, int port, int timeout) Write the given file to socket using the given portnumber and default buffersize (10000).
SocketWriter(java.io.File file, int port, int bufSize, int timeout) Write the given file to socket using the given portnumber and buffersize.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close all open sockes, if necessary.
java.lang.Throwable	getThrowable() Get the exception that may be occurred during running method.
static void	receive(CORBAFileServerIF server, AoSession aoSession, int port, java.lang.String name, java.io.File file) Receive the given file to the server.
void	run() Start the transaction.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DEFAULT_BUFSIZE

public static final int DEFAULT_BUFSIZE

The default buffer size is 100000.

See Also:

Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

The default port number is 11011.

See Also:

Constant Field Values

ID

public static java.lang.Object ID

serverSocket

protected java.net.ServerSocket serverSocket

timeout

protected int timeout

client

protected java.net.Socket client

file

protected java.io.File file

error

protected java.lang.Throwable error

bufSize

protected int bufSize

Constructor Detail

SocketWriter

public SocketWriter(java.io.File file,
            int timeout)
             throws java.net.UnknownHostException,
                    java.io.IOException

Write the given file to socket with default portnumber (11011) and default buffersize (100000).

Parameters:

file - The file to be transmitted.

timeout - the socket timeout in millisseconds.

Throws:

java.net.UnknownHostException

java.io.IOException

SocketWriter

public SocketWriter(java.io.File file,
            int port,
            int timeout)
             throws java.net.UnknownHostException,
                    java.io.IOException

Write the given file to socket using the given portnumber and default buffersize (10000).

Parameters:

file - The file to be transmitted.

port - the port number to be used.

timeout - teh socket timeout in millisseconds.

Throws:

java.net.UnknownHostException

java.io.IOException

SocketWriter

public SocketWriter(java.io.File file,
            int port,
            int bufSize,
            int timeout)
             throws java.net.UnknownHostException,
                    java.io.IOException

Write the given file to socket using the given portnumber and buffersize.

Parameters:

file - The file to be transmitted.

port - the port number to be used.

bufsize - the buffer size to be used.

timeout - teh socket timeout in millisseconds.

Throws:

java.net.UnknownHostException

java.io.IOException

Method Detail

getThrowable

public java.lang.Throwable getThrowable()

Get the exception that may be occurred during running method.

Returns:

the exception

run

public void run()

Start the transaction. If this method has finished the socket is ready for use again.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

See Also:

getThrowable()

close

public void close()

Close all open sockes, if necessary.

receive

public static void receive(CORBAFileServerIF server,
           AoSession aoSession,
           int port,
           java.lang.String name,
           java.io.File file)
                    throws java.net.UnknownHostException,
                           java.io.FileNotFoundException,
                           java.net.ConnectException,
                           java.lang.InterruptedException,
                           java.io.IOException,
                           CORBAFileServerException

Receive the given file to the server.

Parameters:

server - The CORABFileServer instance

aoSession - the ASAM ODS session for the secerity check.

port - the port to used.

name - the name of the file on server side.

file - the file to be sent.

Throws:

java.net.UnknownHostException

java.io.FileNotFoundException

java.net.ConnectException

java.lang.InterruptedException

java.io.IOException

CORBAFileServerException