mirror/OpenBK7231T_App
3
0
Fork 0
mirror of https://github.com/openshwprojects/OpenBK7231T_App.git synced 2026-02-09 18:35:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

XR809 tcp port - not tested

Browse Source
This commit is contained in:
openshwprojects
2022-02-12 17:32:16 +01:00
parent d6278bae7d
commit 7da9528431
3 changed files with 59 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
src/httpserver/http_tcp_server.c
View File

@ -5,7 +5,17 @@
#include "lwip/inet.h"
#include "../logging/logging.h"
#include "new_http.h"
#if PLATFORM_XR809
#define kNoErr 0 //! No error occurred.
typedef void *beken_thread_arg_t;
typedef int OSStatus;
static OS_Thread_t g_http_thread;
#else
#include "str_pub.h"
#endif
static void tcp_server_thread( beken_thread_arg_t arg );
static void tcp_client_thread( beken_thread_arg_t arg );
@ -16,11 +26,20 @@ void start_tcp_http()
{
OSStatus err = kNoErr;
#if PLATFORM_XR809
err = OS_ThreadCreate(&g_http_thread,
"TCP_server",
tcp_server_thread,
NULL,
OS_THREAD_PRIO_CONSOLE,
0x800);
#else
err = rtos_create_thread( NULL, BEKEN_APPLICATION_PRIORITY,
"TCP_server",
(beken_thread_function_t)tcp_server_thread,
0x800,
(beken_thread_arg_t)0 );
#endif
if(err != kNoErr)
{
ADDLOG_ERROR(LOG_FEATURE_HTTP, "create \"TCP_server\" thread failed!\r\n");
@ -91,8 +110,12 @@ exit:
if ( reply != NULL )
os_free( reply );
close( fd );
rtos_delete_thread( NULL );
close( fd );;
#if PLATFORM_XR809
OS_ThreadDelete( NULL );
#else
rtos_delete_thread( NULL );
#endif
}
/* TCP server listener thread */
@ -129,12 +152,24 @@ static void tcp_server_thread( beken_thread_arg_t arg )
{
os_strcpy( client_ip_str, inet_ntoa( client_addr.sin_addr ) );
ADDLOG_DEBUG(LOG_FEATURE_HTTP, "TCP Client %s:%d connected, fd: %d", client_ip_str, client_addr.sin_port, client_fd );
if ( kNoErr
!= rtos_create_thread( NULL, BEKEN_APPLICATION_PRIORITY,
if ( kNoErr !=
#if PLATFORM_XR809
OS_ThreadCreate(&g_http_thread,
"TCP Clients",
tcp_client_thread,
client_fd,
OS_THREAD_PRIO_CONSOLE,
0x800)
#else
rtos_create_thread( NULL, BEKEN_APPLICATION_PRIORITY,
"TCP Clients",
(beken_thread_function_t)tcp_client_thread,
0x800,
(beken_thread_arg_t)client_fd ) )
(beken_thread_arg_t)client_fd )
#endif
)
{
close( client_fd );
client_fd = -1;
@ -147,5 +182,9 @@ static void tcp_server_thread( beken_thread_arg_t arg )
ADDLOG_ERROR(LOG_FEATURE_HTTP, "Server listerner thread exit with err: %d", err );
close( tcp_listen_fd );
#if PLATFORM_XR809
OS_ThreadDelete( NULL );
#else
rtos_delete_thread( NULL );
#endif
}

16
src/httpserver/new_http.c
View File

@ -2,13 +2,16 @@
#include "../new_common.h"
#include "ctype.h"
#ifndef WINDOWS
#include "lwip/sockets.h"
#include "str_pub.h"
#else
#if WINDOWS
//#include <windows.h>
#include <winsock2.h>
//#include <ws2tcpip.h>
#elif PLATFORM_XR809
#include <stdarg.h>
#else
#include "lwip/sockets.h"
#include "str_pub.h"
#endif
#include "new_http.h"
#include "../new_pins.h"
@ -16,6 +19,8 @@
#include "../ota/ota.h"
#ifdef WINDOWS
#elif PLATFORM_XR809
#elif defined(PLATFORM_BK7231N)
// tuya-iotos-embeded-sdk-wifi-ble-bk7231n/sdk/include/tuya_hal_storage.h
#include "tuya_hal_storage.h"
@ -656,6 +661,9 @@ int HTTP_ProcessPacket(http_request_t *request) {
#ifdef WINDOWS
poststr(request,"Not available on Windows<br>");
#elif PLATFORM_XR809
poststr(request,"TODO XR809<br>");
#else
AP_IF_S *ar;
uint32_t num;