/******************************************************************************
 *
 *  Copyright (C) 2009-2012 Broadcom Corporation
 *
 *  Licensed under the Apache License, Version 2.0 (the "License");
 *  you may not use this file except in compliance with the License.
 *  You may obtain a copy of the License at:
 *
 *  http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 *
 ******************************************************************************/

/******************************************************************************
 *
 *  Filename:      bta_pan_co.c
 *
 *  Description:   PAN stack callout api
 *
 *
 ******************************************************************************/
#include "bt_target.h"

#if defined(BTA_PAN_INCLUDED) && (BTA_PAN_INCLUDED == TRUE)
#include "bta_api.h"
#include "bta_pan_api.h"
#include "bta_pan_ci.h"
#include "bta_pan_co.h"
#include "pan_api.h"
#include "bt_common.h"
#include <hardware/bluetooth.h>
#include <hardware/bt_pan.h>
#include "btif_pan_internal.h"
#include "btif_sock_thread.h"
#include <string.h>
#include "btif_util.h"
#include "btcore/include/bdaddr.h"

/*******************************************************************************
**
** Function         bta_pan_co_init
**
** Description
**
**
** Returns          Data flow mask.
**
*******************************************************************************/
uint8_t bta_pan_co_init(uint8_t *q_level)
{
    BTIF_TRACE_API("bta_pan_co_init");
    /* set the q_level to 30 buffers */
    *q_level = 30;
    //return (BTA_PAN_RX_PULL | BTA_PAN_TX_PULL);
    return (BTA_PAN_RX_PUSH_BUF | BTA_PAN_RX_PUSH | BTA_PAN_TX_PULL);
}

/******************************************************************************
**
** Function         bta_pan_co_open
**
** Description
**
**
**
**
**
** Returns          void
**
*******************************************************************************/
void bta_pan_co_open(uint16_t handle, uint8_t app_id, tBTA_PAN_ROLE local_role,
                     tBTA_PAN_ROLE peer_role, BD_ADDR peer_addr)
{
    BTIF_TRACE_API("bta_pan_co_open:app_id:%d, local_role:%d, peer_role:%d, "
                   "handle:%d", app_id, local_role, peer_role, handle);
    btpan_conn_t *conn = btpan_find_conn_addr(peer_addr);

    if(conn == NULL)
    {
        conn = btpan_new_conn(handle, peer_addr, local_role, peer_role);
    }

    if(conn)
    {
        BTIF_TRACE_DEBUG("bta_pan_co_open:tap_fd:%d, open_count:%d, "
                         "conn->handle:%d should = handle:%d, local_role:%d, remote_role:%d",
                         btpan_cb.tap_fd, btpan_cb.open_count, conn->handle, handle,
                         conn->local_role, conn->remote_role);
        //refresh the role & bt address
        btpan_cb.open_count++;
        conn->handle = handle;

        //bdcpy(conn->peer, peer_addr);
        if(btpan_cb.tap_fd < 0)
        {
            btpan_cb.tap_fd = btpan_tap_open();

            if(btpan_cb.tap_fd >= 0)
            {
                create_tap_read_thread(btpan_cb.tap_fd);
            }
        }

        if(btpan_cb.tap_fd >= 0)
        {
            btpan_cb.flow = 1;
            conn->state = PAN_STATE_OPEN;
            bta_pan_ci_rx_ready(handle);
        }
    }
}

/*******************************************************************************
**
** Function         bta_pan_co_close
**
** Description      This function is called by PAN when a connection to a
**                  peer is closed.
**
**
** Returns          void
**
*******************************************************************************/
void bta_pan_co_close(uint16_t handle, uint8_t app_id)
{
    BTIF_TRACE_API("bta_pan_co_close:app_id:%d, handle:%d", app_id, handle);
    btpan_conn_t *conn = btpan_find_conn_handle(handle);

    if(conn && conn->state == PAN_STATE_OPEN)
    {
        BTIF_TRACE_DEBUG("bta_pan_co_close");
        // let bta close event reset this handle as it needs
        // the handle to find the connection upon CLOSE
        //conn->handle = -1;
        conn->state = PAN_STATE_CLOSE;
        btpan_cb.open_count--;

        if(btpan_cb.open_count == 0 && btpan_cb.tap_fd != -1)
        {
            btpan_tap_close(btpan_cb.tap_fd);
            btpan_cb.tap_fd = -1;
        }
    }
}

/*******************************************************************************
**
** Function         bta_pan_co_tx_path
**
** Description      This function is called by PAN to transfer data on the
**                  TX path; that is, data being sent from BTA to the phone.
**                  This function is used when the TX data path is configured
**                  to use the pull interface.  The implementation of this
**                  function will typically call Bluetooth stack functions
**                  PORT_Read() or PORT_ReadData() to read data from RFCOMM
**                  and then a platform-specific function to send data that
**                  data to the phone.
**
**
** Returns          void
**
*******************************************************************************/
void bta_pan_co_tx_path(uint16_t handle, uint8_t app_id)
{
    BT_HDR          *p_buf;
    BD_ADDR            src;
    BD_ADDR            dst;
    uint16_t            protocol;
    uint8_t            ext;
    uint8_t         forward;
    BTIF_TRACE_API("%s, handle:%d, app_id:%d", __func__, handle, app_id);
    btpan_conn_t *conn = btpan_find_conn_handle(handle);

    if(!conn)
    {
        BTIF_TRACE_ERROR("%s: cannot find pan connection", __func__);
        return;
    }
    else
        if(conn->state != PAN_STATE_OPEN)
        {
            BTIF_TRACE_ERROR("%s: conn is not opened, conn:%p, conn->state:%d",
                             __func__, conn, conn->state);
            return;
        }

    do
    {
        /* read next data buffer from pan */
        if((p_buf = bta_pan_ci_readbuf(handle, src, dst, &protocol,
                                       &ext, &forward)))
        {
            bdstr_t bdstr;
            BTIF_TRACE_DEBUG("%s, calling btapp_tap_send, "
                             "p_buf->len:%d, offset:%d", __func__, p_buf->len, p_buf->offset);

            if(is_empty_eth_addr(conn->eth_addr) && is_valid_bt_eth_addr(src))
            {
                BTIF_TRACE_DEBUG("%s pan bt peer addr: %s", __func__,
                                 bdaddr_to_string((tls_bt_addr_t *)conn->peer, bdstr, sizeof(bdstr)));
                bdaddr_to_string((tls_bt_addr_t *)src, bdstr, sizeof(bdstr));
                BTIF_TRACE_DEBUG("%s:     update its ethernet addr: %s", __func__,
                                 bdaddr_to_string((tls_bt_addr_t *)src, bdstr, sizeof(bdstr)));
                wm_memcpy(conn->eth_addr, src, sizeof(conn->eth_addr));
            }

            btpan_tap_send(btpan_cb.tap_fd, src, dst, protocol,
                           (char *)(p_buf + 1) + p_buf->offset, p_buf->len, ext, forward);
            GKI_freebuf(p_buf);
        }
    } while(p_buf != NULL);
}

/*******************************************************************************
**
** Function         bta_pan_co_rx_path
**
** Description
**
**
**
**
** Returns          void
**
*******************************************************************************/
void bta_pan_co_rx_path(uint16_t handle, uint8_t app_id)
{
    UNUSED(handle);
    UNUSED(app_id);
    BTIF_TRACE_API("bta_pan_co_rx_path not used");
}

/*******************************************************************************
**
** Function         bta_pan_co_tx_write
**
** Description      This function is called by PAN to send data to the phone
**                  when the TX path is configured to use a push interface.
**                  The implementation of this function must copy the data to
**                  the phone's memory.
**
**
** Returns          void
**
*******************************************************************************/
void bta_pan_co_tx_write(uint16_t handle, uint8_t app_id, BD_ADDR src, BD_ADDR dst,
                         uint16_t protocol, uint8_t *p_data,
                         uint16_t len, uint8_t ext, uint8_t forward)
{
    UNUSED(handle);
    UNUSED(app_id);
    UNUSED(src);
    UNUSED(dst);
    UNUSED(protocol);
    UNUSED(p_data);
    UNUSED(len);
    UNUSED(ext);
    UNUSED(forward);
    BTIF_TRACE_API("bta_pan_co_tx_write not used");
}

/*******************************************************************************
**
** Function         bta_pan_co_tx_writebuf
**
** Description      This function is called by PAN to send data to the phone
**                  when the TX path is configured to use a push interface with
**                  zero copy.  The phone must free the buffer using function
**                  GKI_freebuf() when it is through processing the buffer.
**
**
** Returns          TRUE if flow enabled
**
*******************************************************************************/
void  bta_pan_co_tx_writebuf(uint16_t handle, uint8_t app_id, BD_ADDR src,
                             BD_ADDR dst, uint16_t protocol, BT_HDR *p_buf,
                             uint8_t ext, uint8_t forward)
{
    UNUSED(handle);
    UNUSED(app_id);
    UNUSED(src);
    UNUSED(dst);
    UNUSED(protocol);
    UNUSED(p_buf);
    UNUSED(ext);
    UNUSED(forward);
    BTIF_TRACE_API("bta_pan_co_tx_writebuf not used");
}

/*******************************************************************************
**
** Function         bta_pan_co_rx_flow
**
** Description      This function is called by PAN to enable or disable
**                  data flow on the RX path when it is configured to use
**                  a push interface.  If data flow is disabled the phone must
**                  not call bta_pan_ci_rx_write() or bta_pan_ci_rx_writebuf()
**                  until data flow is enabled again.
**
**
** Returns          void
**
*******************************************************************************/
void bta_pan_co_rx_flow(uint16_t handle, uint8_t app_id, uint8_t enable)
{
    UNUSED(handle);
    UNUSED(app_id);
    UNUSED(enable);
    BTIF_TRACE_API("bta_pan_co_rx_flow, enabled:%d, not used", enable);
    btpan_conn_t *conn = btpan_find_conn_handle(handle);

    if(!conn || conn->state != PAN_STATE_OPEN)
    {
        return;
    }

    btpan_set_flow_control(enable);
}

/*******************************************************************************
**
** Function         bta_pan_co_filt_ind
**
** Description      protocol filter indication from peer device
**
** Returns          void
**
*******************************************************************************/
void bta_pan_co_pfilt_ind(uint16_t handle, uint8_t indication, tBTA_PAN_STATUS result,
                          uint16_t len, uint8_t *p_filters)
{
    UNUSED(handle);
    UNUSED(indication);
    UNUSED(result);
    UNUSED(len);
    UNUSED(p_filters);
    BTIF_TRACE_API("bta_pan_co_pfilt_ind");
}

/*******************************************************************************
**
** Function         bta_pan_co_mfilt_ind
**
** Description      multicast filter indication from peer device
**
** Returns          void
**
*******************************************************************************/
void bta_pan_co_mfilt_ind(uint16_t handle, uint8_t indication, tBTA_PAN_STATUS result,
                          uint16_t len, uint8_t *p_filters)
{
    UNUSED(handle);
    UNUSED(indication);
    UNUSED(result);
    UNUSED(len);
    UNUSED(p_filters);
    BTIF_TRACE_API("bta_pan_co_mfilt_ind");
}

#endif
