const TensorSpec OutputSpec;
std::error_code OutEC;
std::error_code InEC;
- sys::fs::file_t Inbound;
+ int Inbound = 0;
std::vector<char> OutputBuffer;
std::unique_ptr<Logger> Log;
};
}
InteractiveModelRunner::~InteractiveModelRunner() {
- sys::fs::closeFile(Inbound);
+ sys::fs::file_t FDAsOSHandle = sys::fs::convertFDToNativeFile(Inbound);
+ sys::fs::closeFile(FDAsOSHandle);
}
void *InteractiveModelRunner::evaluateUntyped() {
const size_t Limit = OutputBuffer.size();
while (InsPoint < Limit) {
auto ReadOrErr = ::sys::fs::readNativeFile(
- Inbound, {Buff + InsPoint, OutputBuffer.size() - InsPoint});
+ sys::fs::convertFDToNativeFile(Inbound),
+ {Buff + InsPoint, OutputBuffer.size() - InsPoint});
if (ReadOrErr.takeError()) {
Ctx.emitError("Failed reading from inbound file");
break;
// host to open the pipes RW.
raw_fd_ostream ToCompiler(ToCompilerName, EC);
EXPECT_FALSE(EC);
- sys::fs::file_t FromCompiler = {};
- EXPECT_FALSE(sys::fs::openFileForRead(FromCompilerName, FromCompiler));
+ int FromCompilerHandle = 0;
+ EXPECT_FALSE(
+ sys::fs::openFileForRead(FromCompilerName, FromCompilerHandle));
+ sys::fs::file_t FromCompiler =
+ sys::fs::convertFDToNativeFile(FromCompilerHandle);
EXPECT_EQ(SeenObservations, 0);
// Helper to read headers and other json lines.
SmallVector<char, 1024> Buffer;