From f7a9549bd6ad83f2e0bceec9cddacfa5e3f84a54 Mon Sep 17 00:00:00 2001
From: Mike Buland <eichlan@xagasoft.com>
Date: Mon, 1 May 2006 17:11:04 +0000
Subject: libbu++ is finally laid out the way it should be, trunk, branches,
 and tags.

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

(limited to 'src/programchain.cpp')

diff --git a/src/programchain.cpp b/src/programchain.cpp
new file mode 100644
index 0000000..4e53ac8
--- /dev/null
+++ b/src/programchain.cpp
@@ -0,0 +1,113 @@
+/***************************************************************************
+                          programchain.cpp  -  description
+                             -------------------
+    begin                : Sat Sep 6 2003
+    copyright            : (C) 2003 by Mike Buland
+    email                : eichlan@yf-soft.com
+ ***************************************************************************/
+
+/***************************************************************************
+ *                                                                         *
+ *   This program is free software; you can redistribute it and/or modify  *
+ *   it under the terms of the GNU General Public License as published by  *
+ *   the Free Software Foundation; either version 2 of the License, or     *
+ *   (at your option) any later version.                                   *
+ *                                                                         *
+ ***************************************************************************/
+
+#include <stdlib.h>
+#include "programchain.h"
+
+ProgramChain::ProgramChain()
+{
+	pLog = MultiLog::getLog();
+	pLog->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 )
+		{
+			pLog->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