| /* |
| * 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.osgi.ProviderLocator; |
| import org.omg.IOP.ServiceContext; |
| import org.omg.SendingContext.CodeBase; |
| |
| import java.security.AccessController; |
| import java.security.PrivilegedAction; |
| import java.util.logging.Logger; |
| |
| public final class Util { |
| static final Logger logger = Logger.getLogger(Util.class.getName()); |
| // |
| // Print octets to stream |
| // |
| public static void printOctets(java.io.PrintStream out, byte[] oct, |
| int offset, int length) { |
| final int inc = 8; |
| |
| for (int i = offset; i < offset + length; i += inc) { |
| for (int j = i; j - i < inc; j++) { |
| if (j < offset + length) { |
| int n = (int) oct[j]; |
| if (n < 0) |
| n += 256; |
| String s; |
| if (n < 10) |
| s = " " + n; |
| else if (n < 100) |
| s = " " + n; |
| else |
| s = "" + n; |
| out.print(s + " "); |
| } else |
| out.print(" "); |
| } |
| |
| out.print('"'); |
| |
| for (int j = i; j < offset + length && j - i < inc; j++) { |
| if (oct[j] >= (byte) 32 && oct[j] < (byte) 127) |
| out.print((char) oct[j]); |
| else |
| out.print('.'); |
| } |
| |
| out.println('"'); |
| } |
| } |
| |
| // |
| // Copy a system exception |
| // |
| public static org.omg.CORBA.SystemException copySystemException( |
| org.omg.CORBA.SystemException ex) { |
| org.omg.CORBA.SystemException result = null; |
| |
| try { |
| Class c = ex.getClass(); |
| Class[] paramTypes = { String.class }; |
| java.lang.reflect.Constructor constr = c.getConstructor(paramTypes); |
| Object[] initArgs = { ex.getMessage() }; |
| result = (org.omg.CORBA.SystemException) constr |
| .newInstance(initArgs); |
| result.minor = ex.minor; |
| result.completed = ex.completed; |
| } catch (NoSuchMethodException e) { |
| Assert._OB_assert(ex); |
| } catch (InstantiationException e) { |
| Assert._OB_assert(ex); |
| } catch (IllegalAccessException e) { |
| Assert._OB_assert(ex); |
| } catch (IllegalArgumentException e) { |
| Assert._OB_assert(ex); |
| } catch (java.lang.reflect.InvocationTargetException e) { |
| Assert._OB_assert(ex); |
| } |
| |
| return result; |
| } |
| |
| // |
| // Unmarshal a system exception |
| // |
| public static org.omg.CORBA.SystemException unmarshalSystemException( |
| org.omg.CORBA.portable.InputStream in) { |
| String id = in.read_string(); |
| int minor = in.read_ulong(); |
| org.omg.CORBA.CompletionStatus status = org.omg.CORBA.CompletionStatus |
| .from_int(in.read_ulong()); |
| |
| if (id.equals("IDL:omg.org/CORBA/BAD_PARAM:1.0")) { |
| String reason = MinorCodes.describeBadParam(minor); |
| return new org.omg.CORBA.BAD_PARAM(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/NO_MEMORY:1.0")) { |
| String reason = MinorCodes.describeNoMemory(minor); |
| return new org.omg.CORBA.NO_MEMORY(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/IMP_LIMIT:1.0")) { |
| String reason = MinorCodes.describeImpLimit(minor); |
| return new org.omg.CORBA.IMP_LIMIT(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/COMM_FAILURE:1.0")) { |
| String reason = MinorCodes.describeCommFailure(minor); |
| return new org.omg.CORBA.COMM_FAILURE(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/INV_OBJREF:1.0")) { |
| return new org.omg.CORBA.INV_OBJREF(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/NO_PERMISSION:1.0")) { |
| return new org.omg.CORBA.NO_PERMISSION(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/INTERNAL:1.0")) { |
| return new org.omg.CORBA.INTERNAL(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/MARSHAL:1.0")) { |
| String reason = MinorCodes.describeMarshal(minor); |
| return new org.omg.CORBA.MARSHAL(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/INITIALIZE:1.0")) { |
| String reason = MinorCodes.describeInitialize(minor); |
| return new org.omg.CORBA.INITIALIZE(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/NO_IMPLEMENT:1.0")) { |
| String reason = MinorCodes.describeNoImplement(minor); |
| return new org.omg.CORBA.NO_IMPLEMENT(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/BAD_TYPECODE:1.0")) { |
| return new org.omg.CORBA.BAD_TYPECODE(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/BAD_OPERATION:1.0")) { |
| return new org.omg.CORBA.BAD_OPERATION(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/NO_RESOURCES:1.0")) { |
| String reason = MinorCodes.describeNoResources(minor); |
| return new org.omg.CORBA.NO_RESOURCES(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/NO_RESPONSE:1.0")) { |
| return new org.omg.CORBA.NO_RESPONSE(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/PERSIST_STORE:1.0")) { |
| return new org.omg.CORBA.PERSIST_STORE(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/BAD_INV_ORDER:1.0")) { |
| String reason = MinorCodes.describeBadInvOrder(minor); |
| return new org.omg.CORBA.BAD_INV_ORDER(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/TRANSIENT:1.0")) { |
| String reason = MinorCodes.describeTransient(minor); |
| return new org.omg.CORBA.TRANSIENT(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/FREE_MEM:1.0")) { |
| return new org.omg.CORBA.FREE_MEM(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/INV_IDENT:1.0")) { |
| return new org.omg.CORBA.INV_IDENT(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/INV_FLAG:1.0")) { |
| return new org.omg.CORBA.INV_FLAG(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/INTF_REPOS:1.0")) { |
| String reason = MinorCodes.describeIntfRepos(minor); |
| return new org.omg.CORBA.INTF_REPOS(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/BAD_CONTEXT:1.0")) { |
| return new org.omg.CORBA.BAD_CONTEXT(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/OBJ_ADAPTER:1.0")) { |
| return new org.omg.CORBA.OBJ_ADAPTER(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/DATA_CONVERSION:1.0")) { |
| return new org.omg.CORBA.DATA_CONVERSION(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/OBJECT_NOT_EXIST:1.0")) { |
| String reason = MinorCodes.describeObjectNotExist(minor); |
| return new org.omg.CORBA.OBJECT_NOT_EXIST(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/TRANSACTION_REQUIRED:1.0")) { |
| return new org.omg.CORBA.TRANSACTION_REQUIRED(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/TRANSACTION_ROLLEDBACK:1.0")) { |
| return new org.omg.CORBA.TRANSACTION_ROLLEDBACK(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/INVALID_TRANSACTION:1.0")) { |
| return new org.omg.CORBA.INVALID_TRANSACTION(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/INV_POLICY:1.0")) { |
| String reason = MinorCodes.describeInvPolicy(minor); |
| return new org.omg.CORBA.INV_POLICY(reason, minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/CODESET_INCOMPATIBLE:1.0")) { |
| return new org.omg.CORBA.CODESET_INCOMPATIBLE(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/REBIND:1.0")) { |
| return new org.omg.CORBA.REBIND(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/TIMEOUT:1.0")) { |
| return new org.omg.CORBA.TIMEOUT(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/TRANSACTION_UNAVAILABLE:1.0")) { |
| return new org.omg.CORBA.TRANSACTION_UNAVAILABLE(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/TRANSACTION_MODE:1.0")) { |
| return new org.omg.CORBA.TRANSACTION_MODE(minor, status); |
| } else if (id.equals("IDL:omg.org/CORBA/BAD_QOS:1.0")) { |
| return new org.omg.CORBA.BAD_QOS(minor, status); |
| } |
| |
| // |
| // Unknown exception |
| // |
| String reason = MinorCodes.describeUnknown(minor); |
| return new org.omg.CORBA.UNKNOWN(reason, minor, status); |
| } |
| |
| // |
| // Marshal a system exception |
| // |
| public static void marshalSystemException( |
| org.omg.CORBA.portable.OutputStream out, |
| org.omg.CORBA.SystemException ex) { |
| out.write_string(getExceptionId(ex)); |
| out.write_ulong(ex.minor); |
| out.write_ulong(ex.completed.value()); |
| } |
| |
| private static String[] sysExClassNames_ = { "org.omg.CORBA.BAD_CONTEXT", |
| "org.omg.CORBA.BAD_INV_ORDER", "org.omg.CORBA.BAD_OPERATION", |
| "org.omg.CORBA.BAD_PARAM", "org.omg.CORBA.BAD_QOS", |
| "org.omg.CORBA.BAD_TYPECODE", "org.omg.CORBA.CODESET_INCOMPATIBLE", |
| "org.omg.CORBA.COMM_FAILURE", "org.omg.CORBA.DATA_CONVERSION", |
| "org.omg.CORBA.FREE_MEM", "org.omg.CORBA.IMP_LIMIT", |
| "org.omg.CORBA.INITIALIZE", "org.omg.CORBA.INTERNAL", |
| "org.omg.CORBA.INTF_REPOS", "org.omg.CORBA.INVALID_TRANSACTION", |
| "org.omg.CORBA.INV_FLAG", "org.omg.CORBA.INV_IDENT", |
| "org.omg.CORBA.INV_OBJREF", "org.omg.CORBA.INV_POLICY", |
| "org.omg.CORBA.MARSHAL", "org.omg.CORBA.NO_IMPLEMENT", |
| "org.omg.CORBA.NO_MEMORY", "org.omg.CORBA.NO_PERMISSION", |
| "org.omg.CORBA.NO_RESOURCES", "org.omg.CORBA.NO_RESPONSE", |
| "org.omg.CORBA.OBJECT_NOT_EXIST", "org.omg.CORBA.OBJ_ADAPTER", |
| "org.omg.CORBA.PERSIST_STORE", "org.omg.CORBA.REBIND", |
| "org.omg.CORBA.TIMEOUT", "org.omg.CORBA.TRANSACTION_MODE", |
| "org.omg.CORBA.TRANSACTION_REQUIRED", |
| "org.omg.CORBA.TRANSACTION_ROLLEDBACK", |
| "org.omg.CORBA.TRANSACTION_UNAVAILABLE", "org.omg.CORBA.TRANSIENT", |
| "org.omg.CORBA.UNKNOWN" }; |
| |
| private static String[] sysExIds_ = { "IDL:omg.org/CORBA/BAD_CONTEXT:1.0", |
| "IDL:omg.org/CORBA/BAD_INV_ORDER:1.0", |
| "IDL:omg.org/CORBA/BAD_OPERATION:1.0", |
| "IDL:omg.org/CORBA/BAD_PARAM:1.0", "IDL:omg.org/CORBA/BAD_QOS:1.0", |
| "IDL:omg.org/CORBA/BAD_TYPECODE:1.0", |
| "IDL:omg.org/CORBA/CODESET_INCOMPATIBLE:1.0", |
| "IDL:omg.org/CORBA/COMM_FAILURE:1.0", |
| "IDL:omg.org/CORBA/DATA_CONVERSION:1.0", |
| "IDL:omg.org/CORBA/FREE_MEM:1.0", |
| "IDL:omg.org/CORBA/IMP_LIMIT:1.0", |
| "IDL:omg.org/CORBA/INITIALIZE:1.0", |
| "IDL:omg.org/CORBA/INTERNAL:1.0", |
| "IDL:omg.org/CORBA/INTF_REPOS:1.0", |
| "IDL:omg.org/CORBA/INVALID_TRANSACTION:1.0", |
| "IDL:omg.org/CORBA/INV_FLAG:1.0", |
| "IDL:omg.org/CORBA/INV_IDENT:1.0", |
| "IDL:omg.org/CORBA/INV_OBJREF:1.0", |
| "IDL:omg.org/CORBA/INV_POLICY:1.0", |
| "IDL:omg.org/CORBA/MARSHAL:1.0", |
| "IDL:omg.org/CORBA/NO_IMPLEMENT:1.0", |
| "IDL:omg.org/CORBA/NO_MEMORY:1.0", |
| "IDL:omg.org/CORBA/NO_PERMISSION:1.0", |
| "IDL:omg.org/CORBA/NO_RESOURCES:1.0", |
| "IDL:omg.org/CORBA/NO_RESPONSE:1.0", |
| "IDL:omg.org/CORBA/OBJECT_NOT_EXIST:1.0", |
| "IDL:omg.org/CORBA/OBJ_ADAPTER:1.0", |
| "IDL:omg.org/CORBA/PERSIST_STORE:1.0", |
| "IDL:omg.org/CORBA/REBIND:1.0", "IDL:omg.org/CORBA/TIMEOUT:1.0", |
| "IDL:omg.org/CORBA/TRANSACTION_MODE:1.0", |
| "IDL:omg.org/CORBA/TRANSACTION_REQUIRED:1.0", |
| "IDL:omg.org/CORBA/TRANSACTION_ROLLEDBACK:1.0", |
| "IDL:omg.org/CORBA/TRANSACTION_UNAVAILABLE:1.0", |
| "IDL:omg.org/CORBA/TRANSIENT:1.0", "IDL:omg.org/CORBA/UNKNOWN:1.0" }; |
| |
| private static int binarySearch(String[] arr, String value) { |
| int left = 0; |
| int right = arr.length; |
| int index = -1; |
| |
| while (left < right) { |
| int m = (left + right) / 2; |
| int res = arr[m].compareTo(value); |
| if (res == 0) { |
| index = m; |
| break; |
| } else if (res > 0) |
| right = m; |
| else |
| left = m + 1; |
| } |
| |
| return index; |
| } |
| |
| // |
| // Determine if the repository ID represents a system exception |
| // |
| public static boolean isSystemException(String id) { |
| return (binarySearch(sysExIds_, id) != -1); |
| } |
| |
| // |
| // Determine the repository ID of an exception |
| // |
| public static String getExceptionId(Exception ex) { |
| if (ex instanceof org.omg.CORBA.SystemException) { |
| String className = ex.getClass().getName(); |
| int index = binarySearch(sysExClassNames_, className); |
| |
| if (index == -1) |
| return "IDL:omg.org/CORBA/UNKNOWN:1.0"; |
| else |
| return sysExIds_[index]; |
| } else if (ex instanceof org.omg.CORBA.UserException) { |
| Class exClass = ex.getClass(); |
| String className = exClass.getName(); |
| String id = null; |
| try { |
| |
| Class c = ProviderLocator.loadClass(className + "Helper", exClass, null); |
| java.lang.reflect.Method m = c.getMethod("id", new Class[0]); |
| id = (String) m.invoke(null, new Object[0]); |
| } catch (ClassNotFoundException e) { |
| } catch (NoSuchMethodException e) { |
| Assert._OB_assert(ex); |
| } catch (IllegalAccessException e) { |
| Assert._OB_assert(ex); |
| } catch (IllegalArgumentException e) { |
| Assert._OB_assert(ex); |
| } catch (java.lang.reflect.InvocationTargetException e) { |
| Assert._OB_assert(ex); |
| } catch (SecurityException e) { |
| } |
| |
| // |
| // TODO: Is this correct? |
| // |
| if (id == null) |
| return "IDL:omg.org/CORBA/UserException:1.0"; |
| else |
| return id; |
| } else { |
| Assert._OB_assert(ex); |
| return null; // needed by compiler |
| } |
| } |
| |
| public static void insertException(org.omg.CORBA.Any any, |
| java.lang.Exception ex) { |
| // |
| // Find the helper class for the exception and use it to insert |
| // the exception into the any |
| // |
| |
| try { |
| Class exClass = ex.getClass(); |
| String helper = exClass.getName() + "Helper"; |
| // get the appropriate class for the loading. |
| Class c = ProviderLocator.loadClass(helper, exClass, Thread.currentThread().getContextClassLoader()); |
| final Class[] paramTypes = { org.omg.CORBA.Any.class, exClass }; |
| java.lang.reflect.Method m = c.getMethod("insert", paramTypes); |
| final java.lang.Object[] args = { any, ex }; |
| m.invoke(null, args); |
| } catch (ClassNotFoundException e) { |
| } catch (NoSuchMethodException e) { |
| Assert._OB_assert(ex); |
| } catch (IllegalAccessException e) { |
| Assert._OB_assert(ex); |
| } catch (IllegalArgumentException e) { |
| Assert._OB_assert(ex); |
| } catch (java.lang.reflect.InvocationTargetException e) { |
| Assert._OB_assert(ex); |
| } catch (SecurityException e) { |
| } |
| } |
| |
| static ClassLoader getContextClassLoader () |
| { |
| if (System.getSecurityManager() == null) { |
| return Thread.currentThread ().getContextClassLoader (); |
| } else { |
| return (ClassLoader) |
| AccessController.doPrivileged( |
| new PrivilegedAction() { |
| public Object run() { |
| return Thread.currentThread ().getContextClassLoader (); |
| } |
| }); |
| } |
| } |
| |
| public static CodeBase getSendingContextRuntime(ORBInstance orbInstance_, ServiceContext[] scl) { |
| for(int i = 0 ; i < scl.length ; i++) |
| { |
| if(scl[i].context_id == org.omg.IOP.SendingContextRunTime.value) |
| { |
| return new CodeBaseProxy(orbInstance_, scl[i]); |
| } |
| } |
| |
| return null; |
| } |
| } |
