1 | /*
|
2 | Copyright (c) 2009-2013 Roger Light <roger@atchoo.org>
|
3 | All rights reserved.
|
4 |
|
5 | Redistribution and use in source and binary forms, with or without
|
6 | modification, are permitted provided that the following conditions are met:
|
7 |
|
8 | 1. Redistributions of source code must retain the above copyright notice,
|
9 | this list of conditions and the following disclaimer.
|
10 | 2. Redistributions in binary form must reproduce the above copyright
|
11 | notice, this list of conditions and the following disclaimer in the
|
12 | documentation and/or other materials provided with the distribution.
|
13 | 3. Neither the name of mosquitto nor the names of its
|
14 | contributors may be used to endorse or promote products derived from
|
15 | this software without specific prior written permission.
|
16 |
|
17 | THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
18 | AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
19 | IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
20 | ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
|
21 | LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
|
22 | CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
23 | SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
24 | INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
|
25 | CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
|
26 | ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
|
27 | POSSIBILITY OF SUCH DAMAGE.
|
28 | */
|
29 |
|
30 |
|
31 |
|
32 |
|
33 |
|
34 |
|
35 |
|
36 |
|
37 |
|
38 | int _mosquitto_handle_connack(struct mosquitto *mosq)
|
39 | {
|
40 | uint8_t byte;
|
41 | uint8_t result;
|
42 | int rc;
|
43 |
|
44 | assert(mosq);
|
45 |
|
46 | if(mosq->in_packet.remaining_length != 2){
|
47 | return MOSQ_ERR_PROTOCOL;
|
48 | }
|
49 |
|
50 | _mosquitto_log_printf(mosq, MOSQ_LOG_DEBUG, "Client %s received CONNACK", mosq->id);
|
51 | rc = _mosquitto_read_byte(&mosq->in_packet, &byte); // Reserved byte, not used
|
52 | if(rc) return rc;
|
53 | rc = _mosquitto_read_byte(&mosq->in_packet, &result);
|
54 | if(rc) return rc;
|
55 | pthread_mutex_lock(&mosq->callback_mutex);
|
56 | if(mosq->on_connect){
|
57 | mosq->in_callback = true;
|
58 | mosq->on_connect(mosq, mosq->userdata, result);
|
59 | mosq->in_callback = false;
|
60 | }
|
61 | pthread_mutex_unlock(&mosq->callback_mutex);
|
62 | switch(result){
|
63 | case 0:
|
64 | mosq->state = mosq_cs_connected;
|
65 | return MOSQ_ERR_SUCCESS;
|
66 | case 1:
|
67 | case 2:
|
68 | case 3:
|
69 | case 4:
|
70 | case 5:
|
71 | return MOSQ_ERR_CONN_REFUSED;
|
72 | default:
|
73 | return MOSQ_ERR_PROTOCOL;
|
74 | }
|
75 | }
|
76 |
|