Changeset 12773 for source/ariba/utility/transport

Timestamp:

Mar 26, 2014, 6:28:32 PM (11 years ago)

Author:

hock@…

Message:

WARNING! This revision is not intended for productive use!

!! DEBUGGING ONLY !!

Extreme debugging of StreamTransport.
"Typo" in the locking-code, was very hard to track down!

This revision is stored since a lot dabug code was written and should not just be deleted.

Location:

source/ariba/utility/transport

Files:

• StreamTransport/StreamTransport.cpp (modified) (3 diffs)
• StreamTransport/StreamTransport.hpp (modified) (2 diffs)
• messages/message.hpp (modified) (5 diffs)

source/ariba/utility/transport/StreamTransport/StreamTransport.cpp

@@ -366 +366 @@
         parent(parent),
         out_queues(8), //TODO How much priorities shall we have?
-        sending(false)
+        sending(false),
+        MAGIC_NUMBER(424242)
 {
         header.length = 0;
@@ -594 +595 @@
     bool restart_sending = false;
     
+        // FIXME Mario DEBUGGING  --  copy !!
+        reboost::shared_buffer_t buff = packet.linearize();
+        reboost::message_t msg;
+        msg.push_back(buff);
+        assert ( msg.MAGIC_NUMBER == 421337 );
+        // [ DEBUGGING ]
+        
+        
     // enqueue packet  [locked]
     {
-        unique_lock(out_queues_lock);
-        
-        assert( priority < out_queues.size() );
-        out_queues[priority].push(packet);
+        boost::mutex::scoped_lock lock(out_queues_lock);
+                
+                int debuggingA = out_queues[priority].size();
+//              assert ( debuggingA < 1000 ); // XXX
+                
+                assert ( this->valid );
+        
+        assert( priority < out_queues.size() );  // NOTE: actual assert, not in context with the extended debugging..
+//         out_queues[priority].push(packet);  // FIXME Mario
+                out_queues[priority].push(msg);            // FIXME Mario
+                
+                // XXX
+                int debuggingB = out_queues[priority].size();
+                int magic = out_queues[priority].back().MAGIC_NUMBER;
+                assert ( debuggingB == debuggingA + 1 );
+                assert ( magic == 421337 );
         
         if ( ! sending )
@@ -622 +643 @@
     bool found = false;
 
+        // XXX Mario: Debugging
+        if ( ! this->valid )
+        {
+                this->sending = false;
+                cout << "/// StreamConnection::send_next_package() on INVALID STREAM" << endl;
+                return;
+        }
+        
     // find packet with highest priority  [locked]
     {
-        unique_lock(out_queues_lock);
+        boost::mutex::scoped_lock lock(out_queues_lock);
+                
+                assert ( this->valid ); // XXX TODO ggf. in if (valid) Àndern...
+                assert ( this->sending );
+                assert ( this->MAGIC_NUMBER == 424242 );
+                assert ( this->out_queues.size() == 8 );
         
         for ( vector<OutQueue>::iterator it = out_queues.begin();
                 it != out_queues.end(); it++ )
         {
+                        int debugging = it->size();  // XXX debugging
+//                      assert ( debugging < 1000 );
+                        
             if ( !it->empty() )
             {

source/ariba/utility/transport/StreamTransport/StreamTransport.hpp

@@ -64 +64 @@
         StreamConnection(boost::asio::io_service& io_service, StreamTransportPtr parent);
         
-        virtual ~StreamConnection() {}
+        virtual ~StreamConnection()
+                {
+                        // XXX MARIO Debugging
+                        std::cout << "/// ~StreamConnection(): " << this << ", SENDING: " << this->sending << ", VALID: " << this->valid << std::endl;
+                        
+                        assert ( this->valid == false );
+                }
         
         /// Inherited from transport_connection
@@ -127 +133 @@
         shared_buffer_t buffy;
         
+                
+                // XXX Mario: Debugging
+                const int MAGIC_NUMBER;
     private:
         std::vector<ariba::utility::LinkID*> communication_links;

source/ariba/utility/transport/messages/message.hpp

@@ -11 +11 @@
 #include<boost/shared_ptr.hpp>
 #include<cstring>
+#include <cassert>
 
 #include "shared_buffer.hpp"
@@ -68 +69 @@
         /// Create a new message
         inline message_t() :
-                imsg() {
+                imsg(),
+                MAGIC_IDENTIFIER("!!message_t-MAGIC_IDENTIFIER!!"), // XXX Mario: Debugging
+                MAGIC_NUMBER(421337) // XXX Mario: Debugging
+        {
         }
 
         /// Copy message
         inline message_t(const message_t& msg) :
-                imsg(msg.imsg)
+                imsg(msg.imsg),
+                MAGIC_IDENTIFIER(msg.MAGIC_IDENTIFIER),  // XXX
+                MAGIC_NUMBER(msg.MAGIC_NUMBER) // XXX
+
         {
+                assert ( msg.MAGIC_NUMBER == 421337 ); // XXX
+                
             if ( imsg )
                 imsg->owner = NULL;
@@ -85 +94 @@
 
         /// Assign another message
-        inline message_t& operator=(const message_t& msg) {
-                msg.imsg->owner = NULL;
-                imsg = msg.imsg;
+        inline message_t& operator=(const message_t& msg)
+        {
+                assert ( msg.MAGIC_NUMBER == 421337 ); // XXX
+                
+                if ( msg.imsg )
+                {
+                        msg.imsg->owner = NULL;
+                        imsg = msg.imsg;
+                }
+                else
+                {
+                        // TODO: is this a valid state? (since it can definitely been reached...)
+                        imsg.reset();
+                }
+                
                 return *this;
         }
@@ -252 +273 @@
                 shared_buffer_t buffers[message_max_buffers];
                 mlength_t index, length;
+                
+                // XXX Mario: Debugging
+                const std::string MAGIC_IDENTIFIER;
+                const int MAGIC_NUMBER;
         public:
                 inline imsg_t() :
-                        index(0), length(0) {
+                        owner(NULL),
+                        index(0),
+                        length(0),
+                        MAGIC_IDENTIFIER("!!imsg_t-MAGIC_IDENTIFIER!!"), // XXX Mario: Debugging
+                        MAGIC_NUMBER(133742)
+                {
                 }
                 inline imsg_t(const imsg_t& imsg) :
-                        index(imsg.index), length(imsg.length) {
+                        index(imsg.index), length(imsg.length),
+                        MAGIC_IDENTIFIER(imsg.MAGIC_IDENTIFIER),  // XXX
+                        MAGIC_NUMBER(imsg.MAGIC_NUMBER) // XXX
+                {
                         for (mlength_t i = 0; i < length; i++)
                                 at(index + i) = imsg.at(index + i);
@@ -336 +369 @@
         }
         boost::shared_ptr<imsg_t> imsg;
+        
+        // XXX Mario: Debugging
+public:
+        const std::string MAGIC_IDENTIFIER;
+        const int MAGIC_NUMBER;
 };