source: EcnlProtoTool/trunk/prototool/webserver/websocket.h@ 270

Last change on this file since 270 was 270, checked in by coas-nagasima, 7 years ago

mruby版ECNLプロトタイピング・ツールを追加
  • Property svn:eol-style set to native
  • Property svn:keywords set to Id
  • Property svn:mime-type set to text/x-chdr
File size: 5.9 KB
Line 
1/*
2 * TOPPERS ECHONET Lite Communication Middleware
3 *
4 * Copyright (C) 2015 Cores Co., Ltd. Japan
5 *
6 * 上記著作権者
7は，以下の(1)～(4)の条件を満たす場合に限り，本ソフトウェ
8 * ア（本ソフトウェアを改変したものを含む．以下同じ）を使用・複製・改
9 * 変・再é…
10å¸ƒï¼ˆä»¥ä¸‹ï¼Œåˆ©ç”¨ã¨å‘¼ã¶ï¼‰ã™ã‚‹ã“とを無償で許諾する．
11 * (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作
12 * 権表示，この利用条件および下記の無保証規定が，そのままの形でソー
13 * スコード中に含まれていること．
14 * (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使
15 * 用できる形で再é…
16å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œå†é…
17å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨
18 * 者
19マニュアルなど）に，上記の著作権表示，この利用条件および下記
20 * の無保証規定を掲載すること．
21 * (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使
22 * 用できない形で再é…
23å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œæ¬¡ã®ã„ずれかの条件を満たすこ
24 * と．
25 * (a) 再é…
26å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨è€…
27マニュアルなど）に，上記の著
28 * 作権表示，この利用条件および下記の無保証規定を掲載すること．
29 * (b) 再é…
30å¸ƒã®å½¢æ…
31‹ã‚’，別に定める方法によって，TOPPERSプロジェクトに
32 * 報告すること．
33 * (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
34 * 害からも，上記著作権者
35およびTOPPERSプロジェクトをå…
36è²¬ã™ã‚‹ã“と．
37 * また，本ソフトウェアのユーザまたはエンドユーザからのいかなる理
38 * 由に基づく請求からも，上記著作権者
39およびTOPPERSプロジェクトを
40 * å…
41è²¬ã™ã‚‹ã“と．
42 *
43 * 本ソフトウェアは，無保証で提供されているものである．上記著作権者
44お
45 * よびTOPPERSプロジェクトは，本ソフトウェアに関して，特定の使用目的
46 * に対する適合性も含めて，いかなる保証も行わない．また，本ソフトウェ
47 * アの利用により直接的または間接的に生じたいかなる損害に関しても，そ
48 * の責任を負わない．
49 *
50 * @(#) $Id: websocket.h 270 2017-02-09 04:03:47Z coas-nagasima $
51 */
52
53#ifndef WEBSOCKET_H
54#define WEBSOCKET_H
55
56#include <stddef.h>
57#include <stdint.h>
58#include "t_stddef.h"
59
60#define NUM_ECHONET_MEMPOOL_BLOCK (60) /* 電文用メモリブロックの数 */
61#define ECHONET_MEMPOOL_BLOCK_SIZE (256) /* 電文用メモリブロックのサイズ */
62
63/* T_EDATA管理領域サイズ */
64#define DEF_ECN_EDT_HDR_LEN (sizeof(intptr_t))
65
66/* 管理領域サイズ(64byte - sizeof(T_MSG)) */
67/* #define DEF_ECN_FBS_LIB_HDR_LEN ((ECHONET_MEMPOOL_BLOCK_SIZE + sizeof(int) - 1)>> 2) // */
68#define DEF_ECN_FBS_LIB_HDR_LEN (64 - DEF_ECN_EDT_HDR_LEN)
69
70/* 管理領域を含むブロックに保持するデータサイズ */
71#define DEF_ECN_FBS_FST_DAT_LEN (64)
72
73/* リンクポインタé…
74åˆ—のサイズ(byte) */
75#define DEF_ECN_FBS_LNK_LEN (ECHONET_MEMPOOL_BLOCK_SIZE - DEF_ECN_EDT_HDR_LEN - DEF_ECN_FBS_LIB_HDR_LEN - DEF_ECN_FBS_FST_DAT_LEN)
76
77/* 固定長バッファ最大サイズ */
78#define DEF_ECN_FBS_BUF_MAXLEN ((DEF_ECN_FBS_LNK_LEN / sizeof(void *)) * ECHONET_MEMPOOL_BLOCK_SIZE + DEF_ECN_FBS_FST_DAT_LEN)
79
80/* 子要素バッファのサイズ */
81#define DEF_ECN_FBS_SUB_BUF_LEN ECHONET_MEMPOOL_BLOCK_SIZE
82
83/* リンクポインタé…
84åˆ—に列挙される、子要素バッファ */
85typedef struct {
86 uint8_t payload[ECHONET_MEMPOOL_BLOCK_SIZE];
87} T_ECN_SUB_BLK;
88
89/* リンクポインタé…
90åˆ— */
91typedef union {
92 T_ECN_SUB_BLK *p_sub[DEF_ECN_FBS_LNK_LEN / sizeof(T_ECN_SUB_BLK *)];
93 uint8_t bin[DEF_ECN_FBS_LNK_LEN];
94} T_ECN_FBS_LNK;
95
96/* 管理領域(64byte - sizeof(T_MSG)) */
97typedef struct {
98 uint16_t length; /* メッセージ長 */
99 uint16_t type; /* メッセージタイプ */
100 union {
101 ID mbxid; /* 送信å…
102ƒãƒ¡ãƒ¼ãƒ«ãƒœãƒƒã‚¯ã‚¹ID（内
103部メッセージ） */
104 }sender;
105 union {
106 ID mbxid; /* 送信å…
107ˆãƒ¡ãƒ¼ãƒ«ãƒœãƒƒã‚¯ã‚¹ID（内
108部メッセージ） */
109 }target;
110 union {
111 ID mbxid; /* 返信å…
112ˆãƒ¡ãƒ¼ãƒ«ãƒœãƒƒã‚¯ã‚¹ID（内
113部メッセージ） */
114 }reply;
115
116 int rd; /* 読み取りヘッド情
117å ± */
118 int wr; /* 書き込みヘッド情
119å ± */
120} T_ECN_FBS_HDR;
121
122/* 管理領域を含むブロックの構造 */
123typedef struct {
124 uint8_t _msg[DEF_ECN_EDT_HDR_LEN]; /* T_MSG */
125 T_ECN_FBS_HDR hdr; /* 管理領域 64byte - sizeof(T_MSG) */
126 uint8_t _gap[DEF_ECN_FBS_LIB_HDR_LEN - sizeof(T_ECN_FBS_HDR)];
127 T_ECN_FBS_LNK lnk; /* リンクポインタé…
128åˆ— 128byte */
129 uint8_t payload[DEF_ECN_FBS_FST_DAT_LEN];
130} T_ECN_FST_BLK;
131
132/* FBS-ID */
133typedef struct ecn_fbs_id_strc {
134 T_ECN_FST_BLK *ptr;
135} ECN_FBS_ID;
136
137ER _ecn_fbs_cre(size_t fa_req_size, ECN_FBS_ID *fp_id);
138ER _ecn_fbs_del(ECN_FBS_ID fa_id);
139size_t _ecn_fbs_get_datalen(ECN_FBS_ID fa_id);
140int _ecn_fbs_peek(ECN_FBS_ID fa_id, size_t fa_seek);
141ER _ecn_fbs_poke(ECN_FBS_ID fa_id, size_t fa_seek, int fa_val);
142
143extern ID ecn_api_mailboxid;
144extern ID WEBSOCKET_MBXID;
145
146typedef struct ws_state
147{
148 int state;
149 int fin;
150 enum opecode_t
151 {
152 continuation_frame = 0,
153 text_frame = 1,
154 binary_frame = 2,
155 connection_close = 8,
156 ping = 9,
157 pong = 10
158 } opecode;
159 int payload_len;
160 int masked;
161 char masking_key[4];
162 int data_pos;
163} ws_state_t;
164
165struct websocket
166{
167 ID wbsid;
168 ws_state_t wstate;
169 ws_state_t rstate;
170 ECN_FBS_ID cur_in_msg;
171};
172
173void websocket_init(struct websocket *ws, ID wbsid);
174void websocket_destroy(struct websocket *ws);
175struct websocket *websocket_getws(ID wbsid);
176
177int websocket_input(struct websocket *ws, const void *data, int len);
178bool_t websocket_newdata(struct websocket *ws);
179int websocket_output(struct websocket *ws, void *data, int len);
180
181#endif /* WEBSOCKET_H */
Note: See TracBrowser for help on using the repository browser.