Author: degenaro
Date: Fri Jan 4 14:11:13 2019
New Revision: 1850364
URL: http://svn.apache.org/viewvc?rev=1850364&view=rev
Log: (empty)
Added:
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotAlive.java
(with props)
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotHealthy.java
(with props)
Added:
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotAlive.java
URL:
http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotAlive.java?rev=1850364&view=auto
==============================================================================
---
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotAlive.java
(added)
+++
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotAlive.java
Fri Jan 4 14:11:13 2019
@@ -0,0 +1,110 @@
+/*
+ * 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.uima.ducc.test.service;
+
+import java.io.DataInputStream;
+import java.io.InputStream;
+import java.net.Socket;
+
+import org.apache.uima.ducc.cli.AServicePing;
+import org.apache.uima.ducc.cli.ServiceStatistics;
+
+/**
+ * This is designed for the simple sleeper "service" that does nothing other
than
+ * wait for requests from the pinger.
+ *
+ * The necessary endpoint is CUSTOM:name:host:port
+ */
+public class CustomPingNotAlive
+ extends AServicePing
+{
+ String host;
+ String port;
+ public void init(String arguments, String endpoint)
+ throws Exception
+ {
+ String[] parts = endpoint.split(":");
+ // [1] is the type of service, always ignored
+ host = parts[2];
+ port = parts[3];
+ }
+
+ public void stop()
+ {
+ }
+
+ public long readLong(DataInputStream dis)
+ throws Exception
+ {
+ long stat1 = dis.readLong();
+ return Long.reverseBytes(stat1);
+ }
+
+ public ServiceStatistics getStatistics()
+ {
+ ServiceStatistics stats = new ServiceStatistics(false, false,"<NA>");
+ try {
+ Socket sock = new Socket(host, Integer.parseInt(port));
+ InputStream sock_in = sock.getInputStream();
+
+ DataInputStream dis = new DataInputStream(sock_in);
+
+ long stat1 = readLong(dis);
+ long stat2 = readLong(dis);
+ long stat3 = readLong(dis);
+ long stat4 = readLong(dis);
+
+ stats.setAlive(false);
+ stats.setHealthy(true);
+ stats.setInfo( "S1[" + stat1 +
+ "] S2[" + stat2 +
+ "] S3[" + stat3 +
+ "] S4[" + stat4 +
+ "]"
+ );
+ sock.close();
+ } catch ( Throwable t) {
+ t.printStackTrace();
+ stats.setInfo(t.getMessage());
+ }
+ return stats;
+ }
+
+ public static void main(String[] args)
+ {
+ try {
+ CustomPingNotAlive cp = new CustomPingNotAlive();
+ cp.init(null, args[0]);
+ for ( int i = 0; i < 10; i++ ) {
+ ServiceStatistics stats = cp.getStatistics();
+ System.out.println(stats);
+ Thread.sleep(2000);
+ }
+ cp.stop();
+ } catch (InterruptedException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } catch (Exception e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+}
Propchange:
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotAlive.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added:
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotHealthy.java
URL:
http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotHealthy.java?rev=1850364&view=auto
==============================================================================
---
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotHealthy.java
(added)
+++
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotHealthy.java
Fri Jan 4 14:11:13 2019
@@ -0,0 +1,110 @@
+/*
+ * 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.uima.ducc.test.service;
+
+import java.io.DataInputStream;
+import java.io.InputStream;
+import java.net.Socket;
+
+import org.apache.uima.ducc.cli.AServicePing;
+import org.apache.uima.ducc.cli.ServiceStatistics;
+
+/**
+ * This is designed for the simple sleeper "service" that does nothing other
than
+ * wait for requests from the pinger.
+ *
+ * The necessary endpoint is CUSTOM:name:host:port
+ */
+public class CustomPingNotHealthy
+ extends AServicePing
+{
+ String host;
+ String port;
+ public void init(String arguments, String endpoint)
+ throws Exception
+ {
+ String[] parts = endpoint.split(":");
+ // [1] is the type of service, always ignored
+ host = parts[2];
+ port = parts[3];
+ }
+
+ public void stop()
+ {
+ }
+
+ public long readLong(DataInputStream dis)
+ throws Exception
+ {
+ long stat1 = dis.readLong();
+ return Long.reverseBytes(stat1);
+ }
+
+ public ServiceStatistics getStatistics()
+ {
+ ServiceStatistics stats = new ServiceStatistics(false, false,"<NA>");
+ try {
+ Socket sock = new Socket(host, Integer.parseInt(port));
+ InputStream sock_in = sock.getInputStream();
+
+ DataInputStream dis = new DataInputStream(sock_in);
+
+ long stat1 = readLong(dis);
+ long stat2 = readLong(dis);
+ long stat3 = readLong(dis);
+ long stat4 = readLong(dis);
+
+ stats.setAlive(true);
+ stats.setHealthy(false);
+ stats.setInfo( "S1[" + stat1 +
+ "] S2[" + stat2 +
+ "] S3[" + stat3 +
+ "] S4[" + stat4 +
+ "]"
+ );
+ sock.close();
+ } catch ( Throwable t) {
+ t.printStackTrace();
+ stats.setInfo(t.getMessage());
+ }
+ return stats;
+ }
+
+ public static void main(String[] args)
+ {
+ try {
+ CustomPingNotHealthy cp = new CustomPingNotHealthy();
+ cp.init(null, args[0]);
+ for ( int i = 0; i < 10; i++ ) {
+ ServiceStatistics stats = cp.getStatistics();
+ System.out.println(stats);
+ Thread.sleep(2000);
+ }
+ cp.stop();
+ } catch (InterruptedException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } catch (Exception e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+}
Propchange:
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/service/CustomPingNotHealthy.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
