From 10b377468b0a4bd2230cd203fa1745163ad39f96 Mon Sep 17 00:00:00 2001 From: ZoRo Date: Sat, 22 Aug 2020 23:13:49 +0100 Subject: Initial commit --- Makefile | 9 +++++ daemon.sh | 46 +++++++++++++++++++++++ mqueue_create.c | 95 +++++++++++++++++++++++++++++++++++++++++++++++ mqueue_info.c | 103 +++++++++++++++++++++++++++++++++++++++++++++++++++ mqueue_pop.c | 113 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ mqueue_push.c | 110 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ mqueue_remove.c | 85 ++++++++++++++++++++++++++++++++++++++++++ send_command.sh | 15 ++++++++ 8 files changed, 576 insertions(+) create mode 100644 Makefile create mode 100755 daemon.sh create mode 100644 mqueue_create.c create mode 100644 mqueue_info.c create mode 100644 mqueue_pop.c create mode 100644 mqueue_push.c create mode 100644 mqueue_remove.c create mode 100755 send_command.sh diff --git a/Makefile b/Makefile new file mode 100644 index 0000000..85eeee7 --- /dev/null +++ b/Makefile @@ -0,0 +1,9 @@ +make: + gcc mqueue_create.c -o mqueue_create -lrt + gcc mqueue_pop.c -o mqueue_pop -lrt + gcc mqueue_push.c -o mqueue_push -lrt + gcc mqueue_remove.c -o mqueue_remove -lrt + gcc mqueue_info.c -o mqueue_info -lrt + +clean: + rm -f mqueue_create mqueue_pop mqueue_push mqueue_remove mqueue_info \ No newline at end of file diff --git a/daemon.sh b/daemon.sh new file mode 100755 index 0000000..5d0784b --- /dev/null +++ b/daemon.sh @@ -0,0 +1,46 @@ +#!/bin/sh + + +QUEUE_NAME=/music-player-daemon + +POP_CMD() +{ + ./mqueue_pop -m $QUEUE_NAME +} + +CREATE_QUEUE() +{ + ./mqueue_create -m $QUEUE_NAME +} + +REMOVE_QUEUE() +{ + ./mqueue_remove -m $QUEUE_NAME +} + + + +if [ ! -f "/dev/mqueue$QUEUE_NAME" ]; then + CREATE_QUEUE +fi + +state="1" +while [ $state -ne 0 ]; do + get_cmd=$(POP_CMD) + case "$get_cmd" in + stop) + state="0" + ;; + ls) + ls /dev + ;; + aloha) + echo "aloha" + ;; + esac + sleep 1 +done + +if [ -f "/dev/mqueue$QUEUE_NAME" ]; then + REMOVE_QUEUE +fi diff --git a/mqueue_create.c b/mqueue_create.c new file mode 100644 index 0000000..492e796 --- /dev/null +++ b/mqueue_create.c @@ -0,0 +1,95 @@ +#include +#include +#include +#include +#include +#include +#include + +typedef struct { + char *f_mqname; + int f_verbose; + int f_helper; +} mqueue_params; + +mqueue_params g_params; + +void helper(char *progname) +{ + printf("Usage: %s [OPTS]\n\n" + "Version: 0.0.1 \n" + "-m mqueue name\n" + "-v verbose output\n" + "-h help options\n" + "\n" + , progname); +} + +#define full_mqpath_len 1024 + + +int main(int argc, char **argv) +{ + //stack params + int c,err; + int i; + int mq_fd; + char full_mqpath[full_mqpath_len]; + + + memset(&g_params,0,sizeof(g_params)); + + //process arguments + while ((c = getopt(argc, argv, "m:vh")) != -1) + { + switch (c) + { + case 'm': + g_params.f_mqname = optarg; + break; + case 'v': + g_params.f_verbose = 1; + break; + case 'h': + default: + helper(argv[0]); + exit(1); + } + } + + if (g_params.f_helper) + { + helper(argv[0]); + return 0; + } + + //set mqueue name + if (g_params.f_mqname == NULL) + { + g_params.f_mqname = "/stack-0"; + } + + //compose string + memset(&full_mqpath[0], 0, full_mqpath_len); + snprintf(&full_mqpath[0], full_mqpath_len-1, "%s", g_params.f_mqname); + if (g_params.f_verbose) + { + printf("Full path: %s\n",&full_mqpath); + } + + mq_fd = mq_open(g_params.f_mqname,O_RDWR | O_CREAT, 0666, NULL); + err = errno; + if (mq_fd == -1) + { + if (g_params.f_verbose) + { + printf("ERROR:%d,%s\n",err,strerror(err)); + } + return -1; + } + printf("%s\n",g_params.f_mqname); + + close(mq_fd); + + return 0; +} \ No newline at end of file diff --git a/mqueue_info.c b/mqueue_info.c new file mode 100644 index 0000000..9374ae5 --- /dev/null +++ b/mqueue_info.c @@ -0,0 +1,103 @@ +#include +#include +#include +#include +#include +#include +#include + +typedef struct { + char *f_mqname; + int f_verbose; + int f_helper; +} mqueue_params; + +mqueue_params g_params; + +void helper(char *progname) +{ + printf("Usage: %s [OPTS] VALUE\n\n" + "Version: 0.0.1 \n" + "-m mqueue name\n" + "-v verbose output\n" + "-h help options\n" + "\n" + , progname); +} + +#define full_mqpath_len 1024 + +int main(int argc, char **argv) +{ + //stack params + int ret=0; + int c,err; + int i; + int mq_fd; + char full_mqpath[full_mqpath_len]; + int prio; + struct mq_attr attr; + char *pop_val=NULL; + int pop_size; + + + memset(&g_params,0,sizeof(g_params)); + + //process arguments + while ((c = getopt(argc, argv, "m:vh")) != -1) + { + switch (c) + { + case 'm': + g_params.f_mqname = optarg; + break; + case 'v': + g_params.f_verbose = 1; + break; + case 'h': + default: + helper(argv[0]); + exit(1); + } + } + + if (g_params.f_helper) + { + helper(argv[0]); + return 0; + } + + //set mqueue name + if (g_params.f_mqname == NULL) + { + g_params.f_mqname = "/stack-0"; + } + + //compose string + memset(&full_mqpath[0], 0, full_mqpath_len); + snprintf(&full_mqpath[0], full_mqpath_len-1, "%s", g_params.f_mqname); + if (g_params.f_verbose) + { + printf("Full path: %s\n",&full_mqpath); + } + + mq_fd = mq_open(g_params.f_mqname,O_RDWR | O_CREAT, 0666, NULL); + err = errno; + if (mq_fd == -1) + { + if (g_params.f_verbose) + { + printf("ERROR:%d,%s\n",err,strerror(err)); + } + return -1; + } + + mq_getattr(mq_fd, &attr); + + printf("%d\n",attr.mq_curmsgs); + + + close(mq_fd); + + return ret; +} \ No newline at end of file diff --git a/mqueue_pop.c b/mqueue_pop.c new file mode 100644 index 0000000..32cf6db --- /dev/null +++ b/mqueue_pop.c @@ -0,0 +1,113 @@ +#include +#include +#include +#include +#include +#include +#include + +typedef struct { + char *f_mqname; + int f_verbose; + int f_helper; +} mqueue_params; + +mqueue_params g_params; + +void helper(char *progname) +{ + printf("Usage: %s [OPTS] VALUE\n\n" + "Version: 0.0.1 \n" + "-m mqueue name\n" + "-v verbose output\n" + "-h help options\n" + "\n" + , progname); +} + +#define full_mqpath_len 1024 + +int main(int argc, char **argv) +{ + //stack params + int ret=0; + int c,err; + int i; + int mq_fd; + char full_mqpath[full_mqpath_len]; + int prio; + struct mq_attr attr; + char *pop_val=NULL; + int pop_size; + + + memset(&g_params,0,sizeof(g_params)); + + //process arguments + while ((c = getopt(argc, argv, "m:vh")) != -1) + { + switch (c) + { + case 'm': + g_params.f_mqname = optarg; + break; + case 'v': + g_params.f_verbose = 1; + break; + case 'h': + default: + helper(argv[0]); + exit(1); + } + } + + if (g_params.f_helper) + { + helper(argv[0]); + return 0; + } + + //set mqueue name + if (g_params.f_mqname == NULL) + { + g_params.f_mqname = "/stack-0"; + } + + //compose string + memset(&full_mqpath[0], 0, full_mqpath_len); + snprintf(&full_mqpath[0], full_mqpath_len-1, "%s", g_params.f_mqname); + if (g_params.f_verbose) + { + printf("Full path: %s\n",&full_mqpath); + } + + mq_fd = mq_open(g_params.f_mqname,O_RDWR | O_CREAT, 0666, NULL); + err = errno; + if (mq_fd == -1) + { + if (g_params.f_verbose) + { + printf("ERROR:%d,%s\n",err,strerror(err)); + } + return -1; + } + //printf("%s\n",g_params.f_mqname); + + mq_getattr(mq_fd, &attr); + + pop_val = malloc(attr.mq_msgsize+1); + memset(pop_val, 0, attr.mq_msgsize+1); + + if (attr.mq_curmsgs > 0) + { + pop_size = mq_receive(mq_fd, pop_val, attr.mq_msgsize, &prio); + printf("%s\n",pop_val); + } else { + ret = -1; + } + + close(mq_fd); + free(pop_val); + + return ret; +} \ No newline at end of file diff --git a/mqueue_push.c b/mqueue_push.c new file mode 100644 index 0000000..4f0e976 --- /dev/null +++ b/mqueue_push.c @@ -0,0 +1,110 @@ +#include +#include +#include +#include +#include +#include +#include + +typedef struct { + char *f_mqname; + char *f_push; + int f_verbose; + int f_helper; +} mqueue_params; + +mqueue_params g_params; + +void helper(char *progname) +{ + printf("Usage: %s [OPTS] VALUE\n\n" + "Version: 0.0.1 \n" + "-m mqueue name\n" + "-v verbose output\n" + "-p push value\n" + "-h help options\n" + "\n" + , progname); +} + +#define full_mqpath_len 1024 + +int main(int argc, char **argv) +{ + //stack params + int c,err; + int i; + int mq_fd; + char full_mqpath[full_mqpath_len]; + int prio=10; + char *push_val="NONE"; + int push_size=strlen(push_val); + + + memset(&g_params,0,sizeof(g_params)); + + //process arguments + while ((c = getopt(argc, argv, "m:vhp:")) != -1) + { + switch (c) + { + case 'm': + g_params.f_mqname = optarg; + break; + case 'v': + g_params.f_verbose = 1; + break; + case 'p': + g_params.f_push = optarg; + break; + case 'h': + default: + helper(argv[0]); + exit(1); + } + } + + if (g_params.f_helper) + { + helper(argv[0]); + return 0; + } + + //set mqueue name + if (g_params.f_mqname == NULL) + { + g_params.f_mqname = "/stack-0"; + } + + //compose string + memset(&full_mqpath[0], 0, full_mqpath_len); + snprintf(&full_mqpath[0], full_mqpath_len-1, "%s", g_params.f_mqname); + if (g_params.f_verbose) + { + printf("Full path: %s\n",&full_mqpath); + } + + mq_fd = mq_open(g_params.f_mqname,O_RDWR | O_CREAT, 0666, NULL); + err = errno; + if (mq_fd == -1) + { + if (g_params.f_verbose) + { + printf("ERROR:%d,%s\n",err,strerror(err)); + } + return -1; + } + printf("%s\n",g_params.f_mqname); + + if (g_params.f_push != NULL) + { + push_val = g_params.f_push; + push_size = strlen(push_val); + } + + mq_send(mq_fd, push_val, push_size, prio); + + close(mq_fd); + + return 0; +} \ No newline at end of file diff --git a/mqueue_remove.c b/mqueue_remove.c new file mode 100644 index 0000000..e0ad775 --- /dev/null +++ b/mqueue_remove.c @@ -0,0 +1,85 @@ +#include +#include +#include +#include +#include +#include +#include + +typedef struct { + char *f_mqname; + int f_verbose; + int f_helper; +} mqueue_params; + +mqueue_params g_params; + +void helper(char *progname) +{ + printf("Usage: %s [OPTS] VALUE\n\n" + "Version: 0.0.1 \n" + "-m mqueue name\n" + "-v verbose output\n" + "-h help options\n" + "\n" + , progname); +} + +#define full_mqpath_len 1024 + +int main(int argc, char **argv) +{ + //stack params + int ret=0; + int c,err; + int i; + int mq_fd; + char full_mqpath[full_mqpath_len]; + + + memset(&g_params,0,sizeof(g_params)); + + //process arguments + while ((c = getopt(argc, argv, "m:vh")) != -1) + { + switch (c) + { + case 'm': + g_params.f_mqname = optarg; + break; + case 'v': + g_params.f_verbose = 1; + break; + case 'h': + default: + helper(argv[0]); + exit(1); + } + } + + if (g_params.f_helper) + { + helper(argv[0]); + return 0; + } + + //set mqueue name + if (g_params.f_mqname == NULL) + { + g_params.f_mqname = "/stack-0"; + } + + //compose string + memset(&full_mqpath[0], 0, full_mqpath_len); + snprintf(&full_mqpath[0], full_mqpath_len-1, "%s", g_params.f_mqname); + if (g_params.f_verbose) + { + printf("Full path: %s\n",&full_mqpath); + } + + mq_unlink(g_params.f_mqname); + + close(mq_fd); + + return ret; +} \ No newline at end of file diff --git a/send_command.sh b/send_command.sh new file mode 100755 index 0000000..59219b6 --- /dev/null +++ b/send_command.sh @@ -0,0 +1,15 @@ +#!/bin/sh + +QUEUE_NAME=/music-player-daemon + +SEND_CMD() +{ + ./mqueue_push -m $QUEUE_NAME -p "$1" +} + +echo "Send command to daemon" +if [ -f "/dev/mqueue$QUEUE_NAME" ]; then + SEND_CMD $1 +else + echo "No queue to send" +fi -- cgit v1.2.3