Skip to content

Commit f79e966

Browse files
vordimousvordimous
committed
feat: replace tcp binding port 8080 with 12345
also update any 808x ports
1 parent 1045888 commit f79e966

File tree

79 files changed

+150
-150
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

79 files changed

+150
-150
lines changed

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/bench/TcpServerBM.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ public class TcpServerBM
7777
public void reinit() throws Exception
7878
{
7979
engine.start();
80-
//routedId = controller.route(RouteKind.SERVER, "127.0.0.1:8080", "tcp#0").get();
80+
//routedId = controller.route(RouteKind.SERVER, "127.0.0.1:12345", "tcp#0").get();
8181
}
8282

8383
@TearDown(Level.Trial)
@@ -112,7 +112,7 @@ public GroupState()
112112
public void init() throws Exception
113113
{
114114
channel = SocketChannel.open();
115-
channel.connect(new InetSocketAddress("127.0.0.1", 8080));
115+
channel.connect(new InetSocketAddress("127.0.0.1", 12345));
116116
channel.configureBlocking(false);
117117
}
118118

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/config/TcpConditionConfigAdapterTest.java‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ public void shouldReadCondition()
4949
"{" +
5050
"\"cidr\": \"127.0.0.0/24\"," +
5151
"\"authority\": \"*.example.net\"," +
52-
"\"port\": 8080" +
52+
"\"port\": 12345" +
5353
"}";
5454

5555
TcpConditionConfig condition = jsonb.fromJson(text, TcpConditionConfig.class);
@@ -59,7 +59,7 @@ public void shouldReadCondition()
5959
assertThat(condition.authority, equalTo("*.example.net"));
6060
assertThat(condition.ports, not(nullValue()));
6161
assertThat(condition.ports.length, equalTo(1));
62-
assertThat(condition.ports[0], equalTo(8080));
62+
assertThat(condition.ports[0], equalTo(12345));
6363
}
6464

6565
@Test
@@ -69,13 +69,13 @@ public void shouldWriteCondition()
6969
.inject(identity())
7070
.cidr("127.0.0.0/24")
7171
.authority("*.example.net")
72-
.ports(new int[] { 8080 })
72+
.ports(new int[] { 12345 })
7373
.build();
7474

7575
String text = jsonb.toJson(condition);
7676

7777
assertThat(text, not(nullValue()));
78-
assertThat(text, equalTo("{\"cidr\":\"127.0.0.0/24\",\"authority\":\"*.example.net\",\"port\":8080}"));
78+
assertThat(text, equalTo("{\"cidr\":\"127.0.0.0/24\",\"authority\":\"*.example.net\",\"port\":12345}"));
7979
}
8080

8181
@Test
@@ -85,16 +85,16 @@ public void shouldReadConditionWithPortRange()
8585
"{" +
8686
"\"cidr\": \"127.0.0.0/24\"," +
8787
"\"authority\": \"*.example.net\"," +
88-
"\"port\": 8080-8081" +
88+
"\"port\": 12345-12346" +
8989
"}";
9090

9191
TcpConditionConfig condition = jsonb.fromJson(text, TcpConditionConfig.class);
9292

9393
assertThat(condition, not(nullValue()));
9494
assertThat(condition.ports, not(nullValue()));
9595
assertThat(condition.ports.length, equalTo(2));
96-
assertThat(condition.ports[0], equalTo(8080));
97-
assertThat(condition.ports[1], equalTo(8081));
96+
assertThat(condition.ports[0], equalTo(12345));
97+
assertThat(condition.ports[1], equalTo(12346));
9898
}
9999

100100
@Test
@@ -104,14 +104,14 @@ public void shouldReadConditionWithPortRangeSingleton()
104104
"{" +
105105
"\"cidr\": \"127.0.0.0/24\"," +
106106
"\"authority\": \"*.example.net\"," +
107-
"\"port\": \"8080\"" +
107+
"\"port\": \"12345\"" +
108108
"}";
109109

110110
TcpConditionConfig condition = jsonb.fromJson(text, TcpConditionConfig.class);
111111

112112
assertThat(condition, not(nullValue()));
113113
assertThat(condition.ports, not(nullValue()));
114114
assertThat(condition.ports.length, equalTo(1));
115-
assertThat(condition.ports[0], equalTo(8080));
115+
assertThat(condition.ports[0], equalTo(12345));
116116
}
117117
}

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/config/TcpOptionsConfigAdapterTest.java‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public void shouldReadOptions()
4848
String text =
4949
"{" +
5050
"\"host\": \"localhost\"," +
51-
"\"port\": 8080" +
51+
"\"port\": 12345" +
5252
"}";
5353

5454
TcpOptionsConfig options = jsonb.fromJson(text, TcpOptionsConfig.class);
@@ -57,7 +57,7 @@ public void shouldReadOptions()
5757
assertThat(options.host, equalTo("localhost"));
5858
assertThat(options.ports, not(nullValue()));
5959
assertThat(options.ports.length, equalTo(1));
60-
assertThat(options.ports[0], equalTo(8080));
60+
assertThat(options.ports[0], equalTo(12345));
6161
}
6262

6363
@Test
@@ -66,7 +66,7 @@ public void shouldReadOptionsWithPortRange()
6666
String text =
6767
"{" +
6868
"\"host\": \"localhost\"," +
69-
"\"port\": \"8080-8081\"" +
69+
"\"port\": \"12345-12346\"" +
7070
"}";
7171

7272
TcpOptionsConfig options = jsonb.fromJson(text, TcpOptionsConfig.class);
@@ -75,8 +75,8 @@ public void shouldReadOptionsWithPortRange()
7575
assertThat(options.host, equalTo("localhost"));
7676
assertThat(options.ports, not(nullValue()));
7777
assertThat(options.ports.length, equalTo(2));
78-
assertThat(options.ports[0], equalTo(8080));
79-
assertThat(options.ports[1], equalTo(8081));
78+
assertThat(options.ports[0], equalTo(12345));
79+
assertThat(options.ports[1], equalTo(12346));
8080
}
8181

8282
@Test
@@ -85,7 +85,7 @@ public void shouldReadOptionsWithPortRangeSingleton()
8585
String text =
8686
"{" +
8787
"\"host\": \"localhost\"," +
88-
"\"port\": \"8080\"" +
88+
"\"port\": \"12345\"" +
8989
"}";
9090

9191
TcpOptionsConfig options = jsonb.fromJson(text, TcpOptionsConfig.class);
@@ -94,7 +94,7 @@ public void shouldReadOptionsWithPortRangeSingleton()
9494
assertThat(options.host, equalTo("localhost"));
9595
assertThat(options.ports, not(nullValue()));
9696
assertThat(options.ports.length, equalTo(1));
97-
assertThat(options.ports[0], equalTo(8080));
97+
assertThat(options.ports[0], equalTo(12345));
9898
}
9999

100100
@Test
@@ -103,13 +103,13 @@ public void shouldWriteOptions()
103103
TcpOptionsConfig options = TcpOptionsConfig.builder()
104104
.inject(identity())
105105
.host("localhost")
106-
.ports(new int[] { 8080 })
106+
.ports(new int[] { 12345 })
107107
.build();
108108

109109
String text = jsonb.toJson(options);
110110

111111
assertThat(text, not(nullValue()));
112-
assertThat(text, equalTo("{\"host\":\"localhost\",\"port\":8080}"));
112+
assertThat(text, equalTo("{\"host\":\"localhost\",\"port\":12345}"));
113113
}
114114

115115
@Test
@@ -118,7 +118,7 @@ public void shouldReadOptionsWithBacklog()
118118
String text =
119119
"{" +
120120
"\"host\": \"localhost\"," +
121-
"\"port\": 8080," +
121+
"\"port\": 12345," +
122122
"\"backlog\": 1000" +
123123
"}";
124124

@@ -128,7 +128,7 @@ public void shouldReadOptionsWithBacklog()
128128
assertThat(options.host, equalTo("localhost"));
129129
assertThat(options.ports, not(nullValue()));
130130
assertThat(options.ports.length, equalTo(1));
131-
assertThat(options.ports[0], equalTo(8080));
131+
assertThat(options.ports[0], equalTo(12345));
132132
assertThat(options.backlog, equalTo(1000));
133133
}
134134

@@ -138,13 +138,13 @@ public void shouldWriteOptionsWithBacklog()
138138
TcpOptionsConfig options = TcpOptionsConfig.builder()
139139
.inject(identity())
140140
.host("localhost")
141-
.ports(new int[] { 8080 })
141+
.ports(new int[] { 12345 })
142142
.backlog(1000)
143143
.build();
144144

145145
String text = jsonb.toJson(options);
146146

147147
assertThat(text, not(nullValue()));
148-
assertThat(text, equalTo("{\"host\":\"localhost\",\"port\":8080,\"backlog\":1000}"));
148+
assertThat(text, equalTo("{\"host\":\"localhost\",\"port\":12345,\"backlog\":1000}"));
149149
}
150150
}

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/streams/ClientIOExceptionFromReadIT.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ public void shouldReportIOExceptionFromReadAsAbortAndReset() throws Exception
6161
try (ServerSocketChannel server = ServerSocketChannel.open())
6262
{
6363
server.setOption(SO_REUSEADDR, true);
64-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
64+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
6565

6666
k3po.start();
6767

@@ -87,7 +87,7 @@ public void shouldNotResetWhenProcessingEndAfterIOExceptionFromRead() throws Exc
8787
try (ServerSocketChannel server = ServerSocketChannel.open())
8888
{
8989
server.setOption(SO_REUSEADDR, true);
90-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
90+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
9191

9292
k3po.start();
9393

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/streams/ClientIOExceptionFromWriteIT.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ public void shouldAbortAndResetWhenImmediateWriteThrowsIOException() throws Exce
7575
try (ServerSocketChannel server = ServerSocketChannel.open())
7676
{
7777
server.setOption(SO_REUSEADDR, true);
78-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
78+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
7979

8080
k3po.start();
8181

@@ -112,7 +112,7 @@ public void shouldAbortAndResetWhenDeferredWriteThrowsIOException() throws Excep
112112
try (ServerSocketChannel server = ServerSocketChannel.open())
113113
{
114114
server.setOption(SO_REUSEADDR, true);
115-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
115+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
116116

117117
k3po.start();
118118

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/streams/ClientIT.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ public void shouldReceiveClientSentDataAndEnd() throws Exception
135135
try (ServerSocketChannel server = ServerSocketChannel.open())
136136
{
137137
server.setOption(SO_REUSEADDR, true);
138-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
138+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
139139

140140
k3po.start();
141141

@@ -167,7 +167,7 @@ public void shouldWriteDataAfterReceivingEndOfRead() throws Exception
167167
try (ServerSocketChannel server = ServerSocketChannel.open())
168168
{
169169
server.setOption(SO_REUSEADDR, true);
170-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
170+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
171171

172172
k3po.start();
173173

@@ -202,7 +202,7 @@ public void shouldEstablishConnection() throws Exception
202202
"${app}/connection.established.ipv6/client",
203203
"${net}/connection.established/server"
204204
})
205-
@ScriptProperty("address \"tcp://[::1]:8080\"")
205+
@ScriptProperty("address \"tcp://[::1]:12345\"")
206206
public void shouldEstablishConnectionIPv6() throws Exception
207207
{
208208
k3po.finish();
@@ -297,7 +297,7 @@ public void shouldReceiveServerSentDataAndEnd() throws Exception
297297
try (ServerSocketChannel server = ServerSocketChannel.open())
298298
{
299299
server.setOption(SO_REUSEADDR, true);
300-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
300+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
301301

302302
k3po.start();
303303

@@ -323,7 +323,7 @@ public void shouldWriteDataAfterReceiveEnd() throws Exception
323323
try (ServerSocketChannel server = ServerSocketChannel.open())
324324
{
325325
server.setOption(SO_REUSEADDR, true);
326-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
326+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
327327

328328
k3po.start();
329329

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/streams/ClientLimitsIT.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ public void shouldResetWhenWindowExceeded() throws Exception
6464
try (ServerSocketChannel server = ServerSocketChannel.open())
6565
{
6666
server.setOption(SO_REUSEADDR, true);
67-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
67+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
6868

6969
k3po.start();
7070

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/streams/ClientPartialWriteIT.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,7 @@ public void shouldHandleEndOfStreamWithPendingWrite() throws Exception
142142
try (ServerSocketChannel server = ServerSocketChannel.open())
143143
{
144144
server.setOption(SO_REUSEADDR, true);
145-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
145+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
146146

147147
k3po.start();
148148

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/streams/ClientPartialWriteLimitsIT.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ public void shouldResetStreamsExceedingPartialWriteStreamsLimit() throws Excepti
104104
try (ServerSocketChannel server = ServerSocketChannel.open())
105105
{
106106
server.setOption(SO_REUSEADDR, true);
107-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
107+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
108108

109109
k3po.start();
110110

‎runtime/binding-tcp/src/test/java/io/aklivity/zilla/runtime/binding/tcp/internal/streams/ClientResetAndAbortIT.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ public void shouldShutdownOutputWhenClientSendsAbort() throws Exception
6969
try (ServerSocketChannel server = ServerSocketChannel.open())
7070
{
7171
server.setOption(SO_REUSEADDR, true);
72-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
72+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
7373

7474
k3po.start();
7575

@@ -106,7 +106,7 @@ public void shouldShutdownOutputAndInputWhenClientSendsAbortAndReset() throws Ex
106106
try (ServerSocketChannel server = ServerSocketChannel.open())
107107
{
108108
server.setOption(SO_REUSEADDR, true);
109-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
109+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
110110

111111
k3po.start();
112112

@@ -144,7 +144,7 @@ public void shouldShutdownInputWhenClientSendsReset() throws Exception
144144
try (ServerSocketChannel server = ServerSocketChannel.open())
145145
{
146146
server.setOption(SO_REUSEADDR, true);
147-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
147+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
148148

149149
k3po.start();
150150

@@ -185,7 +185,7 @@ public void shouldShutdownOutputAndInputWhenClientSendsResetAndEnd() throws Exce
185185
try (ServerSocketChannel server = ServerSocketChannel.open())
186186
{
187187
server.setOption(SO_REUSEADDR, true);
188-
server.bind(new InetSocketAddress("127.0.0.1", 8080));
188+
server.bind(new InetSocketAddress("127.0.0.1", 12345));
189189

190190
k3po.start();
191191

0 commit comments

Comments
 (0)