mirror of
https://github.com/matrix-construct/construct
synced 2024-12-24 14:34:00 +01:00
eb00134100
ircd::sys: Add abstract sysfs tool and template from fs::dev.
226 lines
3.7 KiB
C++
226 lines
3.7 KiB
C++
// The Construct
|
|
//
|
|
// Copyright (C) The Construct Developers, Authors & Contributors
|
|
// Copyright (C) 2016-2020 Jason Volk <jason@zemos.net>
|
|
//
|
|
// Permission to use, copy, modify, and/or distribute this software for any
|
|
// purpose with or without fee is hereby granted, provided that the above
|
|
// copyright notice and this permission notice is present in all copies. The
|
|
// full license for this software is available in the LICENSE file.
|
|
|
|
#include <RB_INC_SYS_SYSMACROS_H
|
|
|
|
bool
|
|
ircd::fs::dev::for_each(const blk_closure &closure)
|
|
{
|
|
return for_each(string_view{}, closure);
|
|
}
|
|
|
|
bool
|
|
ircd::fs::dev::for_each(const string_view &type,
|
|
const blk_closure &closure)
|
|
{
|
|
for(const auto &dir : fs::ls(blk::BASE_PATH)) try
|
|
{
|
|
const auto &[major, minor]
|
|
{
|
|
split(filename(path_scratch, dir), ':')
|
|
};
|
|
|
|
const ulong id
|
|
{
|
|
dev::id({lex_cast<ulong>(major), lex_cast<ulong>(minor)})
|
|
};
|
|
|
|
char dtbuf[32];
|
|
if(type && blk::devtype(dtbuf, id) != type)
|
|
continue;
|
|
|
|
if(!closure(id, blk(id)))
|
|
return false;
|
|
}
|
|
catch(const ctx::interrupted &)
|
|
{
|
|
throw;
|
|
}
|
|
catch(const std::exception &e)
|
|
{
|
|
log::error
|
|
{
|
|
log, "%s :%s",
|
|
dir,
|
|
e.what(),
|
|
};
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
ircd::string_view
|
|
ircd::fs::dev::sysfs(const mutable_buffer &out,
|
|
const ulong &id,
|
|
const string_view &relpath)
|
|
{
|
|
thread_local char path_buf[1024];
|
|
const string_view path{fmt::sprintf
|
|
{
|
|
path_buf, "dev/block/%s/%s",
|
|
sysfs_id(name_scratch, id),
|
|
relpath
|
|
}};
|
|
|
|
return sys::get(out, path);
|
|
}
|
|
|
|
ircd::string_view
|
|
ircd::fs::dev::sysfs_id(const mutable_buffer &out,
|
|
const ulong &id)
|
|
{
|
|
return sysfs_id(out, dev::id(id));
|
|
}
|
|
|
|
ircd::string_view
|
|
ircd::fs::dev::sysfs_id(const mutable_buffer &out,
|
|
const major_minor &id)
|
|
{
|
|
return fmt::sprintf
|
|
{
|
|
out, "%lu:%lu", id.first, id.second
|
|
};
|
|
}
|
|
|
|
ulong
|
|
ircd::fs::dev::id(const major_minor &id)
|
|
{
|
|
return makedev(id.first, id.second);
|
|
}
|
|
|
|
ircd::fs::dev::major_minor
|
|
ircd::fs::dev::id(const ulong &id)
|
|
{
|
|
return
|
|
{
|
|
major(id), minor(id)
|
|
};
|
|
}
|
|
|
|
//
|
|
// dev::blk
|
|
//
|
|
|
|
decltype(ircd::fs::dev::blk::SECTOR_SIZE)
|
|
ircd::fs::dev::blk::SECTOR_SIZE
|
|
{
|
|
512
|
|
};
|
|
|
|
decltype(ircd::fs::dev::blk::BASE_PATH)
|
|
ircd::fs::dev::blk::BASE_PATH
|
|
{
|
|
"/sys/dev/block"
|
|
};
|
|
|
|
ircd::fs::dev::blk::blk(const ulong &id)
|
|
:type
|
|
{
|
|
ircd::string(15, [&id]
|
|
(const mutable_buffer &buf)
|
|
{
|
|
return devtype(buf, id);
|
|
})
|
|
}
|
|
,vendor
|
|
{
|
|
ircd::string(15, [&id]
|
|
(const mutable_buffer &buf)
|
|
{
|
|
return sysfs(buf, id, "device/vendor");
|
|
})
|
|
}
|
|
,model
|
|
{
|
|
ircd::string(64, [&id]
|
|
(const mutable_buffer &buf)
|
|
{
|
|
return sysfs(buf, id, "device/model");
|
|
})
|
|
}
|
|
,rev
|
|
{
|
|
ircd::string(15, [&id]
|
|
(const mutable_buffer &buf)
|
|
{
|
|
return sysfs(buf, id, "device/rev");
|
|
})
|
|
}
|
|
,sector_size
|
|
{
|
|
sysfs(id, "queue/hw_sector_size")
|
|
}
|
|
,physical_block
|
|
{
|
|
sysfs(id, "queue/physical_block_size")
|
|
}
|
|
,logical_block
|
|
{
|
|
sysfs(id, "queue/logical_block_size")
|
|
}
|
|
,minimum_io
|
|
{
|
|
sysfs(id, "queue/minimum_io_size")
|
|
}
|
|
,optimal_io
|
|
{
|
|
sysfs(id, "queue/optimal_io_size")
|
|
}
|
|
,sectors
|
|
{
|
|
sysfs(id, "size")
|
|
}
|
|
,queue_depth
|
|
{
|
|
sysfs(id, "device/queue_depth")
|
|
}
|
|
,nr_requests
|
|
{
|
|
sysfs(id, "queue/nr_requests")
|
|
}
|
|
,scheduler
|
|
{
|
|
ircd::string(64, [&id]
|
|
(const mutable_buffer &buf)
|
|
{
|
|
return sysfs(buf, id, "queue/scheduler");
|
|
})
|
|
}
|
|
,rotational
|
|
{
|
|
sysfs<bool>(id, "queue/rotational", false)
|
|
}
|
|
,merges
|
|
{
|
|
!sysfs<bool>(id, "queue/nomerges", true)
|
|
}
|
|
{
|
|
}
|
|
|
|
ircd::string_view
|
|
ircd::fs::dev::blk::devtype(const mutable_buffer &buf,
|
|
const ulong &id)
|
|
{
|
|
char tmp[128];
|
|
string_view ret;
|
|
tokens(sysfs(tmp, id, "uevent"), '\n', [&buf, &ret]
|
|
(const string_view &kv)
|
|
{
|
|
const auto &[key, value]
|
|
{
|
|
split(kv, '=')
|
|
};
|
|
|
|
if(key == "DEVTYPE")
|
|
ret = strlcpy(buf, value);
|
|
});
|
|
|
|
return ret;
|
|
}
|