projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
sessiond: return raw pointer to packet header
[lttng-tools.git]
/
src
/
common
/
fd-tracker
/
fd-tracker.cpp
diff --git
a/src/common/fd-tracker/fd-tracker.cpp
b/src/common/fd-tracker/fd-tracker.cpp
index 9c6f031b0b6dc6e4995dde7d72f50fc158c06824..0c24eab5ea016e74b51e818af1bbcbb02c5b24ff 100644
(file)
--- a/
src/common/fd-tracker/fd-tracker.cpp
+++ b/
src/common/fd-tracker/fd-tracker.cpp
@@
-80,6
+80,7
@@
struct fd_tracker {
struct lttng_unlinked_file_pool *unlinked_file_pool;
};
struct lttng_unlinked_file_pool *unlinked_file_pool;
};
+namespace {
struct open_properties {
int flags;
LTTNG_OPTIONAL(mode_t) mode;
struct open_properties {
int flags;
LTTNG_OPTIONAL(mode_t) mode;
@@
-124,7
+125,7
@@
struct unsuspendable_fd {
struct rcu_head rcu_head;
};
struct rcu_head rcu_head;
};
-st
atic st
ruct {
+struct {
pthread_mutex_t lock;
bool initialized;
unsigned long value;
pthread_mutex_t lock;
bool initialized;
unsigned long value;
@@
-133,6
+134,7
@@
static struct {
.initialized = false,
.value = 0,
};
.initialized = false,
.value = 0,
};
+} /* namespace */
static int match_fd(struct cds_lfht_node *node, const void *key);
static void unsuspendable_fd_destroy(struct unsuspendable_fd *entry);
static int match_fd(struct cds_lfht_node *node, const void *key);
static void unsuspendable_fd_destroy(struct unsuspendable_fd *entry);
@@
-161,8
+163,8
@@
static int fd_tracker_restore_handle(
/* Match function of the tracker's unsuspendable_fds hash table. */
static int match_fd(struct cds_lfht_node *node, const void *key)
{
/* Match function of the tracker's unsuspendable_fds hash table. */
static int match_fd(struct cds_lfht_node *node, const void *key)
{
- struct unsuspendable_fd *entry =
caa_
container_of(
- node,
struct unsuspendable_fd,
tracker_node);
+ struct unsuspendable_fd *entry =
lttng::utils::
container_of(
+ node,
&unsuspendable_fd::
tracker_node);
return hash_match_key_ulong(
(void *) (unsigned long) entry->fd, (void *) key);
return hash_match_key_ulong(
(void *) (unsigned long) entry->fd, (void *) key);
@@
-188,7
+190,7
@@
static void unsuspendable_fd_destroy(struct unsuspendable_fd *entry)
static struct unsuspendable_fd *unsuspendable_fd_create(
const char *name, int fd)
{
static struct unsuspendable_fd *unsuspendable_fd_create(
const char *name, int fd)
{
- struct unsuspendable_fd *entry =
(unsuspendable_fd *) zmalloc(sizeof(*entry)
);
+ struct unsuspendable_fd *entry =
zmalloc<unsuspendable_fd>(
);
if (!entry) {
goto error;
if (!entry) {
goto error;
@@
-365,7
+367,7
@@
end:
struct fd_tracker *fd_tracker_create(const char *unlinked_file_path,
unsigned int capacity)
{
struct fd_tracker *fd_tracker_create(const char *unlinked_file_path,
unsigned int capacity)
{
- struct fd_tracker *tracker =
(fd_tracker *) zmalloc(sizeof(struct fd_tracker)
);
+ struct fd_tracker *tracker =
zmalloc<fd_tracker>(
);
if (!tracker) {
goto end;
if (!tracker) {
goto end;
@@
-526,7
+528,7
@@
struct fs_handle *fd_tracker_open_fs_handle(struct fd_tracker *tracker,
}
}
}
}
- handle =
(fs_handle_tracked *) zmalloc(sizeof(*handle)
);
+ handle =
zmalloc<fs_handle_tracked>(
);
if (!handle) {
goto end;
}
if (!handle) {
goto end;
}
@@
-620,7
+622,7
@@
int fd_tracker_open_unsuspendable_fd(struct fd_tracker *tracker,
unsigned int active_fds;
struct unsuspendable_fd **entries;
unsigned int active_fds;
struct unsuspendable_fd **entries;
- entries =
(unsuspendable_fd **) zmalloc(fd_count * sizeof(*entries)
);
+ entries =
calloc<unsuspendable_fd *>(fd_count
);
if (!entries) {
ret = -1;
goto end;
if (!entries) {
ret = -1;
goto end;
@@
-719,7
+721,7
@@
int fd_tracker_close_unsuspendable_fd(struct fd_tracker *tracker,
* Maintain a local copy of fds_in as the user's callback may modify its
* contents (e.g. setting the fd(s) to -1 after close).
*/
* Maintain a local copy of fds_in as the user's callback may modify its
* contents (e.g. setting the fd(s) to -1 after close).
*/
- fds =
(int *) malloc
(sizeof(*fds) * fd_count);
+ fds =
malloc<int>
(sizeof(*fds) * fd_count);
if (!fds) {
ret = -1;
goto end;
if (!fds) {
ret = -1;
goto end;
@@
-755,8
+757,8
@@
int fd_tracker_close_unsuspendable_fd(struct fd_tracker *tracker,
ret = -EINVAL;
goto end_unlock;
}
ret = -EINVAL;
goto end_unlock;
}
- entry =
caa_
container_of(
- node,
struct unsuspendable_fd,
tracker_node);
+ entry =
lttng::utils::
container_of(
+ node,
&unsuspendable_fd::
tracker_node);
cds_lfht_del(tracker->unsuspendable_fds, node);
unsuspendable_fd_destroy(entry);
cds_lfht_del(tracker->unsuspendable_fds, node);
unsuspendable_fd_destroy(entry);
@@
-823,7
+825,7
@@
static int fs_handle_tracked_get_fd(struct fs_handle *_handle)
{
int ret;
struct fs_handle_tracked *handle =
{
int ret;
struct fs_handle_tracked *handle =
-
container_of(_handle, struct fs_handle_tracked,
parent);
+
lttng::utils::container_of(_handle, &fs_handle_tracked::
parent);
/*
* TODO This should be optimized as it is a fairly hot path.
/*
* TODO This should be optimized as it is a fairly hot path.
@@
-864,7
+866,7
@@
end:
static void fs_handle_tracked_put_fd(struct fs_handle *_handle)
{
struct fs_handle_tracked *handle =
static void fs_handle_tracked_put_fd(struct fs_handle *_handle)
{
struct fs_handle_tracked *handle =
-
container_of(_handle, struct fs_handle_tracked,
parent);
+
lttng::utils::container_of(_handle, &fs_handle_tracked::
parent);
pthread_mutex_lock(&handle->lock);
handle->in_use = false;
pthread_mutex_lock(&handle->lock);
handle->in_use = false;
@@
-875,7
+877,7
@@
static int fs_handle_tracked_unlink(struct fs_handle *_handle)
{
int ret;
struct fs_handle_tracked *handle =
{
int ret;
struct fs_handle_tracked *handle =
-
container_of(_handle, struct fs_handle_tracked,
parent);
+
lttng::utils::container_of(_handle, &fs_handle_tracked::
parent);
pthread_mutex_lock(&handle->tracker->lock);
pthread_mutex_lock(&handle->lock);
pthread_mutex_lock(&handle->tracker->lock);
pthread_mutex_lock(&handle->lock);
@@
-890,7
+892,7
@@
static int fs_handle_tracked_close(struct fs_handle *_handle)
int ret = 0;
const char *path = NULL;
struct fs_handle_tracked *handle =
int ret = 0;
const char *path = NULL;
struct fs_handle_tracked *handle =
-
container_of(_handle, struct fs_handle_tracked,
parent);
+
lttng::utils::container_of(_handle, &fs_handle_tracked::
parent);
struct lttng_directory_handle *inode_directory_handle = NULL;
if (!handle) {
struct lttng_directory_handle *inode_directory_handle = NULL;
if (!handle) {
This page took
0.026534 seconds
and
4
git commands to generate.