mirror of https://github.com/schoebel/mars
119 lines
2.4 KiB
C
119 lines
2.4 KiB
C
// (c) 2011 Thomas Schoebel-Theuer / 1&1 Internet AG
|
|
|
|
//#define BRICK_DEBUGGING
|
|
//#define MARS_DEBUGGING
|
|
//#define IO_DEBUGGING
|
|
|
|
#include <linux/kernel.h>
|
|
#include <linux/module.h>
|
|
#include <linux/string.h>
|
|
|
|
#include "strategy.h"
|
|
#include "../mars_net.h"
|
|
|
|
static
|
|
char *_mars_translate_hostname(const char *name)
|
|
{
|
|
struct mars_global *global = mars_global;
|
|
char *res = brick_strdup(name);
|
|
struct mars_dent *test;
|
|
char *tmp;
|
|
|
|
if (unlikely(!global)) {
|
|
goto done;
|
|
}
|
|
|
|
for (tmp = res; *tmp; tmp++) {
|
|
if (*tmp == ':') {
|
|
*tmp = '\0';
|
|
break;
|
|
}
|
|
}
|
|
|
|
tmp = path_make("/mars/ips/ip-%s", res);
|
|
if (unlikely(!tmp)) {
|
|
goto done;
|
|
}
|
|
|
|
test = mars_find_dent(global, tmp);
|
|
if (test && test->new_link) {
|
|
MARS_DBG("'%s' => '%s'\n", tmp, test->new_link);
|
|
brick_string_free(res);
|
|
res = brick_strdup(test->new_link);
|
|
} else {
|
|
MARS_DBG("no translation for '%s'\n", tmp);
|
|
}
|
|
brick_string_free(tmp);
|
|
|
|
done:
|
|
return res;
|
|
}
|
|
|
|
int mars_send_dent_list(struct mars_socket *sock, struct list_head *anchor)
|
|
{
|
|
struct list_head *tmp;
|
|
struct mars_dent *dent;
|
|
int status = 0;
|
|
for (tmp = anchor->next; tmp != anchor; tmp = tmp->next) {
|
|
dent = container_of(tmp, struct mars_dent, dent_link);
|
|
status = mars_send_struct(sock, dent, mars_dent_meta);
|
|
if (status < 0)
|
|
break;
|
|
}
|
|
if (status >= 0) { // send EOR
|
|
status = mars_send_struct(sock, NULL, mars_dent_meta);
|
|
}
|
|
return status;
|
|
}
|
|
EXPORT_SYMBOL_GPL(mars_send_dent_list);
|
|
|
|
int mars_recv_dent_list(struct mars_socket *sock, struct list_head *anchor)
|
|
{
|
|
int status;
|
|
for (;;) {
|
|
struct mars_dent *dent = brick_zmem_alloc(sizeof(struct mars_dent));
|
|
if (!dent)
|
|
return -ENOMEM;
|
|
|
|
//MARS_IO("\n");
|
|
|
|
INIT_LIST_HEAD(&dent->dent_link);
|
|
INIT_LIST_HEAD(&dent->brick_list);
|
|
|
|
status = mars_recv_struct(sock, dent, mars_dent_meta);
|
|
if (status <= 0) {
|
|
mars_free_dent(dent);
|
|
goto done;
|
|
}
|
|
list_add_tail(&dent->dent_link, anchor);
|
|
}
|
|
done:
|
|
return status;
|
|
}
|
|
EXPORT_SYMBOL_GPL(mars_recv_dent_list);
|
|
|
|
|
|
////////////////// module init stuff /////////////////////////
|
|
|
|
|
|
int __init init_sy_net(void)
|
|
{
|
|
MARS_INF("init_sy_net()\n");
|
|
mars_translate_hostname = _mars_translate_hostname;
|
|
return 0;
|
|
}
|
|
|
|
void __exit exit_sy_net(void)
|
|
{
|
|
MARS_INF("exit_sy_net()\n");
|
|
}
|
|
|
|
#ifndef CONFIG_MARS_HAVE_BIGMODULE
|
|
MODULE_DESCRIPTION("MARS network infrastructure");
|
|
MODULE_AUTHOR("Thomas Schoebel-Theuer <tst@1und1.de>");
|
|
MODULE_LICENSE("GPL");
|
|
|
|
module_init(init_sy_net);
|
|
module_exit(exit_sy_net);
|
|
#endif
|