Package: com.multiversesocial.hyperview
Class: com.multiversesocial.hyperview.HyperConnectionNode
Source: src/com/multiversesocial/hyperview/HyperConnectionNode.java
Lists for IO Vector pool List for external connections ---------------
public class HyperConnectionNode extends Linkable implements BufferConstants, HyperNodeConstants
| Declaration | Value / initializer | Description | Source |
|---|---|---|---|
byte[] buffer | No comment in source; assigned in HyperConnectionNode(), initialize(), cleanUp(); used in toString(). | ||
static final int BUFFER_SIZE | = 512 | TCP/IP minimum receive unit | |
HyperChannel channel | No comment in source; assigned in HyperConnectionNode(), initialize(). | ||
DisconnectVector disconnectVector | List for external connections | ||
ExternalConnectionNode externalConnectionNode | No comment in source; name appears in 2 other source file(s): HyperExternalConnectionHandler, MakeConnection. | ||
int inactivityTimer | No comment in source; assigned in HyperConnectionNode(), cleanUp(); used in saveNode(). | ||
int ioReturnVectorTimeout | No comment in source; assigned in HyperConnectionNode(). | ||
volatile int nodeFlags | No comment in source; assigned in HyperConnectionNode(), cleanUp(); used in saveNode(), getExceptionBits(), getNodeBits(). | ||
int number | No comment in source; assigned in HyperConnectionNode(); used in saveNode(), toString(). | ||
OutputStream outputStream | No comment in source; assigned in HyperConnectionNode(), initialize(); used in toString(). | ||
HyperConnectionHandler parentConnectionHandler | No comment in source; assigned in HyperConnectionNode(), initialize(); used in saveNode(), cleanUp(). | ||
HyperNBInputHandler parentInputHandler | No comment in source; assigned in HyperConnectionNode(), initialize(), cleanUp(); used in saveNode(), getIO(). | ||
HyperNBOutputHandler parentOutputHandler | No comment in source; assigned in HyperConnectionNode(), initialize(), cleanUp(); used in saveNode(), sendIO(). | ||
int pingNumber | No comment in source; assigned in HyperConnectionNode(), initialize(); used in saveNode(). | ||
PortNode portNode | No comment in source; name appears in 5 other source file(s): HyperConnectionHandler, PortControlPane, STDInputHandler, ServerChannelPane …. | ||
int readBlockSize | No comment in source; assigned in HyperConnectionNode(), cleanUp(); used in saveNode(). | ||
int readBytes | No comment in source; assigned in HyperConnectionNode(), cleanUp(); used in saveNode(). | ||
volatile HyperLinkedList readVectorReturnList | Lists for IO Vector pool | ||
SocketAddress remoteAddress | No comment in source; assigned in HyperConnectionNode(), initialize(); used in saveNode(), toString(). | ||
InetSocketAddress remoteInetAddress | No comment in source; assigned in initialize(); used in toString(). | ||
int securityLevel | No comment in source; assigned in HyperConnectionNode(), cleanUp(); used in saveNode(). | ||
volatile Object serverIOReadChangeClass | No comment in source; not referenced by name in this type’s methods. | ||
volatile IOReply serverIOReadClass | No comment in source; name appears in 3 other source file(s): HyperConnectionHandler, HyperDefs, PreferencesPane. | ||
volatile Object serverIOWriteChangeClass | Classes to allow the implementor to overide The default Server IORequests defined in Preferences Using "change" copies of the default class references allows Thread safe swapping on the fly without forcing synchronization when accessing the currently set IORequest | ||
volatile IOReply serverIOWriteClass | No comment in source; name appears in 2 other source file(s): HyperDefs, PreferencesPane. | ||
Socket socket | No comment in source; assigned in HyperConnectionNode(), initialize(), cleanUp(); used in saveNode(), setSocketDefaults(). | ||
SocketChannel socketChannel | No comment in source; assigned in HyperConnectionNode(), initialize(), cleanUp(); used in saveNode(), getWriteVector(), getReadVector(). | ||
Object socketChannelLock | No comment in source; assigned in initialize(), cleanUp(); used in saveNode(). | ||
StateMachine stateMachine | No comment in source; assigned in HyperConnectionNode(), initialize(); used in toString(). | ||
int timeout | No comment in source; assigned in HyperConnectionNode(), cleanUp(); used in saveNode(). | ||
int timeTillTimeout | No comment in source; assigned in HyperConnectionNode(); used in saveNode(). | ||
volatile long totalReadBytes | No comment in source; assigned in HyperConnectionNode(); used in saveNode(). | ||
volatile int totalReadVectors | No comment in source; assigned in HyperConnectionNode(), getReadVector(); used in saveNode(). | ||
volatile int totalWriteVectors | No comment in source; assigned in HyperConnectionNode(), getWriteVector(); used in saveNode(). | ||
volatile long totalWrittenBytes | No comment in source; assigned in HyperConnectionNode(); used in saveNode(). | ||
volatile HyperLinkedList writeVectorReturnList | No comment in source; assigned in HyperConnectionNode(), initialize(); used in saveNode(), returnMsg(), getWriteVector(). |
| Signature | Description | Source |
|---|---|---|
HyperConnectionNode() | 17 statement(s); calls super(). | |
HyperConnectionNode(int tNodeNumber, HyperChannel tChannel) | 24 statement(s); calls super(); creates HyperLinkedList, ServerStateMachine. | |
HyperConnectionNode(HyperConnectionHandler tHandler, int tNodeNumber, ServerSocketChannel tServerSocketChannel) | 25 statement(s); calls super(), tServerSocketChannel.accept().socket(), tServerSocketChannel.accept(), socket.setSoLinger(), sex.printStackTrace() …; creates HyperLinkedList, StateMachine. | |
HyperConnectionNode(PortNode tPortNode) | 22 statement(s); calls super(); creates HyperLinkedList, StateMachine. |
| Signature | Description | Source |
|---|---|---|
public boolean cleanUp() | 15 statement(s); calls socket.close(). | |
public byte getByte() | Returns 1. | |
public byte[] getData() | Returns new byte[1]. | |
public byte[] getData(int tLength) | Returns new byte[tLength]. | |
String getExceptionBits() | Returns "Node " + (((this.nodeFlags & HyperNodeConstants.NODE_EXCEPTION_MASK) == HyperNodeConstants.NODE_EXC. | |
public int getInt() | Returns 1. | |
public HyperNodeReadVector getIO() | 4 statement(s); calls getReadVector(), parentInputHandler.readAddList.dlStore(), parentInputHandler.readAddList.notifyAll(). | |
public void getIO(HyperLinkedList tList) | For lists of HyperNodeReadVectors() ie: queue multiple reads | |
public void getIO(HyperNodeReadVector tempReadVector) | 1 statement(s); calls parentInputHandler.readAddList.dlStore(), parentInputHandler.readAddList.notifyAll(). | |
public long getLong() | Returns 1L. | |
public String getNodeBits() | 9 statement(s); calls sb.append(), sb.toString(); creates StringBuilder. | |
HyperNodeReadVector getReadVector() | 2 statement(s); calls readVectorReturnList.dlDelete(), tHyperNodeReadVector.initialize(), readVectorReturnList.clear(), readVectorReturnList.notifyAll(); creates HyperNodeReadVector. | |
HyperNodeReadVector getReadVector(HyperChannel tChannel, IOReply tReply) | 2 statement(s); calls readVectorReturnList.dlDelete(), tHyperNodeReadVector.initialize(), readVectorReturnList.clear(), readVectorReturnList.notifyAll(); creates HyperNodeReadVector. | |
public short getShort() | Returns 1. | |
HyperNodeWriteVector getWriteVector() | 2 statement(s); calls writeVectorReturnList.dlDelete(), tHyperNodeWriteVector.initialize(), writeVectorReturnList.notifyAll(); creates HyperNodeWriteVector. | |
HyperNodeWriteVector getWriteVector(HyperChannel tChannel) | 3 statement(s); calls System.exit(), writeVectorReturnList.dlDelete(), tHyperNodeWriteVector.initialize(), writeVectorReturnList.notifyAll(); creates HyperNodeWriteVector. | |
public void initialize(int tNodeNumber, HyperChannel tChannel) | 6 statement(s). | |
public void initialize(HyperConnectionHandler tHandler, int tNodeNumber, ServerSocketChannel tServerSocketChannel) | 1 method for local servers and the other for external connections. | |
public void initialize(HyperConnectionHandler tHandler, int tNodeNumber, SocketChannel tSocketChannel) | For external connections. | |
void returnMsg(HyperNodeWriteVector tVector) | 1 statement(s); calls writeVectorReturnList.dlStore(), writeVectorReturnList.notifyAll(). | |
void returnMsg(HyperNodeReadVector tVector) | 3 statement(s); calls readVectorReturnList.dlStore(), readVectorReturnList.notifyAll(). | |
public void saveNode() | 1 statement(s); calls saveNode(). | |
public void saveNode(int tInt) | 23 statement(s); calls HyperConnectionHandler.out(), socket.toString(), remoteAddress.toString(), socketChannel.toString(), parentConnectionHandler.toString() …. | |
public int sendIO(HyperLinkedList tVectorList) | Asynchronous Send HyperNodeWriteVector list | |
public int sendIO(byte data) | 7 statement(s); calls getWriteVector(), tByteBuffer.clear(), tByteBuffer.put(), tByteBuffer.flip(), parentOutputHandler.writeAddList.dlStore() …. | |
public int sendIO(byte[] data, int tLen) | 7 statement(s); calls getWriteVector(), tWriteVector.writeBuffer.clear(), tWriteVector.writeBuffer.put(), tWriteVector.writeBuffer.limit(), tWriteVector.writeBuffer.position() …. | |
void setSocketDefaults() | 1 statement(s); calls socket.setSoTimeout(), socket.setTcpNoDelay(), socket.setSoLinger(), socket.setReuseAddress(), socket.setKeepAlive() …. | |
public void showBufferInfo(ByteBuffer tBuffer) | 6 statement(s); calls tBuffer.capacity(), tBuffer.limit(), tBuffer.position(), tBuffer.remaining(). | |
public String toString() | 11 statement(s); calls sb.append(), stateMachine.toString(), getNodeBits(), remoteAddress.toString(), remoteInetAddress.toString() …; creates StringBuilder. |
Fields: attachment, index, linkFlags, name, next, parentList, prev
Methods: inList(), setName(String)
instantiation — HyperConnectionHandler.java, line 996
996 tempNode = new HyperConnectionNode(this,masterNodeList.items, 997 (ServerSocketChannel)tNextReady);
declaration — DisconnectTimer.java, line 85
85 HyperConnectionNode tHyperConnectionNode = null;
declaration — HyperChannel.java, line 24
24 static HyperConnectionNode channelNode;