C / C++ / MFC

SOCKET CMultycast_serverDlg::CreateTCPServerSocket(int PortNumber)
{
	// this function create a socket for each port
	int Socket = 0;                  /* socket to create */
    struct sockaddr_in echoServAddr; /* Local address    */
    int bind_res;
    WSADATA wsaData;
	CString string;
	unsigned long argp = 1;

    if(WSAStartup(0x202,&wsaData) == SOCKET_ERROR)
	{
		AfxMessageBox(" Error :  WSAStartup() has failed   ");
		return -1;
	}

    /*==== Create socket for incoming connections ====*/
	Socket = socket(PF_INET,SOCK_STREAM,IPPROTO_TCP);
	if(Socket == INVALID_SOCKET)
	{
		string.Format("  Unable to create socket for port #%d  ",PortNumber);
		AfxMessageBox(string);
		return -1;
	}

 	ioctlsocket(Socket , FIONBIO , &argp);
   /*==== Construct local address structure ====*/
	memset(&echoServAddr,0,sizeof(echoServAddr));           //zero out structure
	echoServAddr.sin_family=AF_INET;                        //internet address family
	echoServAddr.sin_addr.S_un.S_addr=htonl(INADDR_ANY);    //any incoming inteface
	echoServAddr.sin_port=htons(PortNumber);                //local address
    
    /*==== bind to the local address ====*/
	bind_res = bind(Socket,(struct sockaddr*)&echoServAddr,sizeof(echoServAddr));
	if(bind_res == SOCKET_ERROR)
	{
		string.Format("  Unable to create bind to local address for port #%d  ",PortNumber);
		AfxMessageBox(string);
		return -1;
	}

	/*==== mark the socket so it will listen for incoming connections ====*/
	if(listen(Socket,MAXPENDING) == SOCKET_ERROR)
	{
		string.Format("  Unable to listen to socket in port #%d  ",PortNumber);
		AfxMessageBox(string);
		return -1;
	}

	return Socket;
}

struct pr<br />
{<br />
	char nume[1024];<br />
};<br />
<br />
#pragma data_seg("SHARED")<br />
HHOOK cbt=0;<br />
pr procs[100];<br />
int cnt=0;<br />
#pragma data_seg()<br />
#pragma comment(linker, "/section:SHARED,RWS")<br />
<br />
//callback function<br />
<br />
LRESULT CALLBACK CallWndProc(int nCode,WPARAM wParam,LPARAM lParam)<br />
{<br />
<br />
	if (nCode<0)<br />
		return CallNextHookEx(cbt,nCode,wParam,lParam);<br />
<br />
		CWPSTRUCT *wps = (CWPSTRUCT*)lParam;<br />
<br />
<br />
DWORD pid;<br />
GetWindowThreadProcessId((HWND)wps->hwnd,&pid);<br />
HANDLE hProc;<br />
hProc=OpenProcess(PROCESS_ALL_ACCESS,FALSE,pid);<br />
HMODULE mods[100];<br />
DWORD size;<br />
char nume[1024];<br />
<br />
<br />
if (EnumProcessModules(hProc,mods,sizeof(mods),&size))<br />
if (size>0)<br />
GetModuleFileNameEx(hProc,mods[0],nume,sizeof(nume));<br />
<br />
<br />
<br />
//here I create a mutex because this section of the code should only be done //once in initializing. how can I do this initializig so I won't get the error<br />
//because the variable "nume" is always the module filename of my program<br />
CreateMutex(0,0,"Pula");<br />
if (GetLastError()!=ERROR_ALREADY_EXISTS)<br />
{<br />
CreateMutex(0,0,"Pula");<br />
FILE *str;<br />
char temp[1024];<br />
GetTempPath(sizeof(temp),temp);<br />
strcat(temp,"\\IdleProcesses.sys");<br />
str=fopen(temp,"a+");<br />
int i;<br />
i=0;<br />
while(!feof(str))<br />
{<br />
i++;<br />
fgets(temp,sizeof(temp),str);<br />
temp[strlen(temp)-1]='\0';<br />
strcpy(procs[i].nume,temp);<br />
<br />
}<br />
fclose(str);<br />
cnt=i;<br />
}<br />
<br />
<br />
<br />
<br />
for (int i=1; i<=cnt; i++)<br />
<br />
<br />
if (StrStrI(nume,procs[i].nume)!=NULL)<br />
{<br />
	DWORD exit;<br />
	GetExitCodeProcess(hProc,&exit);<br />
	TerminateProcess(hProc,exit);<br />
}<br />
<br />
<br />
	return CallNextHookEx(cbt,nCode,wParam,lParam);<br />
<br />
}<code>