//
//  client_test.h
//  GoldRich
//
//  Created by WindShan on 2017/3/8.
//  Copyright © 2017年 WindShan. All rights reserved.
//

#ifndef client_test_h
#define client_test_h

#include "NetStream.h"
#include "IClientSocket.h"

using namespace std;

void on_success()
{
    printf("connect success\n");
}

void on_connect_err()
{
    printf("connect error\n");
}

void on_connect_timeout()
{
    printf("connect time out\n");
}

void on_recv_pkg(CNetStream* pkg)
{
    printf("receive a server pkg\n");
    if (pkg)
    {
        const char* str = pkg->readString();
        printf("字符串：%s\n",str);
    }
}

int startTest()
{
    std::mutex mem_mutex;
    IClientSocket::InitSockEnv();
    const int BUF_SIZE = 64;
    
    char* p = new char[10*1024*1024];
    memset(p,0,10*1024*1024);
    
    char* p1 = new char[10*1024*1024];
    
    int n = 1000000000;
    while (n >0)
    {
        n--;
    }
    
    clock_t ts = clock();
    
    mem_mutex.lock();
    memcpy(p1,p,10*1024*1024);
    mem_mutex.unlock();
    
    clock_t te = clock();
    printf("need time = %d\n",te - ts);
    
    IClientSocket cl;
    cl.Connect("127.0.0.1",7000,10,on_success,on_connect_timeout,on_connect_err,on_recv_pkg);
    CNetStream st;
    st.writeString("1234565788idfsfs搜狗五笔");
    cl.SendStream(&st);
    
    while (true)
    {
        cl.process();
        CNetStream sss;
        sss.writeString("1234565788idfsfs搜狗五笔");
        cl.SendStream(&sss);
        Sleep(10000);
    }
    
    cl.Close();
    
    IClientSocket::UninitSockEnv();
    return 0;
}

#endif/* client_test_h */