Textractor_test/host/textthread.cc

92 lines
2.2 KiB
C++
Raw Normal View History

// textthread.cc
// 8/24/2013 jichi
// Branch IHF/TextThread.cpp, rev 133
#ifdef _MSC_VER
# pragma warning (disable:4100) // C4100: unreference formal parameter
#endif // _MSC_VER
#include "textthread.h"
2018-07-21 04:26:27 +08:00
#include "../vnrhook/include/const.h"
2018-07-21 05:21:35 +08:00
#include "winmutex.h"
2018-07-19 04:18:43 +08:00
extern HWND dummyWindow;
2018-08-09 11:56:36 +08:00
#define TT_LOCK CriticalSectionLocker ttLocker(&ttCs) // Synchronized scope for accessing private data
2018-07-18 05:01:56 +08:00
2018-08-03 05:17:54 +08:00
TextThread::TextThread(ThreadParameter tp, unsigned int threadNumber, DWORD status) :
2018-07-19 04:18:43 +08:00
storage(),
sentenceBuffer(),
2018-08-03 05:17:54 +08:00
status(status),
2018-07-19 04:18:43 +08:00
threadNumber(threadNumber),
output(nullptr),
tp(tp)
{
InitializeCriticalSection(&ttCs);
2018-07-18 05:01:56 +08:00
}
2018-07-19 04:18:43 +08:00
TextThread::~TextThread()
{
2018-07-23 09:10:00 +08:00
EnterCriticalSection(&ttCs);
2018-08-03 14:32:23 +08:00
KillTimer(dummyWindow, (UINT_PTR)this);
2018-07-23 09:10:00 +08:00
LeaveCriticalSection(&ttCs);
2018-07-19 04:18:43 +08:00
DeleteCriticalSection(&ttCs);
}
2018-06-11 07:15:05 +08:00
2018-07-25 16:11:23 +08:00
void TextThread::Clear()
{
2018-07-19 04:18:43 +08:00
TT_LOCK;
storage.clear();
2018-07-25 16:11:23 +08:00
storage.shrink_to_fit();
2018-07-19 04:18:43 +08:00
}
2018-07-26 12:48:18 +08:00
std::wstring TextThread::GetStore()
{
TT_LOCK;
return storage;
}
void TextThread::AddSentence()
{
2018-07-19 04:18:43 +08:00
TT_LOCK;
std::wstring sentence;
if (status & USING_UNICODE)
2018-05-25 16:34:40 +08:00
{
sentence = std::wstring((wchar_t*)sentenceBuffer.data(), sentenceBuffer.size() / 2);
2018-05-25 16:34:40 +08:00
}
2018-08-03 13:48:57 +08:00
else if (status & USING_UTF8)
{
wchar_t* converted = new wchar_t[sentenceBuffer.size()];
sentence = std::wstring(converted, MultiByteToWideChar(CP_UTF8, 0, sentenceBuffer.data(), sentenceBuffer.size(), converted, sentenceBuffer.size()));
delete[] converted;
}
2018-05-25 16:34:40 +08:00
else
2018-06-12 07:49:28 +08:00
{
wchar_t* converted = new wchar_t[sentenceBuffer.size()];
sentence = std::wstring(converted, MultiByteToWideChar(932, 0, sentenceBuffer.data(), sentenceBuffer.size(), converted, sentenceBuffer.size()));
delete[] converted;
2018-06-12 07:49:28 +08:00
}
2018-07-21 05:21:35 +08:00
AddSentence(sentence);
sentenceBuffer.clear();
}
2018-05-25 16:34:40 +08:00
void TextThread::AddSentence(std::wstring sentence)
{
2018-07-19 04:18:43 +08:00
TT_LOCK;
2018-07-21 05:21:35 +08:00
if (output) sentence = output(this, sentence);
2018-07-19 04:18:43 +08:00
storage.append(sentence);
}
void TextThread::AddText(const BYTE *con, int len)
{
2018-07-19 04:18:43 +08:00
TT_LOCK;
2018-07-19 12:09:58 +08:00
sentenceBuffer.insert(sentenceBuffer.end(), con, con + len);
2018-08-03 14:32:23 +08:00
SetTimer(dummyWindow, (UINT_PTR)this, 250, // TODO: Let user change delay before sentenceBuffer is flushed
2018-07-19 12:09:58 +08:00
[](HWND hWnd, UINT uMsg, UINT_PTR idEvent, DWORD dwTime)
{
KillTimer(hWnd, idEvent);
((TextThread*)idEvent)->AddSentence();
});
}
// EOF