LC_D29V_ZZD/app/tupApi.c

#include "tupApi.h"
#include "log.h"
#include <string.h>

void threadPostEvent(LSAPI_OSI_Thread_t *threadId, T_INT32 id){
	LSAPI_OSI_Event_t pEventSend;
	pEventSend.id=id;
 	//LSAPI_OSI_EvnetSend(threadId,&pEventSend);
 	osiEventTrySend(threadId,&pEventSend,0);
}
void userExitThread(const char *name){
	wlog_info("[DieThread:%x]%s", LSAPI_OSI_ThreadCurrent(),name);
	LSAPI_OSI_ThreadExit();
}


void tupParaSet(TUPSEND_DEF *para, T_UINT16 port, LSAPI_SOCK_Callback *callback,T_UINT16 stacksize){
	para->port=port;
	para->tupRecvCallBack=callback;
	para->stacksize=stacksize;
}

void trySendTup(T_UINT8 *data, T_UINT16 len, TUP_ENUM tup, TUPSEND_DEF *para){
	T_INT32 ret;
	if(para->fd<=0) return;
	if(TUP_TCP==para->tupType) ret=LSAPI_SOCK_Send(para->fd,data,len,0);
	else ret=LSAPI_SOCK_Sendto(para->fd,data,len,0, &para->sockAddr, sizeof(LSAPI_SOCK_TcpipSocketAddr_t));
	if(ret<0) wlog_info("tup[%d]:%d send failed", para->fd,len);
	else wlog_info("tup[%d]:%d send ok",para->fd,len);
}
void userCloseSocket(T_INT32 *fd){
	if(*fd<=0) return; 
	wlog_info("SockClose:%d",*fd);
	LSAPI_SOCK_Close(*fd);
	*fd=0;
}

void showTupEventInfo(const char *name, T_UINT32 id,TUPSEND_DEF *para, char needShutWhenSerShut){
	if(para->ptimer_t!=NULL){//有回调�应�清除定时�
		wlog_info("[%s]timerStop",name);
		LSAPI_OSI_TimerStop(para->ptimer_t);
		if(NULL != para->ptimer_t) LSAPI_OSI_TimerDelete(para->ptimer_t);
		para->ptimer_t=NULL;

	}
	switch(id){
		case LSAPI_SOCK_TCPIP_REV_DATA_IND:      wlog_info("[%d %s]:recv data ok",id,name);break;
		case LSAPI_SOCK_TCPIP_CLOSE_IND:         
			para->tupStatus=CNNT_CLOSED;
			if(needShutWhenSerShut==0) userCloseSocket(&para->fd);
			else wlog_info("[%d %s dly shut fd",id,name);	
			 wlog_info("[%d %s]:server shut",id,name);
			break;
			
		case LSAPI_SOCK_TCPIP_ERR_IND:           para->tupStatus=CNNT_ERROR;userCloseSocket(&para->fd);wlog_info("[%d %s]:link err",id,name);break;
		case LSAPI_SOCK_TCPIP_SOCKET_CONNECT_RSP:para->tupStatus=CNNT_OK;wlog_info("[%d %s]:link ok",id,name);break;
		case LSAPI_SOCK_TCPIP_SOCKET_CLOSE_RSP:  para->tupStatus=CNNT_CLOSED;userCloseSocket(&para->fd);wlog_info("[%d %s]:client shut",id,name);break;
		case LSAPI_SOCK_TCPIP_SOCKET_SEND_RSP:   wlog_info("[%d %s]:send data ok",id,name);break;
		default:wlog_info("%d %s]:ignore",id,name);break;
	}
}

void sockTimerOutCallback(void *param){
	TUPSEND_DEF *para=(TUPSEND_DEF *)param;
    wlog_info("sockTimerOutCallback enter");
    LSAPI_OSI_TimerStop(para->ptimer_t);
    userCloseSocket(&para->fd);
    para->errno=3;//连接超时错误3
	threadPostEvent(LSAPI_OSI_ThreadCurrent(),USER_EVENT_EXIT);
}




void AppsockEntry(void *param){
	TUPSEND_DEF *para=(TUPSEND_DEF *)param;
	T_INT32 sockfd;
	T_UINT8 type;
	int g_keepalive = 0;
	wlog_info("[NewThread:sockEntry]%x",LSAPI_OSI_ThreadCurrent());
	
	if(TUP_TCP==para->tupType) type=LSAPI_SOCK_TCPIP_SOCK_STREAM;
	else type=LSAPI_SOCK_TCPIP_SOCK_DGRAM;
	sockfd = LSAPI_SOCK_Create(LSAPI_SOCK_TCPIP_AF_INET, type, 0, para->tupRecvCallBack,(uint32_t)para);
	
	if(sockfd<0){
	  	wlog_info("sockfd create err=%d",LSAPI_SOCK_Error());
	  	para->errno=1;//错误1
	  	LSAPI_OSI_ThreadExit();
	}
	
	para->fd=sockfd;
	wlog_info("tup info:%d,%s:%d", sockfd,para->saddr, para->port);
	
	
	LSAPI_SOCK_TcpipSocketAddr_t *serveraddr=&para->sockAddr;
	
	serveraddr->sin_family = LSAPI_SOCK_TCPIP_AF_INET;
	
	serveraddr->sin_port = LSAPI_SOCK_htons(para->port);
	
	serveraddr->sin_addr.s_addr = LSAPI_SOCK_inet_addr(para->saddr);

	wlog_info("tup info222:%d,%s:%d", sockfd,para->saddr, para->port);

	LSAPI_SOCK_SetSockOpt(sockfd, LSAPI_SOCK_SOL_SOCKET, LSPAI_SOCK_KEEPALIVE, (void *)&g_keepalive, sizeof(g_keepalive));
	
	if(LSAPI_RET_OK != LSAPI_SOCK_Connect(sockfd, serveraddr)){
	  wlog_info("sockfd connect err");
	  userCloseSocket(&sockfd);
	  para->fd=0;
	  para->errno=2;//错误2
	  para->tupStatus=CNNT_ERROR;
	  userExitThread("sockEntry");
	  return;
	}
	para->ptimer_t=LSAPI_OSI_TimerCreate(LSAPI_OSI_ThreadCurrent(), sockTimerOutCallback, param);
	if(NULL != para->ptimer_t) LSAPI_OSI_TimerStart(para->ptimer_t, 10000);//设置为超�0�10000
	wlog_info("open fd:%d",sockfd);
	LSAPI_OSI_Event_t event={};
	
	for(;;){
		LSAPI_OSI_EventWait(LSAPI_OSI_ThreadCurrent(), &event);
		//LSAPI_OSI_Free(pEvent);	
		if(USER_EVENT_EXIT==event.id){
			userCloseSocket(&para->fd);
			if(NULL != para->ptimer_t) LSAPI_OSI_TimerDelete(para->ptimer_t);
			userExitThread("AppsockEntry");
			
		}
	
	}

	
}

TUP_CONNECT_ENUM tryConnectTup(T_INT8 *seraddr, TUP_ENUM tup,TUPSEND_DEF *para){
  //必须使用线程�创建连接�waitevent
  para->saddr=seraddr;
  para->tupType=tup;
  para->errno=0;
  para->tupStatus=CNNT_BUSY;
  para->fd=0;

 if(NULL==LSAPI_OSI_ThreadCreate("AppsockCreate", AppsockEntry,(void *)para,LSAPI_OSI_PRIORITY_NORMAL,para->stacksize,4)){
  	wlog_info("tryConnectTup thread create error for %s",seraddr);
  	return TUP_STATUS_FALSE;
  }
  return TUP_STATUS_WAIT;
  
}