Implemented progress stub on android.

Some bug fixes.

8 files changed, 60 insertions, 15 deletions

diff --git a/Software/Android_Studio/Tango.SharedUI/src/main/java/com/twine/tango/sharedui/editors/ParameterizedEditor.java b/Software/Android_Studio/Tango.SharedUI/src/main/java/com/twine/tango/sharedui/editors/ParameterizedEditor.java
index 6301cdf24..92e4f9305 100644
--- a/Software/Android_Studio/Tango.SharedUI/src/main/java/com/twine/tango/sharedui/editors/ParameterizedEditor.java
+++ b/Software/Android_Studio/Tango.SharedUI/src/main/java/com/twine/tango/sharedui/editors/ParameterizedEditor.java
@@ -58,9 +58,9 @@ public class ParameterizedEditor extends ScrollView
         
         for (ParameterItem item : items)
         {
-            TextView textView = new TextView(this.getContext());
-            textView.setText(item.getName());
-            layout.addView(textView);
+            View titleView = LayoutInflater.from(layout.getContext()).inflate(R.layout.editor_title,layout,false);
+            ((TextView)titleView.findViewById(R.id.editor_title_txtView)).setText(item.getName());
+            layout.addView(titleView);
             
             ViewDataBinding binding = DataBindingUtil.inflate(LayoutInflater.from(layout.getContext()), R.layout.editor_range, layout, false);
             binding.setVariable(BR.item, item);
diff --git a/Software/Android_Studio/Tango.SharedUI/src/main/res/drawable/rounded_rectangle.xml b/Software/Android_Studio/Tango.SharedUI/src/main/res/drawable/rounded_rectangle.xml
new file mode 100644
index 000000000..ed4e6abde
--- /dev/null
+++ b/Software/Android_Studio/Tango.SharedUI/src/main/res/drawable/rounded_rectangle.xml
@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<shape xmlns:android="http://schemas.android.com/apk/res/android">
+    <solid android:color="#606060"/>
+
+    <padding android:left="1dp"
+        android:top="1dp"
+        android:right="1dp"
+        android:bottom="1dp"
+        />
+
+    <corners android:bottomRightRadius="7dp" android:bottomLeftRadius="7dp"
+        android:topLeftRadius="7dp" android:topRightRadius="7dp"/>
+</shape>
\ No newline at end of file
diff --git a/Software/Android_Studio/Tango.SharedUI/src/main/res/layout/editor_title.xml b/Software/Android_Studio/Tango.SharedUI/src/main/res/layout/editor_title.xml
new file mode 100644
index 000000000..cc4a3a901
--- /dev/null
+++ b/Software/Android_Studio/Tango.SharedUI/src/main/res/layout/editor_title.xml
@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="utf-8"?>
+<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    android:orientation="vertical" android:layout_width="match_parent"
+    android:layout_height="match_parent">
+
+
+    <TextView
+        android:id="@+id/editor_title_txtView"
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:layout_marginTop="10dp"
+        android:layout_marginBottom="5dp"
+        android:padding="5dp"
+        android:background="@drawable/rounded_rectangle"
+        android:text="TextView" />
+</LinearLayout>
\ No newline at end of file
diff --git a/Software/Android_Studio/Tango.Stubs/src/main/java/com/twine/tango/stubs/stubs/Calculate.java b/Software/Android_Studio/Tango.Stubs/src/main/java/com/twine/tango/stubs/stubs/Calculate.java
index c91197b99..d6c02fa75 100644
--- a/Software/Android_Studio/Tango.Stubs/src/main/java/com/twine/tango/stubs/stubs/Calculate.java
+++ b/Software/Android_Studio/Tango.Stubs/src/main/java/com/twine/tango/stubs/stubs/Calculate.java
@@ -46,7 +46,7 @@ public class Calculate extends StubBase
                 MessageFactory.createTangoMessage(
                         CalculateRequest.class,
                         CalculateRequest.newBuilder().setA(num1).setB(num2).build())).subscribe((response) ->
-                subject.onNext(String.valueOf(response.getSum())));
+                subject.onNext(String.valueOf(response.getSum())), subject::onError);
         
         return subject;
     }
diff --git a/Software/Android_Studio/Tango.Stubs/src/main/java/com/twine/tango/stubs/stubs/Progress.java b/Software/Android_Studio/Tango.Stubs/src/main/java/com/twine/tango/stubs/stubs/Progress.java
index 94c2a199d..a9d8176a2 100644
--- a/Software/Android_Studio/Tango.Stubs/src/main/java/com/twine/tango/stubs/stubs/Progress.java
+++ b/Software/Android_Studio/Tango.Stubs/src/main/java/com/twine/tango/stubs/stubs/Progress.java
@@ -3,6 +3,8 @@ package com.twine.tango.stubs.stubs;
 import com.twine.tango.pmr.MessageFactory;
 import com.twine.tango.pmr.stubs.ProgressRequestOuterClass.ProgressRequest;
 import com.twine.tango.pmr.stubs.ProgressResponseOuterClass.ProgressResponse;
+import com.twine.tango.sharedui.editors.ParameterAnnotation;
+import com.twine.tango.sharedui.mvvm.DependencyProperty;
 import com.twine.tango.stubs.StubAnnotation;
 import com.twine.tango.stubs.StubBase;
 import com.twine.tango.stubs.StubDirection;
@@ -23,17 +25,23 @@ public class Progress extends StubBase
         super(transporter);
     }
     
+    @ParameterAnnotation(name = "Amount", maximum = 1000, defaultValue = 100)
+    public DependencyProperty<Number> amount = new DependencyProperty<>(100);
+    
+    @ParameterAnnotation(name = "Delay", maximum = 20, defaultValue = 4)
+    public DependencyProperty<Number> delay = new DependencyProperty<>(4);
+    
     @Override
     protected Observable<String> onRun()
     {
         PublishSubject<String> subject = PublishSubject.create();
-    
+        
         getTransporter().<ProgressRequest, ProgressResponse>sendContinuousRequest(
                 MessageFactory.createTangoMessage(
                         ProgressRequest.class,
-                        ProgressRequest.newBuilder().build())).subscribe((response) ->
+                        ProgressRequest.newBuilder().setAmount(amount.get().intValue()).setDelay(delay.get().intValue()).build())).subscribe((response) ->
                 subject.onNext(String.valueOf(response.getProgress())));
-    
+        
         return subject;
     }
 }
diff --git a/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/ITransporter.java b/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/ITransporter.java
index 6794b0f57..475893f02 100644
--- a/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/ITransporter.java
+++ b/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/ITransporter.java
@@ -31,9 +31,11 @@ public interface ITransporter extends ITransportComponent {
 
     <Response extends GeneratedMessageV3> Single<Response> sendResponse(TangoMessage<Response> response,String token);
 
-    void setRequestReceiverListener(EventHandler<MessageContainer> listener);
+    void setRequestReceivedListener(EventHandler<MessageContainer> listener);
 
     Period getRequestTimeout();
 
     void setRequestTimeout(Period duration);
+    
+    
 }
diff --git a/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/TransporterBase.java b/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/TransporterBase.java
index 422f4ad00..5c0715806 100644
--- a/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/TransporterBase.java
+++ b/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/TransporterBase.java
@@ -200,7 +200,7 @@ public abstract class TransporterBase implements ITransporter
         sendingQueue = new ConcurrentLinkedQueue<>();
         pendingRequests = new ArrayList<>();
         arrivedResponses = new ConcurrentLinkedQueue<>();
-        setRequestTimeout(Period.seconds(10));
+        setRequestTimeout(Period.seconds(2));
     }
     
     public TransporterBase(ITransportAdapter adapter)
@@ -226,7 +226,7 @@ public abstract class TransporterBase implements ITransporter
     }
     
     @Override
-    public void setRequestReceiverListener(EventHandler<MessageContainer> listener)
+    public void setRequestReceivedListener(EventHandler<MessageContainer> listener)
     {
         this.requestReceivedListener = listener;
     }
@@ -311,9 +311,10 @@ public abstract class TransporterBase implements ITransporter
                 {
                     if (!subject.hasComplete())
                     {
-                        XLog.i("Request message " + request.getClass().getSimpleName() + " had timed out after " + getRequestTimeout().getSeconds() + " seconds.");
+                        TimeoutException exception = new TimeoutException("Request message " + request.getMessage().getClass().getSimpleName() + " had timed out after " + getRequestTimeout().getSeconds() + " seconds.");
+                        XLog.e(exception);
                         XLog.i("Setting request task exception...");
-                        subject.onError(new TimeoutException());
+                        subject.onError(exception);
                     }
                 });
         
@@ -445,8 +446,11 @@ public abstract class TransporterBase implements ITransporter
                                 }
                             } else
                             {
-                                message.getAdapter().write(message.getSerialize().invoke());
-                                XLog.i("message sent on adapter: " + message.getAdapter().getAddress() + "...");
+                                if (message.getAdapter().getState() == TransportComponentState.Connected)
+                                {
+                                    message.getAdapter().write(message.getSerialize().invoke());
+                                    XLog.i("message sent on adapter: " + message.getAdapter().getAddress() + "...");
+                                }
                             }
                             
                             if (message.getDirection() == TransportMessageDirection.Request)
diff --git a/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/adapters/TcpTransportAdapter.java b/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/adapters/TcpTransportAdapter.java
index 3435917a3..b72d1669b 100644
--- a/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/adapters/TcpTransportAdapter.java
+++ b/Software/Android_Studio/Tango.Transport/src/main/java/com/twine/tango/transport/adapters/TcpTransportAdapter.java
@@ -9,6 +9,7 @@ import com.twine.tango.transport.TransportComponentState;
 
 import java.io.IOException;
 import java.io.InputStream;
+import java.net.InetSocketAddress;
 import java.net.Socket;
 import java.net.SocketException;
 import java.nio.channels.Selector;
@@ -82,7 +83,8 @@ public class TcpTransportAdapter extends TransportAdapterBase
                 {
                     if (!initializedFromConstructor)
                     {
-                        socket = new Socket(getAddress(), getPort());
+                        socket = new Socket();
+                        socket.connect(new InetSocketAddress(getAddress(), getPort()), 2000);
                         //selector = Selector.open();
                         //socket.getChannel().register(selector, SelectionKey.OP_READ);
                     }