public class NTConnection
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
private java.io.DataInputStream |
m_is |
private boolean |
m_isValid |
private java.io.DataOutputStream |
m_os |
NTSocketStream |
m_stream |
private NTEntryTypeManager |
m_typeManager |
static char |
PROTOCOL_REVISION |
private java.lang.Object |
WRITE_LOCK |
| Constructor and Description |
|---|
NTConnection(NTSocketStream stream,
NTEntryTypeManager typeManager) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
flush() |
void |
read(NTConnectionAdapter adapter) |
void |
sendClientHello() |
void |
sendEntryAssignment(NTTableEntry entry) |
void |
sendEntryUpdate(NTTableEntry entry) |
void |
sendKeepAlive() |
private void |
sendMessageHeader(int messageType) |
void |
sendProtocolVersionUnsupported() |
void |
sendServerHelloComplete() |
public static final char PROTOCOL_REVISION
private final java.lang.Object WRITE_LOCK
private final java.io.DataInputStream m_is
private final java.io.DataOutputStream m_os
public final NTSocketStream m_stream
private final NTEntryTypeManager m_typeManager
private boolean m_isValid
public NTConnection(NTSocketStream stream, NTEntryTypeManager typeManager)
public void close()
private void sendMessageHeader(int messageType)
throws java.io.IOException
java.io.IOExceptionpublic void flush()
throws java.io.IOException
java.io.IOExceptionpublic void sendKeepAlive()
throws java.io.IOException
java.io.IOExceptionpublic void sendClientHello()
throws java.io.IOException
java.io.IOExceptionpublic void sendServerHelloComplete()
throws java.io.IOException
java.io.IOExceptionpublic void sendProtocolVersionUnsupported()
throws java.io.IOException
java.io.IOExceptionpublic void sendEntryAssignment(NTTableEntry entry) throws java.io.IOException
java.io.IOExceptionpublic void sendEntryUpdate(NTTableEntry entry) throws java.io.IOException
java.io.IOExceptionpublic void read(NTConnectionAdapter adapter) throws java.io.IOException
java.io.IOException