/
Call.java
43 lines (38 loc) · 1.07 KB
/
Call.java
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
package com.github.dtf.rpc;
import java.nio.channels.SocketChannel;
public class Call {
private byte[] requestBuffer;
private byte[] reponseBuffer;
private SocketChannel clientChannel;
public byte[] getRequestBuffer() {
return requestBuffer;
}
public void setRequestBuffer(byte[] databuffer) {
this.requestBuffer = databuffer;
}
public SocketChannel getClientChannel() {
return clientChannel;
}
public void setClientChannel(SocketChannel clientChannel) {
this.clientChannel = clientChannel;
}
public byte[] getReponseBuffer() {
return reponseBuffer;
}
public void setReponseBuffer(byte[] reponseBuffer) {
this.reponseBuffer = reponseBuffer;
}
public String toString(){
StringBuilder sb = new StringBuilder();
if(clientChannel != null){
sb.append("Rpc request from:" + clientChannel.socket().getRemoteSocketAddress() + "]");
}
if(requestBuffer != null){
sb.append(" [request data:" + new String(requestBuffer) + "]");
}
if(reponseBuffer != null){
sb.append(" [response data:" + new String(reponseBuffer)+ "]");
}
return sb.toString();
}
}