Dotaz: Neblokujici operace se socketem

[roman]

Dobry den, trochu si hraji se socketama v linuxu, takovy maly chat jen mezi dvema pocitaci, jednoduse se pripojim k druhemu stroji, ten muze poslat data nebo naopak je mohu poslat ja.

Mam trochu problem jak do jednoho programu vmesnat i to odesilani, umim prijimat data, cekam v nekonecne smycce a ctu data ze socketu, pokud se nejaka objevi tak je jen zobrazim.

Lze nejak zaridit neblokujici volani read? Abych mohl dovolit uzivateli v tu chvili i zadavat data, ukoncit enterem a odeslat?

Nebo lze nejak zaridit, aby se po prichodu dat vyvolava nejaka mnou definovana fce? Nebo treba signal.

Nebo tuto ulohu musim rozdeli do vlakna ve kterem budu jen cist data ze site a v hlavnim main programu budu cekat na uzivatelsky vstup a ten odesilat do site?

Jo abych nezapomel, pisu to v jazyce C.

Dekuji za info jak toto vyresit.

Odpovědi

[Michal Kubeček]

Chcete-li neblokující čtení, můžete buď použít příznak O_NONBLOCK rovnou při volání open() nebo ho následně nastavit pomocí fcntl(). U socketu to asi jde jen tím druhým způsobem. Obvykle dávám přednost čtení v samostatném threadu nebo procesu, ale ve vašem případě bude možná neblokující čtení v kombinaci s poll() (nebo select()) jednodušší.

[roman]

Dekuji na informaci, zkusim variantu s vlaknem pro cteni, nebyl by nejaky example?

[Michal Kubeček]

Příloha:

• netdemo.tar.bz2 (3902 bytů)

Zkuste se podívat do přílohy, jsou tam tři různé implementace serveru pro službu time (nebo daytime, nikdy si nepamatuji, která je která), mp-poll funguje pomocí poll(), mp-fork používá samostatné procesy a mp-thread samostatná vlákna. Není to sice zrovna to, co byste potřeboval (tahle služba od klienta nic nečte), ale třeba vám to k něčemu bude.

[roman]

dekuji mnohokrat, prostuduji to.

[Pavel Löbl]

Pouziti select je zde asi fakt jednodussi nez vlakna nebo procesy. Takhle by to mohlo jit, ale netvrdim ze to je nejlepsi reseni :) Je to jen navrh, bylo by asi jeste potreba cekat na konec zpravy (nejaky oddelovac), neni zaruceno ze ji prectete celou jednim volanim recv. atd

int sock;

...

struct timeval timeout;
timeout.tv_usec = 0;
	
char buffer[BUFFER_SIZE];
ssize_t ret;
fd_set sock_set;

FD_ZERO(&sock_set);
		
while(1)
{
  timeout.tv_sec = TIMEOUT;

  /* nastaveni deskriptoru ktere budem sledovat */
  FD_SET(sock, &sock_set);
  FD_SET(STDIN_FILENO, &sock_set);	

  /* sledovani deskriptoru */		
  if((ret = select(MAX(sock, STDIN_FILENO)+1, &sock_set, 0, 0, &timeout)) == -1)
      /* osetreni chyby */

  /* pokud lze cist ze socketu */	
  if(FD_ISSET(sock, &sock_set))
  {
    if((ret = recv(sock, buffer, BUFFER_SIZE, O_NONBLOCK) == -1)
      /* osetreni chyby */

    if(ret == 0)
      break;
			
    if((ret = write(STDOUT_FILENO, buffer, ret)) == -1)
      /* osetreni chyby */
  }		

  /* pokud lze cist ze std. vstupu */	
  if(FD_ISSET(STDIN_FILENO, &sock_set))
  {
    if((ret = read(STDIN_FILENO, buffer, BUFFER_SIZE)) == -1)
      /* osetreni chyby */ */
	
    if(ret == 0)
      break;

    if((ret = send(sock, buffer, ret, O_NONBLOCK) == -1)
      /* osetreni chyby */
  }	

  ... 

}

[Mr.S1lent.cz]

Co takhle normalne pouzit neblokujici rezim socketu?

int oldFlag = fcntl( sock_id, F_GETFL, 0 );
fcntl( sock_id, F_SETFL, oldFlag | O_NONBLOCK );

[Vojtěch Horký]

Viz #1.