| /* |
| * 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.CONNECT_TIMEOUT_POLICY_ID; |
| import org.apache.yoko.orb.OB.ConnectTimeoutPolicy; |
| import org.apache.yoko.orb.OB.INTERCEPTOR_POLICY_ID; |
| import org.apache.yoko.orb.OB.InterceptorPolicy; |
| import org.apache.yoko.orb.OB.LOCATE_REQUEST_POLICY_ID; |
| import org.apache.yoko.orb.OB.LOCATION_TRANSPARENCY_POLICY_ID; |
| import org.apache.yoko.orb.OB.LOCATION_TRANSPARENCY_RELAXED; |
| import org.apache.yoko.orb.OB.LocateRequestPolicy; |
| import org.apache.yoko.orb.OB.LocationTransparencyPolicy; |
| import org.apache.yoko.orb.OB.REQUEST_TIMEOUT_POLICY_ID; |
| import org.apache.yoko.orb.OB.RETRY_POLICY_ID; |
| import org.apache.yoko.orb.OB.RETRY_STRICT; |
| import org.apache.yoko.orb.OB.RequestTimeoutPolicy; |
| import org.apache.yoko.orb.OB.RetryAttributes; |
| import org.apache.yoko.orb.OB.RetryPolicy; |
| import org.apache.yoko.orb.OB.TIMEOUT_POLICY_ID; |
| import org.apache.yoko.orb.OB.TimeoutPolicy; |
| |
| final public class RefCountPolicyList { |
| // |
| // The immutable PolicyList |
| // |
| public org.omg.CORBA.Policy[] value; |
| |
| // |
| // The immutable value of the retry policy |
| // |
| public RetryAttributes retry; |
| |
| // |
| // The immutable value of the connect timeout policy |
| // |
| public int connectTimeout; |
| |
| // |
| // The immutable value of the request timeout policy |
| // |
| public int requestTimeout; |
| |
| // |
| // The immutable value of the request start time policy |
| // |
| public org.omg.TimeBase.UtcT requestStartTime; |
| |
| // |
| // The immutable value of the request end time policy |
| // |
| public org.omg.TimeBase.UtcT requestEndTime; |
| |
| // |
| // The immutable value of the reply start time policy |
| // |
| public org.omg.TimeBase.UtcT replyStartTime; |
| |
| // |
| // The immutable value of the reply end time policy |
| // |
| public org.omg.TimeBase.UtcT replyEndTime; |
| |
| // |
| // The immutable value of the relative request timeout policy |
| // |
| public long relativeRequestTimeout; |
| |
| // |
| // The immutable value of the relative round trip timeout policy |
| // |
| public long relativeRoundTripTimeout; |
| |
| // |
| // The immutable value of the rebind mode policy |
| // |
| public short rebindMode; |
| |
| // |
| // The immutable value of the sync scope policy |
| // |
| public short syncScope; |
| |
| // |
| // The immutable value of the location transparency policy |
| // |
| public short locationTransparency; |
| |
| // |
| // the immutable value of the bidir policy |
| // |
| public short biDirMode; |
| |
| // |
| // The immutable value of the InterceptorPolicy, or true if there |
| // is no such policy |
| // |
| public boolean interceptor; |
| |
| // |
| // The immutable value of the LocateRequestPolicy, or false if there |
| // is no such policy |
| // |
| public boolean locateRequest; |
| |
| // |
| // the immutable value of the request priority policy |
| // |
| public org.omg.Messaging.PriorityRange requestPriority; |
| |
| // |
| // the immutable value of the reply priority policy |
| // |
| public org.omg.Messaging.PriorityRange replyPriority; |
| |
| // |
| // the immutable value of the routing policy |
| // |
| public org.omg.Messaging.RoutingTypeRange routingRange; |
| |
| // |
| // the immutable value of the max hops policy |
| // |
| public short maxHops; |
| |
| // |
| // the immutable value of the queue order policy |
| // |
| public short queueOrder; |
| |
| // ---------------------------------------------------------------------- |
| // RefCountPolicyList private and protected members |
| // ---------------------------------------------------------------------- |
| |
| private static RetryAttributes getRetry(org.omg.CORBA.Policy[] policies) { |
| RetryAttributes attributes = new RetryAttributes(); |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == RETRY_POLICY_ID.value) { |
| RetryPolicy policy = (RetryPolicy) policies[i]; |
| |
| attributes.mode = policy.retry_mode(); |
| attributes.interval = policy.retry_interval(); |
| attributes.max = policy.retry_max(); |
| attributes.remote = policy.retry_remote(); |
| |
| return attributes; |
| } |
| } |
| attributes.mode = RETRY_STRICT.value; |
| attributes.interval = 0; |
| attributes.max = 1; |
| attributes.remote = false; |
| |
| return attributes; |
| } |
| |
| private static int getConnectTimeout(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == CONNECT_TIMEOUT_POLICY_ID.value) { |
| ConnectTimeoutPolicy policy = (ConnectTimeoutPolicy) policies[i]; |
| return policy.value(); |
| } |
| } |
| |
| // |
| // Fall back to TimeoutPolicy |
| // |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == TIMEOUT_POLICY_ID.value) { |
| TimeoutPolicy policy = (TimeoutPolicy) policies[i]; |
| return policy.value(); |
| } |
| } |
| |
| return -1; |
| } |
| |
| // |
| // TODO: This needs to be replaced with the new messaging timeout |
| // policies below. |
| // |
| private static int getRequestTimeout(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == REQUEST_TIMEOUT_POLICY_ID.value) { |
| RequestTimeoutPolicy policy = (RequestTimeoutPolicy) policies[i]; |
| return policy.value(); |
| } |
| } |
| |
| // |
| // Fall back to TimeoutPolicy |
| // |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == TIMEOUT_POLICY_ID.value) { |
| TimeoutPolicy policy = (TimeoutPolicy) policies[i]; |
| return policy.value(); |
| } |
| } |
| |
| return -1; |
| } |
| |
| private org.omg.TimeBase.UtcT getRequestStartTime( |
| org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.REQUEST_START_TIME_POLICY_TYPE.value) { |
| org.omg.Messaging.RequestStartTimePolicy policy = (org.omg.Messaging.RequestStartTimePolicy) policies[i]; |
| return policy.start_time(); |
| } |
| } |
| |
| return org.apache.yoko.orb.OB.TimeHelper.utcMin(); |
| } |
| |
| private org.omg.TimeBase.UtcT getRequestEndTime( |
| org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.REQUEST_END_TIME_POLICY_TYPE.value) { |
| org.omg.Messaging.RequestEndTimePolicy policy = (org.omg.Messaging.RequestEndTimePolicy) policies[i]; |
| return policy.end_time(); |
| } |
| } |
| |
| return org.apache.yoko.orb.OB.TimeHelper.utcMin(); |
| } |
| |
| private org.omg.TimeBase.UtcT getReplyStartTime( |
| org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.REPLY_START_TIME_POLICY_TYPE.value) { |
| org.omg.Messaging.ReplyStartTimePolicy policy = (org.omg.Messaging.ReplyStartTimePolicy) policies[i]; |
| return policy.start_time(); |
| } |
| } |
| |
| return org.apache.yoko.orb.OB.TimeHelper.utcMin(); |
| } |
| |
| private org.omg.TimeBase.UtcT getReplyEndTime( |
| org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.REPLY_END_TIME_POLICY_TYPE.value) { |
| org.omg.Messaging.ReplyEndTimePolicy policy = (org.omg.Messaging.ReplyEndTimePolicy) policies[i]; |
| return policy.end_time(); |
| } |
| } |
| |
| return org.apache.yoko.orb.OB.TimeHelper.utcMin(); |
| } |
| |
| private long getRelativeRequestTimeout(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.RELATIVE_REQ_TIMEOUT_POLICY_TYPE.value) { |
| org.omg.Messaging.RelativeRequestTimeoutPolicy policy = (org.omg.Messaging.RelativeRequestTimeoutPolicy) policies[i]; |
| return policy.relative_expiry(); |
| } |
| } |
| |
| return 0; |
| } |
| |
| private long getRelativeRoundTripTimeout(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.RELATIVE_RT_TIMEOUT_POLICY_TYPE.value) { |
| org.omg.Messaging.RelativeRoundtripTimeoutPolicy policy = (org.omg.Messaging.RelativeRoundtripTimeoutPolicy) policies[i]; |
| return policy.relative_expiry(); |
| } |
| } |
| |
| return 0; |
| } |
| |
| private static short getRebindMode(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.REBIND_POLICY_TYPE.value) { |
| org.omg.Messaging.RebindPolicy policy = (org.omg.Messaging.RebindPolicy) policies[i]; |
| return policy.rebind_mode(); |
| } |
| } |
| |
| return org.omg.Messaging.TRANSPARENT.value; |
| } |
| |
| private static short getSyncScope(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.SYNC_SCOPE_POLICY_TYPE.value) { |
| org.omg.Messaging.SyncScopePolicy policy = (org.omg.Messaging.SyncScopePolicy) policies[i]; |
| return policy.synchronization(); |
| } |
| } |
| |
| return org.omg.Messaging.SYNC_NONE.value; |
| } |
| |
| private static short getLocationTransparency(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == LOCATION_TRANSPARENCY_POLICY_ID.value) { |
| LocationTransparencyPolicy policy = (LocationTransparencyPolicy) policies[i]; |
| return policy.value(); |
| } |
| } |
| |
| return LOCATION_TRANSPARENCY_RELAXED.value; |
| } |
| |
| private static short getBiDirMode(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.BiDirPolicy.BIDIRECTIONAL_POLICY_TYPE.value) { |
| org.omg.BiDirPolicy.BidirectionalPolicy policy = (org.omg.BiDirPolicy.BidirectionalPolicy) policies[i]; |
| |
| return policy.value(); |
| } |
| } |
| |
| return org.omg.BiDirPolicy.NORMAL.value; |
| } |
| |
| private static boolean getInterceptor(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == INTERCEPTOR_POLICY_ID.value) { |
| InterceptorPolicy policy = (InterceptorPolicy) policies[i]; |
| return policy.value(); |
| } |
| } |
| |
| return true; |
| } |
| |
| private static boolean getLocateRequest(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == LOCATE_REQUEST_POLICY_ID.value) { |
| LocateRequestPolicy policy = (LocateRequestPolicy) policies[i]; |
| return policy.value(); |
| } |
| } |
| |
| return false; |
| } |
| |
| public static org.omg.Messaging.PriorityRange getRequestPriority( |
| org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.REQUEST_PRIORITY_POLICY_TYPE.value) { |
| org.omg.Messaging.RequestPriorityPolicy policy = (org.omg.Messaging.RequestPriorityPolicy) policies[i]; |
| return policy.priority_range(); |
| } |
| } |
| |
| org.omg.Messaging.PriorityRange range = new org.omg.Messaging.PriorityRange(); |
| range.min = 0; |
| range.max = 0; |
| |
| return range; |
| } |
| |
| public static org.omg.Messaging.PriorityRange getReplyPriority( |
| org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.REPLY_PRIORITY_POLICY_TYPE.value) { |
| org.omg.Messaging.ReplyPriorityPolicy policy = (org.omg.Messaging.ReplyPriorityPolicy) policies[i]; |
| return policy.priority_range(); |
| } |
| } |
| |
| org.omg.Messaging.PriorityRange range = new org.omg.Messaging.PriorityRange(); |
| range.min = 0; |
| range.max = 0; |
| |
| return range; |
| } |
| |
| public static org.omg.Messaging.RoutingTypeRange getRoutingRange( |
| org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.ROUTING_POLICY_TYPE.value) { |
| org.omg.Messaging.RoutingPolicy policy = (org.omg.Messaging.RoutingPolicy) policies[i]; |
| return policy.routing_range(); |
| } |
| } |
| |
| org.omg.Messaging.RoutingTypeRange range = new org.omg.Messaging.RoutingTypeRange(); |
| range.min = org.omg.Messaging.ROUTE_NONE.value; |
| range.max = org.omg.Messaging.ROUTE_NONE.value; |
| |
| return range; |
| } |
| |
| public static short getMaxHops(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.MAX_HOPS_POLICY_TYPE.value) { |
| org.omg.Messaging.MaxHopsPolicy policy = (org.omg.Messaging.MaxHopsPolicy) policies[i]; |
| return policy.max_hops(); |
| } |
| } |
| |
| return Short.MAX_VALUE; |
| } |
| |
| public static short getQueueOrder(org.omg.CORBA.Policy[] policies) { |
| for (int i = 0; i < policies.length; i++) { |
| if (policies[i].policy_type() == org.omg.Messaging.QUEUE_ORDER_POLICY_TYPE.value) { |
| org.omg.Messaging.QueueOrderPolicy policy = (org.omg.Messaging.QueueOrderPolicy) policies[i]; |
| return policy.allowed_orders(); |
| } |
| } |
| |
| return org.omg.Messaging.ORDER_TEMPORAL.value; |
| } |
| |
| // ---------------------------------------------------------------------- |
| // RefCountPolicyList public members |
| // ---------------------------------------------------------------------- |
| |
| public RefCountPolicyList(org.omg.CORBA.Policy[] v) { |
| value = v; |
| retry = getRetry(v); |
| connectTimeout = getConnectTimeout(v); |
| requestTimeout = getRequestTimeout(v); |
| requestStartTime = getRequestStartTime(v); |
| requestEndTime = getRequestEndTime(v); |
| replyStartTime = getReplyStartTime(v); |
| replyEndTime = getReplyEndTime(v); |
| relativeRequestTimeout = getRelativeRequestTimeout(v); |
| relativeRoundTripTimeout = getRelativeRoundTripTimeout(v); |
| rebindMode = getRebindMode(v); |
| syncScope = getSyncScope(v); |
| locationTransparency = getLocationTransparency(v); |
| biDirMode = getBiDirMode(v); |
| interceptor = getInterceptor(v); |
| locateRequest = getLocateRequest(v); |
| requestPriority = getRequestPriority(v); |
| replyPriority = getReplyPriority(v); |
| routingRange = getRoutingRange(v); |
| maxHops = getMaxHops(v); |
| queueOrder = getQueueOrder(v); |
| } |
| } |
