com.highqsoft.corbafileserver

Class SocketReader

java.lang.Object

java.lang.Thread

com.highqsoft.corbafileserver.SocketReader

All Implemented Interfaces:

java.lang.Runnable

public class SocketReader
extends java.lang.Thread

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

   String ret = "";
   String name = file.getName();
   SocketReader reader = null;
   try {
      reader = new SocketReader(file, port);
   } catch (Throwable t) {
      String host = InetAddress.getLocalHost().getHostName(); 
      throw new ConnectException ("Socket connection to "+host+":"+port+" refused");
   }
   if (reader != null) {
      String host = InetAddress.getLocalHost().getHostName(); 
      reader.start();
      try {
         ret = server.saveBySocket(aoSession, name, subDir, host, port);
         reader.join();
         reader = null;
      } catch (Throwable ttt) {
         ttt.printStackTrace();
      } 
      Throwable t = reader.getThrowable();
      if (t != null) {
         if (t instanceof FileNotFoundException) {
            throw (FileNotFoundException)t;
         } else {
            throw (IOException)t;
         }
      }
      reader.close();
   }
   return ret;

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
protected java.net.ServerSocket	serverSocket

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
SocketReader(java.io.File file) Read the data for the given file to socket with default portnumber (11011) and default buffersize (100000).
SocketReader(java.io.File file, int port) Read the data for the given file to socket using the given portnumber and default buffersize (10000).
SocketReader(java.io.File file, int port, int bufSize) Read the data for 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.
void	run() Start the transaction.
static java.lang.String	send(CORBAFileServerIF server, AoSession aoSession, int port, java.io.File file, java.lang.String subDir) Send the given file to the server.

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

serverSocket

protected java.net.ServerSocket serverSocket

client

protected java.net.Socket client

file

protected java.io.File file

error

protected java.lang.Throwable error

bufSize

protected int bufSize

Constructor Detail

SocketReader

public SocketReader(java.io.File file)
             throws java.net.UnknownHostException,
                    java.io.IOException

Read the data for the given file to socket with default portnumber (11011) and default buffersize (100000).

Parameters:

file - The file to be transmitted.

Throws:

java.net.UnknownHostException

java.io.IOException

SocketReader

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

Read the data for 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.

Throws:

java.net.UnknownHostException

java.io.IOException

SocketReader

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

Read the data for 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.

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.

send

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

Send 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.

file - the file to be sent.

subDir - an alternative sub directory, that can be specified, if the filename should not used to determine the destination folder.

Returns:

the server side file location URL string

Throws:

java.net.UnknownHostException

java.io.FileNotFoundException

java.net.ConnectException

java.lang.InterruptedException

java.io.IOException

CORBAFileServerException