| 131 | } |
| 132 | |
| 133 | @Override public synchronized int write(byte[] data, int length) { |
| 134 | int result = -1; |
| 135 | |
| 136 | for (Iterator<AndroidPort> i = ports.iterator(); i.hasNext();) { |
| 137 | AndroidPort port = i.next(); |
| 138 | int nbytes = port.write(data, length); |
| 139 | if (nbytes < 0 && port.getState() == STATE_FAILED) { |
| 140 | error = true; |
| 141 | i.remove(); |
| 142 | |
| 143 | try { |
| 144 | port.close(); |
| 145 | } catch (IOException e) { |
| 146 | } |
| 147 | } else if (nbytes > result) |
| 148 | result = nbytes; |
| 149 | } |
| 150 | |
| 151 | return result; |
| 152 | } |
| 153 | |
| 154 | @Override public void dataReceived(byte[] data, int length) { |
| 155 | InputListener l = inputListener; |