Unsignedio
/
WiPacket
mirror of https://github.com/markqvist/WiPacket.git
1
0
Fork 0
Code Issues Releases Wiki Activity

File transfer examples

master
Mark Qvist 2014-05-26 17:42:46 +02:00
parent f50c76a9b6
commit 34caa987ab
2 changed files with 21 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
examples/rxfile.c
View File

@ -20,7 +20,8 @@ FILE *fd;
#define HEADER_SIZE 4 // Size of unsigned long
#define FRAGMENT_SIZE 1482
#define PACKET_SIZE HEADER_SIZE+FRAGMENT_SIZE
char buffer[PACKET_SIZE];
char sBuffer[PACKET_SIZE];
char aBuffer[HEADER_SIZE];
unsigned long fragment;
unsigned long ack;
@ -92,7 +93,7 @@ int main(int argc, char **argv) {
fragment = 0;
ack = 0;
int nRead;
int sRead;
bool done = false;
while (!done) {
@ -108,21 +109,21 @@ int main(int argc, char **argv) {
}
if (socketReady == 1) {
nRead = recv(wiSocket, buffer, PACKET_SIZE, 0);
if (nRead != 0) {
printf("Read %d bytes\n", nRead);
memcpy(&fragment, buffer, HEADER_SIZE);
sRead = recv(wiSocket, sBuffer, PACKET_SIZE, 0);
if (sRead != 0) {
printf("Read %d bytes\n", sRead);
memcpy(&fragment, sBuffer, HEADER_SIZE);
if (fragment == ack+1) {
printf("Got fragment %lu\n", fragment);
ack++;
if ((fwrite(buffer+HEADER_SIZE, 1, nRead - HEADER_SIZE, fd)) != nRead - HEADER_SIZE) {
if ((fwrite(sBuffer+HEADER_SIZE, 1, sRead - HEADER_SIZE, fd)) != sRead - HEADER_SIZE) {
printf("Error while writing received data to file\n");
exit(1);
}
memcpy(buffer, &ack, HEADER_SIZE);
if (send(wiSocket, buffer, HEADER_SIZE, 0) < 0) {
memcpy(aBuffer, &ack, HEADER_SIZE);
if (send(wiSocket, aBuffer, HEADER_SIZE, 0) < 0) {
printf("Error writing to WiPacket socket while sending ACK\n");
exit(1);
}

20
examples/txfile.c
View File

@ -20,7 +20,8 @@ FILE *fd;
#define HEADER_SIZE 4 // Size of unsigned long
#define FRAGMENT_SIZE 1482
#define PACKET_SIZE HEADER_SIZE+FRAGMENT_SIZE
char buffer[PACKET_SIZE];
char fBuffer[PACKET_SIZE];
char sBuffer[PACKET_SIZE];
unsigned long fragment;
unsigned long ack;
@ -93,15 +94,16 @@ int main(int argc, char **argv) {
fragment = 0;
ack = 0;
int nRead;
while ((nRead = fread(buffer+HEADER_SIZE, 1, FRAGMENT_SIZE, fd))) {
int fRead;
int sRead;
while ((fRead = fread(fBuffer+HEADER_SIZE, 1, FRAGMENT_SIZE, fd))) {
fragment++;
memcpy(buffer, &fragment, HEADER_SIZE);
memcpy(fBuffer, &fragment, HEADER_SIZE);
bool gotAck = false;
while (!gotAck) {
if (send(wiSocket, buffer, nRead, 0) < 0) {
if (send(wiSocket, fBuffer, fRead, 0) < 0) {
printf("Error writing to WiPacket socket\n");
exit(1);
}
@ -119,10 +121,10 @@ int main(int argc, char **argv) {
}
if (socketReady == 1) {
nRead = recv(wiSocket, buffer, PACKET_SIZE, 0);
if (nRead != 0) {
printf("Read %d bytes\n", nRead);
memcpy(&ack, buffer, HEADER_SIZE);
sRead = recv(wiSocket, sBuffer, PACKET_SIZE, 0);
if (sRead != 0) {
printf("Read %d bytes\n", sRead);
memcpy(&ack, sBuffer, HEADER_SIZE);
if (ack == fragment) {
gotAck = true;