tcp_server.c 文件参考

#include "ets_sys.h"
#include "osapi.h"
#include "user_interface.h"
#include "mem.h"
#include "espconn.h"
#include "tcp_server.h"
#include "room_info.h"

tcp_server.c 的引用(Include)关系图:

函数
void	StudyRoom_UpdataData (uint8 *msg_string)
	更新本地数据 更多...
void	StudyRoom_GetStatusHex (uint8 room_no, uint8 *out_hexstr)
void	send2room (uint8 roomNO, char *pdata)
void ICACHE_FLASH_ATTR	tcp_server_init (uint32 port)

变量
struct espconn *	client [4]

函数说明

void StudyRoom_UpdataData

(

uint8 *

msg_string

)

更新本地数据

• 更新单个房间的环境信息
• 更新单个房间的单个用电器的状态

单次调用时，环境信息和用电器状态信息不同时更新

• 由各个房间的client节点发送到本节点的tcp server上，msg_string来自于tcp_server_recv()

参数

[in]

msg_string

信息指令串 0xFF 作为标志位：室内环境信息 0xFE 作为标志位：用电器状态信息

参见

room_status

room_message

                                             {

    uint8 hexstr[128];

    if (msg_string[0] == 0xFF)
    {
        /* msg_string[1] 房间编号，取值范围[1..4] */
        os_memcpy((room_message + msg_string[1] - 1), msg_string + 2, 4 );

    } 
    else if (msg_string[0] == 0xFE)
    {
        // StudyRoom_GetStatusHex(msg_string[1], hexstr);
        // ESP_DEBUG("status str now is: %s, num is %d", hexstr, room_status[0]);

        /* 位运算 先将目标用电器位置零，再将指令赋值给目标用电器位 */
        *(room_status + (msg_string[1] - 1)) &= ~(0x01 << (8 * msg_string[2] + msg_string[3]));
        *(room_status + (msg_string[1] - 1)) |= ((uint32)msg_string[4] << (8 * msg_string[2] + msg_string[3]));

        // StudyRoom_GetStatusHex(msg_string[1], hexstr);
        // ESP_DEBUG("status str now is: %s, num is %d", hexstr, room_status[0]);
    }
    
}

void StudyRoom_GetStatusHex	(	uint8	room_no,
		uint8 *	out_hexstr
	)

void send2room	(	uint8	roomNO,
		char *	pdata
	)

                                           {
    struct espconn *room;
    os_printf("room no is %d\n",roomNO);
    switch(roomNO){
         case ROOM_ONE_NO:
             room = client[ROOM_ONE_NO];
             break;
         case ROOM_TWO_NO:
             room = client[ROOM_TWO_NO];
             break;
         case ROOM_THREE_NO:
             room = client[ROOM_THREE_NO];
             break;
         case ROOM_FOUR_NO:
             room = client[ROOM_FOUR_NO];
             break;
    }

    espconn_send(room, pdata, 5);
}

函数调用图:

void ICACHE_FLASH_ATTR tcp_server_init

(

uint32

port

)

                             {
    static struct espconn s_tcp_server;
    static esp_tcp s_esptcp;

    s_tcp_server.type = ESPCONN_TCP;
    s_tcp_server.state = ESPCONN_NONE;
    s_tcp_server.proto.tcp = &s_esptcp;
    s_tcp_server.proto.tcp->local_port = port;
    espconn_regist_connectcb(&s_tcp_server, tcp_server_listen);

    espconn_accept(&s_tcp_server);
    espconn_regist_time(&s_tcp_server, 0, 0);           // TCP server 瓒呮椂鏃堕棿

    //os_printf("tcp_server_init\r\n");
}

函数调用图:

这是这个函数的调用关系图:

变量说明

struct espconn* client[4]