andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Indentation

Browse Source
This commit is contained in:
Trustin Lee 2013-01-10 13:28:09 +09:00
parent 4528c793ba
commit 8cba765463
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
transport-rxtx/src/main/java/io/netty/transport/rxtx/RxtxChannel.java
View File

@ -101,18 +101,17 @@ public class RxtxChannel extends AbstractOioByteChannel {
@Override
protected void doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception {
RxtxDeviceAddress remote = (RxtxDeviceAddress) remoteAddress;
final CommPortIdentifier cpi =
CommPortIdentifier.getPortIdentifier(remote.getDeviceAddress());
final CommPortIdentifier cpi = CommPortIdentifier.getPortIdentifier(remote.getDeviceAddress());
final CommPort commPort = cpi.open(getClass().getName(), 1000);
deviceAddress = remote;
serialPort = (SerialPort) commPort;
serialPort.setSerialPortParams(
config().getOption(BAUD_RATE),
config().getOption(DATA_BITS).value(),
config().getOption(STOP_BITS).value(),
config().getOption(PARITY_BIT).value()
config().getOption(BAUD_RATE),
config().getOption(DATA_BITS).value(),
config().getOption(STOP_BITS).value(),
config().getOption(PARITY_BIT).value()
);
serialPort.setDTR(config().getOption(DTR));
serialPort.setRTS(config().getOption(RTS));