Merge branch 'develop' of ssh://git.eclipse.org:29418/mosquitto/org.eclipse.mosquitto into develop
Roger A. Light
10 years ago
commit
f6939d4cbb
@ -0,0 +1,29 @@
|
||||
include ../../config.mk
|
||||
|
||||
.PHONY: all
|
||||
|
||||
all : sub_callback sub_single sub_multiple
|
||||
|
||||
sub_callback : callback.o
|
||||
${CROSS_COMPILE}${CC} $^ -o $@ ../../lib/libmosquitto.so.${SOVERSION}
|
||||
|
||||
sub_single : single.o
|
||||
${CROSS_COMPILE}${CC} $^ -o $@ ../../lib/libmosquitto.so.${SOVERSION}
|
||||
|
||||
sub_multiple : multiple.o
|
||||
${CROSS_COMPILE}${CC} $^ -o $@ ../../lib/libmosquitto.so.${SOVERSION}
|
||||
|
||||
callback.o : callback.c ../../lib/libmosquitto.so.${SOVERSION}
|
||||
${CROSS_COMPILE}${CC} -c $< -o $@ -I../../lib ${CFLAGS}
|
||||
|
||||
single.o : single.c ../../lib/libmosquitto.so.${SOVERSION}
|
||||
${CROSS_COMPILE}${CC} -c $< -o $@ -I../../lib ${CFLAGS}
|
||||
|
||||
multiple.o : multiple.c ../../lib/libmosquitto.so.${SOVERSION}
|
||||
${CROSS_COMPILE}${CC} -c $< -o $@ -I../../lib ${CFLAGS}
|
||||
|
||||
../../lib/libmosquitto.so.${SOVERSION} :
|
||||
$(MAKE) -C ../../lib
|
||||
|
||||
clean :
|
||||
-rm -f *.o sub_single sub_multiple
|
||||
@ -0,0 +1,34 @@
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
#include "mosquitto.h"
|
||||
|
||||
int on_message(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *msg)
|
||||
{
|
||||
printf("%s %s (%d)\n", msg->topic, (const char *)msg->payload, msg->payloadlen);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
int main(int argc, char *argv[])
|
||||
{
|
||||
int rc;
|
||||
|
||||
mosquitto_lib_init();
|
||||
|
||||
rc = mosquitto_subscribe_callback(
|
||||
on_message, NULL,
|
||||
"irc/#", 0,
|
||||
"test.mosquitto.org", 1883,
|
||||
NULL, 60, true,
|
||||
NULL, NULL,
|
||||
NULL, NULL);
|
||||
|
||||
if(rc){
|
||||
printf("Error: %s\n", mosquitto_strerror(rc));
|
||||
}
|
||||
|
||||
mosquitto_lib_cleanup();
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
@ -0,0 +1,39 @@
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
#include "mosquitto.h"
|
||||
|
||||
#define COUNT 3
|
||||
|
||||
int main(int argc, char *argv[])
|
||||
{
|
||||
int rc;
|
||||
int i;
|
||||
struct mosquitto_message *msg;
|
||||
|
||||
mosquitto_lib_init();
|
||||
|
||||
rc = mosquitto_subscribe_simple(
|
||||
&msg, COUNT, true,
|
||||
"irc/#", 0,
|
||||
"test.mosquitto.org", 1883,
|
||||
NULL, 60, true,
|
||||
NULL, NULL,
|
||||
NULL, NULL);
|
||||
|
||||
if(rc){
|
||||
printf("Error: %s\n", mosquitto_strerror(rc));
|
||||
mosquitto_lib_cleanup();
|
||||
return rc;
|
||||
}
|
||||
|
||||
for(i=0; i<COUNT; i++){
|
||||
printf("%s %s\n", msg[i].topic, (char *)msg[i].payload);
|
||||
mosquitto_message_free_contents(&msg[i]);
|
||||
}
|
||||
free(msg);
|
||||
|
||||
mosquitto_lib_cleanup();
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
@ -0,0 +1,33 @@
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
#include "mosquitto.h"
|
||||
|
||||
int main(int argc, char *argv[])
|
||||
{
|
||||
int rc;
|
||||
struct mosquitto_message *msg;
|
||||
|
||||
mosquitto_lib_init();
|
||||
|
||||
rc = mosquitto_subscribe_simple(
|
||||
&msg, 1, true,
|
||||
"irc/#", 0,
|
||||
"test.mosquitto.org", 1883,
|
||||
NULL, 60, true,
|
||||
NULL, NULL,
|
||||
NULL, NULL);
|
||||
|
||||
if(rc){
|
||||
printf("Error: %s\n", mosquitto_strerror(rc));
|
||||
mosquitto_lib_cleanup();
|
||||
return rc;
|
||||
}
|
||||
|
||||
printf("%s %s\n", msg->topic, (char *)msg->payload);
|
||||
mosquitto_message_free(&msg);
|
||||
|
||||
mosquitto_lib_cleanup();
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
@ -0,0 +1,223 @@
|
||||
/*
|
||||
Copyright (c) 2016 Roger Light <roger@atchoo.org>
|
||||
|
||||
All rights reserved. This program and the accompanying materials
|
||||
are made available under the terms of the Eclipse Public License v1.0
|
||||
and Eclipse Distribution License v1.0 which accompany this distribution.
|
||||
|
||||
The Eclipse Public License is available at
|
||||
http://www.eclipse.org/legal/epl-v10.html
|
||||
and the Eclipse Distribution License is available at
|
||||
http://www.eclipse.org/org/documents/edl-v10.php.
|
||||
|
||||
Contributors:
|
||||
Roger Light - initial implementation and documentation.
|
||||
*/
|
||||
|
||||
#include <errno.h>
|
||||
#include <stdbool.h>
|
||||
|
||||
#include "mosquitto.h"
|
||||
#include "mosquitto_internal.h"
|
||||
|
||||
struct userdata__callback {
|
||||
const char *topic;
|
||||
int (*callback)(struct mosquitto *, void *, const struct mosquitto_message *);
|
||||
void *userdata;
|
||||
int qos;
|
||||
int rc;
|
||||
};
|
||||
|
||||
struct userdata__simple {
|
||||
struct mosquitto_message *messages;
|
||||
int max_msg_count;
|
||||
int message_count;
|
||||
bool want_retained;
|
||||
};
|
||||
|
||||
|
||||
static void on_connect(struct mosquitto *mosq, void *obj, int rc)
|
||||
{
|
||||
struct userdata__callback *userdata = obj;
|
||||
|
||||
mosquitto_subscribe(mosq, NULL, userdata->topic, userdata->qos);
|
||||
}
|
||||
|
||||
|
||||
static void on_message_callback(struct mosquitto *mosq, void *obj, const struct mosquitto_message *message)
|
||||
{
|
||||
int rc;
|
||||
struct userdata__callback *userdata = obj;
|
||||
|
||||
rc = userdata->callback(mosq, userdata->userdata, message);
|
||||
if(rc){
|
||||
mosquitto_disconnect(mosq);
|
||||
}
|
||||
}
|
||||
|
||||
static int on_message_simple(struct mosquitto *mosq, void *obj, const struct mosquitto_message *message)
|
||||
{
|
||||
struct userdata__simple *userdata = obj;
|
||||
int rc;
|
||||
|
||||
if(userdata->max_msg_count == 0){
|
||||
return 0;
|
||||
}
|
||||
|
||||
/* Don't process stale retained messages if 'want_retained' was false */
|
||||
if(!userdata->want_retained && message->retain){
|
||||
return 0;
|
||||
}
|
||||
|
||||
userdata->max_msg_count--;
|
||||
|
||||
rc = mosquitto_message_copy(&userdata->messages[userdata->message_count], message);
|
||||
if(rc){
|
||||
return rc;
|
||||
}
|
||||
userdata->message_count++;
|
||||
if(userdata->max_msg_count == 0){
|
||||
mosquitto_disconnect(mosq);
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
libmosq_EXPORT int mosquitto_subscribe_simple(
|
||||
struct mosquitto_message **messages,
|
||||
int msg_count,
|
||||
bool want_retained,
|
||||
const char *topic,
|
||||
int qos,
|
||||
const char *host,
|
||||
int port,
|
||||
const char *client_id,
|
||||
int keepalive,
|
||||
bool clean_session,
|
||||
const char *username,
|
||||
const char *password,
|
||||
const struct libmosquitto_will *will,
|
||||
const struct libmosquitto_tls *tls)
|
||||
{
|
||||
struct userdata__simple userdata;
|
||||
int rc;
|
||||
int i;
|
||||
|
||||
if(!topic || msg_count < 1 || !messages){
|
||||
return MOSQ_ERR_INVAL;
|
||||
}
|
||||
|
||||
*messages = NULL;
|
||||
|
||||
userdata.messages = calloc(sizeof(struct mosquitto_message), msg_count);
|
||||
if(!userdata.messages){
|
||||
return MOSQ_ERR_NOMEM;
|
||||
}
|
||||
userdata.message_count = 0;
|
||||
userdata.max_msg_count = msg_count;
|
||||
userdata.want_retained = want_retained;
|
||||
|
||||
rc = mosquitto_subscribe_callback(
|
||||
on_message_simple, &userdata,
|
||||
topic, qos,
|
||||
host, port,
|
||||
client_id, keepalive, clean_session,
|
||||
username, password,
|
||||
will, tls);
|
||||
|
||||
if(!rc && userdata.max_msg_count == 0){
|
||||
*messages = userdata.messages;
|
||||
return MOSQ_ERR_SUCCESS;
|
||||
}else{
|
||||
for(i=0; i<msg_count; i++){
|
||||
mosquitto_message_free_contents(&userdata.messages[i]);
|
||||
}
|
||||
free(userdata.messages);
|
||||
userdata.messages = NULL;
|
||||
return rc;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
libmosq_EXPORT int mosquitto_subscribe_callback(
|
||||
int (*callback)(struct mosquitto *, void *, const struct mosquitto_message *),
|
||||
void *userdata,
|
||||
const char *topic,
|
||||
int qos,
|
||||
const char *host,
|
||||
int port,
|
||||
const char *client_id,
|
||||
int keepalive,
|
||||
bool clean_session,
|
||||
const char *username,
|
||||
const char *password,
|
||||
const struct libmosquitto_will *will,
|
||||
const struct libmosquitto_tls *tls)
|
||||
{
|
||||
struct mosquitto *mosq;
|
||||
struct userdata__callback cb_userdata;
|
||||
int rc;
|
||||
|
||||
if(!callback || !topic){
|
||||
return MOSQ_ERR_INVAL;
|
||||
}
|
||||
|
||||
cb_userdata.topic = topic;
|
||||
cb_userdata.qos = qos;
|
||||
cb_userdata.rc = 0;
|
||||
cb_userdata.userdata = userdata;
|
||||
cb_userdata.callback = callback;
|
||||
|
||||
mosq = mosquitto_new(client_id, clean_session, &cb_userdata);
|
||||
if(!mosq){
|
||||
return MOSQ_ERR_NOMEM;
|
||||
}
|
||||
|
||||
if(will){
|
||||
rc = mosquitto_will_set(mosq, will->topic, will->payloadlen, will->payload, will->qos, will->retain);
|
||||
if(rc){
|
||||
mosquitto_destroy(mosq);
|
||||
return rc;
|
||||
}
|
||||
}
|
||||
if(username){
|
||||
rc = mosquitto_username_pw_set(mosq, username, password);
|
||||
if(rc){
|
||||
mosquitto_destroy(mosq);
|
||||
return rc;
|
||||
}
|
||||
}
|
||||
if(tls){
|
||||
rc = mosquitto_tls_set(mosq, tls->cafile, tls->capath, tls->certfile, tls->keyfile, tls->pw_callback);
|
||||
if(rc){
|
||||
mosquitto_destroy(mosq);
|
||||
return rc;
|
||||
}
|
||||
rc = mosquitto_tls_opts_set(mosq, tls->cert_reqs, tls->tls_version, tls->ciphers);
|
||||
if(rc){
|
||||
mosquitto_destroy(mosq);
|
||||
return rc;
|
||||
}
|
||||
}
|
||||
|
||||
mosquitto_connect_callback_set(mosq, on_connect);
|
||||
mosquitto_message_callback_set(mosq, on_message_callback);
|
||||
|
||||
rc = mosquitto_connect(mosq, host, port, keepalive);
|
||||
if(rc){
|
||||
mosquitto_destroy(mosq);
|
||||
return rc;
|
||||
}
|
||||
rc = mosquitto_loop_forever(mosq, -1, 1);
|
||||
mosquitto_destroy(mosq);
|
||||
if(cb_userdata.rc){
|
||||
rc = cb_userdata.rc;
|
||||
}
|
||||
//if(!rc && cb_userdata.max_msg_count == 0){
|
||||
//return MOSQ_ERR_SUCCESS;
|
||||
//}else{
|
||||
//return rc;
|
||||
//}
|
||||
return MOSQ_ERR_SUCCESS;
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue