#include <ossimIgen.h>

Inheritance diagram for ossimIgen:

Public Member Functions
	ossimIgen ()

virtual	~ossimIgen ()

virtual void	initialize (const ossimKeywordlist &kwl)

virtual void	outputProduct ()
	Writes the output product image. Throws an ossimException if error encountered. More...

Public Member Functions inherited from ossimReferenced
	ossimReferenced ()

	ossimReferenced (const ossimReferenced &)

ossimReferenced &	operator= (const ossimReferenced &)

void	ref () const
	increment the reference count by one, indicating that this object has another pointer which is referencing it. More...

void	unref () const
	decrement the reference count by one, indicating that a pointer to this object is referencing it. More...

void	unref_nodelete () const
	decrement the reference count by one, indicating that a pointer to this object is referencing it. More...

int	referenceCount () const

Protected Member Functions
void	initializeAttributes ()

void	slaveSetup ()

bool	loadProductSpec ()

void	setView ()
	Initializes all clients of the view projection to the current product projection. More...

void	initThumbnailProjection ()
	Modifies the production chain to output redused-resolution thumbnail image. More...

void	initializeChain ()

bool	writeToFile (ossimImageFileWriter *writer)
	Consolidates job of actually writing to the output file. More...

Protected Member Functions inherited from ossimReferenced
virtual	~ossimReferenced ()

Protected Attributes
ossimRefPtr< ossimConnectableContainer >	theContainer

ossimRefPtr< ossimMapProjection >	theProductProjection

ossimRefPtr< ossimImageChain >	theProductChain

ossimRefPtr< ossimTiling >	theTiling

ossimDrect	theOutputRect

bool	theBuildThumbnailFlag

ossimIpt	theThumbnailSize

long	theNumberOfTilesToBuffer

ossimKeywordlist	theKwl

bool	theTilingEnabled

bool	theProgressFlag

bool	theStdoutFlag

ossim_uint32	theThreadCount

Detailed Description

Definition at line 37 of file ossimIgen.h.

Constructor & Destructor Documentation

◆ ossimIgen()

ossimIgen::ossimIgen ( )

Definition at line 44 of file ossimIgen.cpp.

References ossimDrect::makeNan(), and theOutputRect.

 :
 theContainer(new ossimConnectableContainer()),
 theProductProjection(0),
 theProductChain(0),
 theTiling(new ossimTiling),
 theOutputRect(),
 theBuildThumbnailFlag(false),
 theThumbnailSize(0, 0),
 theNumberOfTilesToBuffer(2),
 theKwl(),
 theTilingEnabled(false),
 theProgressFlag(true),
 theStdoutFlag(false),
 theThreadCount(9999) // Default no threading
 {
    theOutputRect.makeNan();
 }

◆ ~ossimIgen()

ossimIgen::~ossimIgen ( )

virtual

Definition at line 63 of file ossimIgen.cpp.

References ossimConnectableContainer::deleteAllChildren(), ossimConnectableObject::disconnect(), theContainer, theProductProjection, and theTiling.

 {
    theProductProjection = 0;
    theTiling = 0;
    theContainer->disconnect();
    theContainer->deleteAllChildren();
    theContainer = 0;
 }

Member Function Documentation

◆ initialize()

void ossimIgen::initialize ( const ossimKeywordlist & kwl )

virtual

Definition at line 247 of file ossimIgen.cpp.

References ossimMpi::instance(), slaveSetup(), and theKwl.

 {
 #if OSSIM_HAS_MPI
    if(ossimMpi::instance()->getNumberOfProcessors() > 0)
    {
       if(ossimMpi::instance()->getRank() != 0)
       {
          slaveSetup();
          return;
       }
    }
 #endif
    theKwl = kwl;
    if(traceDebug())
    {
       ossimNotify(ossimNotifyLevel_DEBUG)
          << "The igen kewyord list  ==== \n" << theKwl << std::endl;
    }
    ossimKeywordlist kwlPrefs = ossimPreferences::instance()->preferencesKWL();
 
    kwlPrefs.addPrefixToAll("preferences.");
    theKwl.add(kwlPrefs);
 
    initializeAttributes();
 
    // now stream it to all slave processors
    //
 #if OSSIM_HAS_MPI
    if(ossimMpi::instance()->getNumberOfProcessors() > 0)
    {
       std::ostringstream outputKeywordlist;
 
       theKwl.writeToStream(outputKeywordlist);
       ossimString kwlString = outputKeywordlist.str();
       ossim_uint32 size = kwlString.size();
 
       for(long processor = 1;
          processor < ossimMpi::instance()->getNumberOfProcessors();
          ++processor)
       {
          // let's send the keywordlist argument.
          // This is two steps.  We send a message to
          // indicate the size and then we send the
          // string.
          //
          MPI_Send(&size,
             1,
             MPI_INT,
             processor,
             0,
             MPI_COMM_WORLD);
 
          MPI_Send((void*)kwlString.c_str(),
             size,
             MPI_CHAR,
             processor,
             0,
             MPI_COMM_WORLD);
       }
    }
 #endif
    loadProductSpec();
 
 }

◆ initializeAttributes()

void ossimIgen::initializeAttributes ( )

protected

Definition at line 72 of file ossimIgen.cpp.

References ossimPreferences::addPreferences(), ossimKeywordlist::find(), ossimMpi::instance(), ossimPreferences::instance(), theBuildThumbnailFlag, theKwl, theProgressFlag, theThumbnailSize, theTilingEnabled, and ossimString::toBool().

Referenced by slaveSetup().

 {
    theBuildThumbnailFlag  = false;
    theThumbnailSize = ossimIpt(0,0);
    theTilingEnabled = false;
 
    if(ossimMpi::instance()->getRank() != 0)
    {
       ossimPreferences::instance()->addPreferences(theKwl,
          "preferences.",
          true);
    }
 
    const char* lookup = theKwl.find("igen.output_progress");
    if (lookup)
    {
       ossimString os = lookup;
       theProgressFlag = os.toBool();
    }
 
    const char* thumbnailStr = theKwl.find("igen.thumbnail");
    if(traceDebug())
    {
       ossimNotify(ossimNotifyLevel_DEBUG)
          << "Thumbnail string = " << ossimString(thumbnailStr) << std::endl;
    }
    if(thumbnailStr)
    {
       theBuildThumbnailFlag= ossimString(thumbnailStr).toBool();
       if(traceDebug())
       {
          ossimNotify(ossimNotifyLevel_DEBUG)
             << "Generate thumbnail attribute is set to "
             << theBuildThumbnailFlag << std::endl;
       }
       if(theBuildThumbnailFlag)
       {
          const char* resStr = theKwl.find("igen.thumbnail_res");
          if(resStr)
          {
             theThumbnailSize = ossimIpt(0,0);
             std::istringstream in(resStr);
             ossimString x,y;
 
             in >> x >> y;
 
             ossim_int32 ix = x.toInt32();
             ossim_int32 iy = y.toInt32();
 
             if (ix > 0)
             {
                theThumbnailSize.x = ix;
             }
             else
             {
                theThumbnailSize.x = 128;
             }
 
             if (iy > 0)
             {
                theThumbnailSize.y = iy;
             }
             else
             {
                theThumbnailSize.y = theThumbnailSize.x;
             }
          }
          else
          {
             theThumbnailSize = ossimIpt(128, 128);
          }
       }
    }
    const char* numberOfSlaveTileBuffersStr = theKwl.find("igen.slave_tile_buffers");
    if(numberOfSlaveTileBuffersStr)
    {
       theNumberOfTilesToBuffer = ossimString(numberOfSlaveTileBuffersStr).toLong();
    }
 
    const char* tilingKw = theKwl.find("igen.tiling.type");
    if(tilingKw)
    {
       theTilingEnabled = true;
       if(!theTiling->loadState(theKwl, "igen.tiling."))
       {
          theTilingEnabled = false;
       }
    }
 }

◆ initializeChain()

void ossimIgen::initializeChain ( )

protected

Definition at line 725 of file ossimIgen.cpp.

References ossimRefPtr< T >::get(), ossimImageChain::getBoundingRect(), ossimImageChain::getImageGeometry(), ossimDrect::hasNans(), ossimImageChain::initialize(), ossimImageGeometry::setImageSize(), ossimDrect::size(), ossimDrect::stretchOut(), theOutputRect, and theProductChain.

Referenced by outputProduct(), and setView().

 {
    // Force initialization of the chain to recompute parameters:
    theProductChain->initialize();
    theOutputRect = theProductChain->getBoundingRect();
    
    if(!theOutputRect.hasNans())
    {
       // Stretch the rectangle out to integer boundaries.
       theOutputRect.stretchOut();
 
       // Communicate the new product size to the view's geometry object. This is a total HACK that 
       // external code needs to worry about setting this. Something is wrong with this picture 
       // (OLK 02/11)
       ossimImageGeometry* geom = theProductChain->getImageGeometry().get();
       if (geom)
          geom->setImageSize(ossimIpt(theOutputRect.size()));
    }
 }

◆ initThumbnailProjection()

void ossimIgen::initThumbnailProjection ( )

protected

Modifies the production chain to output redused-resolution thumbnail image.

Definition at line 691 of file ossimIgen.cpp.

References ossimMapProjection::applyScale(), ossimRefPtr< T >::get(), ossimDrect::hasNans(), ossimDrect::height(), ossimDrect::lr(), ossim::max(), setView(), theOutputRect, theProductProjection, theThumbnailSize, ossimDrect::ul(), ossimDrect::width(), ossimIpt::x, ossimDpt::x, ossimIpt::y, and ossimDpt::y.

Referenced by outputProduct().

 {
    double thumb_size = ossim::max(theThumbnailSize.x, theThumbnailSize.y);
    ossimMapProjection* mapProj = dynamic_cast<ossimMapProjection*>(theProductProjection.get());
 
    if(mapProj && !theOutputRect.hasNans())
    {
       double xScale = theOutputRect.width()  / thumb_size;
       double yScale = theOutputRect.height() / thumb_size;
       double scale = ossim::max(xScale, yScale);
       mapProj->applyScale(ossimDpt(scale, scale), true);
    }
 
    // Need to change the view in the product chain:
    setView();
 
    // Clamp output rectangle to thumbnail bounds.
    ossimDpt ul = theOutputRect.ul();
    ossimDpt lr = theOutputRect.lr();
    if ( (lr.x - ul.x + 1) > thumb_size)
    {
       lr.x = ul.x + thumb_size - 1;
    }
    if ( (lr.y - ul.y + 1) > thumb_size )
    {
       lr.y = ul.y + thumb_size - 1;
    }
    theOutputRect = ossimDrect(ul, lr);
 }

◆ loadProductSpec()

bool ossimIgen::loadProductSpec ( )

protected

Definition at line 312 of file ossimIgen.cpp.

 {
    const char* MODULE = "ossimIgen::loadProductSpec";
    if(traceDebug())  CLOG << "entered..." << std::endl;
 
    // Clear out the overall container and initialize it with spec in KWL:
    theContainer->deleteAllChildren();
    theContainer->loadState(theKwl);
 
    // There should be a product chain defined in the container:
    // ossimConnectableObject* obj = 
    //   theContainer->findFirstObjectOfType(STATIC_TYPE_NAME(ossimImageChain), false);
    // theProductChain = PTR_CAST(ossimImageChain, obj);
 
    ossimTypeNameVisitor visitor( ossimString("ossimImageChain"),
                                  true, // firstofTypeFlag
                                  (ossimVisitor::VISIT_INPUTS |
                                   ossimVisitor::VISIT_CHILDREN) );
    theContainer->accept( visitor );
    theProductChain = visitor.getObjectAs<ossimImageChain>(0);
    
    if (!theProductChain.valid())
    {
       // Search for a connectable container specified that contains the entire product chain:
       // ossimConnectableObject* obj2 = 
       //    theContainer->findFirstObjectOfType(STATIC_TYPE_NAME(ossimImageFileWriter), true);
       // ossimImageFileWriter* writer = PTR_CAST(ossimImageFileWriter, obj2);
       visitor.reset();
       visitor.setTypeName( ossimString( "ossimImageFileWriter" ) );
       theContainer->accept( visitor );
       ossimRefPtr<ossimImageFileWriter> writer = visitor.getObjectAs<ossimImageFileWriter>(0);
       if ( writer.valid() )
       {
          theProductChain = dynamic_cast<ossimImageChain*>( writer->getInput() );
       }
 
       if (!theProductChain.valid())
       {
          ossimNotify(ossimNotifyLevel_FATAL) << MODULE 
             << " -- No processing chain defined for generating product." << std::endl;
          return false; 
       }
    }
 
    // The output projection is specified separately in the KWL:
    ossimString prefix = "product.projection.";
    theProductProjection = dynamic_cast<ossimMapProjection*>( 
       ossimProjectionFactoryRegistry::instance()->createProjection(theKwl, prefix) );
 
    const char* lookup = theKwl.find("igen.write_to_stdout");
    if (lookup && ossimString(lookup).toBool())
    {
       theStdoutFlag = true;
    }
 
    return true;
 }

◆ outputProduct()

void ossimIgen::outputProduct ( )

virtual

Writes the output product image. Throws an ossimException if error encountered.

Definition at line 373 of file ossimIgen.cpp.

References ossimConnectableContainer::accept(), ossimImageChain::addFirst(), ossimImageFileWriter::changeSequencer(), ossimConnectableObject::connectMyInputTo(), ossimMultiThreadSequencer::d_cacheEmptyCount, ossimMultiThreadSequencer::d_idleTime2, ossimMultiThreadSequencer::d_idleTime5, ossimMultiThreadSequencer::d_jobGetTileT, ossimMultiThreadSequencer::d_maxCacheUsed, ossimFilename::dirCat(), ossimConnectableObject::disconnect(), ossimRefPtr< T >::get(), ossimTilingPoly::getExteriorCut(), ossimImageFileWriter::getFilename(), ossimTilingPoly::getInteriorCut(), ossimMultiThreadSequencer::getNumberOfThreads(), ossimCollectionVisitor::getObjectAs(), ossimMultiThreadSequencer::handlerGetTileT(), ossimTilingPoly::hasExteriorCut(), ossimTilingPoly::hasInteriorCut(), ossimTiling::initialize(), ossimImageFileWriter::initialize(), initializeChain(), initThumbnailProjection(), ossimMpi::instance(), ossimFilename::isDir(), ossimTilingPoly::isFeatureBoundingIntersect(), ossimTiling::next(), ossimFilename::path(), ossimImageFileWriter::setAreaOfInterest(), ossimImageFileWriter::setFilename(), ossimImageFileWriter::setOutputStream(), ossimRectangleCutFilter::setRectangle(), setView(), theBuildThumbnailFlag, theContainer, theNumberOfTilesToBuffer, theOutputRect, theProductChain, theProductProjection, theStdoutFlag, theThreadCount, theTiling, theTilingEnabled, ossimString::toString(), ossimTilingPoly::useMbr(), ossimRefPtr< T >::valid(), ossimVisitor::VISIT_CHILDREN, ossimVisitor::VISIT_INPUTS, and writeToFile().

 {
    // Verify that all vitals have been initialized:
    if (!theProductChain.valid())
    {
       std::string err = "ossimIgen::outputProduct() ERROR:  No product processing chain has yet"
          " been established. Nothing to output!";
       throw(ossimException(err));
    }
    if (!theProductProjection.valid())
    {
       std::string err = "ossimIgen::outputProduct() ERROR:  No product projection has yet"
          " been established. Nothing to output!";
       throw(ossimException(err));
    }
 
    // Update the chain with the product view specified:
    setView();
    initializeChain();
 
    // if it's a thumbnail then adjust the GSD and reset the view proj to the chain.
    if(theBuildThumbnailFlag)
       initThumbnailProjection();
 
    ossimRefPtr<ossimImageSourceSequencer> sequencer = 0;
 
 #if OSSIM_HAS_MPI
    // only allocate the slave connection if the number of processors is larger than 1
    if(ossimMpi::instance()->getNumberOfProcessors() > 1)
    {
       if(ossimMpi::instance()->getRank()!=0)
          sequencer = new ossimImageMpiSWriterSequenceConnection(0, theNumberOfTilesToBuffer);
       else
          sequencer = new ossimImageMpiMWriterSequenceConnection();
    }
 #endif
 
    // we will just load a serial connection if MPI is not supported.
    // Threading?
    if (!sequencer.valid() && (theThreadCount != 9999))
       sequencer = new ossimMultiThreadSequencer(0, theThreadCount);
 
    if (!sequencer.valid())
       sequencer = new ossimImageSourceSequencer(0);
 
 
    // Look for the first writer (should be the only writer) in our list of objects:
 
    // ossimRefPtr<ossimImageFileWriter> writer  = 0;
    // ossimConnectableObject::ConnectableObjectList imageWriters =
    //    theContainer->findAllObjectsOfType(STATIC_TYPE_INFO(ossimImageFileWriter), false);
 
    ossimTypeNameVisitor visitor( ossimString("ossimImageFileWriter"),
                                  true, // firstofTypeFlag
                                  (ossimVisitor::VISIT_INPUTS |
                                   ossimVisitor::VISIT_CHILDREN) );
    theContainer->accept( visitor );
    ossimRefPtr<ossimImageFileWriter> writer = visitor.getObjectAs<ossimImageFileWriter>(0);
    
    if ( !writer.valid() )
    {
       sequencer = 0;
       std::string err = "ossimIgen::outputProduct() ERROR:  No image writer object was found in "
          " processing chain.";
       throw(ossimException(err));
    }
 
    // writer = PTR_CAST(ossimImageFileWriter, imageWriters[0].get());
    writer->changeSequencer(sequencer.get());
    writer->connectMyInputTo(theProductChain.get());
    
    // Check for writing to standard output flag. Not all writers support this so check and 
    // throw an error if not supported.
    if (theStdoutFlag)
    {
       if ( writer->setOutputStream(std::cout) == false )
       {
          std::string err = "ERROR:  The write to standard out flag is set; however, writer does "
             "not support going to standard out. Bummer...";
          throw(ossimException(err));
       }
    }
    
    writer->initialize();
 
    if ( theBuildThumbnailFlag )
    {
       //---
       // Use theOutputRect as it has been clamped to be within the requested thumbnail size.
       // 
       // Relying of the bounding rectangle of the scaled product chain has given us off by
       // one rectangles, i.e., a width of 513 instead of 512.
       // 
       // NOTE: This must be called after the writer->initialize() as
       // ossimImageFileWriter::initialize incorrectly resets theAreaOfInterest
       // back to the bounding rect.
       //---
       writer->setAreaOfInterest( ossimIrect(theOutputRect) );
    }
 
    // If multi-file tiled output is not desired perform simple output, handle special:
    if(theTilingEnabled && theProductProjection.valid())
    {
       theTiling->initialize(*(theProductProjection.get()), theOutputRect);
 
       ossimRectangleCutFilter* cut = 0;
       ossimTilingPoly* tilingPoly = dynamic_cast<ossimTilingPoly*>( theTiling.get() );
       
       ossimFilename tempFile = writer->getFilename();
       if(!tempFile.isDir())
       {
          tempFile = tempFile.path();
       }
 
       ossimString tileName;
       ossimIrect clipRect;
 
       // 'next' method modifies the mapProj which is the same instance as theProductProjection,
       // so this data member is modified here, then later accessed by setView:
       while(theTiling->next(theProductProjection, clipRect, tileName))
       {
          if ( !tilingPoly )//use ossimTiling or ossimTilingRect
          {
             // Disconnect prior to setting up chain.
             writer->disconnect();
 
             // This will progate the updated projection from theTiling->next call.
             setView();
 
             // Recompute the bounding rect:
             initializeChain();
 
             // Hook writer up:
             writer->connectMyInputTo(theProductChain.get());
             writer->setFilename(tempFile.dirCat(tileName));
             writer->initialize();
 
             // Set the clip rect for tile:
             writer->setAreaOfInterest( clipRect );
          }
          else //otherwise use ossimTilingPoly
          {
             if (tilingPoly != NULL)
             {
                if (!tilingPoly->isFeatureBoundingIntersect())//if clip rect does not intersect with output rect, do nothing
                {
                   continue;
                }
                if (tilingPoly->useMbr())//if use_mbr flag is set to true, all pixels within the MBR will be preserved
                {
                   if (cut == NULL)
                   {
                       cut = new ossimRectangleCutFilter;
                       theProductChain->addFirst(cut);
                   }
                   setView();
                   cut->setRectangle(clipRect);
                }
                else
                {
                   if ( tilingPoly->hasExteriorCut() )
                   {
                      theProductChain->addFirst( tilingPoly->getExteriorCut().get() );
                   }
                   if ( tilingPoly->hasInteriorCut() )
                   {
                      theProductChain->addFirst( tilingPoly->getInteriorCut().get() );
                   }
                }
             }
 
             initializeChain();
             writer->disconnect();
             writer->connectMyInputTo(theProductChain.get());
             writer->setFilename(tempFile.dirCat(tileName));
             writer->initialize();
             
          } // if ( !tilingPoly ){} else{
          
 
          // Write the file:
          if ( !writeToFile( writer.get() ))
          {
             break;
          }
       }
    }
    else
    {
       // No multi-file tiling, just conventional write to single file:
       writeToFile(writer.get());
    }
 
    //########## DEBUG CODE FOR TIMING MULTI THREAD LOCKS ##############
    if (sequencer.valid() && (theThreadCount != 9999))
    {
       ossimMultiThreadSequencer* mts = dynamic_cast<ossimMultiThreadSequencer*>(sequencer.get());
       if (mts != NULL)
       {
 
          double jgtt = mts->d_jobGetTileT;
          ossim_uint32 num_threads = mts->getNumberOfThreads();
          double jgttpj = jgtt/num_threads;
          cout<<setprecision(3)<<endl;
          cout << "Multi-threading metrics ---"<<endl;
          cout << "   Number of threads:      " << num_threads<< endl;
          cout << "   Max cache used:         "<< mts->d_maxCacheUsed << endl;
          cout << "   Cache emptied count:    "<< ossimString::toString(mts->d_cacheEmptyCount) << endl;
          cout << "   Time waiting on jobs:   "<<mts->d_idleTime2<<" s"<<endl;
          cout << "   Time waiting on cache:  "<<mts->d_idleTime5<<" s"<<endl;
          cout << "   Handler getTile T:      "<<mts->handlerGetTileT()<<" s"<<endl;
          cout << "   Job getTile T:          "<<jgtt<<" s"<<endl;
          cout << "   Average getTile T/job:  "<<jgttpj<<" s\n"<<endl;
       }
    }
    //##################################################################
 }

◆ setView()

void ossimIgen::setView ( )

protected

Initializes all clients of the view projection to the current product projection.

Definition at line 653 of file ossimIgen.cpp.

References ossimImageChain::accept(), ossimProjection::dup(), ossimCollectionVisitor::getObjectAs(), ossimCollectionVisitor::getObjects(), initializeChain(), ossimViewInterface::setView(), STATIC_TYPE_INFO, theProductChain, theProductProjection, ossimRefPtr< T >::valid(), ossimVisitor::VISIT_CHILDREN, and ossimVisitor::VISIT_INPUTS.

Referenced by initThumbnailProjection(), and outputProduct().

 {
    if( theProductChain.valid() && theProductProjection.valid() )
    {
       // Find all view clients in the chain, and notify them of the new view:
 #if 0
       ossimConnectableObject::ConnectableObjectList clientList;
       theProductChain->findAllInputsOfType(clientList, STATIC_TYPE_INFO(ossimViewInterface), true, true);
       for(ossim_uint32 i = 0; i < clientList.size();++i)
       {
          ossimViewInterface* viewClient = dynamic_cast<ossimViewInterface*>( clientList[i].get() );
          if (viewClient)
             viewClient->setView(theProductProjection->dup());
       }
 #endif
       
       ossimTypeNameVisitor visitor( ossimString("ossimViewInterface"),
                                     false, // firstofTypeFlag
                                     (ossimVisitor::VISIT_INPUTS|
                                      ossimVisitor::VISIT_CHILDREN) );
       theProductChain->accept( visitor );
       for( ossim_uint32 i = 0; i < visitor.getObjects().size(); ++i )
       {
          ossimViewInterface* viewClient = visitor.getObjectAs<ossimViewInterface>( i );
          if (viewClient)
          {
             viewClient->setView( theProductProjection->dup() );
          }
       }
 
       // Force recompute of bounding rect:
       initializeChain();
    }
 }

◆ slaveSetup()

void ossimIgen::slaveSetup ( )

protected

Definition at line 162 of file ossimIgen.cpp.

References ossimKeywordlist::clear(), ossimMpi::getRank(), initializeAttributes(), ossimMpi::instance(), ossimNotify(), ossimNotifyLevel_WARN, ossimKeywordlist::parseStream(), status, and theKwl.

Referenced by initialize().

 {
 #if OSSIM_HAS_MPI
    int stringSize;
    MPI_Status status;
    int numberOfTimes = 0;
 
    memset((void *)&status, 0, sizeof(MPI_Status));
 
 
    // we first need to receive the size of the keyword list to load
    MPI_Recv(&stringSize,
       1,
       MPI_INT,
       0,    // source
       0,    // tag
       MPI_COMM_WORLD,
       &status);
 
    if(status.MPI_ERROR != MPI_SUCCESS)
    {
       ossimNotify(ossimNotifyLevel_WARN)
          << "SLAVE = "
          << ossimMpi::instance()->getRank()
          << "Had errors receiving!!!!" << std::endl;
       return;
    }
 
    char* buf = new char[stringSize+1];
 
    numberOfTimes = 0;
 
    memset((void *)&status, 0, sizeof(MPI_Status));
 
    // now lets get the keywordlist as a string so we can load it up
    MPI_Recv(buf,
       stringSize,
       MPI_CHAR,
       0, // source
       0, // tag
       MPI_COMM_WORLD,
       &status);
 
    if(status.MPI_ERROR != MPI_SUCCESS)
    {
       ossimNotify(ossimNotifyLevel_WARN)
          << "SLAVE = " << ossimMpi::instance()->getRank()
          << "Had errors receiving in ossimIgen::slaveCreate(!!!!"
          << std::endl;
       return;
    }
    buf[stringSize] = '\0';
 
    if(status.MPI_ERROR != MPI_SUCCESS)
    {
       ossimNotify(ossimNotifyLevel_WARN)
          << "SLAVE = " << ossimMpi::instance()->getRank()
          << "Had errors receiving!!!!" << std::endl;
       return;
    }
 
    // now lets convert the received keywordlist into an actual
    // ossimKeywordlist by using the parsStream method.
    std::ostringstream kwlStream;
 
    kwlStream << buf << ends;
 
    istringstream kwlInStream(kwlStream.str());
    theKwl.clear();
    theKwl.parseStream(kwlInStream);
    initializeAttributes();
    delete [] buf;
    buf = 0;
 
    if(traceDebug())
    {
       ossimNotify(ossimNotifyLevel_DEBUG) << "****************** KWL ************************" << std::endl;
       ossimNotify(ossimNotifyLevel_DEBUG) << theKwl << std::endl;
       ossimNotify(ossimNotifyLevel_DEBUG) << "**************** END KWL ************************" << std::endl;
 
    }
    loadProductSpec();
 #endif
 }

◆ writeToFile()

bool ossimIgen::writeToFile ( ossimImageFileWriter * writer )

protected

Consolidates job of actually writing to the output file.

Definition at line 594 of file ossimIgen.cpp.

References ossimImageFileWriter::addListener(), ossimMpi::instance(), and theProgressFlag.

Referenced by outputProduct().

 {
    ossimStdOutProgress* prog = 0;
    if ( (ossimMpi::instance()->getRank() == 0) && theProgressFlag)
    {
       // Add a listener to master.
       prog = new ossimStdOutProgress(0, true);
       writer->addListener(prog);
    }
 
    if (traceLog() && (ossimMpi::instance()->getRank() == 0))
    {
       ossimFilename logFile = writer->getFilename();
       logFile.setExtension(ossimString("log"));
 
       ossimRefPtr<ossimConnectableContainer> container = new ossimConnectableContainer;
       writer->fillContainer(*container.get());
       ossimKeywordlist logKwl;
       container->saveState(logKwl);
       logKwl.write(logFile.c_str());
    }
 
    try
    {
       writer->execute();
    }
 
    // Catch internal exceptions:
    catch(const ossimException& e)
    {
       ossimNotify(ossimNotifyLevel_FATAL)
          << "ossimIgen::outputProduct ERROR:\n"
          << "Caught exception!\n"
          << e.what()
          << std::endl;
       return false;
    }
    catch(...)
    {
       ossimNotify(ossimNotifyLevel_FATAL)
          << "ossimIgen::outputProduct ERROR:\n"
          << "Unknown exception caught!\n"
          << std::endl;
       return false;
    }
 
    if (prog)
    {
       writer->removeListener(prog);
       delete prog;
       prog = 0;
    }
 
    return true;
 }