Re: [RFC PATCH bpf-next 03/16] bpf: provide a way for targets to register themselves

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 





On 4/10/20 3:18 PM, Andrii Nakryiko wrote:
On Wed, Apr 8, 2020 at 4:26 PM Yonghong Song <yhs@xxxxxx> wrote:

Here, the target refers to a particular data structure
inside the kernel we want to dump. For example, it
can be all task_structs in the current pid namespace,
or it could be all open files for all task_structs
in the current pid namespace.

Each target is identified with the following information:
    target_rel_path   <=== relative path to /sys/kernel/bpfdump
    target_proto      <=== kernel func proto which represents
                           bpf program signature for this target
    seq_ops           <=== seq_ops for seq_file operations
    seq_priv_size     <=== seq_file private data size
    target_feature    <=== target specific feature which needs
                           handling outside seq_ops.

It's not clear what "feature" stands for here... Is this just a sort
of private_data passed through to dumper?

This is described later. It is some kind of target passed to the dumper.



The target relative path is a relative directory to /sys/kernel/bpfdump/.
For example, it could be:
    task                  <=== all tasks
    task/file             <=== all open files under all tasks
    ipv6_route            <=== all ipv6_routes
    tcp6/sk_local_storage <=== all tcp6 socket local storages
    foo/bar/tar           <=== all tar's in bar in foo

^^ this seems useful, but I don't think code as is supports more than 2 levels?

Currently implement should support it.
You need
 - first register 'foo'. target name 'foo'.
- then register 'foo/bar'. 'foo' will be the parent of 'bar'. target name 'foo/bar'. - then 'foo/bar/tar'. 'foo/bar' will be the parent of 'tar'. target name 'foo/bar/tar'.



The "target_feature" is mostly used for reusing existing seq_ops.
For example, for /proc/net/<> stats, the "net" namespace is often
stored in file private data. The target_feature enables bpf based
dumper to set "net" properly for itself before calling shared
seq_ops.

bpf_dump_reg_target() is implemented so targets
can register themselves. Currently, module is not
supported, so there is no bpf_dump_unreg_target().
The main reason is that BTF is not available for modules
yet.

Since target might call bpf_dump_reg_target() before
bpfdump mount point is created, __bpfdump_init()
may be called in bpf_dump_reg_target() as well.

The file-based dumpers will be regular files under
the specific target directory. For example,
    task/my1      <=== dumper "my1" iterates through all tasks
    task/file/my2 <=== dumper "my2" iterates through all open files
                       under all tasks

Signed-off-by: Yonghong Song <yhs@xxxxxx>
---
  include/linux/bpf.h |   4 +
  kernel/bpf/dump.c   | 190 +++++++++++++++++++++++++++++++++++++++++++-
  2 files changed, 193 insertions(+), 1 deletion(-)

diff --git a/include/linux/bpf.h b/include/linux/bpf.h
index fd2b2322412d..53914bec7590 100644
--- a/include/linux/bpf.h
+++ b/include/linux/bpf.h
@@ -1109,6 +1109,10 @@ struct bpf_link *bpf_link_get_from_fd(u32 ufd);
  int bpf_obj_pin_user(u32 ufd, const char __user *pathname);
  int bpf_obj_get_user(const char __user *pathname, int flags);

+int bpf_dump_reg_target(const char *target, const char *target_proto,
+                       const struct seq_operations *seq_ops,
+                       u32 seq_priv_size, u32 target_feature);
+
  int bpf_percpu_hash_copy(struct bpf_map *map, void *key, void *value);
  int bpf_percpu_array_copy(struct bpf_map *map, void *key, void *value);
  int bpf_percpu_hash_update(struct bpf_map *map, void *key, void *value,
diff --git a/kernel/bpf/dump.c b/kernel/bpf/dump.c
index e0c33486e0e7..45528846557f 100644
--- a/kernel/bpf/dump.c
+++ b/kernel/bpf/dump.c
@@ -12,6 +12,173 @@
  #include <linux/filter.h>
  #include <linux/bpf.h>

+struct bpfdump_target_info {
+       struct list_head list;
+       const char *target;
+       const char *target_proto;
+       struct dentry *dir_dentry;
+       const struct seq_operations *seq_ops;
+       u32 seq_priv_size;
+       u32 target_feature;
+};
+
+struct bpfdump_targets {
+       struct list_head dumpers;
+       struct mutex dumper_mutex;

nit: would be a bit simpler if these were static variables with static
initialization, similar to how bpfdump_dentry is separate?

yes, we could do that. not 100% sure whether it will be simpler or not.
the structure is to glue them together.


+};
+
+/* registered dump targets */
+static struct bpfdump_targets dump_targets;
+
+static struct dentry *bpfdump_dentry;
+
+static struct dentry *bpfdump_add_dir(const char *name, struct dentry *parent,
+                                     const struct inode_operations *i_ops,
+                                     void *data);
+static int __bpfdump_init(void);
+
+static int dumper_unlink(struct inode *dir, struct dentry *dentry)
+{
+       kfree(d_inode(dentry)->i_private);
+       return simple_unlink(dir, dentry);
+}
+
+static const struct inode_operations bpf_dir_iops = {
+       .lookup         = simple_lookup,
+       .unlink         = dumper_unlink,
+};
+
+int bpf_dump_reg_target(const char *target,
+                       const char *target_proto,
+                       const struct seq_operations *seq_ops,
+                       u32 seq_priv_size, u32 target_feature)
+{
+       struct bpfdump_target_info *tinfo, *ptinfo;
+       struct dentry *dentry, *parent;
+       const char *lastslash;
+       bool existed = false;
+       int err, parent_len;
+
+       if (!bpfdump_dentry) {
+               err = __bpfdump_init();

This will be called (again) if bpfdump_init() fails? Not sure why? In
rare cases, some dumper will fail to initialize, but then some might
succeed, which is going to be even more confusing, no?

I can have a static variable to say bpfdump_init has been attempted to
avoid such situation to avoid any second try.


+               if (err)
+                       return err;
+       }
+
+       tinfo = kmalloc(sizeof(*tinfo), GFP_KERNEL);
+       if (!tinfo)
+               return -ENOMEM;
+
+       tinfo->target = target;
+       tinfo->target_proto = target_proto;
+       tinfo->seq_ops = seq_ops;
+       tinfo->seq_priv_size = seq_priv_size;
+       tinfo->target_feature = target_feature;
+       INIT_LIST_HEAD(&tinfo->list);
+
+       lastslash = strrchr(target, '/');
+       if (!lastslash) {
+               parent = bpfdump_dentry;

Two nits here. First, it supports only one and two levels. But it
seems like it wouldn't be hard to support multiple? Instead of
reverse-searching for /, you can forward search and keep track of
"current parent".

nit2:

parent = bpfdump_dentry;
if (lastslash) {

     parent = ptinfo->dir_dentry;
}

seems a bit cleaner (and generalizes to multi-level a bit better).

+       } else {
+               parent_len = (unsigned long)lastslash - (unsigned long)target;
+
+               mutex_lock(&dump_targets.dumper_mutex);
+               list_for_each_entry(ptinfo, &dump_targets.dumpers, list) {
+                       if (strlen(ptinfo->target) == parent_len &&
+                           strncmp(ptinfo->target, target, parent_len) == 0) {
+                               existed = true;
+                               break;
+                       }
+               }
+               mutex_unlock(&dump_targets.dumper_mutex);
+               if (existed == false) {
+                       err = -ENOENT;
+                       goto free_tinfo;
+               }
+
+               parent = ptinfo->dir_dentry;
+               target = lastslash + 1;
+       }
+       dentry = bpfdump_add_dir(target, parent, &bpf_dir_iops, tinfo);
+       if (IS_ERR(dentry)) {
+               err = PTR_ERR(dentry);
+               goto free_tinfo;
+       }
+
+       tinfo->dir_dentry = dentry;
+
+       mutex_lock(&dump_targets.dumper_mutex);
+       list_add(&tinfo->list, &dump_targets.dumpers);
+       mutex_unlock(&dump_targets.dumper_mutex);
+       return 0;
+
+free_tinfo:
+       kfree(tinfo);
+       return err;
+}
+

[...]

+       if (S_ISDIR(mode)) {
+               inode->i_op = i_ops;
+               inode->i_fop = f_ops;
+               inc_nlink(inode);
+               inc_nlink(dir);
+       } else {
+               inode->i_fop = f_ops;
+       }
+
+       d_instantiate(dentry, inode);
+       dget(dentry);

lookup_one_len already bumped refcount, why the second time here?

good question. this is what security/inode.c is doing and seems working.
do not really know the science behind this. will check more.


+       inode_unlock(dir);
+       return dentry;
+
+dentry_put:
+       dput(dentry);
+       dentry = ERR_PTR(err);
+unlock:
+       inode_unlock(dir);
+       return dentry;
+}
+

[...]




[Index of Archives]     [Linux Samsung SoC]     [Linux Rockchip SoC]     [Linux Actions SoC]     [Linux for Synopsys ARC Processors]     [Linux NFS]     [Linux NILFS]     [Linux USB Devel]     [Video for Linux]     [Linux Audio Users]     [Yosemite News]     [Linux Kernel]     [Linux SCSI]


  Powered by Linux