January 2011 - jboss-remoting-commits

JBoss Remoting SVN: r6233 - in remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/servlet: preservelines/WEB-INF and 1 other directory.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-28 21:24:58 -0500 (Fri, 28 Jan 2011) New Revision: 6233 Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/servlet/nopreservelines/WEB-INF/web.xml remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/servlet/preservelines/WEB-INF/web.xml Log: JBREM-1271: Current versions seem to be broken; reverting to earlier versions that work. Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/servlet/nopreservelines/WEB-INF/web.xml =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/servlet/nopreservelines/WEB-INF/web.xml 2011-01-29 00:57:23 UTC (rev 6232) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/servlet/nopreservelines/WEB-INF/web.xml 2011-01-29 02:24:58 UTC (rev 6233) @@ -16,7 +16,7 @@ <servlet-class>org.jboss.remoting.transport.servlet.web.ServerInvokerServlet</servlet-class> <init-param> <param-name>invokerName</param-name> - <param-value>jboss.remoting:service=invoker,transport=servlet</param-value> + <param-value>jboss.remoting:host=localhost,port=8080,service=invoker,transport=servlet</param-value> <description>The servlet server invoker</description> </init-param> <load-on-startup>1</load-on-startup> Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/servlet/preservelines/WEB-INF/web.xml =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/servlet/preservelines/WEB-INF/web.xml 2011-01-29 00:57:23 UTC (rev 6232) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/servlet/preservelines/WEB-INF/web.xml 2011-01-29 02:24:58 UTC (rev 6233) @@ -16,7 +16,7 @@ <servlet-class>org.jboss.remoting.transport.servlet.web.ServerInvokerServlet</servlet-class> <init-param> <param-name>invokerName</param-name> - <param-value>jboss.remoting:service=invoker,transport=servlet</param-value> + <param-value>jboss.remoting:host=localhost,port=8080,service=invoker,transport=servlet</param-value> <description>The servlet server invoker</description> </init-param> <load-on-startup>1</load-on-startup>

13 years, 3 months

1
0
0 / 0

JBoss Remoting SVN: r6232 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/retriable.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-28 19:57:23 -0500 (Fri, 28 Jan 2011) New Revision: 6232 Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java Log: JBREM-1271: Removed unused import. Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java 2011-01-29 00:52:53 UTC (rev 6231) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java 2011-01-29 00:57:23 UTC (rev 6232) @@ -39,7 +39,6 @@ import org.apache.log4j.Level; import org.apache.log4j.Logger; import org.apache.log4j.PatternLayout; -import org.jboss.logging.XLevel; import org.jboss.remoting.Client; import org.jboss.remoting.InvocationRequest; import org.jboss.remoting.InvokerLocator;

13 years, 3 months

1
0
0 / 0

JBoss Remoting SVN: r6231 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/http/chunked.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-28 19:52:53 -0500 (Fri, 28 Jan 2011) New Revision: 6231 Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/http/chunked/ChunkedUnmarshallingTestCase.java Log: JBREM-1271: Added metadata. Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/http/chunked/ChunkedUnmarshallingTestCase.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/http/chunked/ChunkedUnmarshallingTestCase.java 2011-01-29 00:47:50 UTC (rev 6230) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/http/chunked/ChunkedUnmarshallingTestCase.java 2011-01-29 00:52:53 UTC (rev 6231) @@ -136,6 +136,11 @@ port = PortUtil.findFreePort(host); locatorURI = getTransport() + "://" + host + ":" + port; locatorURI += "/?chunkedLength=10"; + String metadata = System.getProperty("remoting.metadata"); + if (metadata != null) + { + locatorURI += "&" + metadata; + } serverLocator = new InvokerLocator(locatorURI); log.info("Starting remoting server with locator uri of: " + locatorURI); HashMap config = new HashMap();

13 years, 3 months

1
0
0 / 0

JBoss Remoting SVN: r6230 - remoting2/branches/2.x/docs/guide/en.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-28 19:47:50 -0500 (Fri, 28 Jan 2011) New Revision: 6230 Modified: remoting2/branches/2.x/docs/guide/en/chap9.xml Log: JBREM-1271: Corrected misspellings. Modified: remoting2/branches/2.x/docs/guide/en/chap9.xml =================================================================== --- remoting2/branches/2.x/docs/guide/en/chap9.xml 2011-01-29 00:47:20 UTC (rev 6229) +++ remoting2/branches/2.x/docs/guide/en/chap9.xml 2011-01-29 00:47:50 UTC (rev 6230) @@ -2,7 +2,7 @@ <chapter id="chapter-connection-failure" xreflabel="Network Connection Monitoring"> <title>Network Connection Monitoring</title> - <para>Remoting has two mechanisms for monitoring the health of estabilished + <para>Remoting has two mechanisms for monitoring the health of established connections, which inform listeners on the client and server sides when a possible connection failure has been detected.</para> @@ -103,12 +103,12 @@ <title>Server side monitoring</title> <para>A remoting server also has the capability to detect when a client is - no longer available. This is done by estabilishing a lease with the remoting + no longer available. This is done by establishing a lease with the remoting clients that connect to a server. On the client side, an <classname>org.jboss.remoting.LeasePinger</classname> periodically sends PING messages to the server, and on the server side an <classname>org.jboss.remoting.Lease</classname> informs registered listeners - if the PING doesn't arrive withing the specified timeout period.</para> + if the PING doesn't arrive within the specified timeout period.</para> <para><emphasis role="bold">Server side activation.</emphasis> To turn on server side connection failure detection of remoting clients, it is

13 years, 3 months

1
0
0 / 0

JBoss Remoting SVN: r6229 - remoting2/branches/2.x/docs/guide/en.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-28 19:47:20 -0500 (Fri, 28 Jan 2011) New Revision: 6229 Modified: remoting2/branches/2.x/docs/guide/en/chap5.xml Log: JBREM-1271: Corrected misspelling. Modified: remoting2/branches/2.x/docs/guide/en/chap5.xml =================================================================== --- remoting2/branches/2.x/docs/guide/en/chap5.xml 2011-01-28 23:38:19 UTC (rev 6228) +++ remoting2/branches/2.x/docs/guide/en/chap5.xml 2011-01-29 00:47:20 UTC (rev 6229) @@ -1383,7 +1383,7 @@ only one, instance of <classname>java.net.ServerSocket</classname> for each configured bind address. Typically there would exactly one <classname>ServerSocket</classname>, but there would be more than one - for a mltihome server with multiple bind addresses. Upon being started, + for a multihome server with multiple bind addresses. Upon being started, it will also create and start a number of threads to be used for accepting incoming requests from the ServerSocket. These threads are called the accept threads and the number of them created is controlled

13 years, 3 months

1
0
0 / 0

JBoss Remoting SVN: r6228 - remoting2/branches/2.x/src/main/org/jboss/remoting/transporter.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-28 18:38:19 -0500 (Fri, 28 Jan 2011) New Revision: 6228 Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/transporter/TransporterClient.java Log: JBREM-1246: Created versions of each of the constructors and each of the factory methods that takes a metadata map, which is passed to Client.invoke(). Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/transporter/TransporterClient.java =================================================================== --- remoting2/branches/2.x/src/main/org/jboss/remoting/transporter/TransporterClient.java 2011-01-28 21:23:20 UTC (rev 6227) +++ remoting2/branches/2.x/src/main/org/jboss/remoting/transporter/TransporterClient.java 2011-01-28 23:38:19 UTC (rev 6228) @@ -46,6 +46,7 @@ import java.security.PrivilegedActionException; import java.security.PrivilegedExceptionAction; import java.util.ArrayList; +import java.util.Map; /** * Class to be used as a factory via static method calls to get @@ -64,6 +65,8 @@ private final Logger log = Logger.getLogger(TransporterClient.class); private static final long serialVersionUID = 7418567482011657189L; + + private Map metadata; /** * Creates the remoting client to server POJO. @@ -80,6 +83,20 @@ /** * Creates the remoting client to server POJO. + * Is not clustered. + * + * @param locator + * @throws Exception + */ + private TransporterClient(InvokerLocator locator, Map metadata) throws Exception + { + remotingClient = new Client(locator); + remotingClient.connect(); + this.metadata = metadata; + } + + /** + * Creates the remoting client to server POJO. * Is clustered * * @param locator @@ -100,6 +117,23 @@ * * @param locator * @param targetSubsystem + * @throws Exception + */ + private TransporterClient(InvokerLocator locator, String targetSubsystem, Map metadata) throws Exception + { + remotingClient = new Client(locator, targetSubsystem); + remotingClient.connect(); + this.isClustered = true; + this.subSystem = targetSubsystem; + this.metadata = metadata; + } + + /** + * Creates the remoting client to server POJO. + * Is clustered + * + * @param locator + * @param targetSubsystem * @param loadbalancer policy * @throws Exception */ @@ -113,6 +147,25 @@ } /** + * Creates the remoting client to server POJO. + * Is clustered + * + * @param locator + * @param targetSubsystem + * @param loadbalancer policy + * @throws Exception + */ + private TransporterClient(InvokerLocator locator, String targetSubsystem, LoadBalancer loadbalancer, Map metadata) throws Exception + { + this.loadBalancer = loadbalancer; + remotingClient = new Client(locator, targetSubsystem); + remotingClient.connect(); + this.isClustered = true; + this.subSystem = targetSubsystem; + this.metadata = metadata; + } + + /** * Disconnects the remoting client */ private void disconnect() @@ -206,6 +259,42 @@ * * @param locatorURI - the remoting locator uri to the target server where the target POJO exists. * @param targetClass - the interface class of the POJO will be calling upon. + * @param clustered - true will cause the transporter to look for other remoting serves that have the POJO running + * and include it in the client's target list. If a call on first target fails, will seamlessly fail over to one + * of the other discovered targets. + * @return dynamic remote proxy typed to the interface specified by the targetClass param. + * @throws Exception + */ + public static Object createTransporterClient(String locatorURI, Class targetClass, boolean clustered, Map metadata) throws Exception + { + if (!clustered) + { + return createTransporterClient(locatorURI, targetClass, metadata); + } + else + { + if (InternalTransporterServices.getInstance().getNetworkRegistry() == null) + { + setupDetector(); + } + InvokerLocator locator = new InvokerLocator(locatorURI); + TransporterClient client = new TransporterClient(locator, targetClass.getName()); + ClassLoader tcl = (ClassLoader) AccessController.doPrivileged( new PrivilegedAction() + { + public Object run() + { + return Thread.currentThread().getContextClassLoader(); + } + }); + return Proxy.newProxyInstance(tcl, new Class[]{targetClass}, client); + } + } + + /** + * Create a remote proxy to a POJO on a remote server. + * + * @param locatorURI - the remoting locator uri to the target server where the target POJO exists. + * @param targetClass - the interface class of the POJO will be calling upon. * @param loadBalancer - policy for selecting which target server to use from list of available servers. * @return dynamic remote proxy typed to the interface specified by the targetClass param. * @throws Exception @@ -233,18 +322,60 @@ * * @param locatorURI - the remoting locator uri to the target server where the target POJO exists. * @param targetClass - the interface class of the POJO will be calling upon. + * @param loadBalancer - policy for selecting which target server to use from list of available servers. * @return dynamic remote proxy typed to the interface specified by the targetClass param. * @throws Exception */ + public static Object createTransporterClient(String locatorURI, Class targetClass, LoadBalancer loadBalancer, Map metadata) throws Exception + { + if (InternalTransporterServices.getInstance().getNetworkRegistry() == null) + { + setupDetector(); + } + InvokerLocator locator = new InvokerLocator(locatorURI); + TransporterClient client = new TransporterClient(locator, targetClass.getName(), loadBalancer, metadata); + ClassLoader tcl = (ClassLoader) AccessController.doPrivileged( new PrivilegedAction() + { + public Object run() + { + return Thread.currentThread().getContextClassLoader(); + } + }); + return Proxy.newProxyInstance(tcl, new Class[]{targetClass}, client); + } + + /** + * Create a remote proxy to a POJO on a remote server. + * + * @param locatorURI - the remoting locator uri to the target server where the target POJO exists. + * @param targetClass - the interface class of the POJO will be calling upon. + * @return dynamic remote proxy typed to the interface specified by the targetClass param. + * @throws Exception + */ public static Object createTransporterClient(String locatorURI, Class targetClass) throws Exception { InvokerLocator locator = new InvokerLocator(locatorURI); return createTransporterClient(locator, targetClass); } + /** * Create a remote proxy to a POJO on a remote server. * + * @param locatorURI - the remoting locator uri to the target server where the target POJO exists. + * @param targetClass - the interface class of the POJO will be calling upon. + * @return dynamic remote proxy typed to the interface specified by the targetClass param. + * @throws Exception + */ + public static Object createTransporterClient(String locatorURI, Class targetClass, Map metadata) throws Exception + { + InvokerLocator locator = new InvokerLocator(locatorURI); + return createTransporterClient(locator, targetClass, metadata); + } + + /** + * Create a remote proxy to a POJO on a remote server. + * * @param locator - the remoting locator to the target server where the target POJO exists. * @param targetClass - the interface class of the POJO will be calling upon. * @return dynamic remote proxy typed to the interface specified by the targetClass param. @@ -264,6 +395,27 @@ } /** + * Create a remote proxy to a POJO on a remote server. + * + * @param locator - the remoting locator to the target server where the target POJO exists. + * @param targetClass - the interface class of the POJO will be calling upon. + * @return dynamic remote proxy typed to the interface specified by the targetClass param. + * @throws Exception + */ + public static Object createTransporterClient(InvokerLocator locator, Class targetClass, Map metadata) throws Exception + { + TransporterClient client = new TransporterClient(locator, targetClass.getName(), metadata); + ClassLoader tcl = (ClassLoader) AccessController.doPrivileged( new PrivilegedAction() + { + public Object run() + { + return Thread.currentThread().getContextClassLoader(); + } + }); + return Proxy.newProxyInstance(tcl, new Class[]{targetClass}, client); + } + + /** * Needs to be called by user when no longer need to make calls on remote POJO. Otherwise will * maintain remote connection until this is called. * @@ -318,7 +470,14 @@ try { failOver = false; - response = remotingClient.invoke(request); + if (metadata != null) + { + response = remotingClient.invoke(request, metadata); + } + else + { + response = remotingClient.invoke(request); + } } catch (CannotConnectException cnc) {

13 years, 3 months

1
0
0 / 0

JBoss Remoting SVN: r6226 - remoting2/branches/2.2/src/main/org/jboss/remoting.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-26 20:36:20 -0500 (Wed, 26 Jan 2011) New Revision: 6226 Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/MicroRemoteClientInvoker.java Log: JBREM-1269: Removed synchronization from getLeasePinger(). Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/MicroRemoteClientInvoker.java =================================================================== --- remoting2/branches/2.2/src/main/org/jboss/remoting/MicroRemoteClientInvoker.java 2011-01-27 01:35:36 UTC (rev 6225) +++ remoting2/branches/2.2/src/main/org/jboss/remoting/MicroRemoteClientInvoker.java 2011-01-27 01:36:20 UTC (rev 6226) @@ -670,9 +670,6 @@ protected LeasePinger getLeasePinger() { - synchronized(clientLeaseLock) - { - return leasePinger; - } + return leasePinger; } }

13 years, 3 months

1
0
0 / 0

JBoss Remoting SVN: r6225 - remoting2/branches/2.x/src/main/org/jboss/remoting.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-26 20:35:36 -0500 (Wed, 26 Jan 2011) New Revision: 6225 Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/MicroRemoteClientInvoker.java Log: JBREM-1269: Removed synchronization from getLeasePinger(). Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/MicroRemoteClientInvoker.java =================================================================== --- remoting2/branches/2.x/src/main/org/jboss/remoting/MicroRemoteClientInvoker.java 2011-01-26 04:54:17 UTC (rev 6224) +++ remoting2/branches/2.x/src/main/org/jboss/remoting/MicroRemoteClientInvoker.java 2011-01-27 01:35:36 UTC (rev 6225) @@ -722,10 +722,7 @@ protected LeasePinger getLeasePinger() { - synchronized(clientLeaseLock) - { - return leasePinger; - } + return leasePinger; } static private String getSystemProperty(final String name)

13 years, 3 months

1
0
0 / 0

JBoss Remoting SVN: r6224 - remoting2/branches/2.2/src/main/org/jboss/remoting.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-25 23:54:17 -0500 (Tue, 25 Jan 2011) New Revision: 6224 Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/Lease.java remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java Log: JBREM-1144: Adding a unique id to Lease. Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/Lease.java =================================================================== --- remoting2/branches/2.2/src/main/org/jboss/remoting/Lease.java 2011-01-26 04:50:00 UTC (rev 6223) +++ remoting2/branches/2.2/src/main/org/jboss/remoting/Lease.java 2011-01-26 04:54:17 UTC (rev 6224) @@ -23,6 +23,7 @@ import org.jboss.logging.Logger; import org.jboss.remoting.util.TimerUtil; +import org.jboss.util.id.GUID; import java.util.Collection; import java.util.HashMap; @@ -59,6 +60,9 @@ private static final Logger log = Logger.getLogger(Lease.class); private static final boolean isTraceEnabled = log.isTraceEnabled(); + + /** Used by ConnectionValidator to detect a change of server. **/ + protected String leaseId = new GUID().toString(); public Lease(String clientSessionId, long leasePeriod, String locatorurl, Map requestPayload, ConnectionNotifier notifier, Map clientLeases) @@ -355,6 +359,11 @@ { return leasePingerId; } + + protected String getLeaseId() + { + return leaseId; + } private void stopLease() { Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java =================================================================== --- remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java 2011-01-26 04:50:00 UTC (rev 6223) +++ remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java 2011-01-26 04:54:17 UTC (rev 6224) @@ -798,19 +798,20 @@ if (invokerSessionId != null) { // Comes from ConnectionValidator configured to tie validation with lease. - boolean response = checkForClientLease(invokerSessionId); - if (trace) log.trace(this + " responding " + response + " to $PING$ for invoker sessionId " + invokerSessionId); + String leaseId = checkForClientLease(invokerSessionId); + Boolean success = leaseId == null ? Boolean.FALSE : Boolean.TRUE; + if (trace) log.trace(this + " responding " + leaseId + " to $PING$ for invoker sessionId " + invokerSessionId); if (metadata.get(Remoting.USE_SERVER_CONNECTION_IDENTITY) != null) { Map responseMap = new HashMap(); - responseMap.put(Remoting.SERVER_ID, serverId); - if (trace) log.trace(this + " returning serverId: " + serverId); - return new InvocationResponse(invocation.getSessionId(), new Boolean(response), false, responseMap); + responseMap.put(Remoting.SERVER_ID, leaseId); + if (trace) log.trace(this + " returning leaseId: " + leaseId); + return new InvocationResponse(invocation.getSessionId(), success, false, responseMap); } else { - if (trace) log.trace(this + " not returning serverId: " + serverId); - return new Boolean(response); + if (trace) log.trace(this + " not returning leaseId: " + leaseId); + return success; } } else @@ -1902,7 +1903,7 @@ } } - private boolean checkForClientLease(String invokerSessionId) + private String checkForClientLease(String invokerSessionId) { if(leaseManagement && invokerSessionId != null) { @@ -1912,16 +1913,16 @@ if(clientLease == null) { if(trace) { log.trace("No lease established for invoker session id (" + invokerSessionId + ")"); } - return false; + return null; } else { if(trace) { log.trace("Found lease for invoker session id (" + invokerSessionId + ")"); } - return true; + return clientLease.getLeaseId(); } } - return false; + return null; } /**

13 years, 3 months

1
0
0 / 0

JBoss Remoting SVN: r6223 - remoting2/branches/2.x/src/main/org/jboss/remoting.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2011-01-25 23:50:00 -0500 (Tue, 25 Jan 2011) New Revision: 6223 Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/ServerInvoker.java Log: JBREM-1144: invoke() returns leaseId instead of serverId. Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/ServerInvoker.java =================================================================== --- remoting2/branches/2.x/src/main/org/jboss/remoting/ServerInvoker.java 2011-01-26 04:45:31 UTC (rev 6222) +++ remoting2/branches/2.x/src/main/org/jboss/remoting/ServerInvoker.java 2011-01-26 04:50:00 UTC (rev 6223) @@ -867,7 +867,7 @@ if (metadata.get(Remoting.USE_SERVER_CONNECTION_IDENTITY) != null) { Map responseMap = new HashMap(); - responseMap.put(Remoting.SERVER_ID, serverId); + responseMap.put(Remoting.SERVER_ID, leaseId); if (trace) log.trace(this + " returning leaseId: " + leaseId); return new InvocationResponse(invocation.getSessionId(), success, false, responseMap); }

13 years, 3 months

1
0
0 / 0

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

jboss-remoting-commits January 2011