nsukit::TCPStreamUItf类 参考

#include <tcp_interface.h>

类 nsukit::TCPStreamUItf 继承关系图:

类
struct	Memory

Public 成员函数
	TCPStreamUItf ()=default
	~TCPStreamUItf () override
nsukitStatus_t	accept (nsuInitParam_t *param) override
nsukitStatus_t	close () override
nsukitStatus_t	set_timeout (float s) override
nsuMemory_p	alloc_buffer (nsuStreamLen_t length, nsuVoidBuf_p buf=nullptr) override
nsukitStatus_t	free_buffer (nsuMemory_p fd) override
nsuVoidBuf_p	get_buffer (nsuMemory_p fd, nsuStreamLen_t length) override
nsukitStatus_t	open_send (nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset=0) override
nsukitStatus_t	open_recv (nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset=0) override
nsukitStatus_t	wait_stream (nsuMemory_p fd, float timeout=1.) override
nsukitStatus_t	break_stream (nsuMemory_p fd) override
nsukitStatus_t	stream_recv (nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset=0, bool(*stop_event)()=nullptr, float timeout=5., int flag=1) override
nsukitStatus_t	stream_send (nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset=0, bool(*stop_event)()=nullptr, float timeout=5., int flag=1) override
virtual nsuMemory_p	alloc_buffer (nsuStreamLen_t length, nsuVoidBuf_p buf=nullptr)
virtual nsukitStatus_t	free_buffer (nsuMemory_p fd)
virtual nsuVoidBuf_p	get_buffer (nsuMemory_p fd, nsuStreamLen_t length)
virtual nsukitStatus_t	open_send (nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset=0)
virtual nsukitStatus_t	open_recv (nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset=0)
virtual nsukitStatus_t	wait_stream (nsuMemory_p fd, float timeout=1.)
virtual nsukitStatus_t	break_stream (nsuMemory_p fd)
virtual nsukitStatus_t	stream_recv (nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset=0, bool(*stop_event)()=nullptr, float timeout=5., int flag=1)
virtual nsukitStatus_t	stream_send (nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset=0, bool(*stop_event)()=nullptr, float timeout=5., int flag=1)
Public 成员函数 继承自 nsukit::U_Interface
virtual	~U_Interface ()=default
virtual nsukitStatus_t	accept (nsuInitParam_t *param)
virtual nsukitStatus_t	close ()
virtual nsukitStatus_t	set_timeout (float s)

静态 Protected 成员函数
static void	_recv (SocketGenerator *sock, ThreadSafeEvent *stop_event, Memory *mem, uint32_t block, nsuStreamLen_t length, nsuStreamLen_t offset=0)

Protected 属性
SocketGenerator	sockGen {5002, "127.0.0.1", false}
float	tcpTimeout = 0.
std::string	ipAddr = "127.0.0.1"
uint16_t	tcpPort = 5002
uint32_t	block_size = 4 * 1024 * 1024
ThreadSafeEvent	stop_event
std::mutex	opLock
std::thread	upload_thread
std::thread	download_thread
std::map< unsigned int, Memory * >	memory_dict {}
unsigned int	memory_index = 0

详细描述

在文件 tcp_interface.h 第 87 行定义.

构造及析构函数说明

TCPStreamUItf()

nsukit::TCPStreamUItf::TCPStreamUItf ( )

default

~TCPStreamUItf()

TCPStreamUItf::~TCPStreamUItf ( )

override

在文件 tcp_interface.cpp 第 96 行定义.

成员函数说明

_recv()

void TCPStreamUItf::_recv ( SocketGenerator *  sock, ThreadSafeEvent *  stop_event, Memory *  mem, uint32_t  block, nsuStreamLen_t  length, nsuStreamLen_t  offset = 0  )

staticprotected

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

accept()

nsukitStatus_t TCPStreamUItf::accept ( nsuInitParam_t *  param )

overridevirtual

参数

param

返回

重载 nsukit::U_Interface .

在文件 tcp_interface.cpp 第 111 行定义.

alloc_buffer()

nsuMemory_p TCPStreamUItf::alloc_buffer ( nsuStreamLen_t  length, nsuVoidBuf_p  buf = nullptr  )

overridevirtual

参数

length
buf

返回

重载 nsukit::I_BaseStreamUItf .

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

break_stream()

nsukitStatus_t TCPStreamUItf::break_stream ( nsuMemory_p  fd )

overridevirtual

参数

fd

返回

重载 nsukit::I_BaseStreamUItf .

在文件 tcp_interface.cpp 第 267 行定义.

close()

nsukitStatus_t TCPStreamUItf::close ( )

overridevirtual

返回

重载 nsukit::U_Interface .

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

free_buffer()

nsukitStatus_t TCPStreamUItf::free_buffer ( nsuMemory_p  fd )

overridevirtual

参数

fd

返回

重载 nsukit::I_BaseStreamUItf .

在文件 tcp_interface.cpp 第 168 行定义.

get_buffer()

nsuVoidBuf_p TCPStreamUItf::get_buffer ( nsuMemory_p  fd, nsuStreamLen_t  length  )

overridevirtual

参数

fd
length

返回

重载 nsukit::I_BaseStreamUItf .

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

open_recv()

nsukitStatus_t TCPStreamUItf::open_recv ( nsuChnlNum_t  chnl, nsuMemory_p  fd, nsuStreamLen_t  length, nsuStreamLen_t  offset = 0  )

overridevirtual

参数

chnl
fd
length
offset

返回

重载 nsukit::I_BaseStreamUItf .

在文件 tcp_interface.cpp 第 188 行定义.

open_send()

nsukitStatus_t TCPStreamUItf::open_send ( nsuChnlNum_t  chnl, nsuMemory_p  fd, nsuStreamLen_t  length, nsuStreamLen_t  offset = 0  )

overridevirtual

参数

chnl
fd
length
offset

返回

重载 nsukit::I_BaseStreamUItf .

在文件 tcp_interface.cpp 第 289 行定义.

set_timeout()

nsukitStatus_t TCPStreamUItf::set_timeout ( float  s )

overridevirtual

参数

s

返回

重载 nsukit::U_Interface .

在文件 tcp_interface.cpp 第 141 行定义.

stream_recv()

nsukitStatus_t TCPStreamUItf::stream_recv ( nsuChnlNum_t  chnl, nsuMemory_p  fd, nsuStreamLen_t  length, nsuStreamLen_t  offset = 0, bool(*)()  stop_event = nullptr, float  timeout = 5., int  flag = 1  )

overridevirtual

参数

chnl
fd
length
offset
stop_event
timeout
flag

返回

重载 nsukit::I_BaseStreamUItf .

在文件 tcp_interface.cpp 第 276 行定义.

stream_send()

nsukitStatus_t TCPStreamUItf::stream_send ( nsuChnlNum_t  chnl, nsuMemory_p  fd, nsuStreamLen_t  length, nsuStreamLen_t  offset = 0, bool(*)()  stop_event = nullptr, float  timeout = 5., int  flag = 1  )

overridevirtual

参数

chnl
fd
length
offset
stop_event
timeout
flag

返回

重载 nsukit::I_BaseStreamUItf .

在文件 tcp_interface.cpp 第 295 行定义.

wait_stream()

nsukitStatus_t TCPStreamUItf::wait_stream ( nsuMemory_p  fd, float  timeout = 1.  )

overridevirtual

参数

fd
timeout

返回

重载 nsukit::I_BaseStreamUItf .

在文件 tcp_interface.cpp 第 248 行定义.

类成员变量说明

block_size

uint32_t nsukit::TCPStreamUItf::block_size = 4 * 1024 * 1024

protected

在文件 tcp_interface.h 第 106 行定义.

download_thread

std::thread nsukit::TCPStreamUItf::download_thread

protected

在文件 tcp_interface.h 第 111 行定义.

ipAddr

std::string nsukit::TCPStreamUItf::ipAddr = "127.0.0.1"

protected

在文件 tcp_interface.h 第 104 行定义.

memory_dict

std::map<unsigned int, Memory *> nsukit::TCPStreamUItf::memory_dict {}

protected

在文件 tcp_interface.h 第 113 行定义.

memory_index

unsigned int nsukit::TCPStreamUItf::memory_index = 0

protected

在文件 tcp_interface.h 第 114 行定义.

opLock

std::mutex nsukit::TCPStreamUItf::opLock

protected

在文件 tcp_interface.h 第 109 行定义.

sockGen

SocketGenerator nsukit::TCPStreamUItf::sockGen {5002, "127.0.0.1", false}

protected

在文件 tcp_interface.h 第 101 行定义.

stop_event

ThreadSafeEvent nsukit::TCPStreamUItf::stop_event

protected

在文件 tcp_interface.h 第 108 行定义.

tcpPort

uint16_t nsukit::TCPStreamUItf::tcpPort = 5002

protected

在文件 tcp_interface.h 第 105 行定义.

tcpTimeout

float nsukit::TCPStreamUItf::tcpTimeout = 0.

protected

在文件 tcp_interface.h 第 103 行定义.

upload_thread

std::thread nsukit::TCPStreamUItf::upload_thread

protected

在文件 tcp_interface.h 第 110 行定义.

---

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

• D:/Work/CppProject/NSUKit/include/interface/tcp_interface.h
• D:/Work/CppProject/NSUKit/src/interface/tcp_interface.cpp