FogConnect
1.0.0
FogConnet은 P2P 네트워크의 연결, 스케줄링, 전송 및 기타 기능을 통합하는 구성 요소입니다.
<IP:Port>
목록을 수집 및 유지합니다.FogConnect는 다음 패키지에 의존합니다:
공통 Deps를 설치합니다:
sudo apt-get install git make
종속성을 설치합니다.
sudo apt-get install openssl libssl-dev libwebsockets-dev libjansson-dev libevent-dev libglib2.0-dev
make
평균 P2P 연결 설정 시간: 1.2~2초
우분투 16.04.3 LTS
Intel(R) Core(TM) i5-7500 CPU @ 2.40GHz
메모리: 7840MB
#include "fog_connect.h"
char CRLF [ 2 ] = "rn" ;
void on_connect ( void * arg ) {
}
void on_recv ( void * arg ) {
fc_info * ud = ( fc_info * ) arg ;
size_t len = 0 ;
char * msg = evbuffer_readln ( ud -> buff , & len , EVBUFFER_EOL_CRLF );
if ( msg != NULL ) {
fc_send ( ud -> pr_connect , msg , len );
fc_send ( ud -> pr_connect , CRLF , sizeof ( CRLF ));
printf ( "sending: %sn" , msg );
fc_free ( msg );
}
}
void on_close ( void * arg ) {
}
int main () {
fc_setup ( "**:**:**:**:**:1c" );
fc_set_callback ( on_connect , on_recv , on_close );
getchar ();
fc_exit ();
return 0 ;
}
#include "fog_connect.h"
void on_connect ( void * arg ) {
fc_info * ud = ( fc_info * ) arg ;
char * msg = strdup ( "hellorn" );
fc_send ( ud -> pr_connect , msg , strlen ( msg ));
printf ( "sending: %sn" , msg );
fc_free ( msg );
}
void on_recv ( void * arg ) {
fc_info * ud = ( fc_info * ) arg ;
size_t len = 0 ;
char * msg = evbuffer_readln ( ud -> buff , & len , EVBUFFER_EOL_CRLF );
if ( msg != NULL ) {
printf ( "receiving: %sn" , msg );
fc_free ( msg );
fc_disconnect ( ud -> pr_connect );
}
}
void on_close ( void * arg ) {
}
int main () {
fc_setup ( "**:**:**:**:**:2c" );
fc_connect_peer ( "**:**:**:**:**:1c" , FOG_TRANSPORT_PROTOCOL_KCP , on_connect , on_recv , on_close );
getchar ();
fc_exit ();
return 0 ;
}