AuroraRuntime/Include/Aurora/IO/Net/ISocketChannel.hpp

224 lines
7.4 KiB
C++
Raw Normal View History

[+] Network + Protocol + TLS - Initial Commit ============================================================================= Network ]==================================================================== ============================================================================= [+] Added (very) early Aurora::IO::Net implementation [+] AuNet::EHostnameType [+] AuNet::EIPProtocol [+] AuNet::ENetworkError [+] AuNet::ETransportProtocol [+] AuNet::INetInterface [+] AuNet::INetSrvDatagram [+] AuNet::INetSrvResolve [+] AuNet::INetSrvSockets [+] AuNet::INetSrvWorkers [+] AuNet::INetWorker [+] AuNet::IPAddress [+] AuNet::IResolver [+] AuNet::ISocket [+] AuNet::IResolver [+] AuNet::ISocketBase [+] AuNet::ISocketChannel [+] AuNet::ISocketDriver [+] AuNet::ISocketDriverFactory [+] AuNet::ISocketServer [+] AuNet::ISocketServerDriver [+] AuNet::NetEndpoint [+] AuNet::NetError [+] AuNet::NetHostname (+implementation) ============================================================================= Protocol ]=================================================================== ============================================================================= [+] IProtocolInterceptor [+] IProtocolInterceptorEx [+] IProtocolStack (+implementation) ============================================================================= TLS ]======================================================================== ============================================================================= [+] ITLSContext [+] TLSProtocolRecv [+] TLSProtocolSend (+implementation) ============================================================================= IO Bug Fixes ]=============================================================== ============================================================================= [*] IOProcessor::SubmitIOWorkItem should signal the CvEvent, forcing at least once future tick (wont optimize with if in tick & not yet dispatched work items) [*] Split IOPipeWork in into IOPipeProcessor header [+] IOPipeWork::GetBuffer (internal reallocation) [*] Harden against IAsyncTransactions without a loop source [*] Missing null `if (processor->listener)` in IOProcessor [*] Solved some soft-lock conditions under Linux's LoopQueue (added deferred commits) [*] Quick hack: IOProcessor::HasItems() should OR the early can-tick check function. ============================================================================= Other ]====================================================================== ============================================================================= [+] Linux: LSSignalCatcher [+] `static void AuResetMember(Aurora::Memory::ByteBuffer &ref)` for AuROXTL [*] Attempt to enforce a normalization and don't overwrite-readptr-under-istreamwriters policy in ByteBuffer_ReadWrite (circular buffers) [*] Bad ECC ctors ============================================================================= Known issues ]=============================================================== ============================================================================= > Linux net is nowhere near done > UDP socket emulation layer isn't implemented > Ciphersuite API is a stub > Private key API is a stub > ...therefore no TLS servers > Missing thread safety precautions under net > Net implementation is still beri early
2022-08-28 19:02:06 +00:00
/***
Copyright (C) 2022 J Reece Wilson (a/k/a "Reece"). All rights reserved.
File: ISocketChannel.hpp
Date: 2022-8-15
Author: Reece
***/
#pragma once
namespace Aurora::IO::Protocol
{
struct IProtocolStack;
}
namespace Aurora::IO::Net
{
struct ISocket;
struct ISocketChannelEventListener;
[+] Network + Protocol + TLS - Initial Commit ============================================================================= Network ]==================================================================== ============================================================================= [+] Added (very) early Aurora::IO::Net implementation [+] AuNet::EHostnameType [+] AuNet::EIPProtocol [+] AuNet::ENetworkError [+] AuNet::ETransportProtocol [+] AuNet::INetInterface [+] AuNet::INetSrvDatagram [+] AuNet::INetSrvResolve [+] AuNet::INetSrvSockets [+] AuNet::INetSrvWorkers [+] AuNet::INetWorker [+] AuNet::IPAddress [+] AuNet::IResolver [+] AuNet::ISocket [+] AuNet::IResolver [+] AuNet::ISocketBase [+] AuNet::ISocketChannel [+] AuNet::ISocketDriver [+] AuNet::ISocketDriverFactory [+] AuNet::ISocketServer [+] AuNet::ISocketServerDriver [+] AuNet::NetEndpoint [+] AuNet::NetError [+] AuNet::NetHostname (+implementation) ============================================================================= Protocol ]=================================================================== ============================================================================= [+] IProtocolInterceptor [+] IProtocolInterceptorEx [+] IProtocolStack (+implementation) ============================================================================= TLS ]======================================================================== ============================================================================= [+] ITLSContext [+] TLSProtocolRecv [+] TLSProtocolSend (+implementation) ============================================================================= IO Bug Fixes ]=============================================================== ============================================================================= [*] IOProcessor::SubmitIOWorkItem should signal the CvEvent, forcing at least once future tick (wont optimize with if in tick & not yet dispatched work items) [*] Split IOPipeWork in into IOPipeProcessor header [+] IOPipeWork::GetBuffer (internal reallocation) [*] Harden against IAsyncTransactions without a loop source [*] Missing null `if (processor->listener)` in IOProcessor [*] Solved some soft-lock conditions under Linux's LoopQueue (added deferred commits) [*] Quick hack: IOProcessor::HasItems() should OR the early can-tick check function. ============================================================================= Other ]====================================================================== ============================================================================= [+] Linux: LSSignalCatcher [+] `static void AuResetMember(Aurora::Memory::ByteBuffer &ref)` for AuROXTL [*] Attempt to enforce a normalization and don't overwrite-readptr-under-istreamwriters policy in ByteBuffer_ReadWrite (circular buffers) [*] Bad ECC ctors ============================================================================= Known issues ]=============================================================== ============================================================================= > Linux net is nowhere near done > UDP socket emulation layer isn't implemented > Ciphersuite API is a stub > Private key API is a stub > ...therefore no TLS servers > Missing thread safety precautions under net > Net implementation is still beri early
2022-08-28 19:02:06 +00:00
struct ISocketChannel : Protocol::IProtocolBaseReader, Protocol::IProtocolBaseWriter
{
/**
* @brief
* @return
*/
virtual AuSPtr<ISocket> ToParent() = 0;
/**
* @brief If not under the drivers data available tick,
* schedules the buffered data
*/
virtual void ScheduleOutOfFrameWrite() = 0;
/**
* @brief
* @return
* @warning [not recommended]
* @warning requires: SpecifyManualRead
*/
virtual AuSPtr<IAsyncTransaction> ToReadTransaction() = 0;
/**
* @brief
* @return
* @warning [not recommended]
* @warning requires: SpecifyManualWrite
*/
virtual AuSPtr<IAsyncTransaction> ToWriteTransaction() = 0;
//
// Protocol stack APIs
// [used for tls, compression, encryption, and friends]
//
/**
* @brief
* @return
*/
virtual AuSPtr<Protocol::IProtocolStack> NewProtocolRecvStack() = 0;
/**
* @brief
* @return
*/
virtual AuSPtr<Protocol::IProtocolStack> NewProtocolSendStack() = 0;
/**
* @brief
* @param pRecvProtocol
*/
virtual void SpecifyRecvProtocol(const AuSPtr<Protocol::IProtocolStack> &pRecvProtocol) = 0;
/**
* @brief
* @param pSendProtocol
*/
virtual void SpecifySendProtocol(const AuSPtr<Protocol::IProtocolStack> &pSendProtocol) = 0;
//
// The following specify functions are to be used before the socket has established / during preestablish.
// Exceptions will be noted.
//
/**
* @brief Disables usage of the ToWriteTransaction api.
* @param bEnableDirectAIOWrite when true, disables protocol handler behaviour
* and enables the ::ToWriteTransaction() routine
* @return
*/
virtual bool SpecifyManualWrite(bool bEnableDirectAIOWrite) = 0;
/**
* @brief Disables automatic pipe processing of the socket. Instead,
* you must use the ToReadTransaction to read until EoS.
* @param bEnableDirectAIOWrite when true, disables the pipe procoessor
* @return
*/
virtual bool SpecifyManualRead(bool bEnableDirectAIORead) = 0;
/**
* @brief
* @param
* @return
* @warning May only succeed after preestablish if SpecifyManualWrite was set true.
*
* Otherwise, nagle is disabled bc it is a beyond dumb optimization of an era of TTY.
* It is not unreasonable for a client and server to use a similar tick rate, with
* identical io-constraints, doing things at a similar rate, to process packets given
* shared bandwidth constraints before DoS-dropping.
* (just configure your buffer sizes correctly - perhaps in real time)
*
* Point is, any reasonably buffered protocol *wants* a flush after a frame or more has
* been written in an IO/application tick.
* If you don't, you end up waiting on the other side to send a response to a request you've
* never actually sent.
*
* As a frame of reference, NGINX, CURL, chromium, all either use nodelay by default or the
* community recommends its' usage as a default.
* https://bugzilla.mozilla.org/show_bug.cgi?id=542401
* https://curl.se/libcurl/c/CURLOPT_TCP_NODELAY.html
* https://github.com/websocket-client/websocket-client/issues/41
*/
virtual bool SpecifyTCPNoDelay(bool bFuckNagle) = 0;
/**
* @brief [...]
* @return
*/
virtual bool GetCurrentTCPNoDelay() = 0;
/**
* @brief In manual mode, you may wish to use the loop source
* interface of the IAsyncTransaction. By default, Network
* io is optimized in such a way that IO fences aren't
* required for use.
* default: false
* @param bAllocateFence
* @return
*/
virtual bool SpecifyTransactionsHaveIOFence(bool bAllocateFence) = 0;
/**
* @brief Specifies the READ-bound rate-limit per IO tick
* @param uBytes
* @param pCallbackOptional
* @return
*/
virtual bool SpecifyPerTickAsyncReadLimit(AuUInt uBytes) = 0;
/**
* @brief Reallocate both the input and output bytebuffer
* @param uBytes ...
* @param pCallbackOptional optional if on thread
* @return
* [can work after establish under the right conditions]
*/
virtual bool SpecifyBufferSize(AuUInt uBytes,
const AuSPtr<AuAsync::PromiseCallback<AuNullS, AuNullS>> &pCallbackOptional) = 0;
/**
* @brief
* @param uBytes ...
* @param pCallbackOptional optional if on thread
* @return
* @warning The size specified must not interfer with the current
* operation or state of the underlying stream.
* You cannot resize a buffer, mid-pipe, if it means dropping buffered data
* [can work after establish under the right conditions]
*/
virtual bool SpecifyInputBufferSize(AuUInt uBytes,
const AuSPtr<AuAsync::PromiseCallback<AuNullS, AuNullS>> &pCallbackOptional) = 0;
/**
* @brief [...]
* @return
*/
virtual AuUInt GetInputBufferSize() = 0;
/**
* @brief
* @param uBytes ...
* @param pCallbackOptional optional if on thread
* @return
* @warning The size specified must not interfer with the current
* operation or state of the underlying stream.
* You cannot resize a buffer, mid-pipe, if it means dropping buffered data
* [can work after establish under the right conditions]
*/
virtual bool SpecifyOutputBufferSize(AuUInt uBytes,
const AuSPtr<AuAsync::PromiseCallback<AuNullS, AuNullS>> &pCallbackOptional) = 0;
/**
* @brief [...]
* @return
*/
virtual AuUInt GetOutputBufferSize() = 0;
/**
* @brief
* @return
*/
virtual AuSPtr<ISocketStats> GetRecvStats() = 0;
/**
* @brief
* @return
*/
virtual AuSPtr<ISocketStats> GetSendStats() = 0;
/**
* @brief
* @param pListener
*/
virtual void AddEventListener(const AuSPtr<ISocketChannelEventListener> &pListener) = 0;
/**
* @brief
* @param pListener
*/
virtual void RemoveEventListener(const AuSPtr<ISocketChannelEventListener> &pListener) = 0;
AURT_ADD_USR_DATA;
[+] Network + Protocol + TLS - Initial Commit ============================================================================= Network ]==================================================================== ============================================================================= [+] Added (very) early Aurora::IO::Net implementation [+] AuNet::EHostnameType [+] AuNet::EIPProtocol [+] AuNet::ENetworkError [+] AuNet::ETransportProtocol [+] AuNet::INetInterface [+] AuNet::INetSrvDatagram [+] AuNet::INetSrvResolve [+] AuNet::INetSrvSockets [+] AuNet::INetSrvWorkers [+] AuNet::INetWorker [+] AuNet::IPAddress [+] AuNet::IResolver [+] AuNet::ISocket [+] AuNet::IResolver [+] AuNet::ISocketBase [+] AuNet::ISocketChannel [+] AuNet::ISocketDriver [+] AuNet::ISocketDriverFactory [+] AuNet::ISocketServer [+] AuNet::ISocketServerDriver [+] AuNet::NetEndpoint [+] AuNet::NetError [+] AuNet::NetHostname (+implementation) ============================================================================= Protocol ]=================================================================== ============================================================================= [+] IProtocolInterceptor [+] IProtocolInterceptorEx [+] IProtocolStack (+implementation) ============================================================================= TLS ]======================================================================== ============================================================================= [+] ITLSContext [+] TLSProtocolRecv [+] TLSProtocolSend (+implementation) ============================================================================= IO Bug Fixes ]=============================================================== ============================================================================= [*] IOProcessor::SubmitIOWorkItem should signal the CvEvent, forcing at least once future tick (wont optimize with if in tick & not yet dispatched work items) [*] Split IOPipeWork in into IOPipeProcessor header [+] IOPipeWork::GetBuffer (internal reallocation) [*] Harden against IAsyncTransactions without a loop source [*] Missing null `if (processor->listener)` in IOProcessor [*] Solved some soft-lock conditions under Linux's LoopQueue (added deferred commits) [*] Quick hack: IOProcessor::HasItems() should OR the early can-tick check function. ============================================================================= Other ]====================================================================== ============================================================================= [+] Linux: LSSignalCatcher [+] `static void AuResetMember(Aurora::Memory::ByteBuffer &ref)` for AuROXTL [*] Attempt to enforce a normalization and don't overwrite-readptr-under-istreamwriters policy in ByteBuffer_ReadWrite (circular buffers) [*] Bad ECC ctors ============================================================================= Known issues ]=============================================================== ============================================================================= > Linux net is nowhere near done > UDP socket emulation layer isn't implemented > Ciphersuite API is a stub > Private key API is a stub > ...therefore no TLS servers > Missing thread safety precautions under net > Net implementation is still beri early
2022-08-28 19:02:06 +00:00
};
}