Merge pull request #8404 from sfc-gh-mpilman/bugfixes/pr8397/address-review
Address review comments
This commit is contained in:
commit
004180d8fc
|
@ -94,6 +94,7 @@ ACTOR Future<int> actorFuzz0(FutureStream<int> inputStream, PromiseStream<int> o
|
|||
}
|
||||
|
||||
ACTOR Future<int> actorFuzz1(FutureStream<int> inputStream, PromiseStream<int> outputStream, Future<Void> error) {
|
||||
state int ifstate = 0;
|
||||
state int i661806;
|
||||
for (i661806 = 0; i661806 < 5; i661806++) {
|
||||
outputStream.send(477566);
|
||||
|
@ -140,6 +141,7 @@ ACTOR Future<int> actorFuzz1(FutureStream<int> inputStream, PromiseStream<int> o
|
|||
}
|
||||
|
||||
ACTOR Future<int> actorFuzz2(FutureStream<int> inputStream, PromiseStream<int> outputStream, Future<Void> error) {
|
||||
state int ifstate = 0;
|
||||
int input = waitNext(inputStream);
|
||||
outputStream.send(input + 475677);
|
||||
return 930237;
|
||||
|
|
|
@ -344,7 +344,6 @@ private:
|
|||
int64_t l = wait(f->size());
|
||||
TraceEvent("AFCUnderlyingSize").detail("Filename", filename).detail("Size", l);
|
||||
return Reference<AsyncFileCached>(new AsyncFileCached(f, filename, l, pageCache)).castTo<IAsyncFile>();
|
||||
// return new AsyncFileCached(f, filename, l, pageCache);
|
||||
} catch (Error& e) {
|
||||
if (e.code() != error_code_actor_cancelled)
|
||||
openFiles.erase(filename);
|
||||
|
|
Loading…
Reference in New Issue