in src/afs.cc [3526:3547]
void process_read_requests()
{
#ifdef AFS_VERBOSE
const char* tag = "read";
#endif
std::lock_guard<std::mutex> lock(mutex_);
for (auto& request : readRequests_)
{
request->finished = true;
{
ProcessorLockGuard lock(this);
request->readBytes = request->buffer->read(request->n, request->output);
}
P("%s: %s: %s: kill executor: %d",
Tag,
tag_,
tag,
request->localSession->peerPID);
kill(request->localSession->peerPID, SIGUSR1);
}
readRequests_.clear();
}