cleanup
This commit is contained in:
parent
abd072a67c
commit
eff19cc1d8
@ -187,7 +187,7 @@ bool Participant::Publish(IMessage *msg) {
|
|||||||
void Participant::ReceiveData(unsigned char bufferSize,
|
void Participant::ReceiveData(unsigned char bufferSize,
|
||||||
Participant *remoteParticipant) {
|
Participant *remoteParticipant) {
|
||||||
unsigned char msgId = this->buffer[0];
|
unsigned char msgId = this->buffer[0];
|
||||||
std::cout << "receive msg " << (int)msgId << "\n";
|
// std::cout << "receive msg " << (int)msgId << "\n";
|
||||||
switch (msgId) {
|
switch (msgId) {
|
||||||
case ClientMsg::id: {
|
case ClientMsg::id: {
|
||||||
ClientMsg *msg = new ClientMsg(this->buffer);
|
ClientMsg *msg = new ClientMsg(this->buffer);
|
||||||
@ -283,8 +283,8 @@ Thing *Participant::Get(unsigned char networkId, unsigned char thingId) {
|
|||||||
std::cout << "Get " << (int)networkId << "/" << (int)thingId << " from "
|
std::cout << "Get " << (int)networkId << "/" << (int)thingId << " from "
|
||||||
<< this->things.size() << " things\n";
|
<< this->things.size() << " things\n";
|
||||||
for (auto &thing : this->things) {
|
for (auto &thing : this->things) {
|
||||||
std::cout << " ? " << (int)thing->networkId << "/" << (int)thing->id
|
// std::cout << " ? " << (int)thing->networkId << "/" << (int)thing->id
|
||||||
<< "\n";
|
// << "\n";
|
||||||
if (thing->networkId == networkId && thing->id == thingId) {
|
if (thing->networkId == networkId && thing->id == thingId) {
|
||||||
return thing;
|
return thing;
|
||||||
}
|
}
|
||||||
|
@ -89,7 +89,7 @@ void UdpPosix::Receive() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
ReceiveData(packetSize, remoteParticipant);
|
ReceiveData(packetSize, remoteParticipant);
|
||||||
std::cout << "Received data\n";
|
// std::cout << "Received data\n";
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user