SegmentedInputStorage.cpp [plain text]
#include "config.h"
#include "SegmentedInputStorage.h"
#if ENABLE(WEB_REPLAY)
#if !LOG_DISABLED
#include "Logging.h"
#include "SerializationMethods.h"
#include <replay/EncodedValue.h>
#include <wtf/text/CString.h>
#include <wtf/text/WTFString.h>
#endif
namespace WebCore {
#if !LOG_DISABLED
static const char* queueTypeToLogPrefix(InputQueue inputQueue, bool isLoad)
{
if (isLoad) {
switch (inputQueue) {
case InputQueue::EventLoopInput: return "(DSPTCH-LOAD)";
case InputQueue::LoaderMemoizedData: return "<LDMEMO-LOAD";
case InputQueue::ScriptMemoizedData: return "<---<---<---JSMEMO-LOAD";
case InputQueue::Count: return "ERROR!";
}
} else {
switch (inputQueue) {
case InputQueue::EventLoopInput: return ">DSPTCH-STORE";
case InputQueue::LoaderMemoizedData: return "<LDMEMO-STORE";
case InputQueue::ScriptMemoizedData: return "<---<---<---JSMEMO-STORE";
case InputQueue::Count: return "ERROR!";
}
}
}
static String jsonStringForInput(const NondeterministicInputBase& input)
{
EncodedValue encodedValue = EncodingTraits<NondeterministicInputBase>::encodeValue(input);
return encodedValue.asObject()->toJSONString();
}
#endif // !LOG_DISABLED
static size_t offsetForInputQueue(InputQueue inputQueue)
{
return static_cast<size_t>(inputQueue);
}
SegmentedInputStorage::SegmentedInputStorage()
: m_inputCount(0)
{
for (size_t i = 0; i < offsetForInputQueue(InputQueue::Count); i++)
m_queues.append(new QueuedInputs);
}
SegmentedInputStorage::~SegmentedInputStorage()
{
for (size_t i = 0; i < offsetForInputQueue(InputQueue::Count); i++)
delete m_queues.at(i);
}
NondeterministicInputBase* SegmentedInputStorage::load(InputQueue inputQueue, size_t offset)
{
ASSERT(offset < queueSize(inputQueue));
NondeterministicInputBase* input = queue(inputQueue).at(offset).get();
ASSERT(input);
LOG(WebReplay, "%-20s %s: %s %s\n", "ReplayEvents", queueTypeToLogPrefix(inputQueue, true), input->type().string().utf8().data(), jsonStringForInput(*input).utf8().data());
return input;
}
void SegmentedInputStorage::store(std::unique_ptr<NondeterministicInputBase> input)
{
ASSERT(input);
ASSERT(input->queue() < InputQueue::Count);
LOG(WebReplay, "%-14s#%-5u %s: %s %s\n", "ReplayEvents", m_inputCount++, queueTypeToLogPrefix(input->queue(), false), input->type().string().utf8().data(), jsonStringForInput(*input).utf8().data());
m_queues.at(offsetForInputQueue(input->queue()))->append(WTF::move(input));
}
size_t SegmentedInputStorage::queueSize(InputQueue inputQueue) const
{
return queue(inputQueue).size();
}
const SegmentedInputStorage::QueuedInputs& SegmentedInputStorage::queue(InputQueue queue) const
{
ASSERT(queue < InputQueue::Count);
return *m_queues.at(offsetForInputQueue(queue));
}
}
#endif // ENABLE(WEB_REPLAY)