* This is needed because the way the servers are represented in the ECOMP product is as their fully qualified URL's. * This is very problematic, because we cant identify their region from the URL, URL's change, and we cant identify the * versions of the service implementations. In otherwords, the URL does not provide us enough information. *
** The zone abstraction layer is designed to detect the versions of the services dynamically, and step up or down to * match those reported versions. In order to do that, we need to know before hand what region we are accessing (since * the supported versions may be different by regions). We will need to authenticate to the identity service in order to * do this, plus we have to duplicate the code supporting proxies and trusted hosts that exists in the abstraction * layer, but that cant be helped. *
** What we do to circumvent this is connect to the provider using the lowest supported identity api, and read the entire * service catalog into this object. Then, we parse the vm URL to extract the host and port and match that to the * compute services defined in the catalog. When we find a compute service that has the same host name and port, * whatever region that service is supporting is the region for that server. *
** While we really only need to do this for compute nodes, there is no telling what other situations may arise where the * full service catalog may be needed. Also, there is very little additional cost (additional RAM) associated with * caching the full service catalog since there is no way to list only a portion of it. *
*/ public abstract class ServiceCatalog { /** * The openstack connector version to use */ public static final String CLIENT_CONNECTOR_CLASS = "com.woorea.openstack.connector.JaxRs20Connector"; /** * The service name for the compute service endpoint */ public static final String COMPUTE_SERVICE = "compute"; //$NON-NLS-1$ /** * The default domain for authentication */ public static final String DEFAULT_DOMAIN = "Default"; /** * The service name for the identity service endpoint */ public static final String IDENTITY_SERVICE = "identity"; //$NON-NLS-1$ /** * The service name for the compute service endpoint */ public static final String IMAGE_SERVICE = "image"; //$NON-NLS-1$ /** * The service name for the metering service endpoint */ public static final String METERING_SERVICE = "metering"; //$NON-NLS-1$ /** * The service name for the network service endpoint */ public static final String NETWORK_SERVICE = "network"; //$NON-NLS-1$ /** * The service name for the persistent object service endpoint */ public static final String OBJECT_SERVICE = "object-store"; //$NON-NLS-1$ /** * The service name for the orchestration service endpoint */ public static final String ORCHESTRATION_SERVICE = "orchestration"; //$NON-NLS-1$ /** * The service name for the volume service endpoint */ public static final String VOLUME_SERVICE = "volume"; //$NON-NLS-1$ /** * The logger to be used */ protected static final EELFLogger logger = EELFManager.getInstance().getLogger(ServiceCatalog.class); /** * The password for authentication */ protected String credential; /** * The domain for authentication */ protected String domain; /** * The time (local) that the token expires and we need to re-authenticate */ protected long expiresLocal; /** * The url of the identity service */ protected String identityURL; /** * The user id for authentication */ protected String principal; /** * The project or tenant identifier */ protected String projectIdentifier; /** * Properties for proxy information */ protected Properties properties; /** * The set of all regions that have been defined */ protected Set
* This method is used to track requests made to the various service implementations and to provide additional
* information for diagnostic purposes. The RequestState class stores the state in thread-local storage
* and is available to all code on that thread.
*
* This method first obtains the stack trace and scans the stack backward for the call to this method. It then backs * up one more call and assumes that method is the request that we are "tracking". *
* * @param states A variable argument list of additional state values that the caller wants to add to the request * state thread-local object to track the context. */ protected void trackRequest(State... states) { RequestState.clear(); for (State state : states) { RequestState.put(state.getName(), state.getValue()); } Thread currentThread = Thread.currentThread(); StackTraceElement[] stack = currentThread.getStackTrace(); if (stack != null && stack.length > 0) { int index = 0; StackTraceElement element = null; for (; index < stack.length; index++) { element = stack[index]; if ("trackRequest".equals(element.getMethodName())) { //$NON-NLS-1$ break; } } index++; if (index < stack.length) { element = stack[index]; RequestState.put(RequestState.METHOD, element.getMethodName()); RequestState.put(RequestState.CLASS, element.getClassName()); RequestState.put(RequestState.LINE_NUMBER, Integer.toString(element.getLineNumber())); RequestState.put(RequestState.THREAD, currentThread.getName()); // RequestState.put(RequestState.PROVIDER, context.getProvider().getName()); // RequestState.put(RequestState.TENANT, context.getTenantName()); // RequestState.put(RequestState.PRINCIPAL, context.getPrincipal()); } } } }