| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You 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. |
| */ |
| |
| package org.apache.yoko.orb.OB; |
| |
| import org.apache.yoko.orb.OB.CorbalocProtocol; |
| import org.apache.yoko.orb.OB.CorbalocURLScheme; |
| |
| public class CorbalocURLScheme_impl extends org.omg.CORBA.LocalObject implements |
| CorbalocURLScheme { |
| private ORBInstance orbInstance_; |
| |
| private java.util.Hashtable protocols_ = new java.util.Hashtable(); |
| |
| // ------------------------------------------------------------------ |
| // CorbalocURLScheme_impl private member implementations |
| // ------------------------------------------------------------------ |
| |
| private static byte[] stringToKey(String keyStr) { |
| byte[] result = new byte[keyStr.length()]; |
| |
| for (int i = 0; i < result.length; i++) { |
| char ch = keyStr.charAt(i); |
| if (ch > 255) { |
| throw new org.omg.CORBA.BAD_PARAM( |
| MinorCodes |
| .describeBadParam(org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart) |
| + ": invalid character in key, char value = 0x" + Integer.toHexString(ch), |
| org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart, |
| org.omg.CORBA.CompletionStatus.COMPLETED_NO); |
| } |
| result[i] = (byte) ch; |
| } |
| |
| return result; |
| } |
| |
| private org.omg.CORBA.Object parse_addresses(String str, int startIdx, |
| int endIdx, String keyStr) { |
| // |
| // Check for rir: |
| // |
| if (str.substring(startIdx, startIdx + 4).equals("rir:")) { |
| int comma = str.indexOf(',', startIdx); |
| if (comma != -1 && comma <= endIdx) { |
| throw new org.omg.CORBA.BAD_PARAM( |
| MinorCodes |
| .describeBadParam(org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart) |
| + ": rir cannot be used with other protocols", |
| org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart, |
| org.omg.CORBA.CompletionStatus.COMPLETED_NO); |
| } |
| |
| if (startIdx + 3 != endIdx) { |
| throw new org.omg.CORBA.BAD_PARAM(org.apache.yoko.orb.OB.MinorCodes |
| .describeBadParam(org.apache.yoko.orb.OB.MinorCodes.MinorBadAddress) |
| + ": rir does not allow an address", |
| org.apache.yoko.orb.OB.MinorCodes.MinorBadAddress, |
| org.omg.CORBA.CompletionStatus.COMPLETED_NO); |
| } |
| |
| try { |
| InitialServiceManager initialServiceManager = orbInstance_.getInitialServiceManager(); |
| return initialServiceManager.resolveInitialReferences(keyStr); |
| } catch (org.omg.CORBA.ORBPackage.InvalidName ex) { |
| throw new org.omg.CORBA.BAD_PARAM( |
| MinorCodes |
| .describeBadParam(org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart) |
| + ": invalid initial reference token \"" + keyStr + "\"", |
| org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart, |
| org.omg.CORBA.CompletionStatus.COMPLETED_NO); |
| } |
| } |
| |
| // |
| // Unescape stringified object key and convert to octets |
| // |
| byte[] key = stringToKey(URLUtil.unescapeURL(keyStr)); |
| |
| // |
| // Convert addresses (separated by ',') into IOR profiles |
| // |
| java.util.Vector profiles = new java.util.Vector(); |
| int pos = startIdx; |
| while (pos <= endIdx) { |
| // |
| // Get the protocol identifier - we'll assume that protocols are |
| // terminated by a ':' |
| // |
| String protocol; |
| int colon = str.indexOf(':', pos); |
| if (colon == -1) { |
| throw new org.omg.CORBA.BAD_PARAM( |
| MinorCodes |
| .describeBadParam(org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart) |
| + ": no protocol", |
| org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart, |
| org.omg.CORBA.CompletionStatus.COMPLETED_NO); |
| } |
| else if (colon > endIdx) { |
| break; |
| } |
| if (colon == pos) {// ":" is shorthand for "iiop:" |
| protocol = "iiop"; |
| } |
| else { |
| protocol = str.substring(pos, colon).toLowerCase(); |
| } |
| pos = colon; |
| |
| // |
| // Check for rir (again) |
| // |
| if (protocol.equals("rir")) { |
| throw new org.omg.CORBA.BAD_PARAM( |
| MinorCodes |
| .describeBadParam(org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart) |
| + ": rir cannot be used with other protocols", |
| org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart, |
| org.omg.CORBA.CompletionStatus.COMPLETED_NO); |
| } |
| |
| // |
| // Get the protocol address |
| // |
| String addr; |
| if (pos == endIdx) { |
| addr = ""; |
| pos++; |
| } else { |
| int addrStart = pos + 1; // skip ':' |
| int addrEnd; |
| int comma = str.indexOf(',', addrStart); |
| if (comma == -1 || comma > endIdx) { |
| addrEnd = endIdx; |
| pos = endIdx + 1; |
| } else { |
| addrEnd = comma - 1; |
| pos = comma + 1; |
| } |
| addr = str.substring(addrStart, addrEnd + 1); |
| } |
| |
| // |
| // Find the protocol object |
| // |
| CorbalocProtocol p = find_protocol(protocol); |
| if (p != null) { |
| org.omg.IOP.TaggedProfile profile = p.parse_address(addr, key); |
| profiles.addElement(profile); |
| } |
| } |
| |
| if (profiles.size() == 0) { |
| throw new org.omg.CORBA.BAD_PARAM(org.apache.yoko.orb.OB.MinorCodes |
| .describeBadParam(org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart) |
| + ": no valid protocol addresses", |
| org.apache.yoko.orb.OB.MinorCodes.MinorBadSchemeSpecificPart, |
| org.omg.CORBA.CompletionStatus.COMPLETED_NO); |
| } |
| |
| org.omg.IOP.IOR ior = new org.omg.IOP.IOR(); |
| ior.type_id = ""; |
| ior.profiles = new org.omg.IOP.TaggedProfile[profiles.size()]; |
| profiles.copyInto(ior.profiles); |
| |
| ObjectFactory objectFactory = orbInstance_.getObjectFactory(); |
| return objectFactory.createObject(ior); |
| } |
| |
| // ------------------------------------------------------------------ |
| // CorbalocURLScheme_impl constructor |
| // ------------------------------------------------------------------ |
| |
| public CorbalocURLScheme_impl(ORBInstance orbInstance) { |
| orbInstance_ = orbInstance; |
| } |
| |
| // ------------------------------------------------------------------ |
| // Standard IDL to Java Mapping |
| // ------------------------------------------------------------------ |
| |
| public String name() { |
| return "corbaloc"; |
| } |
| |
| public org.omg.CORBA.Object parse_url(String url) { |
| // |
| // Get the object key |
| // |
| int slash = url.indexOf('/'); |
| |
| // |
| // Although an object key is optional according to the specification, |
| // we consider this to be an invalid URL |
| // |
| if (slash == -1) { |
| throw new org.omg.CORBA.BAD_PARAM(org.apache.yoko.orb.OB.MinorCodes |
| .describeBadParam(org.apache.yoko.orb.OB.MinorCodes.MinorOther) |
| + ": no key specified", org.apache.yoko.orb.OB.MinorCodes.MinorOther, |
| org.omg.CORBA.CompletionStatus.COMPLETED_NO); |
| } |
| |
| int addrStart = 9; // skip "corbaloc:" |
| int addrEnd = slash - 1; |
| if (addrStart == slash) { |
| throw new org.omg.CORBA.BAD_PARAM(org.apache.yoko.orb.OB.MinorCodes |
| .describeBadParam(org.apache.yoko.orb.OB.MinorCodes.MinorBadAddress) |
| + ": no protocol address", org.apache.yoko.orb.OB.MinorCodes.MinorBadAddress, |
| org.omg.CORBA.CompletionStatus.COMPLETED_NO); |
| } |
| |
| String key = url.substring(slash + 1); |
| return parse_addresses(url, addrStart, addrEnd, key); |
| } |
| |
| public void destroy() { |
| java.util.Enumeration e = protocols_.elements(); |
| while (e.hasMoreElements()) { |
| CorbalocProtocol protocol = (CorbalocProtocol) e.nextElement(); |
| protocol.destroy(); |
| } |
| protocols_.clear(); |
| orbInstance_ = null; |
| } |
| |
| public void add_protocol(CorbalocProtocol protocol) |
| throws org.apache.yoko.orb.OB.CorbalocURLSchemePackage.ProtocolAlreadyExists { |
| String name = protocol.name(); |
| if (protocols_.containsKey(name)) { |
| throw new org.apache.yoko.orb.OB.CorbalocURLSchemePackage.ProtocolAlreadyExists(); |
| } |
| protocols_.put(name, protocol); |
| } |
| |
| public CorbalocProtocol find_protocol(String name) { |
| return (CorbalocProtocol) protocols_.get(name); |
| } |
| } |
