RGBCube/serenity
1
Fork 0
mirror of https://github.com/RGBCube/serenity synced 2025-07-25 17:07:34 +00:00
Code Issues Activity Actions

ProcFS: Add sysctl strings.

Browse source 
They are backed by a Lockable<String> to ensure that access is synchronized.
This commit is contained in:
Andreas Kling 2019-02-08 09:46:46 +01:00
parent dabb3c902a
commit a3799cb71e
2 changed files with 51 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

50
Kernel/ProcFS.cpp
View file

@ -542,6 +542,7 @@ struct SysVariableData final : public ProcFSInodeCustomData {
enum Type { enum Type {
Invalid, Invalid,
Boolean, Boolean,
String,
}; };
Type type { Invalid }; Type type { Invalid };
Function<void()> notify_callback; Function<void()> notify_callback;
@ -582,6 +583,41 @@ static ssize_t write_sys_bool(InodeIdentifier inode_id, const ByteBuffer& data)
return data.size(); return data.size();
} }
static ByteBuffer read_sys_string(InodeIdentifier inode_id)
{
auto inode_ptr = ProcFS::the().get_inode(inode_id);
if (!inode_ptr)
return { };
auto& inode = static_cast<ProcFSInode&>(*inode_ptr);
ASSERT(inode.custom_data());
auto buffer = ByteBuffer::create_uninitialized(2);
auto& custom_data = *static_cast<const SysVariableData*>(inode.custom_data());
ASSERT(custom_data.type == SysVariableData::String);
ASSERT(custom_data.address);
auto* lockable_string = reinterpret_cast<Lockable<String>*>(custom_data.address);
LOCKER(lockable_string->lock());
return lockable_string->resource().to_byte_buffer();
}
static ssize_t write_sys_string(InodeIdentifier inode_id, const ByteBuffer& data)
{
auto inode_ptr = ProcFS::the().get_inode(inode_id);
if (!inode_ptr)
return { };
auto& inode = static_cast<ProcFSInode&>(*inode_ptr);
ASSERT(inode.custom_data());
auto& custom_data = *static_cast<const SysVariableData*>(inode.custom_data());
ASSERT(custom_data.address);
{
auto* lockable_string = reinterpret_cast<Lockable<String>*>(custom_data.address);
LOCKER(lockable_string->lock());
lockable_string->resource() = String((const char*)data.pointer(), data.size());
}
if (custom_data.notify_callback)
custom_data.notify_callback();
return data.size();
}
void ProcFS::add_sys_bool(String&& name, bool* var, Function<void()>&& notify_callback) void ProcFS::add_sys_bool(String&& name, bool* var, Function<void()>&& notify_callback)
{ {
InterruptDisabler disabler; InterruptDisabler disabler;
@ -596,6 +632,20 @@ void ProcFS::add_sys_bool(String&& name, bool* var, Function<void()>&& notify_ca
m_sys_entries.append({ strdup(name.characters()), name.length(), read_sys_bool, write_sys_bool, move(inode) }); m_sys_entries.append({ strdup(name.characters()), name.length(), read_sys_bool, write_sys_bool, move(inode) });
} }
void ProcFS::add_sys_string(String&& name, Lockable<String>& var, Function<void()>&& notify_callback)
{
InterruptDisabler disabler;
unsigned index = m_sys_entries.size();
auto inode = adopt(*new ProcFSInode(*this, sys_var_to_identifier(fsid(), index).index()));
auto data = make<SysVariableData>();
data->type = SysVariableData::String;
data->notify_callback = move(notify_callback);
data->address = &var;
inode->set_custom_data(move(data));
m_sys_entries.append({ strdup(name.characters()), name.length(), read_sys_string, write_sys_string, move(inode) });
}
bool ProcFS::initialize() bool ProcFS::initialize()
{ {
return true; return true;

1
Kernel/ProcFS.h
View file

@ -27,6 +27,7 @@ public:
void add_sys_file(String&&, Function<ByteBuffer(ProcFSInode&)>&& read_callback, Function<ssize_t(ProcFSInode&, const ByteBuffer&)>&& write_callback); void add_sys_file(String&&, Function<ByteBuffer(ProcFSInode&)>&& read_callback, Function<ssize_t(ProcFSInode&, const ByteBuffer&)>&& write_callback);
void add_sys_bool(String&&, bool*, Function<void()>&& notify_callback = nullptr); void add_sys_bool(String&&, bool*, Function<void()>&& notify_callback = nullptr);
void add_sys_string(String&&, Lockable<String>&, Function<void()>&& notify_callback = nullptr);
private: private:
ProcFS(); ProcFS();