--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/g23m-aci/gdd_dio/gdd_dio_dtxf.c	Sun Jul 15 04:40:46 2018 +0000
@@ -0,0 +1,219 @@
+/*
++-----------------------------------------------------------------------------
+|  File     : gdd_dio_txf.c
++-----------------------------------------------------------------------------
+|  Copyright 2002 Texas Instruments Berlin, AG
+|                 All rights reserved.
+|
+|                 This file is confidential and a trade secret of Texas
+|                 Instruments Berlin, AG
+|                 The receipt of or possession of this file does not convey
+|                 any rights to reproduce or disclose its contents or to
+|                 manufacture, use, or sell anything it may describe, in
+|                 whole, or in part, without the specific written consent of
+|                 Texas Instruments Berlin, AG.
++-----------------------------------------------------------------------------
+|  Purpose  : This modul is part of the entity gdd_dio and implements the
+|             dtx service functions.
++-----------------------------------------------------------------------------
+*/
+
+
+#define ENTITY_GDD_DIO
+
+/*==== INCLUDES =============================================================*/
+
+#include "typedefs.h"   /* to get Condat data types */
+#include "vsi.h"        /* to get a lot of macros */
+
+/* GDD stuff */
+#include "gdd_dio.h"       /* to get the global entity definitions */
+#include "gdd_dio_con_mgr.h"
+
+#include "gdd_dio_dtxf.h"
+#include "gdd_dio_rxf.h"
+#include "gdd_dio_drxf.h" /* Needed for allocate_gdd_desc_list() etc */
+
+#include "gdd_dio_queue.h"
+
+/*==== CONST ================================================================*/
+
+/*==== LOCAL VARS ===========================================================*/
+
+/*==== PRIVATE FUNCTIONS ====================================================*/
+
+/*==== PUBLIC FUNCTIONS =====================================================*/
+
+
+GLOBAL GDD_RESULT gdd_dio_dtx_get_send_buffer
+(
+ T_GDD_CON_HANDLE  con_handle,
+ T_GDD_BUF **      send_buf,
+ U16               data_size
+ )
+{
+  T_GDD_INST_ID inst;
+  T_GDD_DIO_DATA * gdd_dio_data;
+  T_GDD_DIO_CON_DATA * con_data;
+  T_dio_buffer       * dio_buf;
+  
+  TRACE_USER_CLASS(TC_FUNC_DATA_FLOW, "[GDD] gdd_dio_dtx_get_send_buffer()");
+  
+  inst = (T_GDD_INST_ID)inst_num_from_dev_id(con_handle);
+  
+  /**
+  * Do the necessary checks.
+  */
+  if(inst < 0)
+  {
+    TRACE_ERROR("[GDD] Invalid connection handle");
+    return GDD_INVALID_PARAMS;
+  }
+  
+  if(inst >= GDD_NUM_INSTS)
+  {
+    TRACE_ERROR("[GDD] inst id out of bounds");
+    return GDD_INTERNAL_ERROR;
+  }
+  gdd_dio_data = &gdd_dio_data_base[inst];
+  
+  if(gdd_dio_init_flag[inst] EQ FALSE)
+  {
+    TRACE_ERROR("[GDD] Instance not initialized");
+    return GDD_INVALID_PARAMS;
+  }
+  
+  if (gdd_dio_data->ker.state NEQ GDD_DIO_KER_READY)
+  {
+    TRACE_ERROR("[GDD] DIO driver not initialized");
+    return GDD_INTERNAL_ERROR;
+  }  
+  
+  con_data = get_con_data(gdd_dio_data, con_handle);
+  if(con_data EQ NULL)
+  {
+    TRACE_ERROR("[GDD] Invalid connection handle");
+    return GDD_INVALID_PARAMS;
+  }
+  
+  if(data_size EQ 0 || data_size > con_data->dio_cap.mtu_data)
+  {
+    TRACE_ERROR("[GDD] requested data_size (MTU size) out of range");
+    return GDD_INVALID_PARAMS;
+  }
+  
+  if( con_data->con_state EQ GDD_DIO_CON_CONNECT ||
+    con_data->con_state EQ GDD_DIO_CON_SENDING ||
+    gdd_dio_queue_peek_next_for_dequeue(&con_data->rx_queue, &dio_buf) EQ FALSE)
+  {
+  /* Set the flag indicating the somebody (the client) is waiting for a send
+  buffer. As a consequence, the signal GDD_SIGTYPE_SEND_BUF_AVAILABLE
+    will be sent as soon as we receive a new RX buffer from PSI. */
+    char * reason;
+    if(con_data->con_state EQ GDD_DIO_CON_CONNECT)
+      reason = "con_state=GDD_DIO_CON_CONNECT";
+    else if(con_data->con_state EQ GDD_DIO_CON_SENDING)
+      reason = "con_state=GDD_DIO_CON_SENDING";
+    else
+      reason = "no buffer available in RX queue";
+    
+    con_data->wait_send_buf = TRUE;
+    
+    TRACE_EVENT_P2("[GDD] Cannot return buffer [con_handle=0x%4x: %s]",
+      con_handle, reason);
+    
+    return GDD_NO_BUF_AVAILABLE;
+  }
+  else
+  {
+  /* Make sure that buffer can hold what is requested.
+  We must take into account that the first 2-byte segment holding
+    the protocol ID which is not part of the pay-load */
+    if(data_size > (dio_buf->length-2))
+    {
+      TRACE_ERROR("[GDD] Requested buffer size too large");
+      return GDD_REQ_BUF_TOO_LARGE;
+    }
+    else
+    {
+      /* Setup current descriptor list and pass it back to the client */
+      (*send_buf) = (T_GDD_BUF *)dio_buf;
+      
+      con_data->con_state = GDD_DIO_CON_SENDING;
+      
+      return GDD_OK;
+    }
+  }
+}
+
+
+ GLOBAL GDD_RESULT gdd_dio_dtx_send_buffer(T_GDD_CON_HANDLE con_handle, T_GDD_BUF * buf)
+ {
+#ifdef GDD_MAKE_DTX_CONTEXT_SWITCH
+   U32 signal = GDD_DIO_SIGNAL_SEND_DATA | (U32)con_handle;
+#endif /* GDD_MAKE_DTX_CONTEXT_SWITCH */
+   T_GDD_INST_ID inst;
+   T_GDD_DIO_DATA * gdd_dio_data;
+   T_GDD_DIO_CON_DATA * con_data;
+   T_dio_buffer * dio_buf;
+   
+   TRACE_USER_CLASS(TC_FUNC_DATA_FLOW, "[GDD] gdd_dio_dtx_send_buffer()");
+   
+   inst = (T_GDD_INST_ID)inst_num_from_dev_id(con_handle);
+   
+   /**
+   * Do the necessary checks.
+   */
+   if(inst < 0)
+   {
+     TRACE_ERROR("[GDD] Invalid connection handle");
+     return GDD_INVALID_PARAMS;
+   }
+   else if(inst >= GDD_NUM_INSTS)
+   {
+     TRACE_ERROR("[GDD] inst id out of bounds");
+     return GDD_INTERNAL_ERROR;
+   }
+   gdd_dio_data = &gdd_dio_data_base[inst];
+   
+   if(gdd_dio_init_flag[inst] EQ FALSE)
+   {
+     TRACE_ERROR("[GDD] Instance not initialized");
+     return GDD_ALREADY_INITIALIZED;
+   }
+   
+   if (gdd_dio_data->ker.state NEQ GDD_DIO_KER_READY)
+   {
+     TRACE_ERROR("[GDD] DIO driver not initialized");
+     return GDD_INTERNAL_ERROR;
+   }  
+   
+   con_data = get_con_data(gdd_dio_data, con_handle);
+   if(con_data EQ NULL)
+   {
+     TRACE_ERROR("[GDD] Invalid connection handle");
+     return GDD_INVALID_PARAMS;
+   }
+   
+   /* The pointer which is next for dequeue must be the one which
+   corresponds to the buffer for sending ! */
+   if(gdd_dio_queue_peek_next_for_dequeue(&con_data->rx_queue, &dio_buf) EQ FALSE)
+   {
+     return GDD_INTERNAL_ERROR;
+   } 
+#ifdef GDD_MAKE_DTX_CONTEXT_SWITCH
+#ifdef MEMORY_SUPERVISION  
+   vsi_c_ssend(hCommGDD_DIO, signal, (T_VOID_STRUCT*)dio_buf, sizeof(T_VOID_STRUCT*), __FILE__, __LINE__);
+#else
+   vsi_c_ssend(hCommGDD_DIO, signal, (T_VOID_STRUCT*)dio_buf, sizeof(T_VOID_STRUCT*));
+#endif
+   return GDD_OK;
+#else /* GDD_MAKE_DTX_CONTEXT_SWITCH */
+   /* Call the corresponding RX function directly instead of sending signal */
+   gdd_dio_rx_sig_send_data(con_handle, dio_buf);
+   return GDD_OK;
+#endif /* GDD_MAKE_DTX_CONTEXT_SWITCH */  
+
+
+ }
+