Commit 3897860d authored by Pavel Vainerman's avatar Pavel Vainerman

(UNet): убрал лишнее неиспользуемое поле iotype,

небольшие правки в инициализации
parent 6141adc3
...@@ -175,12 +175,12 @@ class UNetExchange: ...@@ -175,12 +175,12 @@ class UNetExchange:
private: private:
UNetExchange(); UNetExchange();
timeout_t initPause; timeout_t initPause = { 0 };
UniSetTypes::uniset_rwmutex mutex_start; UniSetTypes::uniset_rwmutex mutex_start;
PassiveTimer ptHeartBeat; PassiveTimer ptHeartBeat;
UniSetTypes::ObjectId sidHeartBeat = { UniSetTypes::DefaultObjectId }; UniSetTypes::ObjectId sidHeartBeat = { UniSetTypes::DefaultObjectId };
timeout_t maxHeartBeat = 10; timeout_t maxHeartBeat = { 10 };
IOController::IOStateList::iterator itHeartBeat; IOController::IOStateList::iterator itHeartBeat;
UniSetTypes::ObjectId test_id = { UniSetTypes::DefaultObjectId }; UniSetTypes::ObjectId test_id = { UniSetTypes::DefaultObjectId };
...@@ -238,7 +238,7 @@ class UNetExchange: ...@@ -238,7 +238,7 @@ class UNetExchange:
// ( реализацию см. ReceiverInfo::step() ) // ( реализацию см. ReceiverInfo::step() )
UniSetTypes::ObjectId sidRespond; UniSetTypes::ObjectId sidRespond;
IOController::IOStateList::iterator itRespond; IOController::IOStateList::iterator itRespond;
bool respondInvert; bool respondInvert = { false };
UniSetTypes::ObjectId sidLostPackets; UniSetTypes::ObjectId sidLostPackets;
IOController::IOStateList::iterator itLostPackets; IOController::IOStateList::iterator itLostPackets;
UniSetTypes::ObjectId sidChannelNum; UniSetTypes::ObjectId sidChannelNum;
...@@ -248,7 +248,7 @@ class UNetExchange: ...@@ -248,7 +248,7 @@ class UNetExchange:
typedef std::deque<ReceiverInfo> ReceiverList; typedef std::deque<ReceiverInfo> ReceiverList;
ReceiverList recvlist; ReceiverList recvlist;
bool no_sender; /*!< флаг отключения посылки сообщений (создания потока для посылки)*/ bool no_sender = { false }; /*!< флаг отключения посылки сообщений (создания потока для посылки)*/
std::shared_ptr<UNetSender> sender; std::shared_ptr<UNetSender> sender;
std::shared_ptr<UNetSender> sender2; std::shared_ptr<UNetSender> sender2;
......
...@@ -172,7 +172,6 @@ bool UNetReceiver::createConnection( bool throwEx ) ...@@ -172,7 +172,6 @@ bool UNetReceiver::createConnection( bool throwEx )
try try
{ {
udp = make_shared<UDPReceiveU>(addr, port); udp = make_shared<UDPReceiveU>(addr, port);
//udp = make_shared<UDPReceiveU>();
udp->setBlocking(false); // делаем неблокирующее чтение (нужно для libev) udp->setBlocking(false); // делаем неблокирующее чтение (нужно для libev)
evReceive.set<UNetReceiver, &UNetReceiver::callback>(this); evReceive.set<UNetReceiver, &UNetReceiver::callback>(this);
...@@ -537,7 +536,7 @@ void UNetReceiver::readEvent( ev::io& watcher ) ...@@ -537,7 +536,7 @@ void UNetReceiver::readEvent( ev::io& watcher )
} }
// только если "режим подготовки закончился, то можем генерировать "события" // только если "режим подготовки закончился, то можем генерировать "события"
if( ptPrepare.checkTime() && trTimeout.change(ptRecvTimeout.checkTime()) ) if( ptPrepare.checkTime() && trTimeout.change(tout) )
{ {
auto w = shared_from_this(); auto w = shared_from_this();
...@@ -795,7 +794,6 @@ void UNetReceiver::initDCache( UniSetUDP::UDPMessage& pack, bool force ) ...@@ -795,7 +794,6 @@ void UNetReceiver::initDCache( UniSetUDP::UDPMessage& pack, bool force )
if( d.id != pack.d_id[i] ) if( d.id != pack.d_id[i] )
{ {
d.id = pack.d_id[i]; d.id = pack.d_id[i];
d.iotype = conf->getIOType(d.id);
shm->initIterator(d.ioit); shm->initIterator(d.ioit);
} }
} }
...@@ -840,7 +838,6 @@ void UNetReceiver::initACache( UniSetUDP::UDPMessage& pack, bool force ) ...@@ -840,7 +838,6 @@ void UNetReceiver::initACache( UniSetUDP::UDPMessage& pack, bool force )
if( d.id != pack.a_dat[i].id ) if( d.id != pack.a_dat[i].id )
{ {
d.id = pack.a_dat[i].id; d.id = pack.a_dat[i].id;
d.iotype = conf->getIOType(d.id);
shm->initIterator(d.ioit); shm->initIterator(d.ioit);
} }
} }
......
...@@ -271,24 +271,23 @@ class UNetReceiver: ...@@ -271,24 +271,23 @@ class UNetReceiver:
struct CacheItem struct CacheItem
{ {
long id; long id = { UniSetTypes::DefaultObjectId };
IOController::IOStateList::iterator ioit; IOController::IOStateList::iterator ioit;
UniversalIO::IOType iotype;
CacheItem(): CacheItem():
id(UniSetTypes::DefaultObjectId), iotype(UniversalIO::UnknownIOType) {} id(UniSetTypes::DefaultObjectId) {}
}; };
typedef std::vector<CacheItem> CacheVec; typedef std::vector<CacheItem> CacheVec;
struct CacheInfo struct CacheInfo
{ {
CacheInfo(): CacheInfo():
cache_init_ok(false) cache_init_ok(false){}
{
} bool cache_init_ok = { false };
bool cache_init_ok;
CacheVec cache; CacheVec cache;
}; };
// ключом является UDPMessage::getDataID() // ключом является UDPMessage::getDataID()
typedef std::unordered_map<long, CacheInfo> CacheMap; typedef std::unordered_map<long, CacheInfo> CacheMap;
CacheMap d_icache_map; /*!< кэш итераторов для булевых */ CacheMap d_icache_map; /*!< кэш итераторов для булевых */
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment