threadsafe fixes

libs/main/io_devices/pipeer.cpp

@@ -623,7 +623,10 @@ bool PIPeer::dataRead(const uchar * readed, ssize_t size) {
 			return true;
 		}
 		cnt++;
-		if (cnt > _PIPEER_MSG_TTL || from == dp->name) return true;
+		if (cnt > _PIPEER_MSG_TTL || from == dp->name) {
+			eth_mutex.unlock();
+			return true;
+		}
 		sba << type << from << to << cnt << pba;
 		// piCout << "translate packet" << from << "->" << to << ", ttl =" << cnt;
 		sendToNeighbour(dp, sba);

libs/mqtt_client/pimqttclient.cpp

@@ -60,7 +60,7 @@ STATIC_INITIALIZER_END
 
 PRIVATE_DEFINITION_START(PIMQTT::Client)
 	MQTTClient client = nullptr;
-	bool connected    = false;
+	std::atomic<bool> connected{false};
 
 	PIProtectedVariable<EndpointsStorage> endpoints;