int uapi_ws_send_text(const char *text)
{
if (!text) return -1;
- if (g_ws_connected != WS_STATE_CONNECTED || g_ws_client_fd < 0) {
- HAISI_WS_WARN("Cannot send text, connection state: %d\n", g_ws_connected);
+ int network_status = uapi_dev_runtime_get_cat1_networkstat();
+ if (network_status != 1 || g_ws_connected != WS_STATE_CONNECTED || g_ws_client_fd < 0) {
+ HAISI_WS_WARN("Cannot send text, connection state: %d , network_status: %d\n", g_ws_connected,network_status);
return -1;
}
HAISI_WS_DEBUG("uapi_ws_send_text: %s\n", text);
// 发送数据
HAISI_WS_WARN("uapi_ws_send_text \n");
- //
- extern int ln_ws_get_connection_state(void);
- int ret = 0;
- int network_status = uapi_dev_runtime_get_cat1_networkstat();
- //获取websocket连接状态
- int wsState = ln_ws_get_connection_state();
- bool wsConnected = (wsState == 2); // WS_STATE_CONNECTED = 2
- if(network_status == 1 && wsConnected == true)
- {
- HAISI_WS_WARN("uapi_ws_send_text success: network_status=%d, wsConnected=%d\n", network_status, wsConnected);
- ret = WebSocketClientSendText(g_ws_client_fd, text, strlen(text));
- }
- else
- {
- HAISI_WS_WARN("uapi_ws_send_text failed: network_status=%d, wsConnected=%d\n", network_status, wsConnected);
- ret = -1;
- }
- // HAISI_WS_DEBUG("uapi_ws_send_text ret: %d\n", ret);
+ int ret = WebSocketClientSendText(g_ws_client_fd, text, strlen(text));
+ HAISI_WS_DEBUG("uapi_ws_send_text ret: %d\n", ret);
// 更新最后发送时间
if (ret == 0) {