---

Sender Klassenreferenz

Sender zerlegt und verschickt Textfiles. Mehr...

#include <Sender.h>

Öffentliche Datenelemente
	Sender (int iPort)
void	run (void)
Private Datenelemente
RNPRESULT	MessageHandler (void *pvoidPacket, WORD wSize)
Private, statische Datenelemente
RNPRESULT	StaticMessageHandler (void *pvoidUserContext, void *pvoidPacket, WORD wSize)
Private Attribute
int	m_iPort
	Port, das für die Verbindung genutzt wird. Mehr...

---

Ausführliche Beschreibung

Sender zerlegt und verschickt Textfiles.

Sender verbindet sich zu einer IP und schickt dann ein (zerstückeltes) Textfile an den Receiver.

---

Beschreibung der Konstruktoren und Destruktoren

Sender::Sender (  int    iPort )

Konstruktor, hinterlegt den Port { m_iPort=iPort; }

---

Dokumentation der Elementfunktionen

RNPRESULT Sender::MessageHandler (  void *    pvoidPacket, WORD    wSize )  [private]

Empfängt und verarbeitet die Nachrichten. Dafür wird zunächst der Nachrichtentyp anhand von MessageGeneric::m_Type erkannt, und dann der void* entsprechend gecasted. { MessageGeneric* pmsgTmp= (MessageGeneric*)pvoidPacket; /* switch (pmsgTmp->m_Type) { default: return RNP_BUFFER_RETURNED; } */ return RNP_BUFFER_RETURNED; }

void Sender::run (  void    )

Fragt den Users nach einer IP und baut eine Verbindung auf. Der User kann nun Textfiles verschicken. { RNPRESULT rnprTmp; char pcEingabe[1024]; // IP erfragen printf("IP >"); gets(pcEingabe); // RNPacket initialisieren RNPacket rnpSend; if(rnpSend.initMessageCallBack(this,StaticMessageHandler) == RNP_OK) { printf("MessageHandler inited.\n"); } else { return; } // Verbindung aufbauen printf("Trying to connect..."); do { rnprTmp=rnpSend.socketConnect(pcEingabe,m_iPort); if (kbhit()) { printf("\nUser aborted.\n"); getch(); return; } Sleep(100); printf("."); } while (rnprTmp == RNP_SOCKET_NOT_CONNECTED); printf("\n"); // Testen ob Verbindung erfolgreich if (rnprTmp != RNP_OK) { printf("Error occured.\n"); return; } printf("Connected to %s.\n",pcEingabe); DWORD dwPacketNr=0; int iCharCount; // In Schleife nach Filenamen fragen while(true) { printf("File >"); gets(pcEingabe); // Bei leerer Eingabe beenden if (pcEingabe[0]==0) { break; } // File öffnen FILE* pfileIn=fopen(pcEingabe,"r"); iCharCount=0; // Erfolgreich geöffnet ? if (pfileIn==NULL) { printf("File does not exist! Sending input itself.\n"); } else { printf("Sending file...\n"); } // Packet erstellen MessageCharFragment msgcfTmp; msgcfTmp.m_Type=MSGID_CHARFRAGMENT; msgcfTmp.m_dwNextPacketNr=c_dwFirstCharFragment; int iBuf; // Packete in einer Schleife erstellen do { // dieses Packet bekommt Nummer, die das Vorhergehende als Nachfolger hatte (klar, oder? ;) msgcfTmp.m_dwPacketNr=msgcfTmp.m_dwNextPacketNr; int iCount; // Charbuffer lesen aus File oder Eingabe for (iCount=0; iCount<c_dwSizeCharFragment; iCount++) { if (pfileIn!=NULL) { iBuf=fgetc(pfileIn); } else { iBuf=pcEingabe[iCharCount]; if (iBuf==0) { iBuf=EOF; } else { iCharCount++; } } msgcfTmp.m_cBuffer[iCount]=(char)iBuf; // am Ende nur noch Nullen anhängen if (iBuf==EOF) { msgcfTmp.m_cBuffer[iCount]=0; } } // Packetnummer weiterzählen if (iBuf==EOF) { msgcfTmp.m_dwNextPacketNr=c_dwLastCharFragment; } else { msgcfTmp.m_dwNextPacketNr=dwPacketNr; dwPacketNr++; } // Senden, falls möglich do { rnprTmp=rnpSend.sendMessage((void*)&msgcfTmp,sizeof(msgcfTmp)); // bei Tastedruck abbrechen if (kbhit()) { break; } } while (rnprTmp==RNP_SOCKET_NOT_WRITEABLE); //Verbindungsabbruch if (rnprTmp != RNP_OK) { printf("Connection closed...\n"); return; } //User hat gedrückt if (kbhit()) { printf("\nUser aborted.\n"); getch(); return; } } while (iBuf!=EOF); // Alle Pakete erfolgreich versendet! (evtl. File schliessen) printf("All Packets send.\n"); if (pfileIn != NULL) fclose(pfileIn); } // Socket schliessen if(rnpSend.socketClose() == RNP_OK) { printf("Socket closed.\n"); } else { printf("Error occured while closing Socket.\n"); } }

RNPRESULT Sender::StaticMessageHandler (  void *    pvoidUserContext, void *    pvoidPacket, WORD    wSize )  [static, private]

Ruft den eigentlichen (nicht static definierten) MessageHandler auf. { Sender* pThisObject = (Sender*) pvoidUserContext; return pThisObject->MessageHandler(pvoidPacket,wSize); }

---

Dokumentation der Datenelemente

int Sender::m_iPort [private]

Port, das für die Verbindung genutzt wird.

---

Die Dokumentation für diese Klasse wurde erzeugt aufgrund der Dateien:

• Sender.h
• Sender.cpp

---