Toggle navigation
Home
com.navercorp.pinpoint.rpc.server.SocketChannel to com.navercorp.pinpoint.rpc.server.WritablePinpointServer
No. of Instances - 17
No. of Commits - 1
No. of Projects - {'pinpoint'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Rename Variable
channel
to
pinpointServer
socketChannel
to
pinpointServer
channel
to
pinpointServer
channel
to
pinpointServer
channel
to
pinpointServer
channel
to
pinpointServer
channel
to
pinpointServer
socketChannel
to
pinpointServer
socketChannel
to
pinpointServer
channel
to
pinpointServer
channel
to
pinpointServer
channel
to
pinpointServer
Cascading Type Change (Similar)
SocketChannel
to
WritablePinpointServer
Update Anonymous class
{ @Override public void handleSend( SendPacket sendPacket, SocketChannel channel){ receive(sendPacket,channel); } @Override public void handleRequest( RequestPacket requestPacket, SocketChannel channel){ requestResponse(requestPacket,channel); } @Override public HandshakeResponseCode handleHandshake( Map properties){ if (properties == null) { return HandshakeResponseType.ProtocolError.PROTOCOL_ERROR; } boolean hasAllType=AgentHandshakePropertyType.hasAllType(properties); if (!hasAllType) { return HandshakeResponseType.PropertyError.PROPERTY_ERROR; } boolean supportServer=MapUtils.getBoolean(properties,AgentHandshakePropertyType.SUPPORT_SERVER.getName(),true); if (supportServer) { return HandshakeResponseType.Success.DUPLEX_COMMUNICATION; } else { return HandshakeResponseType.Success.SIMPLEX_COMMUNICATION; } } }
to
{ @Override public void handleSend( SendPacket sendPacket, WritablePinpointServer pinpointServer){ receive(sendPacket,pinpointServer); } @Override public void handleRequest( RequestPacket requestPacket, WritablePinpointServer pinpointServer){ requestResponse(requestPacket,pinpointServer); } @Override public HandshakeResponseCode handleHandshake( Map properties){ if (properties == null) { return HandshakeResponseType.ProtocolError.PROTOCOL_ERROR; } boolean hasAllType=AgentHandshakePropertyType.hasAllType(properties); if (!hasAllType) { return HandshakeResponseType.PropertyError.PROPERTY_ERROR; } boolean supportServer=MapUtils.getBoolean(properties,AgentHandshakePropertyType.SUPPORT_SERVER.getName(),true); if (supportServer) { return HandshakeResponseType.Success.DUPLEX_COMMUNICATION; } else { return HandshakeResponseType.Success.SIMPLEX_COMMUNICATION; } } }