From f4c20290509d7ed3a8fd5304577e7a4cc0b9d974 Mon Sep 17 00:00:00 2001
From: Mike Buland <eichlan@xagasoft.com>
Date: Tue, 3 Apr 2007 03:49:53 +0000
Subject: 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.

---
 src/old/programchain.cpp | 96 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 96 insertions(+)
 create mode 100644 src/old/programchain.cpp

(limited to 'src/old/programchain.cpp')

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;
+}
-- 
cgit v1.2.3