X-Git-Url: https://git.llucax.com/z.facultad/75.74/practicos.git/blobdiff_plain/32f33ac62101f37de1133688b45c8eb837d5b8d8..91fb3ca6b56328c626dabb35e2de9a5ae525b1b1:/practicas/pipi/src/devque.cpp?ds=inline diff --git a/practicas/pipi/src/devque.cpp b/practicas/pipi/src/devque.cpp index 32b71a7..1e812ff 100644 --- a/practicas/pipi/src/devque.cpp +++ b/practicas/pipi/src/devque.cpp @@ -28,6 +28,9 @@ DevQue::DevQue(mac_type mac, key_t key, size_t mtu) void DevQue::transmit(const std::string& data, const mac_type& mac) throw (std::runtime_error, std::logic_error) { +#ifdef DEBUG_TRACE + std::cout << "DevQue[" << que_id << "]::transmit()\n"; +#endif if (data.size() > mtu) throw std::logic_error("Tamaño de datos mayor al MTU"); Frame* f = (Frame*) malloc(sizeof(Frame) + mtu); @@ -37,9 +40,9 @@ void DevQue::transmit(const std::string& data, const mac_type& mac) f->size = data.size(); memcpy(f->frame, data.data(), data.size()); int res = msgsnd(que_id, f, mtu + sizeof(size_t), 0); -#ifdef DEBUG2 - std::cout << "DevQue::transmit(msgtype/mac = " << f->mac << ", size = " - << f->size << ")\n"; +#ifdef DEBUG_QUE + std::cout << "DevQue[" << que_id << "]::transmit(msgtype/mac = " + << f->mac << ", size = " << f->size << ")\n"; #endif free(f); if (res == -1) @@ -48,11 +51,17 @@ void DevQue::transmit(const std::string& data, const mac_type& mac) std::string DevQue::receive() throw (std::runtime_error) { +#ifdef DEBUG_TRACE + std::cout << "DevQue[" << que_id << "]::receive()\n"; +#endif return receive(mac); } std::string DevQue::receive(mac_type& mac) throw (std::runtime_error) { +#ifdef DEBUG_TRACE + std::cout << "DevQue[" << que_id << "]::receive(mac)\n"; +#endif Frame* f = (Frame*) malloc(sizeof(Frame) + mtu); if (!f) throw std::runtime_error("No se puede reservar memoria"); @@ -66,9 +75,9 @@ std::string DevQue::receive(mac_type& mac) throw (std::runtime_error) if (mac == 0) mac = f->mac; free(f); -#ifdef DEBUG2 - std::cout << "DevQue::receive(msgtype/mac = " << mac << ", size = " - << s.size() << ")\n"; +#ifdef DEBUG_QUE + std::cout << "DevQue[" << que_id << "]::receive(msgtype/mac = " + << mac << ", size = " << s.size() << ")\n"; #endif return s; }