Network module: TCP/UDP/HTTP factories, background worker, and completion event plumbing. Script: net <- eve.Network(); 更多...

#include <Network.h>

类 eve::network::Network 继承关系图:

Public 成员函数
	Module_REG (Network)

	Network ()

	~Network () override

TcpSocket *	newTcp ()
	Creates a new TCP socket (client or server).

UdpSocket *	newUdp ()
	Creates a new UDP socket.

HttpRequest *	newHttp (std::string method, std::string url)
	Creates a new HTTP request (method e.g. "GET"/"POST", full URL).

Channel *	newChannel (TcpSocket *socket)
	Creates a length-prefixed Channel over a TCP socket.

Session *	newSession ()
	Creates a named-channel session container.

NetWriter *	newWriter ()
	Creates a streaming byte writer.

NetReader *	newReader (std::string bytes)
	Creates a streaming byte reader over a string buffer.

UdpLink *	newUdpLink (UdpSocket *socket)
	Creates a framed UDP link over a socket.

NetRpc *	newRpc (UdpLink *link)
	Creates an RPC client over a UDP link.

NetHost *	newHost ()
	Creates a UDP host (peer discovery / broadcast).

void	setTimeout (int ms)
	Default socket/HTTP timeout in milliseconds.

int	getTimeout () const

void	setVerifySsl (bool verify)
	Whether TLS peer certificates are verified (default true).

bool	getVerifySsl () const

void	pump ()
	Drains worker completions and emits them as events; call per frame.

void	post (NetCompletion c)
	Posts a completion to the worker queue (thread-safe).

void	drainForTest (std::vector< NetCompletion > &out)
	Test helper: drains pending completions into out.

NetWorker *	worker () const
	Background worker thread handle (advanced).

void	watchTcp (TcpSocket *sock)
	Internal: register/unregister sockets for pump polling.

void	unwatchTcp (TcpSocket *sock)

void	watchUdp (UdpSocket *sock)

void	unwatchUdp (UdpSocket *sock)

void	pollSockets ()
	Internal: polls watched sockets; called from the NetWorker thread.

void	bindChannel (TcpSocket sock, Channel ch)
	Internal: bind a Channel to its socket (and reverse lookup).

void	unbindChannel (TcpSocket *sock)

Channel *	channelFor (TcpSocket *sock) const

void	bindUdpLink (UdpSocket sock, UdpLink link)

void	unbindUdpLink (UdpSocket *sock)

void	bindUdpHost (UdpSocket sock, NetHost host)

void	unbindUdpHost (UdpSocket *sock)

Public 成员函数继承自 eve::Module
virtual	~Module ()

virtual std::string	getName () const =0

详细描述

Network module: TCP/UDP/HTTP factories, background worker, and completion event plumbing. Script: net <- eve.Network();

在文件 Network.h 第 30 行定义.

构造及析构函数说明

◆ Network()

eve::network::Network::Network ( )

在文件 Network.cpp 第 77 行定义.

◆ ~Network()

eve::network::Network::~Network ( )

override

在文件 Network.cpp 第 82 行定义.

成员函数说明

◆ bindChannel()

void eve::network::Network::bindChannel	(	TcpSocket *	sock,
		Channel *	ch
	)

Internal: bind a Channel to its socket (and reverse lookup).

在文件 Network.cpp 第 197 行定义.

被这些函数引用 newChannel().

◆ bindUdpHost()

void eve::network::Network::bindUdpHost	(	UdpSocket *	sock,
		NetHost *	host
	)

在文件 Network.cpp 第 143 行定义.

被这些函数引用 eve::network::NetHost::start().

◆ bindUdpLink()

void eve::network::Network::bindUdpLink	(	UdpSocket *	sock,
		UdpLink *	link
	)

在文件 Network.cpp 第 135 行定义.

被这些函数引用 newUdpLink().

◆ channelFor()

Channel * eve::network::Network::channelFor ( TcpSocket * sock ) const

在文件 Network.cpp 第 207 行定义.

◆ drainForTest()

void eve::network::Network::drainForTest ( std::vector< NetCompletion > & out )

Test helper: drains pending completions into out.

在文件 Network.cpp 第 171 行定义.

◆ getTimeout()

int eve::network::Network::getTimeout ( ) const

在文件 Network.cpp 第 155 行定义.

被这些函数引用 eve::network::HttpRequest::submit().

◆ getVerifySsl()

bool eve::network::Network::getVerifySsl ( ) const

在文件 Network.cpp 第 163 行定义.

被这些函数引用 eve::network::HttpRequest::submit().

◆ Module_REG()

eve::network::Network::Module_REG ( Network )

◆ newChannel()

Channel * eve::network::Network::newChannel ( TcpSocket * socket )

Creates a length-prefixed Channel over a TCP socket.

在文件 Network.cpp 第 99 行定义.

引用了 bindChannel().

◆ newHost()

NetHost * eve::network::Network::newHost ( )

Creates a UDP host (peer discovery / broadcast).

在文件 Network.cpp 第 131 行定义.

◆ newHttp()

HttpRequest * eve::network::Network::newHttp	(	std::string	method,
		std::string	url
	)

Creates a new HTTP request (method e.g. "GET"/"POST", full URL).

在文件 Network.cpp 第 95 行定义.

◆ newReader()

NetReader * eve::network::Network::newReader ( std::string bytes )

Creates a streaming byte reader over a string buffer.

在文件 Network.cpp 第 114 行定义.

◆ newRpc()

NetRpc * eve::network::Network::newRpc ( UdpLink * link )

Creates an RPC client over a UDP link.

在文件 Network.cpp 第 127 行定义.

◆ newSession()

Session * eve::network::Network::newSession ( )

Creates a named-channel session container.

在文件 Network.cpp 第 106 行定义.

◆ newTcp()

TcpSocket * eve::network::Network::newTcp ( )

Creates a new TCP socket (client or server).

在文件 Network.cpp 第 87 行定义.

◆ newUdp()

UdpSocket * eve::network::Network::newUdp ( )

Creates a new UDP socket.

在文件 Network.cpp 第 91 行定义.

被这些函数引用 eve::network::NetHost::start().

◆ newUdpLink()

UdpLink * eve::network::Network::newUdpLink ( UdpSocket * socket )

Creates a framed UDP link over a socket.

在文件 Network.cpp 第 120 行定义.

引用了 bindUdpLink().

◆ newWriter()

NetWriter * eve::network::Network::newWriter ( )

Creates a streaming byte writer.

在文件 Network.cpp 第 110 行定义.

◆ pollSockets()

void eve::network::Network::pollSockets ( )

Internal: polls watched sockets; called from the NetWorker thread.

在文件 Network.cpp 第 213 行定义.

引用了 c, eve::network::Conn, eve::network::Data, eve::network::Err, eve::network::TcpSocket::getPeer(), n, post(), eve::network::TcpSocket::pushAccepted(), eve::network::Tcp, eve::network::NetCompletion::type, eve::network::Udp, unwatchTcp() , 以及 watchTcp().

◆ post()

void eve::network::Network::post ( NetCompletion c )

Posts a completion to the worker queue (thread-safe).

在文件 Network.cpp 第 167 行定义.

引用了 c.

被这些函数引用 eve::network::UdpSocket::bind(), eve::network::UdpSocket::connect(), eve::network::TcpSocket::flushSend(), eve::network::TcpSocket::listen(), pollSockets(), eve::network::TcpSocket::queueSend() , 以及 eve::network::Channel::sendMsg().

◆ pump()

void eve::network::Network::pump ( )

Drains worker completions and emits them as events; call per frame.

在文件 Network.cpp 第 363 行定义.

引用了 c, eve::network::Data , 以及 eve::network::Udp.

◆ setTimeout()

void eve::network::Network::setTimeout ( int ms )

Default socket/HTTP timeout in milliseconds.

在文件 Network.cpp 第 151 行定义.

◆ setVerifySsl()

void eve::network::Network::setVerifySsl ( bool verify )

Whether TLS peer certificates are verified (default true).

在文件 Network.cpp 第 159 行定义.

◆ unbindChannel()

void eve::network::Network::unbindChannel ( TcpSocket * sock )

在文件 Network.cpp 第 202 行定义.

被这些函数引用 eve::network::Channel::~Channel().

◆ unbindUdpHost()

void eve::network::Network::unbindUdpHost ( UdpSocket * sock )

在文件 Network.cpp 第 147 行定义.

被这些函数引用 eve::network::NetHost::~NetHost().

◆ unbindUdpLink()

void eve::network::Network::unbindUdpLink ( UdpSocket * sock )

在文件 Network.cpp 第 139 行定义.

◆ unwatchTcp()

void eve::network::Network::unwatchTcp ( TcpSocket * sock )

在文件 Network.cpp 第 181 行定义.

被这些函数引用 eve::network::TcpSocket::close() , 以及 pollSockets().

◆ unwatchUdp()

void eve::network::Network::unwatchUdp ( UdpSocket * sock )

在文件 Network.cpp 第 192 行定义.

被这些函数引用 eve::network::UdpSocket::close().

◆ watchTcp()

void eve::network::Network::watchTcp ( TcpSocket * sock )

Internal: register/unregister sockets for pump polling.

在文件 Network.cpp 第 175 行定义.

被这些函数引用 eve::network::TcpSocket::listen() , 以及 pollSockets().

◆ watchUdp()

void eve::network::Network::watchUdp ( UdpSocket * sock )

在文件 Network.cpp 第 186 行定义.

被这些函数引用 eve::network::UdpSocket::bind() , 以及 eve::network::UdpSocket::connect().

◆ worker()

NetWorker * eve::network::Network::worker ( ) const

inline

Background worker thread handle (advanced).

在文件 Network.h 第 73 行定义.

被这些函数引用 eve::network::TcpSocket::connect(), eve::network::UdpSocket::send() , 以及 eve::network::UdpSocket::sendTo().

该类的文档由以下文件生成:

src/modules/network/Network.h
src/modules/network/Network.cpp

Public 成员函数