Changeset 5309

Show
Ignore:
Timestamp:
10/10/07 09:54:32 (6 years ago)
Author:
jgaeddert
Message:

fixing bug under run_continuous mode where feedback port waits 5 seconds; setting debug level

Location:
experimental/components/DataGenerator/branches/DataGenerator-metadata
Files:
2 modified

Legend:

Unmodified
Added
Removed
  • experimental/components/DataGenerator/branches/DataGenerator-metadata/DataGenerator.cpp

    r5119 r5309  
    266266    while (!pause_component) { 
    267267        metadataIn->getMetaData( feedback_metadata ); 
     268        metadataIn->bufferEmptied(); 
    268269 
    269270        num_received_packets++; 
    270         std::cout << "DataGen received packet " << feedback_metadata->packet_id << std::endl; 
    271  
    272         if ( feedback_metadata->packet_id == num_packets-1) { 
    273             // signal mode change 
    274             std::cout << "GetFeedbackMetaData: received final metadata packet.  Waiting 5 seconds..." << std::endl; 
    275             usleep(5000000); 
    276             if (!run_continuous) { 
     271        DEBUG(5, DataGen, "received packet " << feedback_metadata->packet_id); 
     272 
     273        if (!run_continuous) { 
     274            if ( feedback_metadata->packet_id == num_packets-1) { 
     275                // signal mode change 
     276                std::cout << "GetFeedbackMetaData: received final metadata packet.  Waiting 5 seconds..." << std::endl; 
     277                usleep(5000000); 
    277278                std::cout << "...posting semaphore" << std::endl; 
    278279                ready_to_generate->post(); 
     
    280281        } 
    281282 
    282         metadataIn->bufferEmptied(); 
    283     } 
    284 } 
    285  
     283    } 
     284} 
     285 
  • experimental/components/DataGenerator/branches/DataGenerator-metadata/main.cpp

    r5092 r5309  
    2323#include <iostream> 
    2424#include "ossie/ossieSupport.h" 
     25#include "ossie/debug.h" 
    2526 
    2627#include "DataGenerator.h" 
     
    3132 
    3233int main(int argc, char* argv[]) 
     34{ 
     35    ossieDebugLevel = 1; 
    3336 
    34 { 
    3537    ossieSupport::ORB *orb = new ossieSupport::ORB; 
    3638    omni_mutex component_running_mutex;