[
Date Prev][
Date Next][
Thread Prev][
Thread Next][
Date Index][
Thread Index]
[
List Home]
|
Re: [ecf-dev] How to catch an Exception while registering a remote service?
|
Hi Christoph,
On 2/6/2016 6:35 AM, Keimel, Christoph wrote:
Hi Everybody,
Thanks Wim und Scott for the input on my earlier questions regarding network failures. That helped a lot!
Today I am trying to tackle something else that sometimes happens during startup: A service is not correctly registered as a remote service because the address used for the binding is already in use (stack trace see [1]). This happens on site from time to time and I would like to show an error message if it does but I don't know how to catch this event.
I register the service with:
ServiceRegistration<?> registration = bundleContext.registerService(clazz, service, props);
This leads to an exception being logged, but I can't catch it. Actually it looks to me like the returned registration is valid, and it probably is locally.
Yes the registration returned is valid locally.
Is there a setting I could use to have registerService fail if the remote registration fails?
By RSA specification, there is not a pre-defined setting that would have
the registerService fail if the remote registration fails. This could be
added for ECF, but I'm sort of hesitant to do so (as it would be
non-standard), given that there are approaches (discussed below) that
can be used to deal with this situation.
Or some other way to detect this error? In my case, the service is only used remotely, so I would really like to know if it couldn't be registered for some reason.
Yes, of course. There are a couple of ways to deal with this
technically. First, just a little bit of explanation of the way that
RSA behaves:
In RSA there's a concept of a 'topology manager' [1]. On the remote
service host, the topology manager has the role of
a) intercepting the registerService call via the OSGi service hook
b) making a decision about whether to export the service (e.g. based
upon the service properties and/or other things),
c) calling
org.osgi.service.remoteserviceadmin.RemoteServiceAdmin.exportService(ServiceReference,
Map) to export the service
If you look at the RemoteServiceAdmin service exportService method
signature [2], you will see that it returns an
Collection<ExportRegistration>. In this collection will be at least one
instance of ExportRegistration, and in this export registration is
access to a Throwable that was possibly thrown by the call to
exportService (e.g. because the port was already taken). If everything
was exported successfully, the Throwable is null.
ECF has a 'default' topology manager (called the BasicTopologyManager)
that is present in this bundle:
org.eclipse.ecf.osgi.services.distribution. This topology manager is
what's called 'promiscuous' because it automatically tries to export
*all* appropriate calls to registerService (i.e. those that have the
required remote service properties) *and* because it has no means to do
so, it can't return the ExportRegistration returned from
RemoteServiceAdmin.exportService, but rather it simply logs any export
error.
With the RSA concept of a topology manager, there are a few ways to get
access to these export registrations and the underlying Throwable
exception.
1) One way is to register an instance of
org.osgi.service.remoteserviceadmin.RemoteServiceAdminListener [3], and
the when a export event occurs your listener will be called with the
appropriate RemoteServiceAdminEvent. You can then check whether or not
the export succeeded by checking whether an Throwable was thrown, and
then if it did occur then you can do something else after the
registerService call returns. Note that the RemoteServiceAdminListener
will be called synchronously by the same thread that calls
registerService and RSA.exportService. Actually, all
RemoteServiceAdminListeners will be called before RSA.exportService returns.
2) A second way would be to create your own topology manager and replace
the BasicTopologyManager with your own. Then you could add logic (by
extending the BasicTopologyManager) to check the ExportRegistration
returned by RSA.exportService, and if found you could throw a
RuntimeException to halt the registerService call. Note you can do many
other things by replacing the BasicTopologyManager.
3) A third way would be to simply remove the BasicTopologyManager, and
call RemoteServiceAdmin.exportService *directly* in your own application
code. You could then get the ExportRegistration returned, check for
any exceptions upon export and do whatever was desired/appropriate.
I think that each of these would allow you to handle your exceptional
cases. They differ a little bit in how much control you have, but it
does add a lot of flexibility over the remote service export and import
and it's all within specification.
Please let all know if this helps.
Scott
[1] http://wiki.eclipse.org/EIG:Remote_Services_Admin
[2]
http://download.eclipse.org/rt/ecf/latest/javadoc/org/osgi/service/remoteserviceadmin/RemoteServiceAdmin.html
[3]
http://download.eclipse.org/rt/ecf/latest/javadoc/org/osgi/service/remoteserviceadmin/RemoteServiceAdminListener.html
ECF Version 3.12.0.v20151130-0157
Distribution Provider: generic
Discovery provider: zeroconf
In case you want to know why this can happen although everything is configured correctly, here is the explanation: An application using remote services is running and works ok. For some reason the user closes the application and restarts it right away. Unfortunately, after the window is gone the application takes some time (2-3 seconds) to actually shut down. If it is restarted to early, the data area is already free (otherwise equinox would already through an error) but the remote binding address is not. Since the error is only logged the restarted application window is shown, but the remote services are not available. From the users point of view it is currently impossible to detect this problem without looking into the log (which our default game operator won't do).
Right, makes perfect sense.
Scott
Thanks for your help!
Cheers,
Christoph
[1] Stacke Trace
15:12:50.963 ERROR o.e.ecf.osgi.services.distribution - FrameworkEvent ERROR
org.osgi.framework.ServiceException: Exception in org.eclipse.ecf.internal.osgi.services.distribution.BasicTopologyManagerComponent.event()
at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.notifyHookPrivileged(ServiceRegistry.java:1288) ~[na:na]
at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.notifyHooksPrivileged(ServiceRegistry.java:1263) ~[na:na]
at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.notifyEventListenerHooksPrivileged(ServiceRegistry.java:1235) ~[na:na]
at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEventPrivileged(ServiceRegistry.java:841) ~[na:na]
at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEvent(ServiceRegistry.java:801) ~[na:na]
at org.eclipse.osgi.internal.serviceregistry.ServiceRegistrationImpl.register(ServiceRegistrationImpl.java:127) ~[na:na]
at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.registerService(ServiceRegistry.java:225) ~[na:na]
at org.eclipse.osgi.internal.framework.BundleContextImpl.registerService(BundleContextImpl.java:464) ~[na:na]
at org.eclipse.osgi.internal.framework.BundleContextImpl.registerService(BundleContextImpl.java:482) ~[na:na]
at org.eclipse.osgi.internal.framework.BundleContextImpl.registerService(BundleContextImpl.java:998) ~[na:na]
at de.kware.pi.core.component.RemoteServiceComponent.registerService(RemoteServiceComponent.java:105) ~[na:na]
at de.kware.app.agent.bomb.internal.BombActivator.start(BombActivator.java:60) ~[na:na]
...
Caused by: java.lang.IllegalArgumentException: Failed to select, create, or configure ECF host container
at org.eclipse.ecf.osgi.services.remoteserviceadmin.RemoteServiceAdmin.exportService(RemoteServiceAdmin.java:324) ~[na:na]
at org.eclipse.ecf.osgi.services.remoteserviceadmin.AbstractTopologyManager.handleServiceRegistering(AbstractTopologyManager.java:442) ~[na:na]
at org.eclipse.ecf.osgi.services.remoteserviceadmin.AbstractTopologyManager.handleEvent(AbstractTopologyManager.java:404) ~[na:na]
at org.eclipse.ecf.internal.osgi.services.distribution.BasicTopologyManagerImpl.event(BasicTopologyManagerImpl.java:119) ~[na:na]
at org.eclipse.ecf.internal.osgi.services.distribution.BasicTopologyManagerComponent.event(BasicTopologyManagerComponent.java:57) ~[na:na]
at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry$6.call(ServiceRegistry.java:1238) ~[na:na]
at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.notifyHookPrivileged(ServiceRegistry.java:1280) ~[na:na]
... 42 common frames omitted
Caused by: org.eclipse.ecf.osgi.services.remoteserviceadmin.SelectContainerException: Exception creating or configuring container
at org.eclipse.ecf.osgi.services.remoteserviceadmin.AbstractContainerSelector.createContainer(AbstractContainerSelector.java:153) ~[na:na]
at org.eclipse.ecf.osgi.services.remoteserviceadmin.AbstractHostContainerSelector.createRSContainer(AbstractHostContainerSelector.java:333) ~[na:na]
at org.eclipse.ecf.osgi.services.remoteserviceadmin.AbstractHostContainerSelector.createMatchingContainer(AbstractHostContainerSelector.java:319) ~[na:na]
at org.eclipse.ecf.osgi.services.remoteserviceadmin.AbstractHostContainerSelector.createAndConfigureHostContainers(AbstractHostContainerSelector.java:244) ~[na:na]
at org.eclipse.ecf.osgi.services.remoteserviceadmin.HostContainerSelector.selectHostContainers(HostContainerSelector.java:77) ~[na:na]
at org.eclipse.ecf.osgi.services.remoteserviceadmin.RemoteServiceAdmin$1.run(RemoteServiceAdmin.java:315) ~[na:na]
at java.security.AccessController.doPrivileged(Native Method) ~[na:1.8.0_60]
at org.eclipse.ecf.osgi.services.remoteserviceadmin.RemoteServiceAdmin.exportService(RemoteServiceAdmin.java:312) ~[na:na]
... 48 common frames omitted
Caused by: org.eclipse.ecf.core.ContainerCreateException: Create of containerType=ecf.generic.server failed.
at org.eclipse.ecf.provider.generic.GenericContainerInstantiator.createInstance(GenericContainerInstantiator.java:303) ~[na:na]
at org.eclipse.ecf.core.ContainerFactory.createContainer(ContainerFactory.java:296) ~[na:na]
at org.eclipse.ecf.core.ContainerFactory.createContainer(ContainerFactory.java:592) ~[na:na]
at org.eclipse.ecf.osgi.services.remoteserviceadmin.AbstractContainerSelector.createContainer(AbstractContainerSelector.java:147) ~[na:na]
... 55 common frames omitted
Caused by: java.net.BindException: Address already in use: JVM_Bind
at java.net.TwoStacksPlainSocketImpl.socketBind(Native Method) ~[na:1.8.0_60]
at java.net.TwoStacksPlainSocketImpl.socketBind(TwoStacksPlainSocketImpl.java:137) ~[na:1.8.0_60]
at java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:387) ~[na:1.8.0_60]
at java.net.TwoStacksPlainSocketImpl.bind(TwoStacksPlainSocketImpl.java:110) ~[na:1.8.0_60]
at java.net.PlainSocketImpl.bind(PlainSocketImpl.java:190) ~[na:1.8.0_60]
at java.net.ServerSocket.bind(ServerSocket.java:375) ~[na:1.8.0_60]
at java.net.ServerSocket.<init>(ServerSocket.java:237) ~[na:1.8.0_60]
at org.eclipse.ecf.provider.comm.tcp.Server.<init>(Server.java:42) ~[na:na]
at org.eclipse.ecf.provider.generic.TCPServerSOContainerGroup.putOnTheAir(TCPServerSOContainerGroup.java:71) ~[na:na]
at org.eclipse.ecf.provider.generic.TCPServerSOContainer.<init>(TCPServerSOContainer.java:94) ~[na:na]
at org.eclipse.ecf.provider.generic.GenericContainerInstantiator.createServerContainer(GenericContainerInstantiator.java:282) ~[na:na]
at org.eclipse.ecf.provider.generic.GenericContainerInstantiator.createInstance(GenericContainerInstantiator.java:297) ~[na:na]
... 58 common frames omitted
_______________________________________________
ecf-dev mailing list
ecf-dev@xxxxxxxxxxx
To change your delivery options, retrieve your password, or unsubscribe from this list, visit
https://dev.eclipse.org/mailman/listinfo/ecf-dev
