no message
parent
99793e8db9
commit
b08b85026e
|
@ -7,3 +7,5 @@ build/
|
||||||
libd/
|
libd/
|
||||||
general/third/
|
general/third/
|
||||||
general/CMakeFiles/
|
general/CMakeFiles/
|
||||||
|
test/src/tcptest/third/
|
||||||
|
test/src/cpp11/third/
|
||||||
|
|
|
@ -164,6 +164,7 @@ int TcpClientLibevent::ConnectServer() {
|
||||||
bufferevent_free(bev);
|
bufferevent_free(bev);
|
||||||
bev = nullptr;
|
bev = nullptr;
|
||||||
printf("Connect failed\n");
|
printf("Connect failed\n");
|
||||||
|
return -1;
|
||||||
}
|
}
|
||||||
this->mStatus = TcpClientLibevent::CONNECTED;
|
this->mStatus = TcpClientLibevent::CONNECTED;
|
||||||
return 0;
|
return 0;
|
||||||
|
|
|
@ -1,9 +1,34 @@
|
||||||
#include "TcpClient.h"
|
#include "TcpClient.h"
|
||||||
#include <iostream>
|
#include <iostream>
|
||||||
#include <atomic>
|
#include <atomic>
|
||||||
|
#include<chrono>
|
||||||
|
#include<thread>
|
||||||
|
|
||||||
|
extern "C"{
|
||||||
|
#include <time.h>
|
||||||
|
}
|
||||||
|
|
||||||
using namespace std;
|
using namespace std;
|
||||||
int main(){
|
|
||||||
TcpClientLibevent mTcp("127.0.0.1",8443, nullptr);
|
|
||||||
|
|
||||||
|
class Observer: public TcpClientLibevent::TcpClientObserver {
|
||||||
|
void OnConnected() {
|
||||||
|
std::cout<<"connected";
|
||||||
|
}
|
||||||
|
virtual void OnDisConnected() {
|
||||||
|
|
||||||
|
}
|
||||||
|
virtual void OnData(uint8_t *dat,uint64_t len){
|
||||||
|
|
||||||
|
}
|
||||||
|
virtual void OnClose(){
|
||||||
|
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
int main(){
|
||||||
|
Observer p ;
|
||||||
|
TcpClientLibevent mTcp("127.0.0.1",8443, &p);
|
||||||
|
while(true){
|
||||||
|
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
|
||||||
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue