mirror of
https://github.com/AskDavis/Casinotest.git
synced 2026-01-06 21:09:48 -08:00
fixed struct initialisations
This commit is contained in:
@@ -71,9 +71,9 @@ void StartWalletServerThread()
|
|||||||
// start the client, (by connecting to the STOMP server)
|
// start the client, (by connecting to the STOMP server)
|
||||||
walletServer.stomp_client->start();
|
walletServer.stomp_client->start();
|
||||||
// subscribe to server in queues
|
// subscribe to server in queues
|
||||||
walletServer.stomp_client->subscribe(WalletServer::server_in_queue, (STOMP::pfnOnStompMessage_t) &walletServer.in_queue_callback);
|
walletServer.stomp_client->subscribe(WalletServer::server_in_queue, (STOMP::pfnOnStompMessage_t) &WalletServer::in_queue_callback);
|
||||||
// connect to NotifyStartNewWalletServerSession signal
|
// connect to NotifyStartNewWalletServerSession signal
|
||||||
walletServer.NotifyStartNewWalletServerSession.connect(boost::bind(&walletServer.NotifySessionCreated, &walletServer, _1, _2));
|
walletServer.NotifyStartNewWalletServerSession.connect(boost::bind(&WalletServer::NotifySessionCreated, &walletServer, _1, _2));
|
||||||
// connect to NotifyBlocksChanged signal
|
// connect to NotifyBlocksChanged signal
|
||||||
uiInterface.NotifyBlocksChanged.connect(boost::bind(&WalletServer::NotifyBlocksChanged, &walletServer));
|
uiInterface.NotifyBlocksChanged.connect(boost::bind(&WalletServer::NotifyBlocksChanged, &walletServer));
|
||||||
}
|
}
|
||||||
@@ -98,7 +98,7 @@ void StopWalletServerThread()
|
|||||||
// remove sessions
|
// remove sessions
|
||||||
sessions.clear();
|
sessions.clear();
|
||||||
// Interupt all WalletServerSession threads
|
// Interupt all WalletServerSession threads
|
||||||
printf("StopWalletServerThread - Session Threads: %i\n", walletServerSessionsTG.size());
|
printf("StopWalletServerThread - Session Threads: %lu\n", walletServerSessionsTG.size());
|
||||||
printf("StopWalletServerThread - Interrupt All\n");
|
printf("StopWalletServerThread - Interrupt All\n");
|
||||||
walletServerSessionsTG.interrupt_all();
|
walletServerSessionsTG.interrupt_all();
|
||||||
// Join all WalletServerSessions to wait for their completion
|
// Join all WalletServerSessions to wait for their completion
|
||||||
|
|||||||
@@ -59,7 +59,7 @@ class WalletServerSession
|
|||||||
// start the client, (by connecting to the STOMP server)
|
// start the client, (by connecting to the STOMP server)
|
||||||
session_stomp_client->start();
|
session_stomp_client->start();
|
||||||
// connect to Signals
|
// connect to Signals
|
||||||
uiInterface.NotifyBlocksChanged.connect(boost::bind(&NotifyBlocksChanged, this));
|
uiInterface.NotifyBlocksChanged.connect(boost::bind(&WalletServerSession::NotifyBlocksChanged, this));
|
||||||
printf("WalletServerSession - Start Dequeue for session: %s\n", sessionId.c_str());
|
printf("WalletServerSession - Start Dequeue for session: %s\n", sessionId.c_str());
|
||||||
while (true)
|
while (true)
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user