|
|
| version 1.1.2.6, 2012/05/08 11:45:57 | version 1.2.2.1, 2012/07/03 12:22:56 |
|---|---|
| Line 1 | Line 1 |
| /************************************************************************* | |
| * (C) 2011 AITNET ltd - Sofia/Bulgaria - <misho@aitbg.com> | |
| * by Michael Pounov <misho@openbsd-bg.org> | |
| * | |
| * $Author$ | |
| * $Id$ | |
| * | |
| ************************************************************************** | |
| The ELWIX and AITNET software is distributed under the following | |
| terms: | |
| All of the documentation and software included in the ELWIX and AITNET | |
| Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> | |
| Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012 | |
| by Michael Pounov <misho@elwix.org>. All rights reserved. | |
| Redistribution and use in source and binary forms, with or without | |
| modification, are permitted provided that the following conditions | |
| are met: | |
| 1. Redistributions of source code must retain the above copyright | |
| notice, this list of conditions and the following disclaimer. | |
| 2. Redistributions in binary form must reproduce the above copyright | |
| notice, this list of conditions and the following disclaimer in the | |
| documentation and/or other materials provided with the distribution. | |
| 3. All advertising materials mentioning features or use of this software | |
| must display the following acknowledgement: | |
| This product includes software developed by Michael Pounov <misho@elwix.org> | |
| ELWIX - Embedded LightWeight unIX and its contributors. | |
| 4. Neither the name of AITNET nor the names of its contributors | |
| may be used to endorse or promote products derived from this software | |
| without specific prior written permission. | |
| THIS SOFTWARE IS PROVIDED BY AITNET AND CONTRIBUTORS ``AS IS'' AND | |
| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |
| IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE | |
| ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE | |
| FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL | |
| DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS | |
| OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) | |
| HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT | |
| LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY | |
| OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF | |
| SUCH DAMAGE. | |
| */ | |
| #include "global.h" | #include "global.h" |
| #include "mqtt.h" | #include "mqtt.h" |
| #include "client.h" | #include "client.h" |
| Line 69 main(int argc, char **argv) | Line 114 main(int argc, char **argv) |
| register int i; | register int i; |
| struct timeval accu; | struct timeval accu; |
| if (!(args = malloc(sizeof(struct tagArgs)))) { | if (!(args = io_malloc(sizeof(struct tagArgs)))) { |
| printf("Error:: in alloc arguments #%d - %s\n", errno, strerror(errno)); | printf("Error:: in alloc arguments #%d - %s\n", errno, strerror(errno)); |
| return 1; | return 1; |
| } else | } else |
| Line 79 main(int argc, char **argv) | Line 124 main(int argc, char **argv) |
| if (!(args->msg = mqtt_msgAlloc(USHRT_MAX))) { | if (!(args->msg = mqtt_msgAlloc(USHRT_MAX))) { |
| printf("Error:: in mqtt buffer #%d - %s\n", mqtt_GetErrno(), mqtt_GetError()); | printf("Error:: in mqtt buffer #%d - %s\n", mqtt_GetErrno(), mqtt_GetError()); |
| args->free(args); | args->free(args); |
| free(args); | io_free(args); |
| return 1; | return 1; |
| } | } |
| Line 113 main(int argc, char **argv) | Line 158 main(int argc, char **argv) |
| case 'h': | case 'h': |
| default: | default: |
| args->free(args); | args->free(args); |
| free(args); | io_free(args); |
| Usage(); | Usage(); |
| return 1; | return 1; |
| } | } |
| Line 122 main(int argc, char **argv) | Line 167 main(int argc, char **argv) |
| if (argc < 2) { | if (argc < 2) { |
| printf("Error:: host for connect not found or connection id!\n\n"); | printf("Error:: host for connect not found or connection id!\n\n"); |
| args->free(args); | args->free(args); |
| free(args); | io_free(args); |
| Usage(); | Usage(); |
| return 1; | return 1; |
| } else { | } else { |
| Line 132 main(int argc, char **argv) | Line 177 main(int argc, char **argv) |
| if (!io_gethostbyname(*argv, port, &args->addr)) { | if (!io_gethostbyname(*argv, port, &args->addr)) { |
| printf("Error:: host not valid #%d - %s\n", io_GetErrno(), io_GetError()); | printf("Error:: host not valid #%d - %s\n", io_GetErrno(), io_GetError()); |
| args->free(args); | args->free(args); |
| free(args); | io_free(args); |
| Usage(); | Usage(); |
| return 1; | return 1; |
| } | } |
| Line 141 main(int argc, char **argv) | Line 186 main(int argc, char **argv) |
| if (!(args->cli = mqtt_cli_Open(&args->addr.sa, args->ka))) { | if (!(args->cli = mqtt_cli_Open(&args->addr.sa, args->ka))) { |
| args->free(args); | args->free(args); |
| free(args); | io_free(args); |
| return 2; | return 2; |
| } | } |
| Line 184 main(int argc, char **argv) | Line 229 main(int argc, char **argv) |
| mqtt_cli_Close(&args->cli); | mqtt_cli_Close(&args->cli); |
| args->free(args); | args->free(args); |
| free(args); | io_free(args); |
| return ret; | return ret; |
| } | } |