| /* |
| * 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.OCI.IIOP; |
| |
| import java.util.logging.Level; |
| import java.util.logging.Logger; |
| |
| import org.apache.yoko.orb.OB.Assert; |
| import org.apache.yoko.orb.OCI.IIOP.PLUGIN_ID; |
| import org.omg.CORBA.ORBPackage.InvalidName; |
| import org.omg.IOP.Codec; |
| import org.omg.IOP.CodecFactory; |
| import org.omg.IOP.ENCODING_CDR_ENCAPS; |
| import org.omg.IOP.Encoding; |
| import org.omg.IOP.CodecFactoryPackage.UnknownEncoding; |
| |
| final class AccFactory_impl extends org.omg.CORBA.LocalObject implements |
| org.apache.yoko.orb.OCI.AccFactory { |
| |
| // the real logger backing instance. We use the interface class as the locator |
| static final Logger logger = Logger.getLogger(org.apache.yoko.orb.OCI.AccFactory.class.getName()); |
| private static final Encoding CDR_1_2_ENCODING = new Encoding(ENCODING_CDR_ENCAPS.value, (byte) 1, (byte) 2); |
| // |
| // AccFactory information |
| // |
| private AccFactoryInfo_impl info_; |
| |
| private org.omg.CORBA.ORB orb_; // The ORB |
| |
| private ConnectionHelper connectionHelper_; // client connection helper |
| |
| private ListenerMap listenMap_; |
| private ExtendedConnectionHelper extendedConnectionHelper_; |
| |
| // ------------------------------------------------------------------ |
| // Standard IDL to Java Mapping |
| // ------------------------------------------------------------------ |
| |
| public String id() { |
| return PLUGIN_ID.value; |
| } |
| |
| public int tag() { |
| return org.omg.IOP.TAG_INTERNET_IOP.value; |
| } |
| |
| public org.apache.yoko.orb.OCI.AccFactoryInfo get_info() { |
| return info_; |
| } |
| |
| public org.apache.yoko.orb.OCI.Acceptor create_acceptor(String[] params) |
| throws org.apache.yoko.orb.OCI.InvalidParam { |
| String bind = null; |
| String[] hosts = null; |
| boolean keepAlive = true; |
| boolean multiProfile = false; |
| int port = 0; |
| int backlog = 0; |
| boolean numeric = false; |
| |
| int i = 0; |
| while (i < params.length) { |
| if (params[i].equals("--backlog")) { |
| if (i + 1 >= params.length) |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "argument expected " + "for --backlog"); |
| String arg = params[i + 1]; |
| try { |
| backlog = Integer.valueOf(arg).intValue(); |
| } catch (NumberFormatException ex) { |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "invalid argument " + "for backlog"); |
| } |
| if (backlog < 1 || backlog > 65535) |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "invalid backlog"); |
| i += 2; |
| } else if (params[i].equals("--bind")) { |
| if (i + 1 >= params.length) |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "argument expected " + "for --bind"); |
| bind = params[i + 1]; |
| i += 2; |
| } else if (params[i].equals("--host")) { |
| if (i + 1 >= params.length) |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "argument expected " + "for --host"); |
| java.util.Vector vec = new java.util.Vector(); |
| int start = 0; |
| String str = params[i + 1]; |
| while (true) { |
| while (start < str.length() && str.charAt(start) == ' ') |
| start++; |
| if (start >= str.length()) |
| break; |
| int comma = str.indexOf(',', start); |
| if (comma == start) |
| start++; |
| else { |
| if (comma == -1) |
| comma = str.length(); |
| int end = comma - 1; |
| while (str.charAt(end) == ' ') |
| end--; |
| vec.addElement(str.substring(start, end + 1)); |
| start = comma + 1; |
| } |
| } |
| if (vec.size() == 0) |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "invalid argument " + "for --host"); |
| hosts = new String[vec.size()]; |
| vec.copyInto(hosts); |
| i += 2; |
| } else if (params[i].equals("--multi-profile")) { |
| multiProfile = true; |
| i++; |
| } else if (params[i].equals("--no-keepalive")) { |
| keepAlive = false; |
| i++; |
| } else if (params[i].equals("--numeric")) { |
| numeric = true; |
| i++; |
| } else if (params[i].equals("--port")) { |
| if (i + 1 >= params.length) |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "argument expected " + "for --port"); |
| String arg = params[i + 1]; |
| try { |
| port = Integer.valueOf(arg).intValue(); |
| } catch (NumberFormatException ex) { |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "invalid argument " + "for port"); |
| } |
| if (port < 1 || port > 65535) |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "invalid port"); |
| i += 2; |
| } else if (connectionHelper_ != null){ |
| throw new org.apache.yoko.orb.OCI.InvalidParam( |
| "unknown parameter: " + params[i]); |
| } else { |
| i++; |
| } |
| } |
| |
| if (hosts == null) { |
| hosts = new String[1]; |
| hosts[0] = org.apache.yoko.orb.OB.Net.getCanonicalHostname(numeric); |
| } |
| |
| logger.fine("Creating acceptor for port=" + port); |
| Codec codec; |
| try { |
| codec = ((CodecFactory) orb_.resolve_initial_references("CodecFactory")).create_codec(CDR_1_2_ENCODING); |
| } catch (InvalidName e) { |
| throw new org.apache.yoko.orb.OCI.InvalidParam("Could not obtain codec factory using name 'CodecFactory'"); |
| } catch (UnknownEncoding e) { |
| throw new org.apache.yoko.orb.OCI.InvalidParam("Could not obtain codec using encoding " + CDR_1_2_ENCODING); |
| } |
| |
| return new Acceptor_impl(bind, hosts, multiProfile, port, backlog, keepAlive, connectionHelper_, extendedConnectionHelper_, listenMap_, params, codec); |
| } |
| |
| public void change_key(org.omg.IOP.IORHolder ior, byte[] key) { |
| // |
| // Extract the IIOP profile information from the provided IOR |
| // |
| for (int profile = 0; profile < ior.value.profiles.length; profile++) { |
| if (ior.value.profiles[profile].tag == org.omg.IOP.TAG_INTERNET_IOP.value) { |
| // |
| // Extract the 1_0 profile body |
| // |
| byte[] data = ior.value.profiles[profile].profile_data; |
| org.apache.yoko.orb.OCI.Buffer buf = new org.apache.yoko.orb.OCI.Buffer( |
| data, data.length); |
| org.apache.yoko.orb.CORBA.InputStream in = new org.apache.yoko.orb.CORBA.InputStream( |
| buf, 0, false, null, null); |
| in._OB_readEndian(); |
| org.omg.IIOP.ProfileBody_1_0 body = org.omg.IIOP.ProfileBody_1_0Helper |
| .read(in); |
| |
| // |
| // Read components if the IIOP version is > 1.0 |
| // |
| org.omg.IOP.TaggedComponent[] components; |
| if (body.iiop_version.major > 1 || body.iiop_version.minor > 0) { |
| int len = in.read_ulong(); |
| components = new org.omg.IOP.TaggedComponent[len]; |
| for (int j = 0; j < len; j++) |
| components[j] = org.omg.IOP.TaggedComponentHelper |
| .read(in); |
| } else |
| components = new org.omg.IOP.TaggedComponent[0]; |
| |
| // |
| // Fill in the new object-key |
| // |
| body.object_key = key; |
| |
| // |
| // Remarshal the new body |
| // |
| org.apache.yoko.orb.OCI.Buffer buf2 = new org.apache.yoko.orb.OCI.Buffer(); |
| org.apache.yoko.orb.CORBA.OutputStream out = new org.apache.yoko.orb.CORBA.OutputStream( |
| buf2); |
| out._OB_writeEndian(); |
| org.omg.IIOP.ProfileBody_1_0Helper.write(out, body); |
| |
| // |
| // Remarshal the components if the IIOP version is > 1.0 |
| // |
| if (body.iiop_version.major > 1 || body.iiop_version.minor > 0) { |
| out.write_ulong(components.length); |
| for (int i = 0; i < components.length; i++) |
| org.omg.IOP.TaggedComponentHelper.write(out, |
| components[i]); |
| } |
| ior.value.profiles[profile].profile_data = new byte[buf2 |
| .length()]; |
| System.arraycopy(buf2.data(), 0, |
| ior.value.profiles[profile].profile_data, 0, buf2 |
| .length()); |
| } |
| } |
| } |
| |
| // ------------------------------------------------------------------ |
| // Yoko internal functions |
| // Application programs must not use these functions directly |
| // ------------------------------------------------------------------ |
| |
| public AccFactory_impl(org.omg.CORBA.ORB orb, ListenerMap lm, ConnectionHelper helper, ExtendedConnectionHelper extendedHelper) { |
| Assert._OB_assert((helper == null) ^ (extendedHelper == null)); |
| orb_ = orb; |
| info_ = new AccFactoryInfo_impl(); |
| listenMap_ = lm; |
| connectionHelper_ = helper; |
| extendedConnectionHelper_ = extendedHelper; |
| } |
| |
| } |
