You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
136 lines
2.1 KiB
136 lines
2.1 KiB
#include "kernel.h"
|
|
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#include <fcntl.h>
|
|
#include <unistd.h>
|
|
#include <glib.h>
|
|
#include <errno.h>
|
|
|
|
#include "xt_MEDIAPROXY.h"
|
|
|
|
#include "aux.h"
|
|
#include "log.h"
|
|
|
|
|
|
|
|
|
|
#if 1
|
|
#define PREFIX "/proc/mediaproxy"
|
|
#else
|
|
#define PREFIX "/tmp/mediaproxy"
|
|
#endif
|
|
|
|
|
|
|
|
|
|
|
|
int kernel_create_table(unsigned int id) {
|
|
char str[64];
|
|
int fd;
|
|
int i;
|
|
|
|
fd = open(PREFIX "/control", O_WRONLY | O_TRUNC);
|
|
if (fd == -1)
|
|
return -1;
|
|
sprintf(str, "add %u\n", id);
|
|
i = write(fd, str, strlen(str));
|
|
if (i == -1)
|
|
goto fail;
|
|
close(fd);
|
|
|
|
return 0;
|
|
|
|
fail:
|
|
close(fd);
|
|
return -1;
|
|
}
|
|
|
|
|
|
int kernel_open_table(unsigned int id) {
|
|
char str[64];
|
|
int fd;
|
|
struct mediaproxy_message msg;
|
|
int i;
|
|
|
|
sprintf(str, PREFIX "/%u/control", id);
|
|
fd = open(str, O_WRONLY | O_TRUNC);
|
|
if (fd == -1)
|
|
return -1;
|
|
|
|
ZERO(msg);
|
|
msg.cmd = MMG_NOOP;
|
|
i = write(fd, &msg, sizeof(msg));
|
|
if (i <= 0)
|
|
goto fail;
|
|
|
|
return fd;
|
|
|
|
fail:
|
|
close(fd);
|
|
return -1;
|
|
}
|
|
|
|
|
|
int kernel_add_stream(int fd, struct mediaproxy_target_info *mti, int update) {
|
|
struct mediaproxy_message msg;
|
|
int ret;
|
|
|
|
msg.cmd = update ? MMG_UPDATE : MMG_ADD;
|
|
msg.target = *mti;
|
|
|
|
ret = write(fd, &msg, sizeof(msg));
|
|
if (ret > 0)
|
|
return 0;
|
|
|
|
mylog(LOG_ERROR, "Failed to push relay stream to kernel: %s", strerror(errno));
|
|
return -1;
|
|
}
|
|
|
|
|
|
int kernel_del_stream(int fd, u_int16_t p) {
|
|
struct mediaproxy_message msg;
|
|
int ret;
|
|
|
|
ZERO(msg);
|
|
msg.cmd = MMG_DEL;
|
|
msg.target.target_port = p;
|
|
|
|
ret = write(fd, &msg, sizeof(msg));
|
|
if (ret > 0)
|
|
return 0;
|
|
|
|
mylog(LOG_ERROR, "Failed to delete relay stream from kernel: %s", strerror(errno));
|
|
return -1;
|
|
}
|
|
|
|
|
|
GList *kernel_list(unsigned int id) {
|
|
char str[64];
|
|
int fd;
|
|
struct mediaproxy_list_entry *buf;
|
|
GList *li = NULL;
|
|
int ret;
|
|
|
|
sprintf(str, PREFIX "/%u/blist", id);
|
|
fd = open(str, O_RDONLY);
|
|
if (fd == -1)
|
|
return NULL;
|
|
|
|
|
|
for (;;) {
|
|
buf = g_slice_alloc(sizeof(*buf));
|
|
ret = read(fd, buf, sizeof(*buf));
|
|
if (ret != sizeof(*buf))
|
|
break;
|
|
li = g_list_prepend(li, buf);
|
|
}
|
|
|
|
g_slice_free1(sizeof(*buf), buf);
|
|
close(fd);
|
|
|
|
return li;
|
|
}
|