data_upload.cpp 文件参考

#include <iostream>
#include <queue>
#include <thread>
#include <condition_variable>
#include "NSUKit.h"

浏览源代码.

类
class	ThreadSafeQueue< T >
struct	Deque

宏定义
#define	STREAM_WITH_TCP
#define	SocType   nsukit::NSUSoc <nsukit::SimCmdUItf, nsukit::SimCmdUItf, nsukit::SimStreamUItf>
#define	SocType   nsukit::NSUSoc <nsukit::TCPCmdUItf, nsukit::TCPCmdUItf, nsukit::TCPStreamUItf>

类型定义
typedef ThreadSafeQueue< void >	memQueue

函数
void	upload_thread (nsukit::BaseKit *_kit, Deque *q, nsuSize_t block, nsuSize_t total, std::mutex *mu)
void	write_file_thread (nsukit::BaseKit *_kit, Deque *q, nsuSize_t block, const std::string &path, std::mutex *mu)
int	main (int argc, char *argv[])

宏定义说明

SocType [1/2]

#define SocType   nsukit::NSUSoc <nsukit::SimCmdUItf, nsukit::SimCmdUItf, nsukit::SimStreamUItf>

在文件 data_upload.cpp 第 45 行定义.

SocType [2/2]

#define SocType   nsukit::NSUSoc <nsukit::TCPCmdUItf, nsukit::TCPCmdUItf, nsukit::TCPStreamUItf>

在文件 data_upload.cpp 第 45 行定义.

STREAM_WITH_TCP

#define STREAM_WITH_TCP

在文件 data_upload.cpp 第 37 行定义.

类型定义说明

memQueue

typedef ThreadSafeQueue<void> memQueue

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

函数说明

main()

int main	(	int	argc,
		char *	argv[]
	)

在文件 data_upload.cpp 第 170 行定义.

upload_thread()

void upload_thread	(	nsukit::BaseKit *	_kit,
		Deque *	q,
		nsuSize_t	block,
		nsuSize_t	total,
		std::mutex *	mu
	)

Data upstream thread retrieves data from the board at a granular level and pushes it into the full queue.

参数

_kit
q
block
total
mu

在文件 data_upload.cpp 第 100 行定义.

write_file_thread()

void write_file_thread	(	nsukit::BaseKit *	_kit,
		Deque *	q,
		nsuSize_t	block,
		const std::string &	path,
		std::mutex *	mu
	)

参数

_kit
q
block
path
mu

在文件 data_upload.cpp 第 136 行定义.