projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix: remove use of stat()
[lttng-tools.git]
/
src
/
common
/
sessiond-comm
/
unix.c
diff --git
a/src/common/sessiond-comm/unix.c
b/src/common/sessiond-comm/unix.c
index bbf030f67f6bc0cef88b956af83da132f548bd57..48fa1049ac99e6d597e8982bceb5e4cfcf9236fe 100644
(file)
--- a/
src/common/sessiond-comm/unix.c
+++ b/
src/common/sessiond-comm/unix.c
@@
-27,15
+27,14
@@
#include <unistd.h>
#include <errno.h>
#include <unistd.h>
#include <errno.h>
-#include <common/defaults.h>
-#include <common/error.h>
+#include <common/common.h>
#include "unix.h"
/*
* Connect to unix socket using the path name.
*/
#include "unix.h"
/*
* Connect to unix socket using the path name.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
int lttcomm_connect_unix_sock(const char *pathname)
{
struct sockaddr_un sun;
int lttcomm_connect_unix_sock(const char *pathname)
{
struct sockaddr_un sun;
@@
-77,7
+76,7
@@
error:
* Do an accept(2) on the sock and return the new file descriptor. The socket
* MUST be bind(2) before.
*/
* Do an accept(2) on the sock and return the new file descriptor. The socket
* MUST be bind(2) before.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
int lttcomm_accept_unix_sock(int sock)
{
int new_fd;
int lttcomm_accept_unix_sock(int sock)
{
int new_fd;
@@
-97,7
+96,7
@@
int lttcomm_accept_unix_sock(int sock)
* Creates a AF_UNIX local socket using pathname bind the socket upon creation
* and return the fd.
*/
* Creates a AF_UNIX local socket using pathname bind the socket upon creation
* and return the fd.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
int lttcomm_create_unix_sock(const char *pathname)
{
struct sockaddr_un sun;
int lttcomm_create_unix_sock(const char *pathname)
{
struct sockaddr_un sun;
@@
-126,13
+125,18
@@
int lttcomm_create_unix_sock(const char *pathname)
return fd;
error:
return fd;
error:
+ if (fd >= 0) {
+ if (close(fd) < 0) {
+ PERROR("close create unix sock");
+ }
+ }
return ret;
}
/*
* Make the socket listen using LTTNG_SESSIOND_COMM_MAX_LISTEN.
*/
return ret;
}
/*
* Make the socket listen using LTTNG_SESSIOND_COMM_MAX_LISTEN.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
int lttcomm_listen_unix_sock(int sock)
{
int ret;
int lttcomm_listen_unix_sock(int sock)
{
int ret;
@@
-151,7
+155,7
@@
int lttcomm_listen_unix_sock(int sock)
*
* Return the size of received data.
*/
*
* Return the size of received data.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
ssize_t lttcomm_recv_unix_sock(int sock, void *buf, size_t len)
{
struct msghdr msg;
ssize_t lttcomm_recv_unix_sock(int sock, void *buf, size_t len)
{
struct msghdr msg;
@@
-190,7
+194,7
@@
ssize_t lttcomm_recv_unix_sock(int sock, void *buf, size_t len)
*
* Return the size of sent data.
*/
*
* Return the size of sent data.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
ssize_t lttcomm_send_unix_sock(int sock, void *buf, size_t len)
{
struct msghdr msg;
ssize_t lttcomm_send_unix_sock(int sock, void *buf, size_t len)
{
struct msghdr msg;
@@
-221,7
+225,7
@@
ssize_t lttcomm_send_unix_sock(int sock, void *buf, size_t len)
/*
* Shutdown cleanly a unix socket.
*/
/*
* Shutdown cleanly a unix socket.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
int lttcomm_close_unix_sock(int sock)
{
int ret, closeret;
int lttcomm_close_unix_sock(int sock)
{
int ret, closeret;
@@
-245,7
+249,7
@@
int lttcomm_close_unix_sock(int sock)
*
* Returns the size of data sent, or negative error value.
*/
*
* Returns the size of data sent, or negative error value.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
ssize_t lttcomm_send_fds_unix_sock(int sock, int *fds, size_t nb_fd)
{
struct msghdr msg;
ssize_t lttcomm_send_fds_unix_sock(int sock, int *fds, size_t nb_fd)
{
struct msghdr msg;
@@
-257,6
+261,7
@@
ssize_t lttcomm_send_fds_unix_sock(int sock, int *fds, size_t nb_fd)
char dummy = 0;
memset(&msg, 0, sizeof(msg));
char dummy = 0;
memset(&msg, 0, sizeof(msg));
+ memset(tmp, 0, CMSG_SPACE(sizeof_fds) * sizeof(char));
if (nb_fd > LTTCOMM_MAX_SEND_FDS)
return -EINVAL;
if (nb_fd > LTTCOMM_MAX_SEND_FDS)
return -EINVAL;
@@
-300,7
+305,7
@@
ssize_t lttcomm_send_fds_unix_sock(int sock, int *fds, size_t nb_fd)
* Expect at most "nb_fd" file descriptors. Returns the number of fd
* actually received in nb_fd.
*/
* Expect at most "nb_fd" file descriptors. Returns the number of fd
* actually received in nb_fd.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
ssize_t lttcomm_recv_fds_unix_sock(int sock, int *fds, size_t nb_fd)
{
struct iovec iov[1];
ssize_t lttcomm_recv_fds_unix_sock(int sock, int *fds, size_t nb_fd)
{
struct iovec iov[1];
@@
-366,7
+371,7
@@
end:
*
* Returns the size of data sent, or negative error value.
*/
*
* Returns the size of data sent, or negative error value.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
ssize_t lttcomm_send_creds_unix_sock(int sock, void *buf, size_t len)
{
struct msghdr msg;
ssize_t lttcomm_send_creds_unix_sock(int sock, void *buf, size_t len)
{
struct msghdr msg;
@@
-380,6
+385,7
@@
ssize_t lttcomm_send_creds_unix_sock(int sock, void *buf, size_t len)
#endif /* __linux__ */
memset(&msg, 0, sizeof(msg));
#endif /* __linux__ */
memset(&msg, 0, sizeof(msg));
+ memset(anc_buf, 0, CMSG_SPACE(sizeof_cred) * sizeof(char));
iov[0].iov_base = buf;
iov[0].iov_len = len;
iov[0].iov_base = buf;
iov[0].iov_len = len;
@@
-422,7
+428,7
@@
ssize_t lttcomm_send_creds_unix_sock(int sock, void *buf, size_t len)
*
* Returns the size of received data, or negative error value.
*/
*
* Returns the size of received data, or negative error value.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
ssize_t lttcomm_recv_creds_unix_sock(int sock, void *buf, size_t len,
lttng_sock_cred *creds)
{
ssize_t lttcomm_recv_creds_unix_sock(int sock, void *buf, size_t len,
lttng_sock_cred *creds)
{
@@
-512,7
+518,7
@@
end:
* Set socket option to use credentials passing.
*/
#ifdef __linux__
* Set socket option to use credentials passing.
*/
#ifdef __linux__
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
int lttcomm_setsockopt_creds_unix_sock(int sock)
{
int ret, on = 1;
int lttcomm_setsockopt_creds_unix_sock(int sock)
{
int ret, on = 1;
@@
-525,7
+531,7
@@
int lttcomm_setsockopt_creds_unix_sock(int sock)
return ret;
}
#elif (defined(__FreeBSD__) || defined(__CYGWIN__))
return ret;
}
#elif (defined(__FreeBSD__) || defined(__CYGWIN__))
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
int lttcomm_setsockopt_creds_unix_sock(int sock)
{
return 0;
int lttcomm_setsockopt_creds_unix_sock(int sock)
{
return 0;
@@
-537,7
+543,7
@@
int lttcomm_setsockopt_creds_unix_sock(int sock)
/*
* Set socket reciving timeout.
*/
/*
* Set socket reciving timeout.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
int lttcomm_setsockopt_rcv_timeout(int sock, unsigned int sec)
{
int ret;
int lttcomm_setsockopt_rcv_timeout(int sock, unsigned int sec)
{
int ret;
@@
-558,7
+564,7
@@
int lttcomm_setsockopt_rcv_timeout(int sock, unsigned int sec)
/*
* Set socket sending timeout.
*/
/*
* Set socket sending timeout.
*/
-__attribute__((visibility("hidden")))
+LTTNG_HIDDEN
int lttcomm_setsockopt_snd_timeout(int sock, unsigned int sec)
{
int ret;
int lttcomm_setsockopt_snd_timeout(int sock, unsigned int sec)
{
int ret;
This page took
0.038445 seconds
and
4
git commands to generate.