Implement protocol module loading
This commit is contained in:
parent
8a8800c818
commit
cdf537c71c
5 changed files with 108 additions and 10 deletions
|
@ -58,6 +58,11 @@ size_t gmrf_iface_get_mtu(gmrf_context_t *ctx, gmrf_iface_t *iface);
|
|||
bool gmrf_iface_send(gmrf_context_t *ctx, gmrf_iface_t *iface, const void *data, size_t len, const gmrf_addr_t *dest);
|
||||
bool gmrf_iface_send_bc(gmrf_context_t *ctx, gmrf_iface_t *iface, const void *data, size_t len);
|
||||
|
||||
|
||||
typedef void (*gmrf_handle_packet_func)(gmrf_context_t *ctx, gmrf_iface_t *iface, const gmrf_addr_t *source, const void *data, size_t len);
|
||||
|
||||
typedef struct gmrf_protocol {
|
||||
gmrf_handle_packet_func handle_packet;
|
||||
} gmrf_protocol_t;
|
||||
|
||||
#endif /* _GMRF_GMRF_H_ */
|
||||
|
|
40
include/mmss/protocol.h
Normal file
40
include/mmss/protocol.h
Normal file
|
@ -0,0 +1,40 @@
|
|||
/*
|
||||
Copyright (c) 2013, Matthias Schiffer <mschiffer@universe-factory.net>
|
||||
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.
|
||||
|
||||
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS 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 COPYRIGHT HOLDER 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.
|
||||
*/
|
||||
|
||||
|
||||
#ifndef _GMRF_MMSS_PROTOCOL_H_
|
||||
#define _GMRF_MMSS_PROTOCOL_H_
|
||||
|
||||
#include <gmrf/gmrf.h>
|
||||
|
||||
|
||||
typedef struct mmss_protocol {
|
||||
const char *name;
|
||||
const char *version;
|
||||
|
||||
gmrf_protocol_t* (*init)(gmrf_context_t *ctx);
|
||||
} mmss_protocol_t;
|
||||
|
||||
#endif /* _GMRF_MMSS_PROTOCOL_H_ */
|
|
@ -3,6 +3,7 @@ include_directories(${GMRF_SOURCE_DIR}/include)
|
|||
add_executable(mmss
|
||||
iface.c
|
||||
mmss.c
|
||||
protocol.c
|
||||
queue.c
|
||||
)
|
||||
target_link_libraries(mmss rt)
|
||||
target_link_libraries(mmss dl)
|
||||
|
|
21
mmss/mmss.h
21
mmss/mmss.h
|
@ -28,6 +28,7 @@
|
|||
#define _GMRF_MMSS_MMSS_H_
|
||||
|
||||
#include <gmrf/gmrf.h>
|
||||
#include <mmss/protocol.h>
|
||||
|
||||
#include "queue.h"
|
||||
|
||||
|
@ -37,15 +38,6 @@ struct mmss_context {
|
|||
mmss_queue_t packet_queue;
|
||||
};
|
||||
|
||||
struct gmrf_context {
|
||||
gmrf_context_t *next;
|
||||
|
||||
mmss_context_t *mmss;
|
||||
gmrf_iface_t *interfaces;
|
||||
|
||||
gmrf_handle_packet_func handle_packet;
|
||||
};
|
||||
|
||||
struct mmss_network {
|
||||
mmss_network_t *next;
|
||||
|
||||
|
@ -65,6 +57,15 @@ struct mmss_packet {
|
|||
};
|
||||
|
||||
|
||||
struct gmrf_context {
|
||||
gmrf_context_t *next;
|
||||
|
||||
mmss_context_t *mmss;
|
||||
gmrf_iface_t *interfaces;
|
||||
|
||||
gmrf_handle_packet_func handle_packet;
|
||||
};
|
||||
|
||||
struct gmrf_iface {
|
||||
gmrf_iface_t *node_next;
|
||||
gmrf_iface_t *network_next;
|
||||
|
@ -76,4 +77,6 @@ struct gmrf_iface {
|
|||
};
|
||||
|
||||
|
||||
const mmss_protocol_t* mmss_load_protocol(const char *module);
|
||||
|
||||
#endif /* _GMRF_MMSS_MMSS_H_ */
|
||||
|
|
49
mmss/protocol.c
Normal file
49
mmss/protocol.c
Normal file
|
@ -0,0 +1,49 @@
|
|||
/*
|
||||
Copyright (c) 2013, Matthias Schiffer <mschiffer@universe-factory.net>
|
||||
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.
|
||||
|
||||
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS 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 COPYRIGHT HOLDER 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 "mmss.h"
|
||||
|
||||
#include <dlfcn.h>
|
||||
#include <stdio.h>
|
||||
|
||||
|
||||
const mmss_protocol_t* mmss_load_protocol(const char *module) {
|
||||
void *handle = dlopen(module, RTLD_NOW);
|
||||
if (!handle) {
|
||||
fprintf(stderr, "unable to load protocol from `%s': %s\n", module, dlerror());
|
||||
return NULL;
|
||||
}
|
||||
|
||||
dlerror();
|
||||
const mmss_protocol_t *proto = dlsym(handle, "mmss_protocol_info");
|
||||
if (!proto) {
|
||||
fprintf(stderr, "unable to load protocol from `%s': %s\n", module, dlerror());
|
||||
dlclose(handle);
|
||||
return NULL;
|
||||
}
|
||||
|
||||
return proto;
|
||||
}
|
Reference in a new issue