diff options
Diffstat (limited to 'sca-cpp/tags/cpp-stable-20060304/sca/runtime/core/src/tuscany/sca/core/SCAEntryPoint.cpp')
| -rw-r--r-- | sca-cpp/tags/cpp-stable-20060304/sca/runtime/core/src/tuscany/sca/core/SCAEntryPoint.cpp | 215 |
1 files changed, 215 insertions, 0 deletions
diff --git a/sca-cpp/tags/cpp-stable-20060304/sca/runtime/core/src/tuscany/sca/core/SCAEntryPoint.cpp b/sca-cpp/tags/cpp-stable-20060304/sca/runtime/core/src/tuscany/sca/core/SCAEntryPoint.cpp new file mode 100644 index 0000000000..a505ba9636 --- /dev/null +++ b/sca-cpp/tags/cpp-stable-20060304/sca/runtime/core/src/tuscany/sca/core/SCAEntryPoint.cpp @@ -0,0 +1,215 @@ +/* + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* $Rev$ $Date: 2005/12/22 11:33:21 $ */ + +#include "tuscany/sca/core/SCAEntryPoint.h" + +#include "tuscany/sca/util/Exceptions.h" +#include "tuscany/sca/util/Utils.h" +#include "tuscany/sca/util/Logging.h" +#include "tuscany/sca/core/SCARuntime.h" +#include "tuscany/sca/core/ComponentServiceWrapper.h" +#include "tuscany/sca/core/ExternalServiceWrapper.h" +using namespace osoa::sca; + +namespace tuscany +{ + namespace sca + { + // =========== + // Constructor + // =========== + SCAEntryPoint::SCAEntryPoint(const char* epName) + : subsystem(0), entrypoint(0), module(0) + { + LOGENTRY(1,"SCAEntryPoint::constructor"); + string message; + + // initialize the system if necessary + System* system = SCARuntime::getInstance()->getSystem(); + + string subsystemName; + string entrypointName; + + Utils::tokeniseUri(epName, subsystemName, entrypointName); + + // -------------------- + // locate the Subsystem + // -------------------- + subsystem = system->findSubsystem(subsystemName); + if (!subsystem) + { + throw EntryPointNotFoundException(epName); + } + + // --------------------- + // locate the EntryPoint + // --------------------- + entrypoint = subsystem->findEntryPoint(entrypointName); + if (entrypoint) + { + // found Subsystem EntryPoint + throw EntryPointNotFoundException("Subsystem EntryPoint not yet supported"); + } + else + { + // ----------------------------------- + // locate the EntryPoint in the Module + // ----------------------------------- + string moduleComponentName; + Utils::tokeniseUri(entrypointName, moduleComponentName, entrypointName); + module = subsystem->findModuleByComponentName(moduleComponentName); + if (module) + { + dataFactory = module->getDataFactory(); + entrypoint = module->findEntryPoint(entrypointName); + } + } + + if (!entrypoint) + { + throw EntryPointNotFoundException(epName); + } + + // --------------------------------- + // Get Wrappers for each wire target + // --------------------------------- + + // Get the target services from the EntryPoint + const EntryPoint::TARGETS& targets = entrypoint->getTargets(); + + // -------------------- + // Validate the request + // -------------------- + switch (entrypoint->getMultiplicity()) + { + case EntryPoint::ONE_MANY: + case EntryPoint::ONE_ONE: + { + if (targets.size() == 0) + { + message = "EntryPoint " + entrypoint->getName() + " not wired"; + throw ServiceNotFoundException(message.c_str()); + } + } + default: + { + } + } // end switch + + for (EntryPoint::TARGETS::const_iterator iter = targets.begin(); + iter!=targets.end(); + iter++) + { + ServiceWrapper* service = getServiceWrapper(*iter); + if (service) + { + services.push_back(service); + } + } + + LOGEXIT(1,"SCAEntryPoint::constructor"); + } + + // ========== + // Destructor + // ========== + SCAEntryPoint::~SCAEntryPoint() + { + LOGENTRY(1,"SCAEntryPoint::destructor"); + + // Delete any ServiceWrappers + for (SERVICES::iterator iter = services.begin(); iter < services.end(); iter++) + { + delete (*iter); + } + LOGEXIT(1,"SCAEntryPoint::destructor"); + } + + + // ====================================================================== + // invoke: + // ====================================================================== + SCA_API DataObjectPtr SCAEntryPoint::invoke(const char* operationName, DataObjectPtr inDataObject) + { + string message; + + // -------------------- + // Validate the request + // -------------------- + if (services.size() == 0) + { + message = "EntryPoint " + entrypoint->getName() + " not wired"; + throw ServiceNotFoundException(message.c_str()); + } + + // ------------------- + // Invoke each target + // ------------------- + Operation operation(operationName, 1); + operation.setParameter(0, &inDataObject); + DataObjectPtr ret; + operation.setReturnValue((void *)&ret); + + for (SERVICES::iterator iter = services.begin(); iter < services.end(); iter++) + { + (*iter)->invoke(operation); + } + + return ret; + } + + + // ====================================================================== + // getServiceWrapper: Create and return an instance of the ServiceWrapper + // ====================================================================== + ServiceWrapper* SCAEntryPoint::getServiceWrapper(WireTarget* target) + { + // ------------------------- + // Determine type of Service + // ------------------------- + switch (target->getServiceType()) + { + case WireTarget::ExternalServiceType: + { + // ---------------- + // External Service + // ---------------- + return ExternalServiceWrapper::createServiceWrapper((ExternalService*)target); + } + + case WireTarget::ComponentServiceType: + { + // ----------------- + // Component Service + // ----------------- + return ComponentServiceWrapper::createServiceWrapper((Service*)target); + } + + default: + { + string message = "Undefined wire target type for : "; + message = message + target->getName(); + throw ServiceNotFoundException(message.c_str()); + } + } // end switch + } + + + } // End namespace sca +} // End namespace tuscany |