[openrtm-commit:00403] r560 - trunk/jp.go.aist.rtm.RTC/src/jp/go/aist/rtm/RTC/port/publisher

[openrtm ＠ openrtm.org]

Author: fsi-katami
Date: 2011-09-12 11:51:59 +0900 (Mon, 12 Sep 2011)
New Revision: 560

Modified:
   trunk/jp.go.aist.rtm.RTC/src/jp/go/aist/rtm/RTC/port/publisher/PublisherFlush.java
Log:
Added the callback caller to write() that calls the callback when connected cutting was detected.  refs #2233

Modified: trunk/jp.go.aist.rtm.RTC/src/jp/go/aist/rtm/RTC/port/publisher/PublisherFlush.java
===================================================================
--- trunk/jp.go.aist.rtm.RTC/src/jp/go/aist/rtm/RTC/port/publisher/PublisherFlush.java	2011-09-12 02:04:41 UTC (rev 559)
+++ trunk/jp.go.aist.rtm.RTC/src/jp/go/aist/rtm/RTC/port/publisher/PublisherFlush.java	2011-09-12 02:51:59 UTC (rev 560)
@@ -84,7 +84,8 @@
      * @return ReturnCode
      */
     public ReturnCode setBuffer(BufferBase<OutputStream> buffer) {
-        return ReturnCode.PORT_ERROR;
+        rtcout.println(Logbuf.TRACE, "setBuffer()" );
+        return ReturnCode.PORT_OK;
     }
     /**
      * <p> Setting buffer pointer </p>
@@ -193,6 +194,9 @@
             case SEND_TIMEOUT:
                  onReceiverTimeout(data);
                  return ret;
+            case CONNECTION_LOST:
+                 onReceiverTimeout(data);
+                 return ret;
             case UNKNOWN_ERROR:
                  onReceiverError(data);
                  return ret;