[WIPS 7번] WIPS 소스/ 채널 바꾸기 #2

패킷을 수신하기 위해서, 채널을 주기적으로 바꾸도록 했다. 처음에는 주기적으로 채널을 변경하도록 만들려고 했는데,  필요한지 모르겠다. 나중에 한번 다시 검증을 해봐야겠다.

thread별로 동기화를 해서, Start되는 것을 맞춰줬어야 하는데, 크게 필요없을 것 같아서 안했다. 나중에 추가로 봐야 할 부분.

 

ChannelThread.c

/*==============================================================*/
/* ȭ ??  ??: ChannelThread.c                                   */
/* ??  ??:                                                      */
/*--------------------------------------------------------------*/
/* ???̺귯??:                                                  */
/* ?? ??  ??: ??????                                            */
/* ???ȭ??: ChannelThread.c                                    */
/* ?? ??  ??: 20.9.01( ?????????? :  .  .)                      */
/*--------------------------------------------------------------*/
/* ??  ??:                                                      */
/*                                                              */
/*--------------------------------------------------------------*/
/*
 * $Log: ChannelThread.c,v $
 *
 *                                                              */
/*--------------------------------------------------------------*/

#define _GNU_SOURCE

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <sched.h>
#include <time.h>


#include "iwlib.h"
#include "wips.h"
#include "ScanThread.h"
#include "IGIetc.h"


extern ap_t         AccessPoint[];
extern ap_t         AllowedAPDev[];
extern device_t     AllowedDevice[];
extern blocklist_t  BlockList[];
extern ini_t  ini;

char overTime(long lastTime, long curTime, int interval)
{
	long gap;

	gap = curTime - lastTime;

	if (gap > interval) return 1;

	return 0;
}


void delayScanTime(int interval)
{
	usleep(interval);
}


void *ChannelThread(void *arg)
{
	int pos;
	char buf[MAX_STRING_LENGTH];
	long lastTime, curTime;
	int rt;
	int skfd;
	double freq;
	struct iwreq wrq;
	struct iw_range range;
	char buffer[128];
	int ch=0;

	tfunc_t *func = (tfunc_t *) arg;


  printf("[!] Change Channel Thread Starting....\n");


	/*-----------------------------------------------
	 * ???? ????? ??, ä???? ??ü ??ȯ?Ͽ?, 
	 * SCAN_THREAD???? SSID?? ?????Ѵ?.
	 * ?????? ?ѹ??? ????ǵ??? ?Ͽ???.
	 */
	skfd = iw_sockets_open();
	if (skfd < 0) { 
		printf("[X] iw_socket_open error\n");
		perror("socket");
		return ((void*)0);
	}
	rt = iw_get_range_info(skfd, ini.dev, &range);
	if (rt < 0)  {
		printf("[X] iw_get_range_info error\n");
		perror("socket");
		return ((void*)0);
	}
	for (int j=0; j<range.num_frequency; j++) {
		freq = iw_freq2float(&(range.freq[j]));
		iw_print_freq_value(buffer, sizeof(buffer), freq);
#ifdef DEBUG_CHANNEL_DETAIL
		printf("[!] Channel Scanning #%.3d : %s\r", range.freq[j].i, buffer);
		fflush(stdout);
#endif

		sprintf(buf, "./%s %s %d %s", ini.sh_chg_channel, ini.dev, range.freq[j].i, ini.logname);
//		printf("%s\n", buf);

		while (ini.deauth) usleep(1000);	

		system(buf);
		delayScanTime(ini.channel_interval);
	}

	pos = -1;
	lastTime = time(0);
	do {
		int channel;

  	printf("[!] Channel Thread Running....\n");
		sleep(0);

		pos++;
		curTime = time(0);

//		if (!isExistBlockAP() || overTime(lastTime, curTime, ini.scan_interval)) {
		if (overTime(lastTime, curTime, ini.scan_interval) || IS0000(AccessPoint[0].mac)) {
			lastTime = curTime;

//			memset(AccessPoint, 0, sizeof(AccessPoint));

			/*---------------------------------------------------------
	 		 * scan_interval?? ?????ٸ?, SSID?? ??ĵ?Ѵ?.
	 		 *
   		 * ?ѹ? ??ĵ ?? ??????, ä?? 1 ???? ä???? 0.5?? ?????ϵ??? ?ϰ?, 
   		 * ä???? ??????Ų??.
	 		 * ?? 14?? ä???? ??ȸ?ϴµ? ?? 7?ʰ? ?ҿ?ȴ?.
	 		 */
			if (iw_get_range_info(skfd, ini.dev, &range) < 0)  {
				fprintf(stderr, "%-8.16s no frequency information.\n\n", ini.dev);
				sleep(1);
				continue;
			}
			printf("\n");

			for (int j=0; j<range.num_frequency; j++) {
				freq = iw_freq2float(&(range.freq[j]));
				iw_print_freq_value(buffer, sizeof(buffer), freq);
#ifdef DEBUG_CHANNEL_DETAIL
				printf("[!] Channel Scanning #%.3d : %s\r", range.freq[j].i, buffer);
				fflush(stdout);
#endif

				sprintf(buf, "./%s %s %d %s", ini.sh_chg_channel, ini.dev, range.freq[j].i, ini.logname);
				while (ini.deauth) usleep(1000);	

				system(buf);
				delayScanTime(ini.channel_interval);
			}
		}
		printf("\n");
		ch = 0;
		for (int i=0; i<MAX_SSID_CNT; i++) {

			if (!AccessPoint[i].enable && IS0000(AccessPoint[i].mac)) break;
			if (!AccessPoint[i].enable) continue;

			if (ch == AccessPoint[i].channel) continue;
			ch = AccessPoint[i].channel;

#ifdef DEBUG_CHANNEL_DETAIL
			printf("[!] Channel Scanning #%.3d : %3.1fGhz\r", AccessPoint[i].channel, AccessPoint[i].frequency/1000.0);
			fflush(stdout);
#endif
			sprintf(buf, "./%s %s %d %s", ini.sh_chg_channel, ini.dev, AccessPoint[i].channel, ini.logname);
			while (ini.deauth) usleep(1000);	
			sleep(0);

			system(buf);
			delayScanTime(ini.channel_interval);
		}
		

		/*-------------------------------------------------
		 * ???̻? ??ȸ?? SSID?????? ???ų?, ?迭?? ?ʰ??? ???, 
		 * 0 ???? ?ٽ? ?????Ѵ?.
		 * ???? ???? ?ɸ? ?? ?Ͽ?, sleep()?? ?ְ?, yield()?? ȣ????.
		 */
		if ( (pos >= MAX_SSID_CNT) ||  
          (!AccessPoint[pos].enable && IS0000(AccessPoint[pos].mac)) ) {
			pos = -1;
			usleep(1000);
			pthread_yield();

			continue;
		}

	} while (1);

	iw_sockets_close(skfd);

  printf("[!] ChannelThread Termination\n");
  return ((void*)0);
}