class DPipeEvent :public CPipeIOEvent
{
public:
DPipeEvent(const std::wstring name = L"")
{
this->flagName = name;
}
int count = 0;
void ReadPackge(CPipePackge * packge)override
{
if (count < 20)
{
printf("read pack data:%d, size:%d, pipe:%s, names:%s \n", packge->buf.GetData(), packge->buf.GetSize(), packge->pipeName.c_str(), this->flagName.c_str());
//std::string s("read packge reponse:");
//Sleep(100);
//char i[4];
//s += itoa(count++, i, 10);
//this->WritePackge(s.c_str(), s.length());
this->WritePackge((const char *)packge->buf.GetData(), packge->buf.GetSize());
}
}
void ConnectStatus(bool status)override
{
printf("connect status, %d", status);
}
};
auto *pip = new CPipeModule;
auto *pipeEvent = new DPipeEvent(L"Server-Pipe1");
pip->SetIOEvent(pipeEvent);
TS_ASSERT(pip->Listen(L"\\\\.\\pipe\\VcamPipe"));
//char test[] = "hahahhahahahahahahah";
//pip->Disconnect();
for (auto i = 0; i < 10; i++)
{
//pipeEvent->WritePackge(test, sizeof(test));
}
CreateThread(NULL, 0, [](LPVOID pM)->DWORD {
Sleep(10000);
((CPipeModule*)pM)->Disconnect();
delete (CPipeModule*)pM;
return 0;
}, pip, 0, NULL);
auto *pip = new CPipeModule;
auto *pipeEvent = new DPipeEvent(L"Client-Pipe1");
pip->SetIOEvent(pipeEvent);
TS_ASSERT(pip->Connect(L"\\\\.\\pipe\\VcamPipe"));
for (int i = 0; i < 100; i++)
{
//srand(i%10);
auto size = 1000;//rand() % 1000;
char *test= new char[size];
printf("rand size:%d\n", size);
//char *test = new char[5000];
pipeEvent->WritePackge(test, size);
delete test;
Sleep(1);
}