forked from qt-creator/qt-creator
Docker: Improve File contents read speed
Change-Id: Ic94715d2c362ac3aa75dabf4f95c74737abd6264 Reviewed-by: hjk <hjk@qt.io>
This commit is contained in:
@@ -128,6 +128,8 @@ public:
|
|||||||
bool runInShell(const CommandLine &cmd, const QByteArray &stdInData = {});
|
bool runInShell(const CommandLine &cmd, const QByteArray &stdInData = {});
|
||||||
QByteArray outputForRunInShell(const CommandLine &cmd);
|
QByteArray outputForRunInShell(const CommandLine &cmd);
|
||||||
|
|
||||||
|
std::optional<QByteArray> fileContents(const FilePath &filePath, qint64 limit, qint64 offset);
|
||||||
|
|
||||||
void updateContainerAccess();
|
void updateContainerAccess();
|
||||||
void changeMounts(QStringList newMounts);
|
void changeMounts(QStringList newMounts);
|
||||||
bool ensureReachable(const FilePath &other);
|
bool ensureReachable(const FilePath &other);
|
||||||
@@ -1010,25 +1012,7 @@ std::optional<QByteArray> DockerDevice::fileContents(const FilePath &filePath,
|
|||||||
qint64 offset) const
|
qint64 offset) const
|
||||||
{
|
{
|
||||||
QTC_ASSERT(handlesFile(filePath), return {});
|
QTC_ASSERT(handlesFile(filePath), return {});
|
||||||
updateContainerAccess();
|
return d->fileContents(filePath, limit, offset);
|
||||||
|
|
||||||
QStringList args = {"if=" + filePath.path(), "status=none"};
|
|
||||||
if (limit > 0 || offset > 0) {
|
|
||||||
const qint64 gcd = std::gcd(limit, offset);
|
|
||||||
args += {QString("bs=%1").arg(gcd),
|
|
||||||
QString("count=%1").arg(limit / gcd),
|
|
||||||
QString("seek=%1").arg(offset / gcd)};
|
|
||||||
}
|
|
||||||
|
|
||||||
QtcProcess proc;
|
|
||||||
proc.setCommand(d->withDockerExecCmd({"dd", args}));
|
|
||||||
proc.start();
|
|
||||||
proc.waitForFinished();
|
|
||||||
|
|
||||||
if (proc.result() != ProcessResult::FinishedWithSuccess)
|
|
||||||
return {};
|
|
||||||
QByteArray output = proc.readAllStandardOutput();
|
|
||||||
return output;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
bool DockerDevice::writeFileContents(const FilePath &filePath, const QByteArray &data) const
|
bool DockerDevice::writeFileContents(const FilePath &filePath, const QByteArray &data) const
|
||||||
@@ -1048,6 +1032,28 @@ void DockerDevice::aboutToBeRemoved() const
|
|||||||
detector.undoAutoDetect(id().toString());
|
detector.undoAutoDetect(id().toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
std::optional<QByteArray> DockerDevicePrivate::fileContents(const FilePath &filePath,
|
||||||
|
qint64 limit,
|
||||||
|
qint64 offset)
|
||||||
|
{
|
||||||
|
updateContainerAccess();
|
||||||
|
|
||||||
|
QStringList args = {"if=" + filePath.path(), "status=none"};
|
||||||
|
if (limit > 0 || offset > 0) {
|
||||||
|
const qint64 gcd = std::gcd(limit, offset);
|
||||||
|
args += {QString("bs=%1").arg(gcd),
|
||||||
|
QString("count=%1").arg(limit / gcd),
|
||||||
|
QString("seek=%1").arg(offset / gcd)};
|
||||||
|
}
|
||||||
|
|
||||||
|
const ContainerShell::RunResult r = m_shell->outputForRunInShell({"dd", args});
|
||||||
|
|
||||||
|
if (r.exitCode != 0)
|
||||||
|
return {};
|
||||||
|
|
||||||
|
return r.stdOut;
|
||||||
|
}
|
||||||
|
|
||||||
void DockerDevicePrivate::fetchSystemEnviroment()
|
void DockerDevicePrivate::fetchSystemEnviroment()
|
||||||
{
|
{
|
||||||
updateContainerAccess();
|
updateContainerAccess();
|
||||||
|
Reference in New Issue
Block a user