*/
#define _LGPL_SOURCE
-#include <fcntl.h>
-#include <unistd.h>
-#include <sys/types.h>
-#include <sys/stat.h>
+#include "pipe.hpp"
#include <common/common.hpp>
-#include "pipe.hpp"
+#include <fcntl.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+#include <unistd.h>
/*
* Lock read side of a pipe.
return ret_val;
}
-static struct lttng_pipe *_pipe_create(void)
+static struct lttng_pipe *_pipe_create()
{
int ret;
struct lttng_pipe *p;
- p = (lttng_pipe *) zmalloc(sizeof(*p));
+ p = zmalloc<lttng_pipe>();
if (!p) {
PERROR("zmalloc pipe create");
goto end;
}
p->fd[0] = p->fd[1] = -1;
- ret = pthread_mutex_init(&p->read_mutex, NULL);
+ ret = pthread_mutex_init(&p->read_mutex, nullptr);
if (ret) {
PERROR("pthread_mutex_init read lock pipe create");
goto error_destroy;
}
- ret = pthread_mutex_init(&p->write_mutex, NULL);
+ ret = pthread_mutex_init(&p->write_mutex, nullptr);
if (ret) {
PERROR("pthread_mutex_init write lock pipe create");
goto error_destroy_rmutex;
(void) pthread_mutex_destroy(&p->read_mutex);
error_destroy:
free(p);
- return NULL;
+ return nullptr;
}
static int _pipe_set_flags(struct lttng_pipe *pipe, int flags)
return p;
error:
lttng_pipe_destroy(p);
- return NULL;
+ return nullptr;
}
/*
*
* Return a newly allocated lttng pipe on success or else NULL.
*/
-struct lttng_pipe *lttng_pipe_named_open(const char *path, mode_t mode,
- int flags)
+struct lttng_pipe *lttng_pipe_named_open(const char *path, mode_t mode, int flags)
{
int ret, fd_r, fd_w;
struct lttng_pipe *pipe;
return pipe;
error:
lttng_pipe_destroy(pipe);
- return NULL;
+ return nullptr;
}
/*
* Return "count" on success. Return < count on error. errno can be used
* to check the actual error.
*/
-ssize_t lttng_pipe_write(struct lttng_pipe *pipe, const void *buf,
- size_t count)
+ssize_t lttng_pipe_write(struct lttng_pipe *pipe, const void *buf, size_t count)
{
ssize_t ret;