Lines Matching refs:context
39 unsigned short Cloud_CoAPMessageId_gen(Cloud_CoAPContext *context) in Cloud_CoAPMessageId_gen() argument
43 ((COAP_MAX_MESSAGE_ID == context->message_id) ? 1 in Cloud_CoAPMessageId_gen()
44 : context->message_id++); in Cloud_CoAPMessageId_gen()
58 static int Cloud_CoAPMessageList_add(Cloud_CoAPContext *context, in Cloud_CoAPMessageList_add() argument
83 memcpy(node->message, context->sendbuf, len); in Cloud_CoAPMessageList_add()
86 if (&context->list.count >= &context->list.maxcount) { in Cloud_CoAPMessageList_add()
90 list_add_tail(&node->sendlist, &context->list.sendlist); in Cloud_CoAPMessageList_add()
91 context->list.count++; in Cloud_CoAPMessageList_add()
99 int Cloud_CoAPMessage_send(Cloud_CoAPContext *context, in Cloud_CoAPMessage_send() argument
105 if (NULL == message || NULL == context) { in Cloud_CoAPMessage_send()
117 memset(context->sendbuf, 0x00, COAP_MSG_MAX_PDU_LEN); in Cloud_CoAPMessage_send()
119 CoAPSerialize_Message(message, context->sendbuf, COAP_MSG_MAX_PDU_LEN); in Cloud_CoAPMessage_send()
122 ret = Cloud_CoAPNetwork_write(&context->network, context->sendbuf, in Cloud_CoAPMessage_send()
129 Cloud_CoAPMessageList_add(context, message, msglen); in Cloud_CoAPMessage_send()
140 static int Cloud_CoAPAckMessage_handle(Cloud_CoAPContext *context, in Cloud_CoAPAckMessage_handle() argument
145 list_for_each_entry(node, &context->list.sendlist, sendlist, in Cloud_CoAPAckMessage_handle()
157 static int Cloud_CoAPAckMessage_send(Cloud_CoAPContext *context, in Cloud_CoAPAckMessage_send() argument
163 return Cloud_CoAPMessage_send(context, &message); in Cloud_CoAPAckMessage_send()
166 static int Cloud_CoAPRespMessage_handle(Cloud_CoAPContext *context, in Cloud_CoAPRespMessage_handle() argument
172 Cloud_CoAPAckMessage_send(context, message->header.msgid); in Cloud_CoAPRespMessage_handle()
175 list_for_each_entry(node, &context->list.sendlist, sendlist, in Cloud_CoAPRespMessage_handle()
190 if (NULL != context->notifier) { in Cloud_CoAPRespMessage_handle()
200 context->list.count--; in Cloud_CoAPRespMessage_handle()
212 static void Cloud_CoAPMessage_handle(Cloud_CoAPContext *context, in Cloud_CoAPMessage_handle() argument
236 if (NULL != context->notifier) { in Cloud_CoAPMessage_handle()
244 Cloud_CoAPAckMessage_handle(context, &message); in Cloud_CoAPMessage_handle()
248 Cloud_CoAPRespMessage_handle(context, &message); in Cloud_CoAPMessage_handle()
252 int Cloud_CoAPMessage_recv(Cloud_CoAPContext *context, unsigned int timeout, in Cloud_CoAPMessage_recv() argument
259 len = Cloud_CoAPNetwork_read(&context->network, context->recvbuf, in Cloud_CoAPMessage_recv()
263 Cloud_CoAPMessage_handle(context, context->recvbuf, len); in Cloud_CoAPMessage_recv()
266 Cloud_CoAPMessage_handle(context, context->recvbuf, len); in Cloud_CoAPMessage_recv()
277 int Cloud_CoAPMessage_cycle(Cloud_CoAPContext *context) in Cloud_CoAPMessage_cycle() argument
281 Cloud_CoAPMessage_recv(context, context->waittime, 0); in Cloud_CoAPMessage_cycle()
283 list_for_each_entry_safe(node, next, &context->list.sendlist, sendlist, in Cloud_CoAPMessage_cycle()
295 ret = Cloud_CoAPNetwork_write(&context->network, in Cloud_CoAPMessage_cycle()
298 if (NULL != context->notifier) { in Cloud_CoAPMessage_cycle()
307 if (NULL != context->notifier) { in Cloud_CoAPMessage_cycle()
314 context->list.count--; in Cloud_CoAPMessage_cycle()
317 node->msgid, context->list.count); in Cloud_CoAPMessage_cycle()