#include <webcface/internal/client_internal.h>

Inheritance diagram for ClientData:

Collaboration diagram for ClientData:

Classes
struct	SyncData

struct	WsData

Public Member Functions
	ClientData (const SharedString &name, const SharedString &host=nullptr, int port=-1)

	ClientData (const ClientData &)=delete

ClientData &	operator= (const ClientData &)=delete

	~ClientData ()

void	close ()

bool	isSelf (const FieldBase &base) const

template<typename T >
bool	messagePushOnline (const T &obj)

template<typename T >
bool	messagePushReq (const T &obj)

template<typename T >
void	messagePushAlways (const T &obj)

void	messagePushAlways (SyncDataSnapshot &&msg)

std::string	packSyncDataFirst (const SyncDataFirst &data)

std::string	packSyncData (std::stringstream &buffer, int &len, const SyncDataSnapshot &data)

void	start ()
	通信関係のスレッドを開始する

void	join ()
	threadを待機 (close時)

void	syncImpl (bool sync, bool forever, std::optional< std::chrono::microseconds > timeout)
	recv_queueのメッセージを処理する

void	onRecv (const std::vector< std::pair< int, std::shared_ptr< void > > > &messages)
	受信時の処理

SharedString	getMemberNameFromId (unsigned int id) const

unsigned int	getMemberIdFromName (const SharedString &name) const

void	pingStatusReq ()
	ping_status_reqをtrueにしmessage_queueに投げる

Public Attributes
SharedString	self_member_name
	Client自身の名前

std::optional< unsigned int >	self_member_id

SharedString	host

int	port

bool	current_curl_connected = false

void *	current_curl_handle = nullptr

std::string	current_curl_path

std::string	current_ws_buf = ""

std::vector< char >	curl_err_buffer

std::thread	ws_thread
	websocket接続、通信するスレッド

std::atomic< bool >	closing = false

MutexProxy< WsData >	ws_data

std::atomic< bool >	auto_reconnect = true

MutexProxy< SyncData >	sync_data

SharedMutexProxy< StrMap1< bool > >	member_entry

SyncDataStore2< MutableNumVector >	value_store

SyncDataStore2< ValAdaptor >	text_store

SyncDataStore2< std::shared_ptr< FuncData >, int, true >	func_store

SyncDataStore2< std::shared_ptr< message::ViewData > >	view_store

SyncDataStore2< ImageData, message::ImageReq >	image_store

SyncDataStore2< std::shared_ptr< RobotModelData > >	robot_model_store

SyncDataStore2< std::shared_ptr< message::Canvas3DData > >	canvas3d_store

SyncDataStore2< std::shared_ptr< message::Canvas2DData > >	canvas2d_store

SyncDataStore2< std::shared_ptr< LogData > >	log_store

SyncDataStore1< std::chrono::system_clock::time_point >	sync_time_store

FuncResultStore	func_result_store

MutexProxy< StrMap1< Queue< FuncCallHandle > > >	func_listener_handlers
	listenerがfetchするの待ちの関数呼び出しをためておく

SharedMutexProxy< StrMap1< unsigned int > >	member_ids

SharedMutexProxy< std::unordered_map< unsigned int, std::string > >	member_lib_name

SharedMutexProxy< std::unordered_map< unsigned int, std::string > >	member_lib_ver

SharedMutexProxy< std::unordered_map< unsigned int, std::string > >	member_addr

std::shared_ptr< std::function< void(Member)> >	member_entry_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Member)> > > >	member_connected_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Member)> > > >	member_disconnected_event

SharedMutexProxy< StrMap2< std::shared_ptr< std::function< void(Value)> > > >	value_change_event

SharedMutexProxy< StrMap2< std::shared_ptr< std::function< void(Variant)> > > >	text_change_event

SharedMutexProxy< StrMap2< std::shared_ptr< std::function< void(Image)> > > >	image_change_event

SharedMutexProxy< StrMap2< std::shared_ptr< std::function< void(RobotModel)> > > >	robot_model_change_event

SharedMutexProxy< StrMap2< std::shared_ptr< std::function< void(View)> > > >	view_change_event

SharedMutexProxy< StrMap2< std::shared_ptr< std::function< void(Canvas3D)> > > >	canvas3d_change_event

SharedMutexProxy< StrMap2< std::shared_ptr< std::function< void(Canvas2D)> > > >	canvas2d_change_event

SharedMutexProxy< StrMap2< std::shared_ptr< std::function< void(Log)> > > >	log_append_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Member)> > > >	sync_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Member)> > > >	ping_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Value)> > > >	value_entry_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Text)> > > >	text_entry_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Func)> > > >	func_entry_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(View)> > > >	view_entry_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Image)> > > >	image_entry_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(RobotModel)> > > >	robot_model_entry_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Canvas3D)> > > >	canvas3d_entry_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Canvas2D)> > > >	canvas2d_entry_event

SharedMutexProxy< StrMap1< std::shared_ptr< std::function< void(Log)> > > >	log_entry_event

std::shared_ptr< spdlog::logger >	logger_internal

SharedMutexProxy< StrMap1< std::unique_ptr< std::streambuf > > >	logger_buf

SharedMutexProxy< StrMap1< std::unique_ptr< std::ostream > > >	logger_os

SharedMutexProxy< StrMap1< std::unique_ptr< std::wstreambuf > > >	logger_buf_w

SharedMutexProxy< StrMap1< std::unique_ptr< std::wostream > > >	logger_os_w

SharedMutexProxy< std::string >	svr_name

SharedMutexProxy< std::string >	svr_version

SharedMutexProxy< std::string >	svr_hostname

std::shared_ptr< std::unordered_map< unsigned int, int > >	ping_status

bool	ping_status_req = false

Constructor & Destructor Documentation

◆ ClientData() [1/2]

ClientData	(	const SharedString &	name,
		const SharedString &	host = `nullptr`,
		int	port = `-1`
	)

explicit

◆ ClientData() [2/2]

ClientData ( const ClientData & )

delete

◆ ~ClientData()

~ClientData ( )

Member Function Documentation

◆ close()

void close ( )

◆ getMemberIdFromName()

unsigned int getMemberIdFromName ( const SharedString & name ) const

inline

◆ getMemberNameFromId()

SharedString getMemberNameFromId ( unsigned int id ) const

inline

◆ isSelf()

bool isSelf ( const FieldBase & base ) const

inline

◆ join()

void join ( )

threadを待機 (close時)

◆ messagePushAlways() [1/2]

template<typename T >

void messagePushAlways ( const T & obj )

inline

接続中かどうかに関係なくメッセージをキューに入れる

syncで確実に送信するデータに使う。

◆ messagePushAlways() [2/2]

void messagePushAlways ( SyncDataSnapshot && msg )

inline

◆ messagePushOnline()

template<typename T >

bool messagePushOnline ( const T & obj )

inline

接続中の場合メッセージをキューに入れtrueを返し、接続していない場合なにもせずfalseを返す

Call, Pingなど

◆ messagePushReq()

template<typename T >

bool messagePushReq ( const T & obj )

inline

sync_firstが空でなければメッセージをキューに入れtrueを返し、 sync_firstが空ならなにもせずfalseを返す

Reqはsync_first時にすべて含まれるので。

◆ onRecv()

void onRecv ( const std::vector< std::pair< int, std::shared_ptr< void > > > & messages )

受信時の処理

◆ operator=()

ClientData & operator= ( const ClientData & )

delete

◆ packSyncData()

std::string packSyncData	(	std::stringstream &	buffer,
		int &	len,
		const SyncDataSnapshot &	data
	)

◆ packSyncDataFirst()

std::string packSyncDataFirst ( const SyncDataFirst & data )

◆ pingStatusReq()

void pingStatusReq ( )

ping_status_reqをtrueにしmessage_queueに投げる

◆ start()

void start ( )

通信関係のスレッドを開始する

◆ syncImpl()

void syncImpl	(	bool	sync,
		bool	forever,
		std::optional< std::chrono::microseconds >	timeout
	)

recv_queueのメッセージを処理する

メッセージがなければtimeout後にreturn
auto_reconnectがfalseで接続できてない場合はreturn (deadlock回避)
timeoutがnulloptならclosingまで永遠にreturnしない

Member Data Documentation

◆ auto_reconnect

std::atomic<bool> auto_reconnect = true

ただの設定フラグなのでmutexやcondとは無関係

◆ canvas2d_change_event

SharedMutexProxy<StrMap2<std::shared_ptr<std::function<void(Canvas2D)> > > > canvas2d_change_event

◆ canvas2d_entry_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Canvas2D)> > > > canvas2d_entry_event

◆ canvas2d_store

SyncDataStore2<std::shared_ptr<message::Canvas2DData> > canvas2d_store

◆ canvas3d_change_event

SharedMutexProxy<StrMap2<std::shared_ptr<std::function<void(Canvas3D)> > > > canvas3d_change_event

◆ canvas3d_entry_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Canvas3D)> > > > canvas3d_entry_event

◆ canvas3d_store

SyncDataStore2<std::shared_ptr<message::Canvas3DData> > canvas3d_store

◆ closing

std::atomic<bool> closing = false

      \brief recv_queueのメッセージを処理するスレッド

      auto_recv がtrueの場合のみ。

     &zwj;/

std::thread sync_thread;

struct SyncDataSnapshot {
    std::chrono::system_clock::time_point time;
    StrMap1<MutableNumVector> value_data;
    StrMap1<ValAdaptor> text_data;
    StrMap1<std::shared_ptr<RobotModelData>> robot_model_data;
    StrMap1<std::shared_ptr<message::ViewData>> view_prev, view_data;
    StrMap1<std::shared_ptr<message::Canvas3DData>> canvas3d_prev,
        canvas3d_data;
    StrMap1<std::shared_ptr<message::Canvas2DData>> canvas2d_prev,
        canvas2d_data;
    StrMap1<ImageData> image_data;
    StrMap1<std::vector<LogLineData>> log_data;
    StrMap1<std::shared_ptr<FuncData>> func_data;
};

struct SyncDataFirst {
    StrMap2<unsigned int> value_req, text_req, robot_model_req, view_req,
        canvas3d_req, canvas2d_req, image_req, log_req;
    StrMap2<message::ImageReq> image_req_info;
    bool ping_status_req;
    SyncDataSnapshot sync_data;
};

/*!
   close()が呼ばれたらtrue、すべてのスレッドは停止する

◆ curl_err_buffer

std::vector<char> curl_err_buffer

◆ current_curl_connected

bool current_curl_connected = false

◆ current_curl_handle

void* current_curl_handle = nullptr

◆ current_curl_path

std::string current_curl_path

◆ current_ws_buf

std::string current_ws_buf = ""

◆ func_entry_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Func)> > > > func_entry_event

◆ func_listener_handlers

MutexProxy<StrMap1<Queue<FuncCallHandle> > > func_listener_handlers

listenerがfetchするの待ちの関数呼び出しをためておく

◆ func_result_store

FuncResultStore func_result_store

◆ func_store

SyncDataStore2<std::shared_ptr<FuncData>, int, true> func_store

◆ host

SharedString host

◆ image_change_event

SharedMutexProxy<StrMap2<std::shared_ptr<std::function<void(Image)> > > > image_change_event

◆ image_entry_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Image)> > > > image_entry_event

◆ image_store

SyncDataStore2<ImageData, message::ImageReq> image_store

◆ log_append_event

SharedMutexProxy<StrMap2<std::shared_ptr<std::function<void(Log)> > > > log_append_event

◆ log_entry_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Log)> > > > log_entry_event

◆ log_store

SyncDataStore2<std::shared_ptr<LogData> > log_store

◆ logger_buf

SharedMutexProxy<StrMap1<std::unique_ptr<std::streambuf> > > logger_buf

◆ logger_buf_w

SharedMutexProxy<StrMap1<std::unique_ptr<std::wstreambuf> > > logger_buf_w

◆ logger_internal

std::shared_ptr<spdlog::logger> logger_internal

◆ logger_os

SharedMutexProxy<StrMap1<std::unique_ptr<std::ostream> > > logger_os

◆ logger_os_w

SharedMutexProxy<StrMap1<std::unique_ptr<std::wostream> > > logger_os_w

◆ member_addr

SharedMutexProxy<std::unordered_map<unsigned int, std::string> > member_addr

◆ member_connected_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Member)> > > > member_connected_event

自身に対するonConnectイベントもここに入れる (member_entry とは扱いが異なる)

◆ member_disconnected_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Member)> > > > member_disconnected_event

◆ member_entry

SharedMutexProxy<StrMap1<bool> > member_entry

存在するメンバーのリスト

(ver2.9〜) 値は接続中true,切断後false
自身の接続状態はここに含まない

◆ member_entry_event

std::shared_ptr<std::function<void(Member)> > member_entry_event

各種イベントはコールバックを登録しようとした時(EventTargetの初期化時) にはじめて初期化する。

なのでmapになっていないmember_entry_eventもnullの可能性がある

◆ member_ids

SharedMutexProxy<StrMap1<unsigned int> > member_ids

◆ member_lib_name

SharedMutexProxy<std::unordered_map<unsigned int, std::string> > member_lib_name

◆ member_lib_ver

SharedMutexProxy<std::unordered_map<unsigned int, std::string> > member_lib_ver

◆ ping_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Member)> > > > ping_event

◆ ping_status

std::shared_ptr<std::unordered_map<unsigned int, int> > ping_status

Initial value:

=

nullptr

◆ ping_status_req

bool ping_status_req = false

◆ port

int port

◆ robot_model_change_event

SharedMutexProxy<StrMap2<std::shared_ptr<std::function<void(RobotModel)> > > > robot_model_change_event

◆ robot_model_entry_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(RobotModel)> > > > robot_model_entry_event

◆ robot_model_store

SyncDataStore2<std::shared_ptr<RobotModelData> > robot_model_store

◆ self_member_id

std::optional<unsigned int> self_member_id

◆ self_member_name

SharedString self_member_name

Client自身の名前

◆ svr_hostname

SharedMutexProxy<std::string> svr_hostname

◆ svr_name

SharedMutexProxy<std::string> svr_name

◆ svr_version

SharedMutexProxy<std::string> svr_version

◆ sync_data

MutexProxy<SyncData> sync_data

◆ sync_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Member)> > > > sync_event

◆ sync_time_store

SyncDataStore1<std::chrono::system_clock::time_point> sync_time_store

◆ text_change_event

SharedMutexProxy<StrMap2<std::shared_ptr<std::function<void(Variant)> > > > text_change_event

◆ text_entry_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Text)> > > > text_entry_event

◆ text_store

SyncDataStore2<ValAdaptor> text_store

◆ value_change_event

SharedMutexProxy<StrMap2<std::shared_ptr<std::function<void(Value)> > > > value_change_event

◆ value_entry_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(Value)> > > > value_entry_event

◆ value_store

SyncDataStore2<MutableNumVector> value_store

◆ view_change_event

SharedMutexProxy<StrMap2<std::shared_ptr<std::function<void(View)> > > > view_change_event

◆ view_entry_event

SharedMutexProxy<StrMap1<std::shared_ptr<std::function<void(View)> > > > view_entry_event

◆ view_store

SyncDataStore2<std::shared_ptr<message::ViewData> > view_store

◆ ws_data

MutexProxy<WsData> ws_data

◆ ws_thread

std::thread ws_thread

websocket接続、通信するスレッド

未接続状態で do_ws_initがtrue (= start()が呼ばれた) or auto_reconnectがtrueのとき、再接続を行う
接続状態のとき、100usごとに受信したデータを recv_queue に入れ、 sync_queue 内のデータを送信する

The documentation for this struct was generated from the following files:

client/include/webcface/internal/client_internal.h
client/src/client_msg_recv.cc
client/src/client_msg_sync.cc
client/src/client_threading.cc

Classes

Public Member Functions

Public Attributes

Constructor & Destructor Documentation

◆ ClientData() [1/2]

◆ ClientData() [2/2]

◆ ~ClientData()

Member Function Documentation

◆ close()

◆ getMemberIdFromName()

◆ getMemberNameFromId()

◆ isSelf()

◆ join()

◆ messagePushAlways() [1/2]

◆ messagePushAlways() [2/2]

◆ messagePushOnline()

◆ messagePushReq()

◆ onRecv()

◆ operator=()

◆ packSyncData()

◆ packSyncDataFirst()

◆ pingStatusReq()

◆ start()

◆ syncImpl()

Member Data Documentation

◆ auto_reconnect

◆ canvas2d_change_event

◆ canvas2d_entry_event

◆ canvas2d_store

◆ canvas3d_change_event

◆ canvas3d_entry_event

◆ canvas3d_store

◆ closing

◆ curl_err_buffer

◆ current_curl_connected

◆ current_curl_handle

◆ current_curl_path

◆ current_ws_buf

◆ func_entry_event

◆ func_listener_handlers

◆ func_result_store

◆ func_store

◆ host

◆ image_change_event

◆ image_entry_event

◆ image_store

◆ log_append_event

◆ log_entry_event

◆ log_store

◆ logger_buf

◆ logger_buf_w

◆ logger_internal

◆ logger_os

◆ logger_os_w

◆ member_addr

◆ member_connected_event

◆ member_disconnected_event

◆ member_entry

◆ member_entry_event

◆ member_ids

◆ member_lib_name

◆ member_lib_ver

◆ ping_event

◆ ping_status

◆ ping_status_req

◆ port

◆ robot_model_change_event

◆ robot_model_entry_event

◆ robot_model_store

◆ self_member_id

◆ self_member_name

◆ svr_hostname

◆ svr_name

◆ svr_version

◆ sync_data

◆ sync_event

◆ sync_time_store

◆ text_change_event

◆ text_entry_event

◆ text_store