Correctly handle output sent to the group input channel

This commit was SVN r23362.

orte/mca/rmcast/spread/rmcast_spread.c

@@ -362,6 +362,13 @@ static int queue_xmit(rmcast_base_send_t *snd,
         }
         ch = orte_rmcast_base.my_group_channel;
         goto process;
+    } else if (ORTE_RMCAST_GROUP_INPUT_CHANNEL == channel) {
+        if (NULL == orte_rmcast_base.my_input_channel) {
+            ORTE_ERROR_LOG(ORTE_ERR_NOT_FOUND);
+            return ORTE_ERR_NOT_FOUND;
+        }
+        ch = orte_rmcast_base.my_input_channel;
+        goto process;
     }
     
     /* find the channel */

orte/mca/rmcast/tcp/rmcast_tcp.c

@@ -306,6 +306,13 @@ static int queue_xmit(rmcast_base_send_t *snd,
         }
         ch = orte_rmcast_base.my_output_channel;
         goto process;
+    } else if (ORTE_RMCAST_GROUP_INPUT_CHANNEL == channel) {
+        if (NULL == orte_rmcast_base.my_input_channel) {
+            ORTE_ERROR_LOG(ORTE_ERR_NOT_FOUND);
+            return ORTE_ERR_NOT_FOUND;
+        }
+        ch = orte_rmcast_base.my_input_channel;
+        goto process;
     }
     
     /* find the channel */

orte/mca/rmcast/udp/rmcast_udp.c

@@ -269,6 +269,13 @@ static int queue_xmit(rmcast_base_send_t *snd,
         }
         ch = orte_rmcast_base.my_output_channel;
         goto process;
+    } else if (ORTE_RMCAST_GROUP_INPUT_CHANNEL == channel) {
+        if (NULL == orte_rmcast_base.my_input_channel) {
+            ORTE_ERROR_LOG(ORTE_ERR_NOT_FOUND);
+            return ORTE_ERR_NOT_FOUND;
+        }
+        ch = orte_rmcast_base.my_input_channel;
+        goto process;
     }
     
     /* find the channel */