Author: jvermillard
Date: Thu Sep 18 00:17:25 2008
New Revision: 696582
URL: http://svn.apache.org/viewvc?rev=696582&view=rev
Log:
added access to output buffer setting
Modified:
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/DefaultSerialSessionConfig.java
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialConnector.java
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSession.java
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionConfig.java
Modified:
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/DefaultSerialSessionConfig.java
URL:
http://svn.apache.org/viewvc/mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/DefaultSerialSessionConfig.java?rev=696582&r1=696581&r2=696582&view=diff
==============================================================================
---
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/DefaultSerialSessionConfig.java
(original)
+++
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/DefaultSerialSessionConfig.java
Thu Sep 18 00:17:25 2008
@@ -28,16 +28,24 @@
* @author The Apache MINA Project ([EMAIL PROTECTED])
* @version $Rev: 529576 $, $Date: 2007-04-17 14:25:07 +0200 (mar., 17 avr.
2007) $
*/
-class DefaultSerialSessionConfig extends AbstractIoSessionConfig implements
SerialSessionConfig {
+class DefaultSerialSessionConfig extends AbstractIoSessionConfig implements
+ SerialSessionConfig {
private int receiveThreshold = -1;
+
private int inputBufferSize = 8;
+
+ private int outputBufferSize = 8;
+
private boolean lowLatency = false;
public DefaultSerialSessionConfig() {
// All default properties were configured above.
}
+ /**
+ * [EMAIL PROTECTED]
+ */
@Override
protected void doSetAll(IoSessionConfig config) {
if (config instanceof SerialSessionConfig) {
@@ -47,27 +55,68 @@
}
}
+ /**
+ * [EMAIL PROTECTED]
+ */
+ @Override
public int getInputBufferSize() {
return inputBufferSize;
}
+ /**
+ * [EMAIL PROTECTED]
+ */
+ @Override
public boolean isLowLatency() {
return lowLatency;
}
+ /**
+ * [EMAIL PROTECTED]
+ */
+ @Override
public void setInputBufferSize(int bufferSize) {
inputBufferSize = bufferSize;
}
+ /**
+ * [EMAIL PROTECTED]
+ */
+ @Override
public void setLowLatency(boolean lowLatency) {
this.lowLatency = lowLatency;
}
+ /**
+ * [EMAIL PROTECTED]
+ */
+ @Override
public int getReceiveThreshold() {
return receiveThreshold;
}
+ /**
+ * [EMAIL PROTECTED]
+ */
+ @Override
public void setReceiveThreshold(int bytes) {
receiveThreshold = bytes;
}
+
+ /**
+ * [EMAIL PROTECTED]
+ */
+ @Override
+ public int getOutputBufferSize() {
+ return outputBufferSize;
+ }
+
+ /**
+ * [EMAIL PROTECTED]
+ */
+ @Override
+ public void setOutputBufferSize(int bufferSize) {
+ outputBufferSize = bufferSize;
+
+ }
}
Modified:
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialConnector.java
URL:
http://svn.apache.org/viewvc/mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialConnector.java?rev=696582&r1=696581&r2=696582&view=diff
==============================================================================
---
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialConnector.java
(original)
+++
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialConnector.java
Thu Sep 18 00:17:25 2008
@@ -159,6 +159,7 @@
}
serialPort.setInputBufferSize(config.getInputBufferSize());
+ serialPort.setOutputBufferSize(config.getOutputBufferSize());
if (config.getReceiveThreshold() >= 0) {
serialPort.enableReceiveThreshold(config.getReceiveThreshold());
Modified:
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSession.java
URL:
http://svn.apache.org/viewvc/mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSession.java?rev=696582&r1=696581&r2=696582&view=diff
==============================================================================
---
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSession.java
(original)
+++
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSession.java
Thu Sep 18 00:17:25 2008
@@ -29,6 +29,10 @@
*/
public interface SerialSession extends IoSession {
SerialSessionConfig getConfig();
+
SerialAddress getRemoteAddress();
+
SerialAddress getLocalAddress();
- SerialAddress getServiceAddress();}
+
+ SerialAddress getServiceAddress();
+}
Modified:
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionConfig.java
URL:
http://svn.apache.org/viewvc/mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionConfig.java?rev=696582&r1=696581&r2=696582&view=diff
==============================================================================
---
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionConfig.java
(original)
+++
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionConfig.java
Thu Sep 18 00:17:25 2008
@@ -44,6 +44,21 @@
*/
void setInputBufferSize(int bufferSize);
+
+ /**
+ * Gets the output buffer size. Note that this method is advisory and the
underlying OS
+ * may choose not to report correct values for the buffer size.
+ * @return input buffer size in bytes
+ */
+ int getOutputBufferSize();
+
+ /**
+ * Sets the output buffer size. Note that this is advisory and memory
availability may
+ * determine the ultimate buffer size used by the driver.
+ * @param bufferSize the buffer size in bytes
+ */
+ void setOutputBufferSize(int bufferSize);
+
/**
* Is the low latency mode is enabled.
* @return low latency on
@@ -69,5 +84,8 @@
* @param bytes minimal amount of byte before producing a new frame, or -1
if disabled
*/
void setReceiveThreshold(int bytes);
+
+
+
}
