X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Fpipe.cpp;h=63a20512d9c8e5bd0fb3012fa899245debf553a3;hb=HEAD;hp=c2dce78816f0fad0e41a935d49371b20f5bbcd0d;hpb=c9e313bc594f40a86eed237dce222c0fc99c957f;p=lttng-tools.git diff --git a/src/common/pipe.cpp b/src/common/pipe.cpp index c2dce7881..63a20512d 100644 --- a/src/common/pipe.cpp +++ b/src/common/pipe.cpp @@ -6,14 +6,14 @@ */ #define _LGPL_SOURCE -#include -#include -#include -#include +#include "pipe.hpp" #include -#include "pipe.hpp" +#include +#include +#include +#include /* * Lock read side of a pipe. @@ -103,24 +103,24 @@ end: 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(); 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; @@ -131,7 +131,7 @@ 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) @@ -205,7 +205,7 @@ struct lttng_pipe *lttng_pipe_open(int flags) return p; error: lttng_pipe_destroy(p); - return NULL; + return nullptr; } /* @@ -213,8 +213,7 @@ error: * * 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; @@ -255,7 +254,7 @@ struct lttng_pipe *lttng_pipe_named_open(const char *path, mode_t mode, return pipe; error: lttng_pipe_destroy(pipe); - return NULL; + return nullptr; } /* @@ -383,8 +382,7 @@ error: * 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;