aboutsummaryrefslogtreecommitdiffstats
path: root/csit/wait_for_port.sh
blob: 0a9adc3aa180bf7262ae04ed95869a783aa2a817 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
#!/bin/sh
# ============LICENSE_START====================================================
#  Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
#  Modifications Copyright (C) 2022 Nordix Foundation.
# =============================================================================
# Licensed 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.
#
# SPDX-License-Identifier: Apache-2.0
# ============LICENSE_END======================================================

usage() {
    echo args: [-t timeout] [-c command] hostname1 port1 hostname2 port2 ... >&2
    exit 1
}

tmout=300
cmd=
while getopts c:t: opt
do
    case "$opt" in
        c)
            cmd="$OPTARG"
            ;;

        t)
            tmout="$OPTARG"
            ;;

        *)
            usage
            ;;
    esac
done

nargs=$((OPTIND-1))
shift "$nargs"

even_args=$(($#%2))
if [ $# -lt 2 ] || [ "$even_args" -ne 0 ]
then
    usage
fi

while [ $# -ge 2 ]
do
    export host="$1"
    export port="$2"
    shift
    shift

    echo "Waiting for $host port $port..."

    while [ "$tmout" -gt 0 ]
    do
        nc -vz "$host" "$port"
        rc=$?

        if [ $rc -eq 0 ]
        then
            break
        else
            tmout=$((tmout-1))
            sleep 1
        fi
    done

    if [ $rc -ne 0 ]
    then
        echo "$host port $port cannot be reached"
        exit $rc
    fi
done

$cmd

exit 0
configuration);
+ List<TopicSource> sources = manager.addTopicSources(configuration);
assertSame(3, sources.size());
assertTrue(allSources(sources));
@@ -185,10 +182,10 @@ public class TopicEndpointProxyTest {
}
@Test
- public void addTopicSinksListOfTopicParameters() {
+ public void testAddTopicSinksListOfTopicParameters() {
TopicEndpoint manager = new TopicEndpointProxy();
- List<TopicSink> sinks = manager.addTopicSinks(group.getTopicSinks());
+ List<TopicSink> sinks = manager.addTopicSinks(group.getTopicSinks());
assertSame(3, sinks.size());
assertFalse(anySource(sinks));
@@ -196,10 +193,10 @@ public class TopicEndpointProxyTest {
}
@Test
- public void addTopicSinksProperties() {
+ public void testAddTopicSinksProperties() {
TopicEndpoint manager = new TopicEndpointProxy();
- List<TopicSink> sinks = manager.addTopicSinks(configuration);
+ List<TopicSink> sinks = manager.addTopicSinks(configuration);
assertSame(3, sinks.size());
assertFalse(anySource(sinks));
@@ -207,10 +204,10 @@ public class TopicEndpointProxyTest {
}
@Test
- public void addTopicsProperties() {
+ public void testAddTopicsProperties() {
TopicEndpoint manager = new TopicEndpointProxy();
- List<Topic> topics = manager.addTopics(configuration);
+ List<Topic> topics = manager.addTopics(configuration);
assertSame(6, topics.size());
assertTrue(allSources(topics));
@@ -218,10 +215,10 @@ public class TopicEndpointProxyTest {
}
@Test
- public void addTopicsTopicParameterGroup() {
+ public void testAddTopicsTopicParameterGroup() {
TopicEndpoint manager = new TopicEndpointProxy();
- List<Topic> topics = manager.addTopics(group);
+ List<Topic> topics = manager.addTopics(group);
assertSame(6, topics.size());
assertTrue(allSources(topics));
@@ -229,15 +226,15 @@ public class TopicEndpointProxyTest {
}
@Test
- public void addTopicsTopicParameterGroupNull() {
+ public void testAddTopicsTopicParameterGroupNull() {
TopicEndpoint manager = new TopicEndpointProxy();
- List<Topic> topics = manager.addTopics(new TopicParameterGroup());
+ List<Topic> topics = manager.addTopics(new TopicParameterGroup());
assertEquals(0, topics.size());
}
@Test
- public void lockSinks_lockSources_locked() {
+ public void testLockSinks_lockSources_locked() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.lock();
for (Topic topic : manager.addTopics(group)) {
@@ -246,7 +243,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void lockSinks_lockSources_unlocked() {
+ public void testLockSinks_lockSources_unlocked() {
TopicEndpoint manager = new TopicEndpointProxy();
for (Topic topic : manager.addTopics(group)) {
assertFalse(topic.isLocked());
@@ -254,13 +251,13 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getTopicSources() {
+ public void testGetTopicSources() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSources(configuration);
manager.addTopicSinks(configuration);
- List<TopicSource> sources = manager.getTopicSources();
+ List<TopicSource> sources = manager.getTopicSources();
assertSame(3, sources.size());
assertTrue(allSources(sources));
@@ -268,13 +265,13 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getTopicSinks() {
+ public void testGetTopicSinks() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSources(configuration);
manager.addTopicSinks(configuration);
- List<TopicSink> sinks = manager.getTopicSinks();
+ List<TopicSink> sinks = manager.getTopicSinks();
assertSame(3, sinks.size());
assertFalse(anySource(sinks));
@@ -282,7 +279,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getUebTopicSources() {
+ public void testGetUebTopicSources() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSources(configuration);
@@ -290,7 +287,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getDmaapTopicSources() {
+ public void testGetDmaapTopicSources() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSources(configuration);
@@ -298,7 +295,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getNoopTopicSources() {
+ public void testGetNoopTopicSources() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSources(configuration);
@@ -306,7 +303,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getUebTopicSinks() {
+ public void testGetUebTopicSinks() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSinks(configuration);
@@ -314,7 +311,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getDmaapTopicSinks() {
+ public void testGetDmaapTopicSinks() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSinks(configuration);
@@ -322,7 +319,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getNoopTopicSinks() {
+ public void testGetNoopTopicSinks() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSinks(configuration);
@@ -330,7 +327,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void lifecycle() {
+ public void testLifecycle() {
TopicEndpoint manager = new TopicEndpointProxy();
assertTrue(manager.start());
@@ -347,7 +344,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void lock() {
+ public void testLock() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.lock();
@@ -358,7 +355,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getTopicSource() {
+ public void testGetTopicSource() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSources(configuration);
@@ -367,15 +364,15 @@ public class TopicEndpointProxyTest {
assertSame(DMAAP_SOURCE_TOPIC, manager.getTopicSource(CommInfrastructure.DMAAP, DMAAP_SOURCE_TOPIC).getTopic());
assertThatIllegalStateException()
- .isThrownBy(() -> manager.getTopicSource(CommInfrastructure.NOOP, NOOP_SINK_TOPIC));
+ .isThrownBy(() -> manager.getTopicSource(CommInfrastructure.NOOP, NOOP_SINK_TOPIC));
assertThatIllegalStateException()
- .isThrownBy(() -> manager.getTopicSource(CommInfrastructure.UEB, UEB_SINK_TOPIC));
+ .isThrownBy(() -> manager.getTopicSource(CommInfrastructure.UEB, UEB_SINK_TOPIC));
assertThatIllegalStateException()
- .isThrownBy(() -> manager.getTopicSource(CommInfrastructure.DMAAP, DMAAP_SINK_TOPIC));
+ .isThrownBy(() -> manager.getTopicSource(CommInfrastructure.DMAAP, DMAAP_SINK_TOPIC));
}
@Test
- public void getTopicSink() {
+ public void testGetTopicSink() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSinks(configuration);
@@ -384,15 +381,15 @@ public class TopicEndpointProxyTest {
assertSame(DMAAP_SINK_TOPIC, manager.getTopicSink(CommInfrastructure.DMAAP, DMAAP_SINK_TOPIC).getTopic());
assertThatIllegalStateException()
- .isThrownBy(() -> manager.getTopicSink(CommInfrastructure.NOOP, NOOP_SOURCE_TOPIC));
+ .isThrownBy(() -> manager.getTopicSink(CommInfrastructure.NOOP, NOOP_SOURCE_TOPIC));
assertThatIllegalStateException()
- .isThrownBy(() -> manager.getTopicSink(CommInfrastructure.UEB, UEB_SOURCE_TOPIC));
+ .isThrownBy(() -> manager.getTopicSink(CommInfrastructure.UEB, UEB_SOURCE_TOPIC));
assertThatIllegalStateException()
- .isThrownBy(() -> manager.getTopicSink(CommInfrastructure.DMAAP, DMAAP_SOURCE_TOPIC));
+ .isThrownBy(() -> manager.getTopicSink(CommInfrastructure.DMAAP, DMAAP_SOURCE_TOPIC));
}
@Test
- public void getUebTopicSource() {
+ public void testGetUebTopicSource() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSources(configuration);
@@ -406,7 +403,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getUebTopicSink() {
+ public void testGetUebTopicSink() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSinks(configuration);
@@ -420,7 +417,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getDmaapTopicSource() {
+ public void testGetDmaapTopicSource() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSources(configuration);
@@ -434,7 +431,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getDmaapTopicSink() {
+ public void testGetDmaapTopicSink() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSinks(configuration);
@@ -449,7 +446,7 @@ public class TopicEndpointProxyTest {
@Test
- public void getNoopTopicSource() {
+ public void testGetNoopTopicSource() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSources(configuration);
@@ -463,7 +460,7 @@ public class TopicEndpointProxyTest {
}
@Test
- public void getNoopTopicSink() {
+ public void testGetNoopTopicSink() {
TopicEndpoint manager = new TopicEndpointProxy();
manager.addTopicSinks(configuration);
@@ -475,4 +472,4 @@ public class TopicEndpointProxyTest {
assertThatIllegalArgumentException().isThrownBy(() -> manager.getNoopTopicSink(null));
assertThatIllegalArgumentException().isThrownBy(() -> manager.getNoopTopicSink(""));
}
-} \ No newline at end of file
+}
diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicEndpointTest.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicEndpointTest.java
index 8e916ba0..0974a041 100644
--- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicEndpointTest.java
+++ b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicEndpointTest.java
@@ -29,6 +29,7 @@ import static org.mockito.Mockito.verify;
import java.util.Arrays;
import java.util.Collections;
+
import org.junit.Before;
import org.junit.Test;
import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure;
@@ -54,7 +55,7 @@ public abstract class NoopTopicEndpointTest<F extends NoopTopicFactory<T>, T ext
}
@Test
- public void tesIo() {
+ public void testIo() {
TopicListener listener = mock(TopicListener.class);
this.endpoint.register(listener);
this.endpoint.start();