#include "SS5Main.h"
int Bala_Vip( char *addr );
int Bala_Err( void );
int Bala_Menu( void );
int Bala_Vip( char *addr );
int Bala_Sticky( char *addr );
int main( int argc, char *argv[] )
{
if( argc > 1 ) {
if( !strncmp(argv[1],"VIP",sizeof("VIP")) )
Bala_Vip( "127.0.0.1" );
else if( !strncmp(argv[1],"STICKY",sizeof("STICKY")) )
Bala_Sticky( "127.0.0.1" );
else
Bala_Err();
}
else
Bala_Menu();
return 0;
}
int Bala_Err( void )
{
printf("Content-type: text/html\n\n");
printf(" SS5 balancing manager\n");
printf("");
printf(" BAD parameter:
");
printf("\n");
return 0;
}
int Bala_Menu( void )
{
printf("Content-type: text/html\n\n");
printf(" SS5 balancing manager menu\n");
printf("");
printf("
MENU:
");
printf(" VIP table ");
printf(" STICKY table ");
printf("\n");
return 0;
}
int Bala_Vip( char *addr )
{
unsigned long int vid,nsess;
char srcip[16];
struct sockaddr_in da_sin;
int s;
char *buf="GET /balancing HTTP/1.1";
char resp[512];
if ( (s = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
return 1;
}
memset((char *)&da_sin, 0, sizeof(struct sockaddr_in));
da_sin.sin_family = AF_INET;
da_sin.sin_port = htons(1080);
da_sin.sin_addr.s_addr = inet_addr(addr);
printf("Content-type: text/html\n\n");
printf(" SS5 balancing manager\n");
printf("");
printf(" VIP table:
");
printf("\n");
printf("| Source IP | Virtual ID | Session number |
\n");
if( connect(s,(struct sockaddr *)&da_sin,sizeof(struct sockaddr_in)) != -1 ) {
if( send(s,buf,strlen(buf),SS5_SEND_OPT) == -1) {
perror("Sending error: ");
return -1;
}
while( recv(s,resp,512,0) > 0 ) {
sscanf(resp,"%s\n%lu\n%lu\n",srcip,&vid,&nsess);
printf("| %s | %lu | %lu |
",srcip,vid,nsess);
}
}
else
perror("Connecting error: ");
printf("
\n");
printf("\n");
return 0;
}
int Bala_Sticky( char *addr )
{
unsigned int vid;
char srcip[16],dstip[16];
time_t ttl,ct;
struct sockaddr_in da_sin;
int s;
char *buf="GET /sticky HTTP/1.1";
char resp[512],cur_time[64];
if ( (s = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
return 1;
}
memset((char *)&da_sin, 0, sizeof(struct sockaddr_in));
da_sin.sin_family = AF_INET;
da_sin.sin_port = htons(1080);
da_sin.sin_addr.s_addr = inet_addr(addr);
printf("Content-type: text/html\n\n");
printf(" SS5 balancing manager\n");
printf("");
printf(" VIP table:
");
printf("\n");
printf("| Source IP | Virtual ID | Destination IP | TTL | Current date |
\n");
if( connect(s,(struct sockaddr *)&da_sin,sizeof(struct sockaddr_in)) != -1 ) {
if( send(s,buf,strlen(buf),SS5_SEND_OPT) == -1) {
perror("Sending error: ");
return -1;
}
while( recv(s,resp,512,0) > 0 ) {
sscanf(resp,"%s\n%u\n%s\n%lu\n%lu\n",srcip,&vid,dstip,&ttl,&ct);
#ifdef SOLARIS
ctime_r(&ct,cur_time,sizeof(cur_time));
#else
ctime_r(&ct,cur_time);
#endif
printf("| %s | %u | %s | %s | %s |
",srcip,vid,dstip,ctime(&ttl),cur_time);
}
}
else
perror("Connecting error: ");
printf("
\n");
printf("\n");
return 0;
}