Skip to content
Merged
Changes from 1 commit
Commits
Show all changes
99 commits
Select commit Hold shift + click to select a range
adb80f3
* add netty dependent
coderzc Mar 22, 2021
170bdcf
* add netty dependent
coderzc Mar 22, 2021
6153840
* add netty dependent
coderzc Mar 22, 2021
31b8bdd
* add netty dependent
coderzc Mar 22, 2021
f1f2fe4
improve copyright
coderzc Mar 22, 2021
d9d280b
modify netty depend
coderzc Mar 23, 2021
90f9566
improve transport config
coderzc Mar 23, 2021
401d705
add NettyTransportServer
coderzc Mar 23, 2021
31c8a0a
* add netty dependent
coderzc Mar 22, 2021
6243396
improve copyright
coderzc Mar 22, 2021
f33b445
modify netty depend
coderzc Mar 23, 2021
dc839ba
delete extra IOMode
coderzc Mar 23, 2021
c805661
* improve NettyTransportServer
coderzc Mar 24, 2021
a3b2838
* improve NettyTransportServer
coderzc Mar 24, 2021
fa1f20f
* improve NettyTransportServer
coderzc Mar 25, 2021
bd414aa
fix check style
coderzc Mar 25, 2021
93a724a
NettyConnectionManager --> NettyClientConnectionManager
coderzc Mar 25, 2021
ab672d3
NettyConnectionManager --> NettyClientConnectionManager
coderzc Mar 25, 2021
44545ea
NettyConnectionManager --> NettyClientConnectionManager
coderzc Mar 25, 2021
cbcfd63
optimize ClientManager, ClientFactory, NettyTransportClient
coderzc Mar 25, 2021
df6b884
optimize ClientManager, ClientFactory, NettyTransportClient
coderzc Mar 25, 2021
db1e637
optimize ClientManager, ClientFactory, NettyTransportClient
coderzc Mar 25, 2021
6e43291
optimize ClientManager,ClientFactory
coderzc Mar 25, 2021
903cf44
* optimize code style
coderzc Mar 26, 2021
bbe4863
* optimize code style
coderzc Mar 26, 2021
12995d2
* improve ConnectionManager interface
coderzc Mar 26, 2021
132f260
* fix code style
coderzc Mar 27, 2021
8df69da
* rebase master
coderzc Mar 27, 2021
b9f6346
improve host and connection error message
coderzc Mar 27, 2021
0a80d99
Transport4Client -> TransportClient, Transport4Server -> TransportServer
coderzc Mar 29, 2021
cd6b359
* add Message,Handler,codec
coderzc Mar 31, 2021
bd142d8
fix code style
coderzc Apr 2, 2021
824ceac
* fix code style
coderzc Apr 2, 2021
dfb3f0e
* fix code style
coderzc Apr 6, 2021
57b8530
improve MessageDecoder
coderzc Apr 6, 2021
a3cadae
fix code style
coderzc Apr 6, 2021
c6cea82
fix code style
coderzc Apr 7, 2021
ff0fff4
* improve test coverage
coderzc Apr 9, 2021
e78d093
fix code style
coderzc Apr 9, 2021
d93ea04
* fix code style
coderzc Apr 9, 2021
4a9da67
* fix code style
coderzc Apr 9, 2021
0229bfb
add timeout
coderzc Apr 9, 2021
a0027ab
add timeout
coderzc Apr 9, 2021
12cf651
* 2000 -> 2000L
coderzc Apr 9, 2021
0b541e6
3000 -> 3000L
coderzc Apr 9, 2021
aede99b
* zero-copy body
coderzc Apr 9, 2021
3476e5e
* use zero-copy transport
coderzc Apr 10, 2021
c758703
add blank line
coderzc Apr 10, 2021
7f3d5c0
improve buffer reference
coderzc Apr 11, 2021
d115d5e
improve buffer reference
coderzc Apr 11, 2021
1a9a4f3
* add WakeHandler
coderzc Apr 12, 2021
c6651b4
* improve code style
coderzc Apr 12, 2021
d4b37b9
add message title
coderzc Apr 12, 2021
5d19234
improve code style
coderzc Apr 12, 2021
d9cd8c6
add ClientChannelListenerOnWrite
coderzc Apr 12, 2021
bf421fd
add ClientChannelListenerOnWrite
coderzc Apr 12, 2021
d71bd52
improve ChannelFutureListenerOnWrite
coderzc Apr 12, 2021
5761e32
improve test coverage
coderzc Apr 12, 2021
e94e5fd
improve test coverage
coderzc Apr 12, 2021
b61d91a
improve code style
coderzc Apr 12, 2021
0ea08ce
improve code style
coderzc Apr 12, 2021
7f44f71
improve code style
coderzc Apr 12, 2021
9a86777
improve code style
coderzc Apr 12, 2021
51e29fd
improve code style
coderzc Apr 12, 2021
1772e52
improve code style
coderzc Apr 12, 2021
d969eaa
improve code style
coderzc Apr 12, 2021
136e46b
improve code style
coderzc Apr 12, 2021
d2a48f0
improve code style
coderzc Apr 12, 2021
ca75306
improve code style
coderzc Apr 12, 2021
768699a
4 -> Integer.BYTES
coderzc Apr 13, 2021
d50466b
* remove 'import static'
coderzc Apr 13, 2021
9598ea0
fix failMessage bodyLength
coderzc Apr 13, 2021
2905c68
improve readString()
coderzc Apr 13, 2021
6118e05
again compile
coderzc Apr 13, 2021
dba069f
remove skipExtraBuffer
coderzc Apr 13, 2021
1631615
slice body and retain it
coderzc Apr 13, 2021
ff14845
slice body and retain it
coderzc Apr 13, 2021
42ec875
slice body and retain it
coderzc Apr 13, 2021
6d64cd5
slice body and retain it
coderzc Apr 13, 2021
84bcd31
fix style
coderzc Apr 13, 2021
58ba674
* improve code style
coderzc Apr 13, 2021
2d74673
improve message
coderzc Apr 13, 2021
081be0c
assert header
coderzc Apr 13, 2021
4f399f4
* rebase master
coderzc Apr 14, 2021
20699fb
improve comment
coderzc Apr 14, 2021
e188287
improve import
coderzc Apr 14, 2021
b0d7d6a
default use EDGE_TRIGGERED
coderzc Apr 15, 2021
8662ea6
improve some comments
coderzc Apr 15, 2021
a3345b3
revert
coderzc Apr 15, 2021
b383a88
revert
coderzc Apr 15, 2021
1b4a11e
recompile
coderzc Apr 15, 2021
759a3f5
improve some comments
coderzc Apr 15, 2021
bd2cbd3
fix too long
coderzc Apr 15, 2021
c516fa9
improve some log
coderzc Apr 15, 2021
71a3abd
improve some log
coderzc Apr 15, 2021
31671be
improve readString, writeString
coderzc Apr 15, 2021
a063a9c
improve some log
coderzc Apr 15, 2021
ea268ef
add TRANSPORT_SYNC_REQUEST_TIMEOUT
coderzc Apr 16, 2021
fbf8036
improve desc
coderzc Apr 16, 2021
File filter

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
revert
  • Loading branch information
coderzc committed Apr 15, 2021
commit a3345b3acad501e370c369c6fc88f91aff4d85d6
Original file line number Diff line number Diff line change
Expand Up @@ -27,40 +27,21 @@ public abstract class TransportSession {

protected volatile TransportStatus status;
protected final AtomicInteger maxRequestId;
protected volatile int maxAckId;

protected TransportSession() {
this.status = TransportStatus.READY;
this.maxRequestId = new AtomicInteger(-1);
this.maxAckId = -1;
}

public TransportStatus status() {
return this.status;
}

protected void ready() {
this.maxRequestId.set(-1);
public void ready() {
this.status = TransportStatus.READY;
}

protected void establish() {
public void establish() {
this.status = TransportStatus.ESTABLISH;
}

public int maxRequestId() {
return this.maxRequestId.get();
}

public int nextRequestId() {
return this.maxRequestId.incrementAndGet();
}

public int incrementAckId() {
return this.maxRequestId.incrementAndGet();
}

abstract void startComplete();

abstract void finishComplete();
}