Code:

---

#define PACKET_SIZE        512
/* Open the file to be sent to the server */
if ((fd = open(deviceInfo->recFile, O_RDONLY)) < 0) {
        sprintf (message, "Error opening file '%s': %s", deviceInfo->recFile, strerror (errno));
        send_msg_to_server (message);
        return NULL;
}
/* Send the file contents to the automation server */
while ((numbytes = read (fd, buf, PACKET_SIZE - 1)) > 0) {
        buf[numbytes] = '\0';
        if ((numbytes = send_msg_to_server (buf)) == -1) {
                close (fd);
                return NULL;
        }
}
close (fd);

---

Code:

---

#define PACKET_SIZE        512
ufds[0].fd = g_sockfd;
ufds[0].events = POLLIN;
addr_len = sizeof (recv_addr);
/* Read the file contents from the socket and write it to a text file */
while ((retval = poll (ufds, 1, TIMEOUT)) > 0) {
        if ((numbytes = recvfrom (g_sockfd, buf, PACKET_SIZE, 0,
                (struct sockaddr *) &recv_addr, &addr_len)) > 0) {
                buf[numbytes] = '\0';
                if ((numbytes = fwrite(&buf, strlen (buf), 1, fpRec)) <= 0) {
                        perror("fwrite");
                        return -1;
                }
                fflush(fpRec);
        } else {
                perror("recvfrom");
                return -1;
        }
}

---

Code:

---

typedef struct _CHUNK_HEADER
{
    int    iType;        // Allows for sending different chunk types
    int    iSize;        // Allows for validating the size
    int    iChecksum;    // Allows for detection of corrupt chunks
    int    iSequence;    // Allows for detection of missing chunks
} CHUNK_HEADER, *PCHUNK_HEADER __attribute__((packed));

---