+
−/*
+
−+-----------------------------------------------------------------------------
+
−|  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 */  
+
−
+
−
+
− }
+
−