Ok, no code is left in src, it's all in src/old. We'll gradually move code back

into src as it's fixed and re-org'd.  This includes tests, which, I may write a
unit test system into libbu++ just to make my life easier.

1 files changed, 96 insertions, 0 deletions

diff --git a/src/old/programchain.cpp b/src/old/programchain.cpp
new file mode 100644
index 0000000..6120d58
--- /dev/null
+++ b/src/old/programchain.cpp
@@ -0,0 +1,96 @@
+#include <stdlib.h>
+#include "programchain.h"
+
+ProgramChain::ProgramChain() :
+        xLog( MultiLog::getInstance() )
+{
+        xLog.LineLog( MultiLog::LStatus, "Program Chain Initialized." );
+}
+
+ProgramChain::~ProgramChain()
+{
+}
+
+bool ProgramChain::addLink( ProgramLink *pLink )
+{
+        if( pLink->init() == false )
+        {
+                emergencyShutdown();
+                return false;
+        }
+
+        lLink.append( pLink );
+
+        pLink->setChain( this );
+
+        return true;
+}
+
+ProgramLink *ProgramChain::getLink( const char *lpName )
+{
+        char a;
+        a = lpName[0];
+        return NULL;
+}
+
+ProgramLink *ProgramChain::getBaseLink()
+{
+        return NULL;
+}
+
+bool ProgramChain::execChainOnce()
+{
+        int nLen = lLink.getSize();
+        for( int j = 0; j < nLen; j++ )
+        {
+                if( ((ProgramLink *)lLink[j])->timeSlice() == false )
+                {
+                        xLog.LineLog( MultiLog::LInfo, "Shutting down due to signal from link #%d", j );
+                        emergencyShutdown();
+                        return false;
+                }
+        }
+
+        return true;
+}
+
+bool ProgramChain::enterChainLoop()
+{
+        for(;;)
+        {
+                if( execChainOnce() == false )
+                {
+                        return false;
+                }
+        }
+
+        return true;
+}
+
+void ProgramChain::emergencyShutdown()
+{
+        int nLen = lLink.getSize();
+        for( int j = 0; j < nLen; j++ )
+        {
+                ((ProgramLink *)lLink[j])->deInit();
+                delete (ProgramLink *)lLink[j];
+        }
+        lLink.empty();
+}
+
+LinkMessage *ProgramChain::broadcastIRM( LinkMessage *pMsgOut, ProgramLink *pSender )
+{
+        int nLen = lLink.getSize();
+        for( int j = 0; j < nLen; j++ )
+        {
+                LinkMessage *pMsg = ((ProgramLink *)lLink[j])->processIRM( pMsgOut );
+                if( pMsg != NULL )
+                {
+                        delete pMsgOut;
+                        return pMsg;
+                }
+        }
+
+        delete pMsgOut;
+        return NULL;
+}