org.wandora.topicmap.remote.server

Class SocketServerInterface

java.lang.Object

org.wandora.topicmap.remote.server.SocketServerInterface

All Implemented Interfaces:

ServerInterface

public class SocketServerInterface
extends java.lang.Object
implements ServerInterface

This is the class implementing ServerInterface, the server interface for the old remote topic maps. It is not used anymore and should be considered deprecated.

Author:

olli

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	SocketServerInterface.PingThread

Field Summary

Fields

Modifier and Type	Field and Description
private ErrorHandler	errorHandler
private boolean	gzip
private java.lang.String	host
private java.io.InputStream	in
private javax.crypto.SecretKey	key
private java.io.InputStream	originalIn
private java.util.Hashtable	originalTimes
private java.io.OutputStream	out
private long	pingdelay
private int	port
private java.net.Socket	s
private java.lang.StringBuffer	session
private TopicMap	tm
private boolean	uncommitted

Constructor Summary

Constructors

Constructor and Description
SocketServerInterface()
SocketServerInterface(java.lang.String host, int port) Creates a new instance of SocketServerInterface
SocketServerInterface(java.lang.String host, int port, long pingdelay)

Method Summary

Modifier and Type	Method and Description
void	applySession(java.lang.StringBuffer session)
void	checkTopics(TopicMap tm)
boolean	cipher()
void	clearCache()
boolean	clearTopicMap()
void	close()
void	commit(boolean force)
void	connect()
java.lang.String	customCommand(java.lang.String command)
static java.lang.String	decode(java.lang.String sis)
boolean	delete(java.lang.String filename)
static java.lang.String	encode(java.lang.String sis)
private Topic	fetchTopic(java.lang.String topicSI)
private Topic[]	fetchTopics(java.lang.String[] topicSIs)
private Topic[]	fetchTopicsOfType(java.lang.String typeSI)
boolean	fileExists(java.lang.String file)
java.lang.StringBuffer	getSession()
java.lang.String	getTimeStamp(Topic t)
Topic	getTopic(java.lang.String topicSI)
Topic	getTopicByName(java.lang.String name)
Topic[]	getTopics(java.lang.String[] topicSIs)
Topic[]	getTopicsOfType(java.lang.String typeSI)
private java.lang.String	getTransferableSI(Topic t)
boolean	gzip()
void	handleServerError(java.lang.Exception e)
private void	initialize()
private void	initializeTopicMap()
boolean	isConnected()
boolean	isUncommitted()
java.lang.String[]	listDirectories(java.lang.String dir)
java.lang.String[]	listFiles(java.lang.String dir)
boolean	login(java.lang.String user, java.lang.String password)
void	mergeIn(TopicMap tm)
boolean	needLogin()
boolean	openTopicMap(java.lang.String key)
boolean	ping()
private java.lang.String	readLine()
static java.lang.String	readLine(java.io.InputStream in)
private void	readTopicMapIn()
void	removeAssociation(Association a)
void	removeBaseName(Topic t)
void	removeData(Topic t, Topic type, Topic version)
void	removeSubjectIdentifier(Topic t, Locator l)
void	removeSubjectLocator(Topic t)
void	removeTopic(Topic t)
void	removeTopicType(Topic t, Topic type)
void	removeVariantName(Topic t, java.util.Collection scope)
void	rollback()
java.lang.String[]	search(java.lang.String query)
void	setServerErrorHandler(ErrorHandler handler)
java.lang.String	upload(java.io.InputStream in, java.lang.String filename, long length)
java.lang.String	upload(java.io.InputStream in, java.lang.String filename, long length, boolean overwrite)
void	writelog(java.lang.String lvl, java.lang.String msg)
boolean	writeTopicMapTo(java.io.OutputStream tmout)

Methods inherited from class java.lang.Object

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

Field Detail

tm

private TopicMap tm

s

private java.net.Socket s

in

private java.io.InputStream in

originalIn

private java.io.InputStream originalIn

out

private java.io.OutputStream out

originalTimes

private java.util.Hashtable originalTimes

pingdelay

private long pingdelay

uncommitted

private boolean uncommitted

gzip

private boolean gzip

key

private javax.crypto.SecretKey key

session

private java.lang.StringBuffer session

errorHandler

private ErrorHandler errorHandler

host

private java.lang.String host

port

private int port

Constructor Detail

SocketServerInterface

public SocketServerInterface(java.lang.String host,
                             int port)
                      throws java.io.IOException

Creates a new instance of SocketServerInterface

Throws:

java.io.IOException

SocketServerInterface

public SocketServerInterface(java.lang.String host,
                             int port,
                             long pingdelay)
                      throws java.io.IOException

Throws:

java.io.IOException

SocketServerInterface

public SocketServerInterface()
                      throws java.io.IOException

Throws:

java.io.IOException

Method Detail

connect

public void connect()
             throws java.io.IOException

Specified by:

connect in interface ServerInterface

Throws:

java.io.IOException

initialize

private void initialize()
                 throws java.io.IOException

Throws:

java.io.IOException

initializeTopicMap

private void initializeTopicMap()

checkTopics

public void checkTopics(TopicMap tm)
                 throws ServerException

Specified by:

checkTopics in interface ServerInterface

Throws:

ServerException

getTimeStamp

public java.lang.String getTimeStamp(Topic t)

commit

public void commit(boolean force)
            throws WandoraException,
                   ServerException

Specified by:

commit in interface ServerInterface

Throws:

WandoraException

ServerException

readLine

private java.lang.String readLine()
                           throws java.io.IOException

Throws:

java.io.IOException

readLine

public static java.lang.String readLine(java.io.InputStream in)
                                 throws java.io.IOException

Throws:

java.io.IOException

fetchTopic

private Topic fetchTopic(java.lang.String topicSI)
                  throws ServerException

Throws:

ServerException

readTopicMapIn

private void readTopicMapIn()
                     throws java.io.IOException,
                            TopicMapException

Throws:

java.io.IOException

TopicMapException

fetchTopicsOfType

private Topic[] fetchTopicsOfType(java.lang.String typeSI)
                           throws ServerException

Throws:

ServerException

fetchTopics

private Topic[] fetchTopics(java.lang.String[] topicSIs)
                     throws ServerException

Throws:

ServerException

getTopic

public Topic getTopic(java.lang.String topicSI)
               throws ServerException

Specified by:

getTopic in interface ServerInterface

Throws:

ServerException

getTopics

public Topic[] getTopics(java.lang.String[] topicSIs)
                  throws ServerException

Specified by:

getTopics in interface ServerInterface

Throws:

ServerException

getTopicsOfType

public Topic[] getTopicsOfType(java.lang.String typeSI)
                        throws ServerException

Specified by:

getTopicsOfType in interface ServerInterface

Throws:

ServerException

mergeIn

public void mergeIn(TopicMap tm)
             throws ServerException

Specified by:

mergeIn in interface ServerInterface

Throws:

ServerException

removeAssociation

public void removeAssociation(Association a)
                       throws ServerException

Specified by:

removeAssociation in interface ServerInterface

Throws:

ServerException

removeData

public void removeData(Topic t,
                       Topic type,
                       Topic version)
                throws ServerException

Specified by:

removeData in interface ServerInterface

Throws:

ServerException

removeTopic

public void removeTopic(Topic t)
                 throws ServerException

Specified by:

removeTopic in interface ServerInterface

Throws:

ServerException

removeVariantName

public void removeVariantName(Topic t,
                              java.util.Collection scope)
                       throws ServerException

Specified by:

removeVariantName in interface ServerInterface

Throws:

ServerException

removeBaseName

public void removeBaseName(Topic t)
                    throws ServerException

Specified by:

removeBaseName in interface ServerInterface

Throws:

ServerException

rollback

public void rollback()
              throws ServerException

Specified by:

rollback in interface ServerInterface

Throws:

ServerException

getTopicByName

public Topic getTopicByName(java.lang.String name)
                     throws ServerException

Specified by:

getTopicByName in interface ServerInterface

Throws:

ServerException

removeSubjectLocator

public void removeSubjectLocator(Topic t)
                          throws ServerException

Specified by:

removeSubjectLocator in interface ServerInterface

Throws:

ServerException

removeTopicType

public void removeTopicType(Topic t,
                            Topic type)
                     throws ServerException

Specified by:

removeTopicType in interface ServerInterface

Throws:

ServerException

clearTopicMap

public boolean clearTopicMap()
                      throws ServerException

Specified by:

clearTopicMap in interface ServerInterface

Throws:

ServerException

clearCache

public void clearCache()

Specified by:

clearCache in interface ServerInterface

writelog

public void writelog(java.lang.String lvl,
                     java.lang.String msg)
              throws ServerException

Specified by:

writelog in interface ServerInterface

Throws:

ServerException

writeTopicMapTo

public boolean writeTopicMapTo(java.io.OutputStream tmout)
                        throws java.io.IOException,
                               ServerException

Specified by:

writeTopicMapTo in interface ServerInterface

Throws:

java.io.IOException

ServerException

upload

public java.lang.String upload(java.io.InputStream in,
                               java.lang.String filename,
                               long length)
                        throws ServerException

Throws:

ServerException

upload

public java.lang.String upload(java.io.InputStream in,
                               java.lang.String filename,
                               long length,
                               boolean overwrite)
                        throws ServerException

Specified by:

upload in interface ServerInterface

Throws:

ServerException

listDirectories

public java.lang.String[] listDirectories(java.lang.String dir)
                                   throws ServerException

Specified by:

listDirectories in interface ServerInterface

Throws:

ServerException

listFiles

public java.lang.String[] listFiles(java.lang.String dir)
                             throws ServerException

Specified by:

listFiles in interface ServerInterface

Throws:

ServerException

fileExists

public boolean fileExists(java.lang.String file)
                   throws ServerException

Specified by:

fileExists in interface ServerInterface

Throws:

ServerException

delete

public boolean delete(java.lang.String filename)
               throws ServerException

Specified by:

delete in interface ServerInterface

Throws:

ServerException

gzip

public boolean gzip()
             throws ServerException

Specified by:

gzip in interface ServerInterface

Throws:

ServerException

cipher

public boolean cipher()
               throws ServerException

Specified by:

cipher in interface ServerInterface

Throws:

ServerException

login

public boolean login(java.lang.String user,
                     java.lang.String password)
              throws ServerException

Specified by:

login in interface ServerInterface

Throws:

ServerException

needLogin

public boolean needLogin()

Specified by:

needLogin in interface ServerInterface

openTopicMap

public boolean openTopicMap(java.lang.String key)
                     throws ServerException

Specified by:

openTopicMap in interface ServerInterface

Throws:

ServerException

removeSubjectIdentifier

public void removeSubjectIdentifier(Topic t,
                                    Locator l)
                             throws ServerException

Specified by:

removeSubjectIdentifier in interface ServerInterface

Throws:

ServerException

customCommand

public java.lang.String customCommand(java.lang.String command)
                               throws ServerException

Specified by:

customCommand in interface ServerInterface

Throws:

ServerException

ping

public boolean ping()
             throws ServerException

Throws:

ServerException

isUncommitted

public boolean isUncommitted()

Specified by:

isUncommitted in interface ServerInterface

search

public java.lang.String[] search(java.lang.String query)
                          throws ServerException

Specified by:

search in interface ServerInterface

Throws:

ServerException

close

public void close()
           throws ServerException

Specified by:

close in interface ServerInterface

Throws:

ServerException

getSession

public java.lang.StringBuffer getSession()

Specified by:

getSession in interface ServerInterface

setServerErrorHandler

public void setServerErrorHandler(ErrorHandler handler)

Specified by:

setServerErrorHandler in interface ServerInterface

handleServerError

public void handleServerError(java.lang.Exception e)

Specified by:

handleServerError in interface ServerInterface

isConnected

public boolean isConnected()

Specified by:

isConnected in interface ServerInterface

applySession

public void applySession(java.lang.StringBuffer session)
                  throws ServerException

Specified by:

applySession in interface ServerInterface

Throws:

ServerException

getTransferableSI

private java.lang.String getTransferableSI(Topic t)

decode

public static java.lang.String decode(java.lang.String sis)

encode

public static java.lang.String encode(java.lang.String sis)