HttpMonitor Class

Ctor

True if the IBaseEndpoint requires authentication

Clients statistics

Connection information IConnectionContext

The controller instances used by this connection

Identifier for the protocol, passed into the ctor from implementing protocols

IPubSubHandler module

Reference to the IServer

Current subscriptions for this connection

IBaseTransport for the protocol

Release resources and update IServerStatistics

Makes sure that there is an instance of a specific controller. Also makes sure that security is in place. Knowing what methods the connection can call.

Determines whether the specified object is equal to the current object.

Invoke the correct RPC controller/method with the payload. Also handles return values when needed

Invoke the correct RPC controller/method with the payload. Also handles return values when needed Will execute 1 operation at the time. Other operations will wait. This will be executed when the IController or the method being invoked is decorated with the RunSynchronouslyAttribute

Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.

Flushes the IBaseTransport write stream

Creates a ControllerDelegate to use when calling the controller/method

Creates and return a DeadConnection message wrapped in a WebSocket frame

Serves as the default hash function.

Creates and returns a PINGFRAME

Gets the Type of the current instance.

True if the controllers repository has a instance of the specific BinaryKey

Setup the properties on the ClientStats object

Creates a shallow copy of the current Object.

Read loop for HTTP/WebSockets

Removes a controller instance from the Controllers repository.

Adds the data to be sent to the OutQueue

Builds a RPC frame and sends it over the IHttpTransport

Builds a RPC frame and sends it over the IHttpTransport

Builds a RPC frame and push it to the OutQueue

Send loop that reads the OutQueue

If the connection is upgraded to WebSockets this starts the heartbeeat.

Returns a string that represents the current object.

Buffer for callback-id.

Length to read from callbackId

CancellationToken used in communication

Reason CloseReason for closing the connection

Controller buffer, controller to call is within

The length to read from the controller

Cache controller since it will save time when same controller is called for each message

Last byte operation read from the IBaseTransport

Flag for knowing if the object has been disposed

Buffer for the IAM message operation

Size of the IAM message

Queue for incoming data

If true the protocol will respond with +OK messages for every valid operation. Only possible for full-duplex connections.

True if the Authenticate(IProtocol) method returned true

Cache for last controller called

Cache for the last controller called as BinaryKey

Cache for last method called

Cache for the last method called as BinaryKey

Length to read from the IBaseTransport

For blocking simultaneous access to certain areas

Method buffer, method to call is within

The length to read from the method

Information about the method to be called ControllerDelegate

Queue for outgoing data

Queue for messages published over a pub/sub pattern

Read buffer

The ReadState for the ReadLoop

The readloop will continue as long as this flag is true. When false the connection will be disposed

Size buffer

Size position (for knowing size to read from size buffer)

Topic parsed from the stream

Length of the topic

Max messages to publish before doing automatic unsubscribe

Length of unsub-count

Flag for knowing if the topic parsed is valid

Write buffer