public class SpinningSocketWriter extends AbstractHandler implements SocketWriter
connection, connectionManager, ioService
Constructor and Description |
---|
SpinningSocketWriter(TcpIpConnection connection,
MetricsRegistry metricsRegistry,
ILogger logger) |
Modifier and Type | Method and Description |
---|---|
long |
bytesPending() |
long |
getLastWriteTimeMillis()
Returns the last
Clock.currentTimeMillis() that a write to the socket completed. |
WriteHandler |
getWriteHandler()
Gets the
WriteHandler that belongs to this SocketWriter. |
void |
offer(OutboundFrame frame)
Offers a Frame to be written to the socket.
|
long |
priorityBytesPending() |
void |
setProtocol(String protocol)
Sets the protocol this SocketWriter should use.
|
void |
shutdown()
Shuts down this SocketWriter.
|
void |
start()
Starts this SocketWriter.
|
int |
totalFramesPending()
Returns the total number of packets (urgent and non normal priority) pending to be written to the socket.
|
void |
write() |
onFailure
public SpinningSocketWriter(TcpIpConnection connection, MetricsRegistry metricsRegistry, ILogger logger)
public void offer(OutboundFrame frame)
SocketWriter
offer
in interface SocketWriter
frame
- the Frame to write.public long bytesPending()
public long priorityBytesPending()
public int totalFramesPending()
SocketWriter
totalFramesPending
in interface SocketWriter
public long getLastWriteTimeMillis()
SocketWriter
Clock.currentTimeMillis()
that a write to the socket completed.
Writing to the socket doesn't mean that data has been send or received; it means that data was written to the
SocketChannel. It could very well be that this data is stuck somewhere in an io-buffer.getLastWriteTimeMillis
in interface SocketWriter
public WriteHandler getWriteHandler()
SocketWriter
WriteHandler
that belongs to this SocketWriter.
This method exists for the TextReadHandler
, but probably should be deleted.getWriteHandler
in interface SocketWriter
public void setProtocol(String protocol)
SocketWriter
Protocols
setProtocol
in interface SocketWriter
protocol
- the protocolpublic void start()
SocketWriter
start
in interface SocketWriter
SocketWriter.shutdown()
public void shutdown()
SocketWriter
shutdown
in interface SocketWriter
SocketWriter.start()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.