Shared memory v serveru – C / C++ – Fórum – Programujte.com

Tak jsem tu zase. Pracuji na chatovacím serveru. Moje Idea je taková, že loginy budu uchovávat ve spojovém seznamu. Vzhledem k tomu že server je více procesní, tak jsem zvolil využít shared memory. No a samozřejmě jsem narazil na nefunčnost. Nehledě na to že se to při uložením loginu do seznamu kousne, tak navíc když se přihlasí další klient tak opět je v seznamu jen jeho login.. Není mi jasný co je na tom špatně. Případně se zamýšlím i na jiné možnosti jak ukládat loginy, ale zatím mě nic nenapadlo. Spojový seznam jsem zvolil z důvodu že mohu při odhlášení lehce odebrat login.. Děkuji moc za pomoc

#include <sys/shm.h>
#include <sys/ipc.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include "LList.h"

void error(char *);
void success(char *);
void send_error(int err);
void recv_error(int err);

int main(int argc, char **argv) {

	char buffer[1024];
	struct list *USERS = NULL;
	pid_t process;

	int shmid = shmget(1000, 16384, IPC_CREAT | 0666);
	USERS = shmat(shmid, NULL, 0);

	struct sockaddr_in serv_adr;
	struct sockaddr_in cli_adr;
	int listenfd, sd_current, clilen, stat;

	if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
		error("Unable to create socket.\n");
	} else {
		printf("Socket created.\n");
	}

	serv_adr.sin_family = AF_INET;
	serv_adr.sin_addr.s_addr = INADDR_ANY;
	serv_adr.sin_port = htons(1024);

	if (bind(listenfd, (struct sockaddr*) &serv_adr, sizeof(serv_adr)) < 0) {
		error("Unable to bind adress.\n");
		close(listenfd);
		exit(1);
	} else {
		printf("Client adress obtained.\n");
	}

	listen(listenfd, 5);

	while (1) {
		clilen = sizeof(cli_adr);
		sd_current = accept(listenfd, (struct sockaddr*) &cli_adr, &clilen);
		if (sd_current < 0) {
			error("Unable to accept connection.\n");
		} else {
			printf("Connection established.\n");
		}
		process = fork();
		if (process == 0) {
			close(listenfd);
			shmid = shmget(1000, 16384, IPC_CREAT | 0666);
			USERS = shmat(shmid, NULL, 0);
			while (1) {
				stat = recv(sd_current, buffer, 1024, 0);
				recv_error(stat);
				int a;
				for (a = 0; a < strlen(buffer); a++) {
					if (buffer[a] == 10) {
						buffer[a] = '\0';
					}
				}
				if ((strncmp(buffer, "#LOGIN#", 7)) == 0) {
					stat = send(sd_current, "OK\n", 3, 0);
					send_error(stat);
					add(buffer, &USERS);
					print(USERS);
					break;
				} else {
					stat = send(sd_current, "ERR\n", 6, 0);
					send_error(stat);
				}
				fflush(stdout);
			}
			fflush(stdout);
			while (1) {
				stat = recv(sd_current, buffer, 255, 0);
				recv_error(stat);
				stat = send(sd_current, "OK", 5, 0);
				send_error(stat);
			}
		} else {
			close(sd_current);
		}
	}
	close(listenfd);
	return 0;
}

pripada mi trochu ujety udrzovat klienty forknutym procesem zrovna pro chat... to se hodi treba pro nejaky ftp/http server - proste kde nepotrebujes komunikovat mezi podprocesorama...

Na chat bych byt tebou zneuzil jednu jednovlaknovou aplikaci, kdy pridavas spojeni do seznamu a pouzijes nad tim select ... ten pak bud vrati, ktere file descriptory maji data na cteni, daj se zapsat(to vetsinou neni problem) nebo chybu a ty to jen zpracujes (zaroven mas vse v jednom procesu, zadny vlakna a tak podobne)

#2 KIIV
No asi to bude mnohem jednoduší. Nějak jsem se snažil o ten fork(), ale už jsem začal uvažovat, že se na něj vykašlu. Takže jdu nastudovat použití toho select()

pripadne pouzit neblokujici rezim (http://www.root.cz/clanky/sokety-a-c-neblokovaci-rezim-soketu/) nicmene se selectem ktery by timeoutoval po dejme tomu sekunde by se dalo udrzet i relativne maly zatizeni procesoru

Tak jsem využil non blocking socket a mám k tomu jeden dotaz. Mámu toto nekonečnou smyčku, ale pro mě z neznámých důvodů akceptuje pouze jedno odeslaní a přijmutí. Víc toho nepřijme a netuším proč.

while (1) {

		sd_current = accept(listenfd, (struct sockaddr*) &cli_adr, &clilen);
		if (sd_current < 0) {
			//	error("Unable to accept connection.\n");
		} else {
			printf("Connection established.\n");
		}

		stat = read(sd_current, buffer, 1024);
		if (stat > 0) {
			printf("%d\n", stat);
		}
		stat = write(sd_current, "OK\n", 3);
		if (stat > 0) {
			printf("%d\n", stat);
		}
	}

Díky

chtelo by to mit kam ukladat a udrzovat ty zbyly spojeni ... takto nejspis prijmes, neco z nej nactes nebo vypises a hned v dalsim kole to uz prepise zase -1 dokud se neotevre nejake jine spojeni

(od toho se pak jeste hodi ten select a seznam socketu..)

#6 KIIV
Toto je testovaci smyčka. I když tám nechám jen read() a budu vypisovat jen pokud bude vysledek > 0 tak by to přeci nemělo na -1 brát zřetel ne? Dle mě mi to nechce při druhém průchodu již nic přečíst ze socketu

tady jde o to ze kdyz nejsou data tak read vraci 0 a ukonci se okamzite co se spusti...

nicmene uplne stejne se chova i accept - bud vrati cislo socketu nebo -1 kdyz se zrovna nic nesnazi pripojit...

(veskrze to znamena ze ten cyklus pojede na maximalni rychlost (a hlavne vytizeni) protoze to nikde proste neceka)

#8 KIIV
No jasně, to mi nedošlo s tím acceptem. Díky moc..

#8 KIIV
Takže server zatím běží. Login i Logout funguje, akorát zatížení procesoru je na max, což se mi moc nelíbí. Ale jestli to dobře chápu, tak řešení je asi právě ten select co?

#10 Redby
jop .. muzes mu nastavit ze ma cekat na tech spojenich nekonecne dlouho nebo treba nastavit ze se ma prerusovat cekani kazdych par sekund (nebo i mikrosekund) - vytizeni je proste proto, ze se nikde neceka s furt to jede a jede

#11 KIIV
OK, zkusím to implementovat. Zatím jsem použil jen usleep(), což taky pomohlo...:-) Díky moc za pomoc. Koukám ty tu jsi taky nonstop.