|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
A connection as used by a server/store. It provides a means of getting the client's input, and of writing reply data back to the client.
Method Summary | |
boolean |
addExtent(DBExtent dbExtent)
Adds the extent to this connections set of extents that have been changed during a transaction. |
void |
closeDatabase()
Close the database. |
void |
commit()
Commits the work done in this connection. |
Reply |
createReply(RequestId requestId)
Provides a Reply to which the server can write replies to the client's requests. |
FOStoreDatabase |
getDatabase()
Provides the database to be used by the server using this connection. |
FOStoreInput |
getInputFromClient()
Provides a DataInput from which the server can read the client's requests. |
FOStoreOutput |
getOutputForClient()
Provides a DataOutput to which the server can write data for the client. |
java.io.DataInput |
getOutputFromServer()
Provide the output from the server to the client reply handler. |
void |
openDatabase(java.lang.String dbname,
java.lang.String user,
long timestamp,
byte[] secret,
boolean create)
Log in to the database. |
void |
processRequests()
Process requests from client. |
void |
readInputFromClient()
Read the input stream from the socket. |
void |
rollback()
Rolls back the work done in this connection. |
void |
sendToClient()
Sends all the reply data to the client. |
void |
setClientInput(FOStoreInput in)
Set client data stream. |
void |
setOkToReleaseDatabase(boolean ok)
Indicates whether or not it is OK to release a database after a message's contents are processed. |
void |
writeOutputToClient()
Write the output from the server to the socket |
Method Detail |
public FOStoreInput getInputFromClient()
public FOStoreOutput getOutputForClient()
public Reply createReply(RequestId requestId) throws java.io.IOException
java.io.IOException
public boolean addExtent(DBExtent dbExtent)
public void commit() throws FOStoreDatabaseException
FOStoreDatabaseException
public void rollback() throws FOStoreDatabaseException
FOStoreDatabaseException
public void sendToClient() throws java.io.IOException, FOStoreDatabaseException
java.io.IOException
FOStoreDatabaseException
public FOStoreDatabase getDatabase()
public void setClientInput(FOStoreInput in) throws java.io.IOException
java.io.IOException
public void processRequests()
public void openDatabase(java.lang.String dbname, java.lang.String user, long timestamp, byte[] secret, boolean create) throws java.lang.InterruptedException, FOStoreDatabaseException
java.lang.InterruptedException
FOStoreDatabaseException
public java.io.DataInput getOutputFromServer()
public void writeOutputToClient() throws java.io.IOException
java.io.IOException
public void readInputFromClient() throws java.io.IOException
java.io.IOException
public void closeDatabase() throws FOStoreDatabaseException
FOStoreDatabaseException
public void setOkToReleaseDatabase(boolean ok)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |