otavia
0.4.6-SNAPSHOT
DocsAPI
Generated with
Copyright (c) 2022, Yan Kun/Otavia Project
Copyright (c) 2022, Yan Kun/Otavia Project
otavia/cc.otavia/cc.otavia.core/cc.otavia.core.transport/cc.otavia.core.transport.nio/cc.otavia.core.transport.nio.channel/NioUnsafeSocketChannel

NioUnsafeSocketChannel

cc.otavia.core.transport.nio.channel.NioUnsafeSocketChannel
See theNioUnsafeSocketChannel companion object
class NioUnsafeSocketChannel(channel: AbstractChannel, ch: SocketChannel, readInterestOp: Int) extends AbstractNioUnsafeChannel[SocketChannel]

Attributes

Companion
object
Graph
Supertypes
class AbstractNioUnsafeChannel[SocketChannel]
trait ChannelState
class Object
trait Matchable
class Any
Show all

Members list

Value members

Concrete methods

override def isActive: Boolean

Return true if the UnsafeChannel is active and so connected.

Return true if the UnsafeChannel is active and so connected.

Attributes

Definition Classes
override def isOpen: Boolean

Returns true if the UnsafeChannel is open and may get active later

Returns true if the UnsafeChannel is open and may get active later

Attributes

Definition Classes
override def isShutdown(direction: ChannelShutdownDirection): Boolean

Returns true if the ChannelShutdownDirection of the UnsafeChannel was shutdown before.

Returns true if the ChannelShutdownDirection of the UnsafeChannel was shutdown before.

Value parameters

direction

shutdown direction

Attributes

Definition Classes
override def localAddress: SocketAddress

Attributes

Definition Classes
override def unsafeBind(local: SocketAddress): Unit

Bind the Channel to the SocketAddress

Bind the Channel to the SocketAddress

Value parameters

localAddress

the SocketAddress to bound to.

Attributes

Throws
Exception

when an error happens.

Definition Classes
override def unsafeConnect(remote: SocketAddress, local: Option[SocketAddress], fastOpen: Boolean): Unit

Attributes

Definition Classes
override def unsafeDisconnect(): Unit

Disconnect this Channel from its remote peer

Disconnect this Channel from its remote peer

Attributes

Throws
Exception

thrown on error.

Definition Classes
override def unsafeFlush(payload: FileRegion | RecyclablePageBuffer): Unit

Attributes

Definition Classes
override def unsafeShutdown(direction: ChannelShutdownDirection): Unit

Shutdown one direction of the Channel.

Shutdown one direction of the Channel.

Value parameters

direction

the direction to shut unsafewn.

Attributes

Throws
Exception

thrown on error.

Definition Classes

Inherited methods

protected def clearScheduledRead(): Unit

Attributes

Inherited from:
AbstractUnsafeChannel
override def closeProcessor(): Unit

Close this processor.

Close this processor.

Attributes

Definition Classes
Inherited from:
AbstractNioUnsafeChannel
override def deregisterSelector(): Unit

Deregister from previous registered Selector.

Deregister from previous registered Selector.

Attributes

Definition Classes
Inherited from:
AbstractNioUnsafeChannel
def directAllocator: PooledPageAllocator

Attributes

Inherited from:
UnsafeChannel
override protected def doClearScheduledRead(): Unit

Clear any previous scheduled read. By default, this method does nothing but implementations might override it to add extra logic.

Clear any previous scheduled read. By default, this method does nothing but implementations might override it to add extra logic.

Attributes

Definition Classes
Inherited from:
AbstractNioUnsafeChannel
def executor: ChannelsActor[_]

Attributes

Inherited from:
AbstractUnsafeChannel
final def executorAddress: ActorAddress[_]

Attributes

Inherited from:
UnsafeChannel
final protected def get(mask: Long): Boolean

Attributes

Inherited from:
CompressionBooleanLong
final def getAt(position: Int): Boolean

Attributes

Inherited from:
CompressionBooleanLong
override def handle(key: SelectionKey): Unit

Handle some IO for the given SelectionKey.

Handle some IO for the given SelectionKey.

Value parameters

key

the SelectionKey that needs to be handled.

Attributes

Definition Classes
Inherited from:
AbstractNioUnsafeChannel
def heapAllocator: PooledPageAllocator

Attributes

Inherited from:
UnsafeChannel
final protected def isAllowHalfClosure: Boolean

Attributes

Inherited from:
AbstractUnsafeChannel
def isConnected: Boolean

Attributes

Inherited from:
AbstractUnsafeChannel
protected def javaChannel: SocketChannel

Attributes

Inherited from:
AbstractNioUnsafeChannel
protected def processRead(attemptedBytesRead: Int, actualBytesRead: Int, numMessagesRead: Int): Unit

Attributes

Inherited from:
AbstractNioUnsafeChannel
def readPlanFactory: ReadPlanFactory

Attributes

Inherited from:
AbstractUnsafeChannel
override def registerSelector(selector: Selector): Unit

Register to a Selector.

Register to a Selector.

Value parameters

selector

the Selector to register to.

Attributes

Throws
ClosedChannelException

if already closed.

Definition Classes
Inherited from:
AbstractNioUnsafeChannel
final protected def set(mask: Long, value: Boolean): Unit

Attributes

Inherited from:
CompressionBooleanLong
final def setAt(position: Int, value: Boolean): Unit

Attributes

Inherited from:
CompressionBooleanLong
def setReadPlan(plan: ReadPlan): Unit

Attributes

Inherited from:
AbstractUnsafeChannel
protected def shutdownReadSide(): Unit

Attributes

Inherited from:
AbstractNioUnsafeChannel
protected def toBinaryString(): String

Attributes

Inherited from:
CompressionBooleanLong
override def unsafeClose(cause: Option[Throwable]): Unit

Close the Channel

Close the Channel

Attributes

Definition Classes
Inherited from:
AbstractNioUnsafeChannel
override def unsafeOpen(path: Path, options: Seq[OpenOption], attrs: Seq[FileAttribute[_]]): Unit

Attributes

Definition Classes
Inherited from:
AbstractNioUnsafeChannel
override def unsafeRead(readPlan: ReadPlan): Unit

Schedule a read operation.

Schedule a read operation.

Attributes

Throws
Exception

thrown on error.

Definition Classes
Inherited from:
AbstractNioUnsafeChannel

Inherited fields

protected var _selectionKey: SelectionKey

Attributes

Inherited from:
AbstractNioUnsafeChannel
protected var currentReadPlan: ReadPlan

Attributes

Inherited from:
AbstractUnsafeChannel
Generated with
Copyright (c) 2022, Yan Kun/Otavia Project
Copyright (c) 2022, Yan Kun/Otavia Project