1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
/*
* @licence app begin@
* SPDX license identifier: MPL-2.0
*
* Copyright (C) 2015, Advanced Driver Information Technology
* Copyright of Advanced Driver Information Technology, Bosch and Denso
*
* This file is part of GENIVI Project DLT - Diagnostic Log and Trace.
*
* This Source Code Form is subject to the terms of the
* Mozilla Public License (MPL), v. 2.0.
* If a copy of the MPL was not distributed with this file,
* You can obtain one at http://mozilla.org/MPL/2.0/.
*
* For further information see http://www.genivi.org/.
* @licence end@
*/
/*!
* \author
* Christoph Lipka <clipka@jp.adit-jv.com>
*
* \copyright Copyright © 2015 ADIT. \n
* License MPL-2.0: Mozilla Public License version 2.0 http://mozilla.org/MPL/2.0/.
*
* \file dlt_daemon_unix_socket.c
*/
#include <stdio.h>
#include <stdlib.h>
#include <sys/un.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <syslog.h>
#include <errno.h>
#include "dlt-daemon.h"
#include "dlt_common.h"
#include "dlt-daemon_cfg.h"
#include "dlt_daemon_socket.h"
#include "dlt_daemon_unix_socket.h"
char err_string[DLT_DAEMON_TEXTBUFSIZE];
int dlt_daemon_unix_socket_open(int *sock, char *sock_path, int type, int mask)
{
struct sockaddr_un addr;
int old_mask;
if (sock == NULL || sock_path == NULL)
{
dlt_log(LOG_ERR, "dlt_daemon_unix_socket_open: arguments invalid");
return -1;
}
if ((*sock = socket(AF_UNIX, type, 0)) == -1)
{
dlt_log(LOG_WARNING, "unix socket: socket() error");
return -1;
}
memset(&addr, 0, sizeof(addr));
addr.sun_family = AF_UNIX;
memcpy(addr.sun_path, sock_path, sizeof(addr.sun_path));
unlink(sock_path);
/* set appropriate access permissions */
old_mask = umask(mask);
if (bind(*sock, (struct sockaddr *) &addr, sizeof(addr)) == -1)
{
dlt_log(LOG_WARNING, "unix socket: bind() error");
return -1;
}
if (listen(*sock, 1) == -1)
{
dlt_log(LOG_WARNING, "unix socket: listen error");
return -1;
}
/* restore permissions */
umask(old_mask);
return 0;
}
int dlt_daemon_unix_socket_close(int sock)
{
int ret = close(sock);
if (ret != 0)
{
sprintf(err_string, "unix socket close failed: %s", strerror(errno));
dlt_log(LOG_WARNING, err_string);
}
return ret;
}
|
