serverscanning/capnproto-java-rpc
16
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

use kj/filesystem

Browse source
This commit is contained in:
David Renshaw 2023-02-08 11:33:00 -05:00 committed by Semisol
parent ad1fa2cc22
commit 57c0215bef
Signed by: Semisol
GPG key ID: 0949D3C25C7FD14F
1 changed files with 10 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
compiler/src/main/cpp/capnpc-java.c++
View file

@ -26,6 +26,7 @@
#include <capnp/schema.capnp.h>
#include <capnp/serialize.h>
#include <kj/debug.h>
#include <kj/filesystem.h>
#include <kj/io.h>
#include <kj/string-tree.h>
#include <kj/vector.h>
@ -47,8 +48,8 @@
#include "config.h"
#endif
#if CAPNP_VERSION < 5000
#error "This version of capnpc-java requires Cap'n Proto version 0.5 or higher."
#if CAPNP_VERSION < 7000
#error "This version of capnpc-java requires Cap'n Proto version 0.7.0 or higher."
#endif
#ifndef VERSION
@ -2318,9 +2319,7 @@ private:
KJ_MAP(n, nestedTexts) { return kj::mv(n.outerTypeDef); }, indent);
return NodeText {
kj::strTree(
kj::mv(top.outerTypeDef),
KJ_MAP(n, nestedTexts) { return kj::mv(n.outerTypeDef); }),
kj::mv(top.outerTypeDef),
kj::strTree(
kj::mv(top.readerBuilderDefs),
@ -2498,36 +2497,13 @@ private:
// -----------------------------------------------------------------
void makeDirectory(kj::StringPtr path) {
KJ_IF_MAYBE(slashpos, path.findLast('/')) {
// Make the parent dir.
makeDirectory(kj::str(path.slice(0, *slashpos)));
}
if (mkdir(path.cStr(), 0777) < 0) {
int error = errno;
if (error != EEXIST) {
KJ_FAIL_SYSCALL("mkdir(path)", error, path);
}
}
}
kj::Own<kj::Filesystem> fs = kj::newDiskFilesystem();
void writeFile(kj::StringPtr filename, const kj::StringTree& text) {
if (!filename.startsWith("/")) {
KJ_IF_MAYBE(slashpos, filename.findLast('/')) {
// Make the parent dir.
makeDirectory(kj::str(filename.slice(0, *slashpos)));
}
}
int fd;
KJ_SYSCALL(fd = open(filename.cStr(), O_CREAT | O_WRONLY | O_TRUNC, 0666), filename);
kj::FdOutputStream out((kj::AutoCloseFd(fd)));
text.visit(
[&](kj::ArrayPtr<const char> text) {
out.write(text.begin(), text.size());
});
const auto path = kj::Path::parse(filename);
auto file = fs->getCurrent().openFile(path,
kj::WriteMode::CREATE | kj::WriteMode::MODIFY | kj::WriteMode::CREATE_PARENT);
file->writeAll(text.flatten());
}
kj::MainBuilder::Validity run() {
@ -2538,7 +2514,7 @@ private:
ReaderOptions options;
options.traversalLimitInWords = 1 << 30; // Don't limit.
StreamFdMessageReader reader(STDIN_FILENO, options);
StreamFdMessageReader reader(0, options);
auto request = reader.getRoot<schema::CodeGeneratorRequest>();
for (auto node: request.getNodes()) {