BRNSystems/minetest
1
0
Fork 0
forked from Mirrorlandia_minetest/minetest
Code Pull Requests 1 Activity

Fix MSVC compiler warning about passing this pointer in initializer list

Browse Source
This commit is contained in:
sapier 2014-08-22 19:25:21 +02:00 committed by kwolekr
parent ab55da589c
commit acb3519502
2 changed files with 28 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/connection.cpp
View File

@ -1236,10 +1236,9 @@ SharedBuffer<u8> UDPPeer::addSpiltPacket(u8 channel,
/* Connection Threads */ /* Connection Threads */
/******************************************************************************/ /******************************************************************************/
ConnectionSendThread::ConnectionSendThread(Connection* parent, ConnectionSendThread::ConnectionSendThread( unsigned int max_packet_size,
unsigned int max_packet_size,
float timeout) : float timeout) :
m_connection(parent), m_connection(NULL),
m_max_packet_size(max_packet_size), m_max_packet_size(max_packet_size),
m_timeout(timeout), m_timeout(timeout),
m_max_commands_per_iteration(1), m_max_commands_per_iteration(1),
@ -1250,6 +1249,7 @@ ConnectionSendThread::ConnectionSendThread(Connection* parent,
void * ConnectionSendThread::Thread() void * ConnectionSendThread::Thread()
{ {
assert(m_connection != NULL);
ThreadStarted(); ThreadStarted();
log_register_thread("ConnectionSend"); log_register_thread("ConnectionSend");
@ -1995,14 +1995,14 @@ void ConnectionSendThread::sendAsPacket(u16 peer_id, u8 channelnum,
m_outgoing_queue.push_back(packet); m_outgoing_queue.push_back(packet);
} }
ConnectionReceiveThread::ConnectionReceiveThread(Connection* parent, ConnectionReceiveThread::ConnectionReceiveThread(unsigned int max_packet_size) :
unsigned int max_packet_size) : m_connection(NULL)
m_connection(parent)
{ {
} }
void * ConnectionReceiveThread::Thread() void * ConnectionReceiveThread::Thread()
{ {
assert(m_connection != NULL);
ThreadStarted(); ThreadStarted();
log_register_thread("ConnectionReceive"); log_register_thread("ConnectionReceive");
@ -2657,8 +2657,8 @@ Connection::Connection(u32 protocol_id, u32 max_packet_size, float timeout,
m_event_queue(), m_event_queue(),
m_peer_id(0), m_peer_id(0),
m_protocol_id(protocol_id), m_protocol_id(protocol_id),
m_sendThread(this, max_packet_size, timeout), m_sendThread(max_packet_size, timeout),
m_receiveThread(this, max_packet_size), m_receiveThread(max_packet_size),
m_info_mutex(), m_info_mutex(),
m_bc_peerhandler(0), m_bc_peerhandler(0),
m_bc_receive_timeout(0), m_bc_receive_timeout(0),
@ -2667,6 +2667,9 @@ Connection::Connection(u32 protocol_id, u32 max_packet_size, float timeout,
{ {
m_udpSocket.setTimeoutMs(5); m_udpSocket.setTimeoutMs(5);
m_sendThread.setParent(this);
m_receiveThread.setParent(this);
m_sendThread.Start(); m_sendThread.Start();
m_receiveThread.Start(); m_receiveThread.Start();
} }
@ -2678,8 +2681,8 @@ Connection::Connection(u32 protocol_id, u32 max_packet_size, float timeout,
m_event_queue(), m_event_queue(),
m_peer_id(0), m_peer_id(0),
m_protocol_id(protocol_id), m_protocol_id(protocol_id),
m_sendThread(this, max_packet_size, timeout), m_sendThread(max_packet_size, timeout),
m_receiveThread(this, max_packet_size), m_receiveThread(max_packet_size),
m_info_mutex(), m_info_mutex(),
m_bc_peerhandler(peerhandler), m_bc_peerhandler(peerhandler),
m_bc_receive_timeout(0), m_bc_receive_timeout(0),
@ -2689,6 +2692,9 @@ Connection::Connection(u32 protocol_id, u32 max_packet_size, float timeout,
{ {
m_udpSocket.setTimeoutMs(5); m_udpSocket.setTimeoutMs(5);
m_sendThread.setParent(this);
m_receiveThread.setParent(this);
m_sendThread.Start(); m_sendThread.Start();
m_receiveThread.Start(); m_receiveThread.Start();

16
src/connection.h
View File

@ -918,13 +918,17 @@ class ConnectionSendThread : public JThread {
public: public:
friend class UDPPeer; friend class UDPPeer;
ConnectionSendThread(Connection* parent, ConnectionSendThread(unsigned int max_packet_size, float timeout);
unsigned int max_packet_size, float timeout);
void * Thread (); void * Thread ();
void Trigger(); void Trigger();
void setParent(Connection* parent) {
assert(parent != NULL);
m_connection = parent;
}
void setPeerTimeout(float peer_timeout) void setPeerTimeout(float peer_timeout)
{ m_timeout = peer_timeout; } { m_timeout = peer_timeout; }
@ -970,11 +974,15 @@ private:
class ConnectionReceiveThread : public JThread { class ConnectionReceiveThread : public JThread {
public: public:
ConnectionReceiveThread(Connection* parent, ConnectionReceiveThread(unsigned int max_packet_size);
unsigned int max_packet_size);
void * Thread (); void * Thread ();
void setParent(Connection* parent) {
assert(parent != NULL);
m_connection = parent;
}
private: private:
void receive (); void receive ();