Package | Description |
---|---|
com.serotonin.mango.rt.dataSource.persistent | |
com.serotonin.mango.rt.publish.persistent |
Constructor and Description |
---|
RangeCountHandler(Packet packet,
java.io.OutputStream out) |
Modifier and Type | Field and Description |
---|---|
(package private) java.util.List<Packet> |
PersistentSendThread.packetsToSend |
Modifier and Type | Method and Description |
---|---|
static Packet |
Packet.borrowPacket(PacketType type,
com.serotonin.util.queue.ByteQueue payload) |
static Packet |
Packet.readPacket(java.io.InputStream in,
int version) |
static Packet |
Packet.readPacketNoBlock(java.io.InputStream in,
int version) |
Modifier and Type | Method and Description |
---|---|
private static void |
Packet.readPayload(java.io.InputStream in,
Packet packet,
int length)
Data may be getting sent very regularly from the publisher, so if there is corruption in the stream an SO timeout
may not get thrown.
|
(package private) void |
SyncHandler.responseReceived(Packet packet) |
(package private) void |
PersistentSendThread.sendPacket(Packet packet) |
static void |
Packet.writePacket(java.io.OutputStream out,
int version,
Packet packet) |