Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
Fix MSVC compiler warning about passing this pointer in initializer list
  • Loading branch information
sapier authored and kwolekr committed Dec 29, 2014
1 parent ab55da5 commit acb3519
Show file tree
Hide file tree
Showing 2 changed files with 28 additions and 14 deletions.
26 changes: 16 additions & 10 deletions src/connection.cpp
Expand Up @@ -1236,10 +1236,9 @@ SharedBuffer<u8> UDPPeer::addSpiltPacket(u8 channel,
/* Connection Threads */
/******************************************************************************/

ConnectionSendThread::ConnectionSendThread(Connection* parent,
unsigned int max_packet_size,
ConnectionSendThread::ConnectionSendThread( unsigned int max_packet_size,
float timeout) :
m_connection(parent),
m_connection(NULL),
m_max_packet_size(max_packet_size),
m_timeout(timeout),
m_max_commands_per_iteration(1),
Expand All @@ -1250,6 +1249,7 @@ ConnectionSendThread::ConnectionSendThread(Connection* parent,

void * ConnectionSendThread::Thread()
{
assert(m_connection != NULL);
ThreadStarted();
log_register_thread("ConnectionSend");

Expand Down Expand Up @@ -1995,14 +1995,14 @@ void ConnectionSendThread::sendAsPacket(u16 peer_id, u8 channelnum,
m_outgoing_queue.push_back(packet);
}

ConnectionReceiveThread::ConnectionReceiveThread(Connection* parent,
unsigned int max_packet_size) :
m_connection(parent)
ConnectionReceiveThread::ConnectionReceiveThread(unsigned int max_packet_size) :
m_connection(NULL)
{
}

void * ConnectionReceiveThread::Thread()
{
assert(m_connection != NULL);
ThreadStarted();
log_register_thread("ConnectionReceive");

Expand Down Expand Up @@ -2657,8 +2657,8 @@ Connection::Connection(u32 protocol_id, u32 max_packet_size, float timeout,
m_event_queue(),
m_peer_id(0),
m_protocol_id(protocol_id),
m_sendThread(this, max_packet_size, timeout),
m_receiveThread(this, max_packet_size),
m_sendThread(max_packet_size, timeout),
m_receiveThread(max_packet_size),
m_info_mutex(),
m_bc_peerhandler(0),
m_bc_receive_timeout(0),
Expand All @@ -2667,6 +2667,9 @@ Connection::Connection(u32 protocol_id, u32 max_packet_size, float timeout,
{
m_udpSocket.setTimeoutMs(5);

m_sendThread.setParent(this);
m_receiveThread.setParent(this);

m_sendThread.Start();
m_receiveThread.Start();
}
Expand All @@ -2678,8 +2681,8 @@ Connection::Connection(u32 protocol_id, u32 max_packet_size, float timeout,
m_event_queue(),
m_peer_id(0),
m_protocol_id(protocol_id),
m_sendThread(this, max_packet_size, timeout),
m_receiveThread(this, max_packet_size),
m_sendThread(max_packet_size, timeout),
m_receiveThread(max_packet_size),
m_info_mutex(),
m_bc_peerhandler(peerhandler),
m_bc_receive_timeout(0),
Expand All @@ -2689,6 +2692,9 @@ Connection::Connection(u32 protocol_id, u32 max_packet_size, float timeout,
{
m_udpSocket.setTimeoutMs(5);

m_sendThread.setParent(this);
m_receiveThread.setParent(this);

m_sendThread.Start();
m_receiveThread.Start();

Expand Down
16 changes: 12 additions & 4 deletions src/connection.h
Expand Up @@ -918,13 +918,17 @@ class ConnectionSendThread : public JThread {
public:
friend class UDPPeer;

ConnectionSendThread(Connection* parent,
unsigned int max_packet_size, float timeout);
ConnectionSendThread(unsigned int max_packet_size, float timeout);

void * Thread ();

void Trigger();

void setParent(Connection* parent) {
assert(parent != NULL);
m_connection = parent;
}

void setPeerTimeout(float peer_timeout)
{ m_timeout = peer_timeout; }

Expand Down Expand Up @@ -970,11 +974,15 @@ class ConnectionSendThread : public JThread {

class ConnectionReceiveThread : public JThread {
public:
ConnectionReceiveThread(Connection* parent,
unsigned int max_packet_size);
ConnectionReceiveThread(unsigned int max_packet_size);

void * Thread ();

void setParent(Connection* parent) {
assert(parent != NULL);
m_connection = parent;
}

private:
void receive ();

Expand Down

0 comments on commit acb3519

Please sign in to comment.