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_log_printf(struct mosquitto *mosq, int priority, const char *fmt, ...)
|
39 | {
|
40 | va_list va;
|
41 | char *s;
|
42 | int len;
|
43 |
|
44 | assert(mosq);
|
45 | assert(fmt);
|
46 |
|
47 | pthread_mutex_lock(&mosq->log_callback_mutex);
|
48 | if(mosq->on_log){
|
49 | len = strlen(fmt) + 500;
|
50 | s = _mosquitto_malloc(len*sizeof(char));
|
51 | if(!s){
|
52 | pthread_mutex_unlock(&mosq->log_callback_mutex);
|
53 | return MOSQ_ERR_NOMEM;
|
54 | }
|
55 |
|
56 | va_start(va, fmt);
|
57 | vsnprintf(s, len, fmt, va);
|
58 | va_end(va);
|
59 | s[len-1] = '\0'; /* Ensure string is null terminated. */
|
60 |
|
61 | mosq->on_log(mosq, mosq->userdata, priority, s);
|
62 |
|
63 | _mosquitto_free(s);
|
64 | }
|
65 | pthread_mutex_unlock(&mosq->log_callback_mutex);
|
66 |
|
67 | return MOSQ_ERR_SUCCESS;
|
68 | }
|
69 |
|