mbtk/libql_lib/src/ql_data_call.c

#include "ql/DSI_ConnectManager.h"
#include "mbtk_info_api.h"
#include <fcntl.h>

extern mbtk_info_handle_t* ql_info_handle;
extern int ql_info_handle_num;
static bool inited = FALSE;

typedef struct
{
    bool active;
    uint8 cid;
    int ip_type;
    char user[128];
    char pass[128];
    QL_DSI_AUTH_PREF_T auth;
} apn_info;

// 2 - 7
static apn_info ql_apn_info[9]={0};
static int mbtk_interval_sec = 0;
static nw_status_cb ql_net_status_cb = NULL;
static ex_conn_status_cb ql_net_ex_status_cb = NULL;
static int now_cid = 0;

void ql_wan_net_state_change_cb(const void* data, int data_len)
{
    uint8 *net_data = NULL;
    net_data = (uint8 *)data;

    if(*net_data > 100 && *net_data < 200)
    {
        int cid;
        cid = *net_data;
        cid = cid - 100;
        ql_apn_info[cid].active = FALSE;//close
        if(ql_net_ex_status_cb != NULL)
        {
            ql_net_ex_status_cb(cid, ql_apn_info[cid].ip_type, CONNECT_DISCON, 0);
        }
    }
    else if(*net_data > 200)
    {
        int cid;
        cid = *net_data;
        cid = cid - 200;
        ql_apn_info[cid].active = TRUE;//open
    }
    else
    {
        if(ql_net_status_cb != NULL)
        {
            ql_net_status_cb(*net_data);

            if(*net_data == 25 || *net_data == 26 || *net_data == 27)
            {
                ql_net_status_cb(CONNECT_CONSUCCESS);
            }
        }

        if(ql_net_ex_status_cb != NULL)
        {
            if(*net_data == 1)
            {
                ql_net_ex_status_cb(now_cid, ql_apn_info[now_cid].ip_type, CONNECT_CONSUCCESS, 0);
            }
        }
    }

}

int ql_wan_init(void)
{
    if(!inited && ql_info_handle == NULL)
    {
        ql_info_handle = mbtk_info_handle_get();
        if(ql_info_handle)
        {
            ql_info_handle_num++;
            inited = TRUE;
            mbtk_pdp_state_change_cb_reg(ql_info_handle, ql_wan_net_state_change_cb);

            //return 0;
        } else {
            LOGE("mbtk_info_handle_get() fail.");
            return -1;
        }
    } else {
        if(!inited) {
            ql_info_handle_num++;
            inited = TRUE;
            mbtk_pdp_state_change_cb_reg(ql_info_handle, ql_wan_net_state_change_cb);
        }
        //return 0;
    }

    mbtk_apn_info_t apns[10] = {0};
    int apn_num = MBTK_APN_CID_MAX;
    int ret = mbtk_apn_get(ql_info_handle, &apn_num, apns);
    if(ret != 0)
    {
        LOGD("mbtk_apn_get ret = %d",ret);
    }
    else
    {
        int i;
        int profile_idx;
        for(i=0;i<MBTK_APN_CID_MAX;i++)
        {
            if(apns[i].cid > 0 && apns[i].cid <= MBTK_APN_CID_MAX)
            {
                profile_idx = apns[i].cid;
                if(apns[i].ip_type == MBTK_IP_TYPE_IPV4V6) // IPV4V6
                    ql_apn_info[profile_idx].ip_type = 0;
                else if(apns[i].ip_type == MBTK_IP_TYPE_IP) // IPV4
                    ql_apn_info[profile_idx].ip_type = 1;
                else if(apns[i].ip_type == MBTK_IP_TYPE_IPV6) // IPV6
                    ql_apn_info[profile_idx].ip_type = 2;
                else
                    ql_apn_info[profile_idx].ip_type = 0;
            }
        }
    }
    return 0;
}

int ql_wan_release(void)
{
    if(ql_info_handle)
    {
        LOGD("ql_info_handle_num = %d", ql_info_handle_num);
        if(ql_info_handle_num == 1) { // 最后一个引用，可释放。
            int ret = mbtk_info_handle_free(&ql_info_handle);
            if(ret) {
                LOGE("mbtk_info_handle_free() fail.");
                return -1;
            }
            else
            {
                ql_info_handle_num = 0;
                ql_info_handle = NULL;
                return 0;
            }
        } else {
            ql_info_handle_num--;
            return 0;
        }
    }
    else
    {
        LOGE("DATA handle not inited.");
        return -1;
    }
}
/*
*Set data call over time.
*/
int ql_wan_set_autoconnect(int auto_status, int interval_sec)
{
    if(auto_status == 0)                    //不开启失败重连
        mbtk_interval_sec = 0;
    else                                    //开启失败重连等待时间
    {
        if(interval_sec <= 0)
            mbtk_interval_sec = interval_sec;
        else
            mbtk_interval_sec = 5; // 默认为5s
    }
    return 0;
}

#ifdef MBTK_AF_SUPPORT
int mbtk_route_config(int profile_idx)
{
    char buf[1024] = {0};
    char dns[128] = {0};
    int offset = 0;
    int fd = -1;
    mbtk_ipv4_info_t ipv4;
    mbtk_ipv6_info_t ipv6;
    sprintf(buf, "route add default dev ccinet%d", profile_idx -1);
    system(buf);

    int ret = mbtk_data_call_state_get(ql_info_handle, profile_idx, &ipv4, &ipv6);
    if(ret != 0)
        return -1;
    else
    {
        memset(buf, 0x0, 1024);
        memset(dns, 0x0, 128);
        offset = sprintf(buf, "search lan\n");
        if(ipv4.valid)
        {
            if(inet_ntop(AF_INET, &(ipv4.PrimaryDNS), dns, 32) == NULL) {
                LOGD("PrimaryDNS error.");
            } else {
                LOGD("PrimaryDNS : %s", dns);
            }
            offset += sprintf(buf + offset, "nameserver %s\n", dns);
            memset(dns, 0x0, 128);
            if(inet_ntop(AF_INET, &(ipv4.SecondaryDNS), dns, 32) == NULL) {
                LOGD("SecondaryDNS error.");
            } else {
                LOGD("SecondaryDNS : %s", dns);
            }
            offset += sprintf(buf + offset, "nameserver %s\n", dns);
        }
        if(ipv6.valid)
        {
            memset(dns, 0x0, 128);
			if(ipv6_2_str(&(ipv6.PrimaryDNS), dns))
            {
				LOGD("PrimaryDNS error.");
			} else {
				LOGD("PrimaryDNS : %s", dns);
			}
            offset += sprintf(buf + offset, "nameserver %s\n", dns);
            memset(dns, 0x0, 128);
			if(ipv6_2_str(&(ipv6.SecondaryDNS), dns))
            {
				LOGD("SecondaryDNS error.");
			} else {
				LOGD("SecondaryDNS : %s", dns);
			}
            offset += sprintf(buf + offset, "nameserver %s\n", dns);
        }

        if(offset > 0)
        {
            fd = open("/tmp/resolv.conf", O_WRONLY | O_TRUNC);
            if(fd < 0)
            {
                LOGD("mbtk_route_config : open fail.");
                return -1;
            }

            ret = write(fd, buf, offset);
            if(ret < 0)
            {
                LOGD("mbtk_route_config : write fail.");
            }

            close(fd);
        }
    }

    return 0;
}
#endif

int ql_wan_start_ex(int profile_idx, int op, ex_conn_status_cb nw_cb)
{
    int ret = -1;
    int count = 0;
    if(ql_info_handle == NULL)
    {
        return -1;
    }

    ql_net_ex_status_cb = nw_cb;
    ql_net_status_cb = NULL;
    now_cid = profile_idx;
    if(profile_idx < MBTK_APN_CID_MIN || profile_idx > MBTK_APN_CID_MAX)
    {
        LOGD("ql_wan_start_ex() cid out of range.");
#if 0
        if(ql_net_ex_status_cb)
            ql_net_ex_status_cb(profile_idx, ql_apn_info[profile_idx].ip_type ,PDP_CID_EXIST_FAIL, 0);
#endif
        return -1;
    }

    //ql_netw_status_cb(ql_apn_info[profile_idx].cid);
    if(op == 0)
    {
        ret = ql_wan_stop(profile_idx);
        goto exit;
    }

#if 0
    if(ql_apn_info[profile_idx].active)
    {
        if(ql_net_ex_status_cb)
            ql_net_ex_status_cb(profile_idx, ql_apn_info[profile_idx].ip_type, PDP_CID_EXIST_FAIL, 0);
        return -1;
    }
#endif

    if(ql_net_ex_status_cb) {
        ql_net_ex_status_cb(profile_idx, ql_apn_info[profile_idx].ip_type, CONNECT_DIAL_IMMEDIATELY, 0);
        ql_net_ex_status_cb(profile_idx, ql_apn_info[profile_idx].ip_type, CONNECT_CONNING, 0);
    }
    
data_call_continue:
    ret = mbtk_data_call_start(ql_info_handle, profile_idx, 0, op == 3 ? TRUE : FALSE, 0);
    if(ret != 0)
    {
        if(mbtk_interval_sec <= 0)
        {
            if(ql_net_ex_status_cb)
                ql_net_ex_status_cb(profile_idx, ql_apn_info[profile_idx].ip_type, CONNECT_DISCON, 0);
            return ret;
        }
        else
        {
            if(count >= 5)
                goto exit;
            sleep(mbtk_interval_sec);
            count++;
            if(ql_net_ex_status_cb)
                ql_net_ex_status_cb(profile_idx, ql_apn_info[profile_idx].ip_type, CONNECT_REDIAL, 0);
            goto data_call_continue;
        }
        LOGD("mbtk_data_call_start() fail.");
    }
    else
    {
        //ql_apn_info[8].cid=profile_idx;
        //ql_netw_status_cb(CONNECT_CONSUCCESS);
#ifdef MBTK_AF_SUPPORT
        if(profile_idx == 1)
        {
            mbtk_route_config(profile_idx);
            
        }
#endif
        LOGD("mbtk_data_call_start() success.");
    }
exit:
    return ret;
}


/*
* Start data call.
*/
int ql_wan_start(int profile_idx, int op, nw_status_cb nw_cb)
{
    int ret = -1;
    int count = 0;
    if(ql_info_handle == NULL)
    {
        return -1;
    }

    ql_net_status_cb = nw_cb;
    ql_net_ex_status_cb = NULL;
    if(profile_idx < MBTK_APN_CID_MIN || profile_idx > MBTK_APN_CID_MAX)
    {
        ql_net_status_cb(PDP_ERROR_UNSPECIFIED);
        return -1;
    }

    //ql_netw_status_cb(ql_apn_info[profile_idx].cid);
    if(op == 0)
    {
        ret = ql_wan_stop(profile_idx);
        goto exit;
    }

    if(ql_apn_info[profile_idx].active)
    {
        ql_net_status_cb(PDP_CID_EXIST_FAIL);
        return -1;
    }

    ql_net_status_cb(CONNECT_DIAL_IMMEDIATELY);
    ql_net_status_cb(CONNECT_CONNING);
data_call_continue:
    ret = mbtk_data_call_start(ql_info_handle, profile_idx, 0, op == 3 ? TRUE : FALSE, 0);
    if(ret != 0)
    {
        if(mbtk_interval_sec <= 0)
        {
            ql_net_status_cb(CONNECT_DISCON);
            return ret;
        }
        else
        {
            if(count >= 5)
                goto exit;
            sleep(mbtk_interval_sec);
            count++;
            ql_net_status_cb(CONNECT_REDIAL);
            goto data_call_continue;
        }
    }
    else
    {
        //ql_apn_info[8].cid=profile_idx;
        //ql_netw_status_cb(CONNECT_CONSUCCESS);
        LOGD("mbtk_data_call_start() success.");
    }
exit:
    return ret;
}

/*
* Stop data call.
*/
int ql_wan_stop(int profile_idx)
{
    int err;
    if(ql_info_handle == NULL)
    {
        return -1;
    }
    if(profile_idx < MBTK_APN_CID_MIN || profile_idx > MBTK_APN_CID_MAX)
    {
        LOGE("CID error.");
        return -1;
    }

#if 0 //mbtk wyq for data_call add "if 0"
    if(!ql_apn_info[profile_idx].active)
    {
        if(ql_net_ex_status_cb)
            ql_net_ex_status_cb(profile_idx, ql_apn_info[profile_idx].ip_type ,PDP_CID_EXIST_FAIL, 0);
        if(ql_net_status_cb)
            ql_net_status_cb(PDP_CID_EXIST_FAIL);
        return -1;
    }
#endif
    err = mbtk_data_call_stop(ql_info_handle, profile_idx, 15);

    return err;
}

/*
* Query data call state.
*/
int ql_get_data_call_info(int profile_idx, ql_data_call_info *info)
{
    if(ql_info_handle == NULL || info == NULL)
    {
        return -1;
    }
    if(profile_idx < MBTK_APN_CID_MIN || profile_idx > MBTK_APN_CID_MAX)
    {
        LOGE("CID error.");
        return -1;
    }
    mbtk_ipv4_info_t ipv4;
    mbtk_ipv6_info_t ipv6;
    memset(info, 0, sizeof(ql_data_call_info));
    int ret = mbtk_data_call_state_get(ql_info_handle, profile_idx, &ipv4, &ipv6);
    if(ret != 0)
        return -1;
    else
    {
        info->profile_idx = profile_idx;
        if(ipv4.valid)
        {
            info->ip_type = 1; // IPV4
            info->v4.state = 1;
            sprintf(info->v4.addr.name, "ccinet%d", profile_idx - 1);
            if(inet_ntop(AF_INET, &(ipv4.IPAddr), info->v4.addr.ip, 32) == NULL) {
                LOGD("IP error.");
            } else {
                LOGD("IP : %s", info->v4.addr.ip);
            }
            if(inet_ntop(AF_INET, &(ipv4.PrimaryDNS), info->v4.addr.pri_dns, 32) == NULL) {
                LOGD("PrimaryDNS error.");
            } else {
                LOGD("PrimaryDNS : %s", info->v4.addr.pri_dns);
            }
            if(inet_ntop(AF_INET, &(ipv4.SecondaryDNS), info->v4.addr.sec_dns, 32) == NULL) {
                LOGD("SecondaryDNS error.");
            } else {
                LOGD("SecondaryDNS : %s", info->v4.addr.sec_dns);
            }
        }
        if(ipv6.valid)
        {
            info->ip_type = 2; // IPV6
            info->v6.state = 1;
            sprintf(info->v6.addr.name, "ccinet%d", profile_idx - 1);
			if(ipv6_2_str(&(ipv6.IPV6Addr), info->v6.addr.ip))
            {
				LOGD("IP error.");
			} else {
				LOGD("IP : %s", info->v6.addr.ip);
			}
			if(ipv6_2_str(&(ipv6.PrimaryDNS), info->v6.addr.pri_dns))
            {
				LOGD("PrimaryDNS error.");
			} else {
				LOGD("PrimaryDNS : %s", info->v6.addr.pri_dns);
			}
			if(ipv6_2_str(&(ipv6.SecondaryDNS), info->v6.addr.sec_dns))
            {
				LOGD("SecondaryDNS error.");
			} else {
				LOGD("SecondaryDNS : %s", info->v6.addr.sec_dns);
			}
        }
        if(ipv4.valid && ipv6.valid)
            info->ip_type = 0; // IPV4V6
        if(!ipv4.valid && !ipv6.valid)
        {
            info->v4.state = 0;
            info->v6.state = 0;
        }
        return 0;
    }

}

/*
* Set specific APN informations.
*
* cid : 2-7
*/
int ql_wan_setapn(int profile_idx, int ip_type, const char *apn, const char *userName,
                            const char *password, QL_DSI_AUTH_PREF_T auth)
{
    if(ql_info_handle == NULL)
    {
        return -1;
    }
    if(profile_idx < MBTK_APN_CID_MIN || profile_idx > MBTK_APN_CID_MAX)
    {
        LOGE("CID error.");
        return -1;
    }
    /*
     QL_DSI_AUTH_PREF_NULL = 0,         //无认证
     QL_DSI_AUTH_PREF_ONLY_PAP,         //PAP 认证
     QL_DSI_AUTH_PREF_ONLY_CHAP,        //CHAP 认证
     QL_DSI_AUTH_PREF_BOTH_PAP_CHAP     //PAP 和 CHAP 认证
    */
    char mbtk_auth[64]={0};
    if(auth == QL_DSI_AUTH_PREF_NULL)
        memcpy(mbtk_auth,"NONE",strlen("NONE")+1);
    else if(auth == QL_DSI_AUTH_PREF_ONLY_PAP)
        memcpy(mbtk_auth,"PAP",strlen("PAP")+1);
    else if(auth == QL_DSI_AUTH_PREF_ONLY_CHAP)
        memcpy(mbtk_auth,"CHAP",strlen("CHAP")+1);
    else
    {
        LOGD("auth input error!");
        return -1;
    }

    memset(&(ql_apn_info[profile_idx]), 0, sizeof(apn_info));
    ql_apn_info[profile_idx].cid = profile_idx;
    ql_apn_info[profile_idx].ip_type = ip_type;
    if(!str_empty(userName) && !str_empty(password)) {
        memcpy(ql_apn_info[profile_idx].user, userName, strlen(userName));
        memcpy(ql_apn_info[profile_idx].pass, password, strlen(password));
        ql_apn_info[profile_idx].auth = auth;
        LOGD("ql_wan_setapn: %d, %d, %s, %s, %s, %s",profile_idx, ip_type, apn, userName, password, mbtk_auth);
    } else {
        LOGD("ql_wan_setapn: %d, %d, %s, NULL, NULL, %s",profile_idx, ip_type, apn, mbtk_auth);
    }

     /*
    if(ip_type < 0 || ip_type > 3)
        ql_netw_status_cb(PDP_UNKNOWN_PDP_ADDRESS_TYPE);
    */
    if(ip_type == 0) // IPV4V6
        ip_type = MBTK_IP_TYPE_IPV4V6;
    else if(ip_type == 1) // IPV4
        ip_type = MBTK_IP_TYPE_IP;
    else if(ip_type == 2) // IPV6
        ip_type = MBTK_IP_TYPE_IPV6;

    return mbtk_apn_set(ql_info_handle, profile_idx, ip_type, apn, userName, password, mbtk_auth);
}

/*
* Get current all APN informations.
*/
int __ql_wan_getapn(int profile_idx, int *ip_type, char *apn, int apnLen, char *userName, int userLen, char *password, int pwdLen,int* auth)
{
    if(ql_info_handle == NULL || apn == NULL)
    {
        return -1;
    }
    if(profile_idx < MBTK_APN_CID_MIN || profile_idx > MBTK_APN_CID_MAX)
    {
        LOGE("CID error.");
        return -1;
    }
    mbtk_apn_info_t apns[10];
    int apn_num = MBTK_APN_CID_MAX;
    int ret = mbtk_apn_get(ql_info_handle, &apn_num, apns);
    if(ret != 0)
    {
        LOGD("mbtk_apn_get ret = %d",ret);
        return -1;
    }
    else
    {
        int i;
        for(i=0;i<MBTK_APN_CID_MAX;i++)
        {
            if(apns[i].cid == profile_idx)
                break;
        }
        if(i == MBTK_APN_CID_MAX)
            return -1;
        LOGD("cid = %d",i);
        if(apns[i].ip_type == MBTK_IP_TYPE_IPV4V6) // IPV4V6
            *ip_type = 0;
        else if(apns[i].ip_type == MBTK_IP_TYPE_IP) // IPV4
            *ip_type = 1;
        else if(apns[i].ip_type == MBTK_IP_TYPE_IPV6) // IPV6
            *ip_type = 2;
        else
            *ip_type = 0;

        if(strlen(apns[i].apn)+1 > apnLen)
            return -1;
        else
            memcpy(apn, apns[i].apn,strlen(apns[i].apn)+1);

        if(strlen(apns[i].user)+1 > userLen)
            return -1;
        else
        {
            if(strlen(apns[i].user) > 0)
                memcpy(userName, apns[i].user, strlen(apns[i].user)+1);
            else
                memcpy(userName, ql_apn_info[profile_idx].user, strlen(ql_apn_info[profile_idx].user)+1);
        }

        if(strlen(apns[i].pass)+1 > pwdLen)
            return -1;
        else
        {
            if(strlen(apns[i].pass) > 0)
                memcpy(password, apns[i].pass, strlen(apns[i].pass)+1);
            else
                memcpy(password, ql_apn_info[profile_idx].pass, strlen(ql_apn_info[profile_idx].pass)+1);
        }

        if(strlen(apns[i].auth) > 0) {
            if(strcmp(apns[i].auth, "NONE") == 0)
                *auth = QL_DSI_AUTH_PREF_NULL;
            else if(strcmp(apns[i].auth, "PAP") == 0)
                *auth = QL_DSI_AUTH_PREF_ONLY_PAP;
            else if(strcmp(apns[i].auth, "CHAP") == 0)
                *auth = QL_DSI_AUTH_PREF_ONLY_CHAP;
            else
            {
                LOGD("auth error!");
                return -1;
            }
        } else {
            *auth = ql_apn_info[profile_idx].auth;
        }

        return 0;
    }
}