Torna indietro   Hardware Upgrade Forum > Software > Programmazione

La rivoluzione dei dati in tempo reale è in arrivo. Un assaggio a Confluent Current 2025
La rivoluzione dei dati in tempo reale è in arrivo. Un assaggio a Confluent Current 2025
Siamo andati a Londra per partecipare a Current 2025, la conferenza annuale di Confluent. Il tema al centro dell'evento era l'elaborazione dei dati in tempo reale resa possibile da Apache Kafka, una piattaforma open source pensata proprio per questo. Si è parlato di come stia cambiando la gestione dei dati in tempo reale, del perché sia importante e di quali siano le prospettive per il futuro
SAP Sapphire 2025: con Joule l'intelligenza artificiale guida app, dati e decisioni
SAP Sapphire 2025: con Joule l'intelligenza artificiale guida app, dati e decisioni
A Madrid SAP rilancia sulla visione di un ecosistema integrato dove app, dati e AI generano un circolo virtuoso capace di affrontare l’incertezza globale. Joule diventa l’interfaccia universale del business, anche oltre il perimetro SAP
Dalle radio a transistor ai Micro LED: il viaggio di Hisense da Qingdao al mondo intero
Dalle radio a transistor ai Micro LED: il viaggio di Hisense da Qingdao al mondo intero
Una delle realtà a maggiore crescita nel mondo dell'elettronica di consumo, Hisense Group, affonda le sue radici nella storica città portuale di Qingdao, famosa per la sua birra. Ed è proprio qui il centro nevralgico dell'espansione mondiale dell'azienda, che sta investendo massicciamente in infrastrutture e ricerca per consolidare ulteriormente la propria leadership tecnologica.
Tutti gli articoli Tutte le news

Vai al Forum
Rispondi
 
Strumenti
Old 27-03-2006, 21:57   #1
Abdujaparov
Senior Member
 
Iscritto dal: Aug 2004
Città: Palermo
Messaggi: 1079
Piccolo server c II

Salve a tuti, sto cercando di realizzare un piccolo server c che dopo aver permesso all'utente di autenticarsi riceve in ingresso un determinato insieme di byte e ritorna la radice n-esima dei numeri ricevuto. In pratica il server riceve un byte con l'indice della radice, un byte contenente la dimensione dell'operando e in base al numero ricevuto legge gli n byte dell'operando.
Io ho scritto il server (il figlio che viene generato, è un server concorrente) in questo modo, solo che non mi viene preso l'operando. Sotto copio solo la parte essenziale per la riceizione e l'invio di dati, da parte del server. Io non ho il client, devo realizzare un server per un client che "dialoga" con il protocollo scritto sopra. Allego anche la parte del client che ho provato a scrivere per fare le prove.
Qualcuno può aiutarmi a capire cosa sbaglio?
Grazie, ciao ciao.

//SERVER
static void compito(int connfd, char* file_pass){

char buf[BUFL];
int n;//numero di byte letti
uint8_t radice, uris;
uint16_t base2;



//parte di autenticazione omessa, quella funziona, sono dati ascci

//entro nel ciclo e vi rimango fino a quando il client non termina la connessione
while(1){
//azzero il buffer in cui metterò i dati binari
memset (&buf, 0, sizeof(buf));
n=0;//azzero il contatore dei byte letti


//attendo di leggere i dati che l'utente mi invia

n=readn(connfd, buf, 2); //leggo i primi due byte

//prendo la radice e la metto in un uint8 che ha grandezza un byte
memcpy(&radice, &buf[0], 1); //copio il primo byte nella variabile radice



//prendo la dimensione e la metto in un uint8 che ha grandezza un byte
uint8_t dim;
memcpy(&dim, &buf[1], 1);
//pulisco il buffer
memset (&buf, 0, sizeof(buf));



//lascio solo il caso in cui la dimensione è due (gli altri valori consentiti sono 1 e 4)
if(dim==2){
n=readn(connfd, buf, 2);
memcpy(&base2, &buf[0], dim);//leggo gli altri 2 byte, solo che n mi viene detto che è 0 e non legge nulla, ma la readn, se non riceve nulla, non dovrebbe rimanere bloccata? perchè invece il programma continua ad andare avanti?


base2=ntohs(base2);
uint16_t ris = sqrtn(base2, radice);
ris=htons(ris);
struct risposta{uint8_t uris; uint16_t risultato;}__attribute__((packed)) dati;
dati.uris=0;
dati.risultato=ris;

Writen(connfd, &dati, sizeof(dati)); //invio la struttura con il risultato

}

}




//CLIENT
uint8_t radice=5;
base= htonl(base); // operando in formato di rete, è un uint16_t
dim = sizeof(base); //dimensione operando, è un uint8_t

//invio i dati
Writen(socket,&pluto, sizeof(radice));
Writen(socket,&dim, sizeof(dim));
Writen(socket,&base,sizeof(base)); //non mi viene letto, mi legge 0 byte dopo aver letto i primi due


//parte per leggere il risultato dal server
int nonno = Readn(socket, buf, 1);
memcpy(&stato,&buf[0],1);

memset(&buf, 0, sizeof(buf));
nonno = Readn(socket, buf, sizeof(base));
memcpy(&ris,&buf[0],sizeof(base));
ris=ntohs(ris);
Abdujaparov è offline   Rispondi citando il messaggio o parte di esso
Old 27-03-2006, 23:25   #2
mr_hyde
Senior Member
 
Iscritto dal: Oct 2005
Città: Genova
Messaggi: 937
Quote:
Originariamente inviato da Abdujaparov
[...]
n=readn(connfd, buf, 2);
memcpy(&base2, &buf[0], dim);//leggo gli altri 2 byte, solo che n mi viene detto che è 0 e non legge nulla, ma la readn, se non riceve nulla, non dovrebbe rimanere bloccata? perchè invece il programma continua ad andare avanti?
Come ti ho gia' scritto nell'altro 3ad non conosco "readn", ma se funziona come "read" ti puo' restituire 0 (e non rimanere bloccata) in alcuni casi, ad esempio se l'altro "capo" della connessione e' stato chiuso (o se ci sono stati altri errori). Controlla sulla documentazone relativa a "readn" se, per caso, quando non restituisce "0" non imposta anche "errno" in modo da capire il significato dello "0" (ho visto alcune implementazioni che fanno proprio cosi').
Comunque, in generale, una read (non "readn" che ripeto non conosco) che restituisce "0" indica un end of file (be', in questo caso direi piu' end of transmission)

Quote:
//CLIENT
uint8_t radice=5;
base= htonl(base); // operando in formato di rete, è un uint16_t
Occhio che htonl converte tipi a 4 byte, non 2 (ti serve quindi un uint32). E' "htons" che va con uint16

Quote:
dim = sizeof(base); //dimensione operando, è un uint8_t
Non e' certo questo il problema, io pero' qui per "pulizia di codice" metterei un cast per evidenziare a chi legge il codice che c'e' un'assegnazione tra tipi diversi che, potenzialmente, puo' portare a perdita di informazione.
Infatti "sizeof" restituisce un tipo "size_t" che, tipicamente, e' semplicemente una typedef ad "unsigned int",
quindi ad un tipo di dato che viene memorizzato su 4 byte, mentre dim e' un uin8 (da quello che scrivi)

Quote:
//parte per leggere il risultato dal server
int nonno = Readn(socket, buf, 1);
memcpy(&stato,&buf[0],1);
scusa, ma perche' non fai semplicemente
uin8_t stato;
int nonno = Readn(socket, &stato, sizeof(uint8_t)) ?
immagino che pero' il prototipo di Readn sia

int Readn(int socketId, void* buffer, unsigned int size)

allora dovresti scrivere

int nonno = Readn(socket, (void*) &stato, sizeof(uint8_t));
Quote:
memset(&buf, 0, sizeof(buf));
nonno = Readn(socket, buf, sizeof(base));
memcpy(&ris,&buf[0],sizeof(base));
cosiderazione analoga a prima

Quote:
ris=ntohs(ris);
quindi ris e' un16_t?

Ciao,
Mr Hyde
__________________
MacMini Late 2009/MacMini 2018
mr_hyde è offline   Rispondi citando il messaggio o parte di esso
Old 28-03-2006, 06:33   #3
Abdujaparov
Senior Member
 
Iscritto dal: Aug 2004
Città: Palermo
Messaggi: 1079
Si è uint16_t, mi sono confuso perchè l'operando può essere, a descrizione del client, un uint_t, uint16_t e uint32_t. La readn dovrebbe essere bloccante e rimanere incantata fino a quando non riceve il numero di byte che aspetta.
A me interessa leggere i byte a piccoli blocchi, prima i primi due, poi l'operando, elaboro (invio un byte di sato ed il risultato su tanti byte quanti sono i byte dell'operando) lo invio e ritorno in attesa, senza altri fronzoli.
Non so se il client mi invia tutto insieme in una struct o prima mi invia prima un byte, poi un byte e poi l'operando con 3 write. Se metto una read mi viene letto solo il primo write, appunto per questo, voglio leggerli a blocchi.
Grazie moltissimo, ciao ciao.
Abdujaparov è offline   Rispondi citando il messaggio o parte di esso
Old 30-03-2006, 14:34   #4
Abdujaparov
Senior Member
 
Iscritto dal: Aug 2004
Città: Palermo
Messaggi: 1079
Ciao a tutti, volevo ringraziare MrHyde sono riuscito a risolvere tutto finalmente ed ora sono contento, però volevo chiedere un'ultima cosa.
Quando il client chiude la connessione il server non esce subito ma prima fa tutte le readn dicendo che ha ricevuto zero ovunque e poi esce. Vedendo quello che sucede spero di essere più chiaro:

Pezzo server:

while(1){

#ifdef TRACE
err_msg("Sono in attesa dei dati su cui operare.\n");
#endif

//attendo di leggere i dati che l'utente mi invia
n=ReadN(connfd, buf, 2);
#ifdef TRACE
err_msg("Ho ricevuto %d bytes\n", n);
#endif

//prendo la radice e la metto in un uint8 che ha grandezza un byte
memcpy(&radice, &buf[0], 1);



#ifdef TRACE
err_msg("Ho ricevuto questa radice %u\n", radice);
#endif


memcpy(&dim, &buf[1], 1);
//pulisco il buffer
memset (&buf, 0, sizeof(buf));

#ifdef TRACE
err_msg("La dimensione dell'operando e': %u\n", dim);
#endif

//qua c'è una readn come le precedenti

#ifdef TRACE
err_msg("La variabile errori e': %u\n", errori);
#endif

/*Se il calcolo è corretto invio 0 seguito dal risultato se è sbagliato invio 1*/


//fine del ciclo e si ritorna su sono in attesa di un operando

}

}

La chiusura del client avviene dopo aver inviato una richiesta ed aver letto la risposta, in questo modo:

Close(socket);

exit(0);

L'output che mi da il server è il seguente:

Sono in attesa dei dati su cui operare.

Ho ricevuto 2 bytes

Ho ricevuto questa radice 3

La dimensione dell'operando e': 4

La variabile errori e': 0

L'operando è: 729 //fine della richiesta

Sono in attesa dei dati su cui operare. //inizio del cliclo

Ho ricevuto 0 bytes //prima readn, non dovrebbe uscire qui?

Ho ricevuto questa radice 0

La dimensione dell'operando e': 0

La variabile errori e': 1

Sono in attesa dei dati su cui operare.

//ora esce del programma
(./server) info - connessione chiusa dal client
(./server) info - figlio 3472 terminato con status 0



Come posso evitare che il server esamini una richiesta inesistente in chiusura di connessione?
Io ho wrappato la funzione readn perchè chiuda il programma appena ci sono problemi nella connessione.
Grazie, ciao ciao.
Abdujaparov è offline   Rispondi citando il messaggio o parte di esso
Old 30-03-2006, 14:50   #5
mr_hyde
Senior Member
 
Iscritto dal: Oct 2005
Città: Genova
Messaggi: 937
Non ho ancora letto bene il tuo post, ma forse setsockopt e SO_LINGER ti possono aiutare.

Ciao,
Mr Hyde
__________________
MacMini Late 2009/MacMini 2018
mr_hyde è offline   Rispondi citando il messaggio o parte di esso
 Rispondi


La rivoluzione dei dati in tempo reale è in arrivo. Un assaggio a Confluent Current 2025 La rivoluzione dei dati in tempo reale è ...
SAP Sapphire 2025: con Joule l'intelligenza artificiale guida app, dati e decisioni SAP Sapphire 2025: con Joule l'intelligenza arti...
Dalle radio a transistor ai Micro LED: il viaggio di Hisense da Qingdao al mondo intero Dalle radio a transistor ai Micro LED: il viaggi...
Meglio un MacBook o un PC portatile con Windows, oggi? Scenari, dubbi e qualche certezza Meglio un MacBook o un PC portatile con Windows,...
realme GT7: un "flaghsip killer" concreto! La recensione realme GT7: un "flaghsip killer" concr...
Download.it salva FilePlanet: oltre 120....
WhatsApp sta per introdurre gli username...
Successo per il primo test della PEC eur...
Cosa cambia con la partnership fra Pure ...
Sony abbandona la produzione interna deg...
Il futuro degli aerei elettrici passa pe...
Sentenza blocca i dazi di Trump: "I...
Xiaomi SU7 è super popolare nei m...
AMAZFIT Active 2 a 94€ e tutti gli altri...
Smartphone con super batteria: Realme pr...
L'IA supererà Bitcoin: consumi en...
E-tattoo: arriva il tatuaggio elettronic...
GreenMindAI Hackathon Catania: annunciat...
DeepSeek R1 si aggiorna: l'IA cinese ade...
Torna in offerta il portatile Lenovo con...
Chromium
GPU-Z
OCCT
LibreOffice Portable
Opera One Portable
Opera One 106
CCleaner Portable
CCleaner Standard
Cpu-Z
Driver NVIDIA GeForce 546.65 WHQL
SmartFTP
Trillian
Google Chrome Portable
Google Chrome 120
VirtualBox
Tutti gli articoli Tutte le news Tutti i download

Strumenti

Regole
Non Puoi aprire nuove discussioni
Non Puoi rispondere ai messaggi
Non Puoi allegare file
Non Puoi modificare i tuoi messaggi

Il codice vB è On
Le Faccine sono On
Il codice [IMG] è On
Il codice HTML è Off
Vai al Forum


Tutti gli orari sono GMT +1. Ora sono le: 14:38.


Powered by vBulletin® Version 3.6.4
Copyright ©2000 - 2025, Jelsoft Enterprises Ltd.
Served by www1v