![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mqttd_calls.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src|
Return to mqttd_calls.c CVS log | Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src |
1.2 misho 1: #include "global.h"
2: #include "mqttd.h"
1.2.2.1 misho 3: #include "rtlm.h"
1.2 misho 4: #include "mqttd_calls.h"
5:
6:
7: int
1.2.2.1 misho 8: cmdPUBLISH(void *srv, void *arg)
1.2 misho 9: {
10: struct mqtthdr *hdr;
1.2.2.1 misho 11: struct tagSession *sess = (struct tagSession*) arg;
1.2 misho 12:
13: ioTRACE(2);
14:
15: if (!sess)
16: return -1;
17:
18: hdr = (struct mqtthdr*) sess->sess_buf->msg_base;
19: switch (hdr->mqtt_msg.qos) {
20: case MQTT_QOS_ONCE:
21: break;
22: case MQTT_QOS_ACK:
23: break;
24: case MQTT_QOS_EXACTLY:
25: break;
26: default:
27: ioDEBUG(1, "Error:: Unknown QoS %d - rejected publishing request",
28: hdr->mqtt_msg.qos);
29: return 0;
30: }
31:
32: return 0;
33: }
1.2.2.1 misho 34:
35: int
36: cmdPUBREL(void *srv, void *arg)
37: {
38: struct mqtthdr *hdr;
39: struct tagSession *sess = (struct tagSession*) arg;
40:
41: ioTRACE(2);
42:
43: if (!sess)
44: return -1;
45:
46: hdr = (struct mqtthdr*) sess->sess_buf->msg_base;
47:
48: return 0;
49: }
50:
51: int
52: cmdSUBSCRIBE(void *srv, void *arg)
53: {
54: struct mqtthdr *hdr;
55: struct tagSession *sess = (struct tagSession*) arg;
56:
57: ioTRACE(2);
58:
59: if (!sess)
60: return -1;
61:
62: hdr = (struct mqtthdr*) sess->sess_buf->msg_base;
63:
64: return 0;
65: }
66:
67: int
68: cmdUNSUBSCRIBE(void *srv, void *arg)
69: {
70: struct mqtthdr *hdr;
71: struct tagSession *sess = (struct tagSession*) arg;
72:
73: ioTRACE(2);
74:
75: if (!sess)
76: return -1;
77:
78: hdr = (struct mqtthdr*) sess->sess_buf->msg_base;
79:
80: return 0;
81: }
82:
83: int
84: cmdPINGREQ(void *srv, void *arg)
85: {
86: struct mqtthdr *hdr;
87: struct tagSession *sess = (struct tagSession*) arg;
1.2.2.2 misho 88: int siz = 0;
1.2.2.1 misho 89:
90: ioTRACE(2);
91:
92: if (!sess)
93: return -1;
94:
95: hdr = (struct mqtthdr*) sess->sess_buf->msg_base;
1.2.2.2 misho 96: siz = mqtt_msgPINGRESP(sess->sess_buf);
97: if (siz == -1) {
98: ioDEBUG(5, "Error:: in msgPINGRESP #%d - %s", mqtt_GetErrno(), mqtt_GetError());
99: return 0;
100: }
101: if ((siz = send(sess->sess_sock, sess->sess_buf->msg_base, siz, 0)) == -1) {
102: ioSYSERR(0);
103: return 0;
104: } else
105: ioDEBUG(5, "Sended %d bytes.", siz);
1.2.2.1 misho 106:
107: return 0;
108: }
109:
110: int
111: cmdCONNECT(void *srv, void *arg)
112: {
113: struct tagStore *store;
114: struct tagSession *sess = (struct tagSession*) arg;
115:
116: ioTRACE(2);
117:
118: if (!sess)
119: return -1;
120:
1.2.2.6 ! misho 121: ioDEBUG(5, "Exec CONNECT session");
1.2.2.3 misho 122: SESS_LOCK;
1.2.2.1 misho 123: TAILQ_REMOVE(&Sessions, sess, sess_node);
1.2.2.3 misho 124: SESS_UNLOCK;
1.2.2.1 misho 125:
126: if (call.FiniSessPUB)
127: call.FiniSessPUB(&cfg, pub, sess->sess_cid, sess->sess_user, "%");
128:
1.2.2.3 misho 129: SESS_ELEM_LOCK(sess);
1.2.2.6 ! misho 130: while ((store = SLIST_FIRST(&sess->sess_subscr))) {
! 131: SLIST_REMOVE_HEAD(&sess->sess_subscr, st_node);
1.2.2.3 misho 132:
1.2.2.6 ! misho 133: if (store->st_subscr.sub_topic.msg_base)
! 134: free(store->st_subscr.sub_topic.msg_base);
! 135: if (store->st_subscr.sub_value.msg_base)
! 136: free(store->st_subscr.sub_value.msg_base);
! 137:
! 138: free(store);
! 139: }
1.2.2.3 misho 140: SESS_ELEM_UNLOCK(sess);
1.2.2.1 misho 141:
142: if (sess->sess_will.msg)
143: free(sess->sess_will.msg);
144: if (sess->sess_will.topic)
145: free(sess->sess_will.topic);
146:
147: call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid,
148: sess->sess_addr, sess->sess_user);
149: return 0;
150: }
151:
152: int
153: cmdDISCONNECT(void *srv, void *arg)
154: {
155: struct tagSession *sess = (struct tagSession*) arg;
156:
157: ioTRACE(2);
158:
159: if (!sess)
160: return -1;
161:
1.2.2.5 misho 162: ioDEBUG(5, "Exec DISCONNECT session");
1.2.2.3 misho 163: SESS_LOCK;
1.2.2.1 misho 164: TAILQ_REMOVE(&Sessions, sess, sess_node);
1.2.2.3 misho 165: SESS_UNLOCK;
1.2.2.1 misho 166:
167: call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid,
168: sess->sess_addr, sess->sess_user);
169: return 0;
170: }