cortex/NodeManager/NodeGroup.cpp

32 // NodeGroup.cpp
34 #include "NodeGroup.h"
72 status_t NodeGroup::release() {
75 		"NodeGroup::release()\n"));
110 // call release() rather than deleting NodeGroup objects
111 NodeGroup::~NodeGroup() {
115 		"~NodeGroup()\n"));
131 //inline uint32 NodeGroup::id() const { return m_id; }
138 const char* NodeGroup::name() const {
143 status_t NodeGroup::setName(const char* name) {
150 uint32 NodeGroup::countNodes() const {
155 NodeRef* NodeGroup::nodeAt(
170 status_t NodeGroup::addNode(
174 		"NodeGroup::addNode()\n"));
249 status_t NodeGroup::removeNode(
253 		"NodeGroup::removeNode()\n"));
299 //				"* NodeGroup::removeNode(): no sync-capable nodes left!\n"));
311 			"*** NodeGroup::removeNode('%s'): error from node->_stop():\n"
346 status_t NodeGroup::removeNode(
350 		"NodeGroup::removeNode(by index)\n"));
359 uint32 NodeGroup::groupFlags() const {
364 status_t NodeGroup::setGroupFlags(
374 bool NodeGroup::canCycle() const {
388 NodeGroup::transport_state_t NodeGroup::transportState() const {
402 status_t NodeGroup::setStartPosition(
407 		"NodeGroup::setStartPosition(%lld)\n", start));
444 bigtime_t NodeGroup::startPosition() const {
464 status_t NodeGroup::setEndPosition(
469 		"NodeGroup::setEndPosition(%lld)\n", end));
529 bigtime_t NodeGroup::endPosition() const {
546 status_t NodeGroup::preroll() {
548 		"NodeGroup::preroll()\n"));
557 status_t NodeGroup::start() {
559 		"NodeGroup::start()\n"));
568 status_t NodeGroup::stop() {
570 		"NodeGroup::stop()\n"));
580 status_t NodeGroup::roll() {
582 		"NodeGroup::roll()\n"));
603 status_t NodeGroup::getTimeSource(
614 status_t NodeGroup::setTimeSource(
649 //			"* NodeGroup::setTimeSource(): setSyncNode() failed: %s\n",
673 BMediaNode::run_mode NodeGroup::runMode() const {
678 status_t NodeGroup::setRunMode(BMediaNode::run_mode mode) {
697 //			&NodeGroup::setRunModeFor)
708 void NodeGroup::MessageReceived(
712 //		"NodeGroup::MessageReceived():\n"));
729 						"* NodeGroup::MessageReceived(M_SET_TIME_SOURCE):\n"
745 						"* NodeGroup::MessageReceived(M_SET_RUN_MODE):\n"
753 						"* NodeGroup::MessageReceived(M_SET_RUN_MODE):\n"
768 						"* NodeGroup::MessageReceived(M_SET_START_POSITION):\n"
782 						"* NodeGroup::MessageReceived(M_SET_END_POSITION):\n"
824 NodeGroup::NodeGroup() :
836 void NodeGroup::observerAdded(
845 void NodeGroup::observerRemoved(
854 void NodeGroup::notifyRelease() {
862 void NodeGroup::releaseComplete() {
870 bool NodeGroup::lock(
874 	D_LOCK(("*** NodeGroup::lock(): %ld\n", find_thread(0)));
879 	D_LOCK(("*** NodeGroup::lock() ACQUIRED: %ld\n", find_thread(0)));
884 bool NodeGroup::unlock(
887 	D_LOCK(("*** NodeGroup::unlock(): %ld\n", find_thread(0)));
892 	D_LOCK(("*** NodeGroup::unlock() RELEASED: %ld\n", find_thread(0)));
897 bool NodeGroup::isLocked(
908 NodeGroup::NodeGroup(
914 	m_lock("NodeGroup::m_lock"),
944 			"*** NodeGroup(): roster->GetTimeSource() failed:\n"
954 uint32 NodeGroup::s_nextID = 1;
955 uint32 NodeGroup::NextID() {
966 void NodeGroup::_refCycleChanged(
970 		"NodeGroup::_refCycleChanged('%s')\n",
986 void NodeGroup::_refLatencyChanged(
990 		"NodeGroup::_refLatencyChanged('%s')\n",
1015 void NodeGroup::_refStopped(
1019 		"NodeGroup::_refStopped('%s')\n",
1053 status_t NodeGroup::_preroll() {
1057 		"NodeGroup::_preroll()\n"));
1091 //			bound_method(*this, &NodeGroup::prerollNode),
1102 //class NodeGroup::calcLatencyFn { public:
1163 status_t NodeGroup::_start() {
1167 		"NodeGroup::_start()\n"));
1200 				"! NodeGroup('%s')::_start():\n"
1227 				"! NodeGroup('%s')::_start():\n"
1248 status_t NodeGroup::_stop() {
1251 		"NodeGroup::_stop()\n"));
1290 status_t NodeGroup::_roll() {
1293 		"NodeGroup::_roll()\n"));
1356 inline void NodeGroup::_changeState(
1374 inline void NodeGroup::_changeState(
1392 const char* const		_portName				= "NodeGroup::m_cyclePort";
1397 status_t NodeGroup::_initCycleThread() {
1401 		"NodeGroup::_initCycleThread()\n"));
1414 		"NodeGroup[cycleThread]",
1419 			"* NodeGroup::_initCycleThread(): spawn_thread() failed:\n"
1430 status_t NodeGroup::_destroyCycleThread() {
1434 		"NodeGroup::_destroyCycleThread()\n"));
1453 				"* NodeGroup::_destroyCycleThread(): port write failed; killing.\n"));
1482 bool NodeGroup::_cycleValid() {
1492 void NodeGroup::_cycleInit(
1497 		"NodeGroup::_cycleInit(%lld)\n",
1523 void NodeGroup::_cycleAddRef(
1552 void NodeGroup::_cycleRemoveRef(
1564 bigtime_t NodeGroup::_cycleBoundary() const {
1571 status_t NodeGroup::_CycleThread(void* user) {
1572 	((NodeGroup*)user)->_cycleThread();
1576 void NodeGroup::_cycleThread() {
1619 				"*** NodeGroup::_cycleThread(): LATE\n"
1644 				"* NodeGroup::_cycleThread(): read_port error:\n"
1673 					"* NodeGroup::_cycleThread(): unknown message code '%"
1689 void NodeGroup::_handleCycleService() {
1692 //		"NodeGroup::_handleCycleService()\n"));
1729 // END -- NodeGroup.cpp --