espressif/ESP8266_RTOS_SDK
1
0
Fork 0
mirror of https://github.com/espressif/ESP8266_RTOS_SDK.git synced 2025-07-15 08:32:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(example): Remove websocket demo which based on nopoll

Browse Source
This commit is contained in:
Wu Jian Gang
2018-04-28 20:49:34 +08:00
parent 81ec660a2d
commit 0e71d7a5ba
4 changed files with 0 additions and 387 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
examples/protocols/websocket/Makefile
View File

@ -1,9 +0,0 @@
#
# This is a project Makefile. It is assumed the directory this Makefile resides in is a
# project subdirectory.
#
PROJECT_NAME := websocket
include $(IDF_PATH)/make/project.mk

5
examples/protocols/websocket/main/component.mk
View File

@ -1,5 +0,0 @@
#
# "main" pseudo-component makefile.
#
# (Uses default behaviour of compiling all source files in directory, adding 'include' to include path.)

74
examples/protocols/websocket/main/user_main.c
View File

@ -1,74 +0,0 @@
/* Websocket example
This example code is in the Public Domain (or CC0 licensed, at your option.)
Unless required by applicable law or agreed to in writing, this
software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
CONDITIONS OF ANY KIND, either express or implied.
*/
#include "esp_common.h"
char test_mode = 4;
/******************************************************************************
* FunctionName : user_rf_cal_sector_set
* Description : SDK just reversed 4 sectors, used for rf init data and paramters.
* We add this function to force users to set rf cal sector, since
* we don't know which sector is free in user's application.
* sector map for last several sectors : ABCCC
* A : rf cal
* B : rf init data
* C : sdk parameters
* Parameters : none
* Returns : rf cal sector
*******************************************************************************/
uint32 user_rf_cal_sector_set(void)
{
flash_size_map size_map = system_get_flash_size_map();
uint32 rf_cal_sec = 0;
switch (size_map) {
case FLASH_SIZE_4M_MAP_256_256:
rf_cal_sec = 128 - 5;
break;
case FLASH_SIZE_8M_MAP_512_512:
rf_cal_sec = 256 - 5;
break;
case FLASH_SIZE_16M_MAP_512_512:
case FLASH_SIZE_16M_MAP_1024_1024:
rf_cal_sec = 512 - 5;
break;
case FLASH_SIZE_32M_MAP_512_512:
case FLASH_SIZE_32M_MAP_1024_1024:
rf_cal_sec = 1024 - 5;
break;
case FLASH_SIZE_64M_MAP_1024_1024:
rf_cal_sec = 2048 - 5;
break;
case FLASH_SIZE_128M_MAP_1024_1024:
rf_cal_sec = 4096 - 5;
break;
default:
rf_cal_sec = 0;
break;
}
return rf_cal_sec;
}
/******************************************************************************
* FunctionName : user_init
* Description : entry of user application, init user function here
* Parameters : none
* Returns : none
*******************************************************************************/
void user_init(void)
{
os_printf("SDK version:%s\n", system_get_sdk_version());
wifi_set_opmode(STATION_MODE);
websocket_start(&test_mode);
}

299
examples/protocols/websocket/main/websocket.c
View File

@ -1,299 +0,0 @@
/*
* LibNoPoll: A websocket library
* Copyright (C) 2013 Advanced Software Production Line, S.L.
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public License
* as published by the Free Software Foundation; either version 2.1
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this program; if not, write to the Free
* Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
* 02111-1307 USA
*
* You may find a copy of the license under this software is released
* at COPYING file. This is LGPL software: you are welcome to develop
* proprietary applications using this library without any royalty or
* fee but returning back any change, improvement or addition in the
* form of source code, project image, documentation patches, etc.
*
* For commercial support on build Websocket enabled solutions
* contact us:
*
* Postal address:
* Advanced Software Production Line, S.L.
* Edificio Alius A, Oficina 102,
* C/ Antonio Suarez Nº 10,
* Alcalá de Henares 28802 Madrid
* Spain
*
* Email address:
* info@aspl.es - http://www.aspl.es/nopoll
*/
#include <nopoll.h>
#include "esp_common.h"
#include "freertos/FreeRTOS.h"
#include "freertos/task.h"
#include "freertos/queue.h"
nopoll_bool debug = nopoll_false;
nopoll_bool show_critical_only = nopoll_false;
LOCAL xQueueHandle Web_QueueStop = NULL;
const char *ping_msg = "{\"path\": \"/v1/ping/\", \"method\": \"GET\"}";
#define local_host_name "iot.espressif.cn"
#define local_host_url "v1/datastreams/tem_hum/datapoint"
#define local_host_port "9000"
#define local_host_ports "9443"
void __report_critical (noPollCtx * ctx, noPollDebugLevel level, const char * log_msg, noPollPtr user_data)
{
if (level == NOPOLL_LEVEL_CRITICAL) {
printf ("CRITICAL: %s\n", log_msg);
}
return;
}
noPollCtx * create_ctx (void) {
/* create a context */
noPollCtx * ctx = nopoll_ctx_new ();
nopoll_log_enable (ctx, debug);
nopoll_log_color_enable (ctx, debug);
/* configure handler */
if (show_critical_only)
nopoll_log_set_handler (ctx, __report_critical, NULL);
return ctx;
}
nopoll_bool test_01 (void) {
noPollCtx * ctx;
noPollConn * conn;
noPollMsg * msg;
int iter;
/* create context */
ctx = create_ctx ();
/* check connections registered */
if (nopoll_ctx_conns (ctx) != 0) {
printf ("ERROR: expected to find 0 registered connections but found: %d\n", nopoll_ctx_conns (ctx));
return nopoll_false;
} /* end if */
nopoll_ctx_unref (ctx);
/* reinit again */
ctx = create_ctx ();
/* call to create a connection */
conn = nopoll_conn_new (ctx, local_host_name, local_host_port, NULL, "/ws", NULL, NULL);
if (! nopoll_conn_is_ok (conn)) {
printf ("ERROR: Expected to find proper client connection status, but found error.. (conn=%p, conn->session=%d, NOPOLL_INVALID_SOCKET=%d, errno=%d, strerr=%s)..\n",
conn, (int) nopoll_conn_socket (conn), (int) NOPOLL_INVALID_SOCKET, errno, strerror (errno));
return nopoll_false;
}
printf ("Test 01: sending basic content..\n");
/* send content text(utf-8) */
if (nopoll_conn_send_text (conn, ping_msg,strlen(ping_msg)) != strlen(ping_msg)) {
printf ("ERROR: Expected to find proper send operation..\n");
return nopoll_false;
}
/* wait for the reply */
iter = 0;
while ((msg = nopoll_conn_get_msg (conn)) == NULL) {
if (! nopoll_conn_is_ok (conn)) {
printf ("ERROR: received websocket connection close during wait reply..\n");
return nopoll_false;
}
nopoll_sleep (10000);
if (iter > 10)
break;
} /* end if */
printf("Recieve data:%s\n",(const char *) nopoll_msg_get_payload (msg));
/* unref message */
nopoll_msg_unref (msg);
/* finish connection */
nopoll_conn_close (conn);
/* finish */
nopoll_ctx_unref (ctx);
return nopoll_true;
}
nopoll_bool test_02 (void) {
noPollCtx * ctx;
noPollConn * conn;
noPollConnOpts * opts;
noPollMsg * msg;
int iter;
/* reinit again */
ctx = create_ctx ();
/* disable verification */
opts = nopoll_conn_opts_new ();
nopoll_conn_opts_ssl_peer_verify (opts, nopoll_false);
/* call to create a connection */
conn = nopoll_conn_tls_new (ctx, opts, local_host_name, local_host_ports, NULL, "/ws", NULL, NULL);
if (! nopoll_conn_is_ok (conn)) {
printf ("ERROR: Expected to find proper client connection status, but found error..\n");
return nopoll_false;
} /* end if */
/* check if the connection already finished its connection
handshake */
while (! nopoll_conn_is_ready (conn)) {
if (! nopoll_conn_is_ok (conn)) {
printf ("ERROR (4.1 dk45): expected to find proper connection handshake finished, but found connection is broken: session=%d, errno=%d : %s..\n",
(int) nopoll_conn_socket (conn), errno, strerror (errno));
return nopoll_false;
} /* end if */
/* wait a bit 10ms */
nopoll_sleep (10000);
} /* end if */
printf ("Test 02: testing sending TLS content over the wire..\n");
if (nopoll_conn_send_text (conn, ping_msg ,strlen(ping_msg)) != strlen(ping_msg)) {
printf ("ERROR: Expected to find proper send operation..\n");
return nopoll_false;
}
/* wait for the reply */
iter = 0;
while ((msg = nopoll_conn_get_msg (conn)) == NULL) {
if (! nopoll_conn_is_ok (conn)) {
printf ("ERROR: received websocket connection close during wait reply..\n");
return nopoll_false;
}
nopoll_sleep (10000);
if (iter > 10)
break;
} /* end if */
printf("Recieve data:%s\n",(const char *) nopoll_msg_get_payload (msg));
/* unref message */
nopoll_msg_unref (msg);
/* finish connection */
nopoll_conn_close (conn);
/* finish */
nopoll_ctx_unref (ctx);
return nopoll_true;
}
LOCAL int websocket_main (char *argv)
{
int iterator = *argv;
printf("interator:%d\n",iterator);
switch (iterator) {
case 1:
if (test_01()) {
printf("Test 01: Simple request/reply [ OK ]\n");
} else {
printf("Test 01: Simple request/reply [ FAILED ]\n");
}
break;
case 2:
if (test_02()) {
printf("Test 02: testing TLS request/reply [ OK ]\n");
} else {
printf("Test 02: testing TLS request/reply [ FAILED ]\n");
}
break;
default:
break;
}
/* call to cleanup */
nopoll_cleanup_library ();
printf ("All tests ok!!\n");
return 0;
}
LOCAL void websocket_task(void *pvParameters)
{
bool ValueFromReceive = false;
portBASE_TYPE xStatus;
struct ip_info ip_config;
struct station_config sta_config;
bzero(&sta_config, sizeof(struct station_config));
sprintf(sta_config.ssid, "WiZLamps");
sprintf(sta_config.password, "");
wifi_station_set_config(&sta_config);
os_printf("%s\n", __func__);
wifi_get_ip_info(STATION_IF, &ip_config);
printf("Delaying...\n");
vTaskDelay(2000 / portTICK_RATE_MS);
websocket_main((char*)pvParameters);
while (1) {
xStatus = xQueueReceive(Web_QueueStop,&ValueFromReceive,0);
if (xStatus == pdPASS && ValueFromReceive == true){
printf("websocket_task exit signal\n");
break;
}
vTaskDelay(3000 / portTICK_RATE_MS);
printf("websocket_task\n");
}
vQueueDelete(Web_QueueStop);
Web_QueueStop = NULL;
vTaskDelete(NULL);
printf("delete the websocket_task\n");
}
/*start the websocket task*/
void websocket_start(void *optarg)
{
if (Web_QueueStop == NULL)
Web_QueueStop = xQueueCreate(1,1);
if (Web_QueueStop != NULL)
xTaskCreate(websocket_task, "websocket_task", 2048, optarg, 4, NULL);
}
/*stop the websocket task*/
sint8 websocket_stop(void)
{
bool ValueToSend = true;
portBASE_TYPE xStatus;
if (Web_QueueStop == NULL)
return -1;
xStatus = xQueueSend(Web_QueueStop,&ValueToSend,0);
if (xStatus != pdPASS)
return -1;
else
return pdPASS;
}
/* end-of-file-found */