From the earlier configuration info, I saw that JRMP was used.
Tim,
The endpoint is a configuration component which determines the communication
protocol.
If you want to take full advantage of River 30 you'll want to use one of the
JERI endpoints. JRMP was provided for backward compatibility with Jini 1.x, it
uses java rmi.
Regards,
Peter.
Sent from my Samsung device.
Include original message
---- Original message ----
From: Timothy C Haas <h...@uwm.edu>
Sent: 28/02/2017 07:33:07 am
To: dev@river.apache.org <dev@river.apache.org>
Subject: Re: reggie not hearing
Gregg;
My apologies but I don't know what an endpoint is. Below is the script that
started reggie. Does that show endpoints?
Regards,
-Tim
---------------------------------------------------
rm /home/haas/jinitmp/*
rm /home/haas/jsutils/log/*
echo [Deleting contents of jinitmp and log directories]
#
rh="/projects/builder-group/jpg/apache-river"
myconfigs="/home/haas/jsutils"
host=$(hostname)
cd /home/haas/jsutils
#
# Start an http server.
#
java -Djava.rmi.server.useCodebaseOnly=false \
-Djava.security.policy=${myconfigs}/start.policy \
-jar ${rh}/lib/start.jar ${myconfigs}/httpd.config &
sleep 5
echo HTTP Server Running on node ${host}
#
# Start an activation daemon. Important: verify that all files in
# the phoenix log directory have been deleted before running phoenix.
#
java -Djava.rmi.server.useCodebaseOnly=false \
-Djava.security.manager= \
-Djava.security.policy=${myconfigs}/policy.all \
-Djava.rmi.server.codebase="http://${host}:4160/phoenix-dl.jar
http://${host}:4160/jsk-dl.jar" \
-DserverHost=${host} \
-jar ${rh}/lib/phoenix.jar ${myconfigs}/phoenixk.config &
echo - Activation Daemon Running -
#
# Start a reggie lookup service.
#
java -Djava.security.policy=${myconfigs}/reggie.policy \
-Djava.rmi.server.useCodebaseOnly=false \
-Dcom.sun.jini.reggie.proxy.debug=true \
-Djava.ext.dirs=${rh}/lib-ext/:${rh}/lib-dl/:${rh}/lib/:${rh}/dep-libs/groovy/
\
-jar ${rh}/lib/start.jar ${myconfigs}/start-reggie.config &
echo - Lookup Service Running -
#
# Start a JavaSpace.
#
java -Djava.security.policy=${myconfigs}/policy.all \
-Djava.rmi.server.useCodebaseOnly=false \
-jar ${rh}/lib/start.jar ${myconfigs}/start-outrigger.config &
echo - JavaSpace Running -
-----------------------------------------------------------------------------------------------
________________________________
From: Gregg Wonderly <ge...@cox.net>
Sent: Monday, February 27, 2017 3:01 PM
To: dev@river.apache.org
Subject: Re: reggie not hearing
What is your configuration for reggie’s endpoints?
Gregg
> On Feb 27, 2017, at 10:38 AM, Timothy C Haas <h...@uwm.edu> wrote:
>
> Folks;
>
> I've fixed my phoenix ClassNotFound problem. Turns out, when
> I log into the San Diego cluster computer, I'm assigned randomly
> to one of their 640 nodes. Almost always, a different one each time.
> I wasn't emptying the phoenix log directory that stored the
> node's address from the previous run
> of phoenix. So, phoenix was always trying to reach classerver
> on the wrong node. I now delete all files in the phoenix log
> directory before I start phoenix. I noticed this problem only
> because I acted on a suggestion from this forum to use curl to
> see if classserver could be reached. This experience might be
> interesting to others working with Apache River on a cluster
> computer platform.
>
> I'm now trying to get my application to register with reggie. The
> following error message indicates I'm timing out on the socket.
> The output shows that the reggie service (I turned on reggie debugging)
> is indeed running and a socket has been connected to.
> My SpaceAccessor.java code that tried to register follows. I'm
> using only Apache River jars. The reggie configuration files
> follow that. I think reggie can be reached on port 4160 but it does
> say a different port in the dump (which changes every time the
> script runs). I think reggie is not hearing the registrar request
> but I don't know how to debug this or fix it.
>
> Regards,
>
> -Tim
>
> ----------------------------------------------------------------
>
> INFO: ClassServer started
>[[/projects/builder-group/jpg/apache-river/lib-dl/,/projects/builder-group/jpg/apache-river/lib/,
> /projects/builder-group/jpg/apache-
> river/lib-ext/], port 4160]
> Feb 27, 2017 8:04:54 AM org.apache.river.outrigger.OutriggerServerImpl <init>
> INFO: Outrigger server started:
>org.apache.river.outrigger.OutriggerServerImpl@502438db
> Feb 27, 2017 8:04:54 AM org.apache.river.phoenix.Activation init
> INFO: activation daemon started
> Feb 27, 2017 8:04:55 AM org.apache.river.reggie.RegistrarImpl$Unicast <init>
> INFO: Reggie Unicast Discovery listening on port 33,814
> Feb 27, 2017 8:04:55 AM org.apache.river.reggie.RegistrarImpl$3 run
> INFO: started Reggie: 8ed3b539-4a66-4941-941a-17715df5eea9, [nonsecure],
>jini://
> tscc-2-53.sdsc.edu:33814/
> java.net.SocketTimeoutException: Read timed out
> at java.net.SocketInputStream.socketRead0(Native Method)
> at java.net.SocketInputStream.read(SocketInputStream.java:152)
> at java.net.SocketInputStream.read(SocketInputStream.java:122)
> at java.io.DataInputStream.readFully(DataInputStream.java:195)
> at
>org.apacheriver.discovery.DiscoveryV2.doUnicastDiscovery(DiscoveryV2.java:460)
> at
>net.jini.core.discovery.LookupLocator$2.performDiscovery(LookupLocator.java:347)
>
> at
>org.apache.river.discovery.internal.MultiIPDiscovery.getSingleResponse(MultiIPDiscovery.java:153)
>
> at
>org.apache.river.discovery.internal.MultiIPDiscovery.getResponse(MultiIPDiscovery.java:82)
> at
>net.jini.core.discovery.LookupLocator.getRegistrar(LookupLocator.java:341)
> at
>net.jini.core.discovery.LookupLocator.getRegistrar(LookupLocator.java:315)
> at SpaceAccessor.<init>(SpaceAccessor.java:83)
>
> --------------------- Socket info from SpaceAccessor.java -------
>
> spaceaccessor: jiniURL= jini://tscc-2-53.sdsc.edu
> locator= jini://tscc-2-53.sdsc.edu:4160/
> Port: 4160
> Canonical Host Name: tscc-2-53.sdsc.edu
> Host Address: 132.249.107.73
>
> Local Address: /132.249.107.73
> Local Port: 40406
> Local Socket Address: /132.249.107.73:40406
>
> Receive Buffer Size: 87379
> Send Buffer Size: 330075
>
> Keep-Alive: false
> SO Timeout: 0
> isConnected= true
> bad request "
> bad request "
> Read timed out
> bad request "
>
> --------------------- SpaceAccessor.java code fragment --------------
>
> import net.jini.corediscovery.LookupLocator;
> import net.jini.core.lookup.*;
> import net.jini.core.entry.Entry;
> import net.jini.space.JavaSpace;
> import net.jini.lookup.entry.*;
> import java.io.*;
> import java.rmi.*;
> import java.net.*;
> import java.util.*;
> import net.jini.discovery.LookupDiscovery;
> import net.jini.discovery.DiscoveryListener;
> import net.jini.discovery.DiscoveryEvent;
> import net.jini.discovery.Constants;
>
> public class SpaceAccessor {
>
> static String jiniURL = "jini://" + Id.mstrip;
>
> static final long MAX_LOOKUP_WAIT = 2000L;
> static final int WAIT = 100000;
>
> JavaSpace space;
>
> public SpaceAccessor() {
> LookupLocator locator = null;
> ServiceRegistrar registrar = null;
>
> try {
> System.setSecurityManager(new SecurityManager());
> }
> catch (Exception e) {
> e.printStackTrace();
> }
>
> if (Id.client) {
> jiniURL = "jini://" + Id.mstrip + ":4160/";
> }
> Id.printf_("spaceaccessor: jiniURL= " + jiniURL);
>
> try {
> locator = new LookupLocator(jiniURL);
> Thread.sleep(1000);
>
> Idprintf_("locator= " + locator.toString());
> Socket socket = new Socket(locator.getHost(),locator.getPort());
> printSocketInformation(socket);
> Id.printf_("isConnected= " + (socketisConnected()));
>
> registrar = locator.getRegistrar(WAIT);
>
> --------------------- start-reggie.config -----------------------
>
> import org.apacheriver.config.ConfigUtil;
> import org.apache.river.start.NonActivatableServiceDescriptor;
> import org.apache.river.start.ServiceDescriptor;
>
> org.apache.river.start {
> private static policy = "policy.all";
> port="4160";
> private static codebasePrefix= " http://" + ConfigUtil.getHostAddress()
> + ":" + port + "/";
> private static codebase = codebasePrefix + "reggie-dl.jar" +
> codebasePrefix + "jsk-dl.jar" +
> codebasePrefix + "reggie.jar" +
> codebasePrefix + "jsk-policy.jar";
> private static classpath =
>
>"${/}projects${/}builder-group${/}jpg${/}apache-river${/}lib${/}reggie.jar";
> private static config = "jrmp-reggie.config";
>
> static serviceDescriptors = new ServiceDescriptor[] {
> new NonActivatableServiceDescriptor(
> codebase, policy, classpath,
> "org.apache.river.reggie.TransientRegistrarImpl",
> new String[] { config })
> };
> }
>
> --------------------- jrmp-reggie.config -----------------------
>
> /*
> * 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 20 (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
Apache License 2.0 - Apache Software
Foundation<http://www.apache.org/licenses/LICENSE-2.0>
www.apache.org
Apache License Version 2.0, January 2004 http://www.apache.org/licenses/ TERMS
AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION 1. Definitions ...
> *
> * 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.
> */
>
> /* Configure source file for JRMP reggie */
>
> import net.jini.jrmp.JrmpExporter;
>
> org.apache.river.reggie {
>
> serverExporter = new JrmpExporter();
> initialMemberGroups = new String[] { "nonsecure" };
>
> }//end org.apache.river.reggie
>
>
