Doc Block fucked around with this message at 18:05 on May 31, 2015

//Read bytes from file inp_fd, send bytes through socket sd, use output of pipe pfd to send packet totals to receiveBytes, pfd2 currently not used

int sendBytes(int inp_fd, int sd, struct sockaddr_in sad, int *pfd, int* pfd2) 
{
	int nIncomingBytes, nOutGoingBytes, alen, bytes_sent, pckts_sent; 
	char buf[1000];									//once working, needs to be changed to be set by user input

	bytes_sent = 0;
	pckts_sent = 0;

	memset(buf, 0, sizeof(buf));
	nIncomingBytes = read(inp_fd, buf, sizeof(buf)); //Initial read in - sizeof(buf) chars
	
	alen = sizeof(sad);
	while(nIncomingBytes > 0)
	{		
		nOutGoingBytes = sendto(sd, buf, sizeof(buf), 0, (struct sockaddr*)&sad, alen); //send to server
		bytes_sent += nIncomingBytes; 						//accumulated for later
		pckts_sent++;								//accumulated to be sent to recieveBytes via pipe pfd
		memset(buf, 0, sizeof(buf)); 						//reset between reads to avoid junk data when full buffer is not used
		nIncomingBytes = read(inp_fd, buf, sizeof(buf)); 			//read next block in from file
	}

	/*At this point, all packets have been sent, so we have a complete count of packets and bytes sent*/
	printf("Packets sent: %d, comprising %d bits.\n", pckts_sent, (bytes_sent*8));
	fcntl(pfd[1], F_SETFD, O_NONBLOCK); 				//make pfd[1] non-blocking, probably not necessary on this side
	write(pfd[1], &pckts_sent, sizeof(pckts_sent));			//send # of packets sent to recieveBytes parent function

	shutdown(sd, 1); 			//shutdown socket, allow for incoming packets
	sleep(5);		 		//timeout before shutdown, this should not be affecting the parent but is blocking it from proceding
	shutdown(sd, 2); 			//shutdown socket entirely
	
	printf("End of Sendable packets function\n"); //DIAG
	return 0;
}

//recv datagrams through sd, read pipe output pfd[0] for packet totals from sendBytes, pfd2 currently not used

int recieveBytes(int sd, int *pfd, int* pfd2)
{
	struct sockaddr_in cad;
	int out_fd;
	int nIncomingBytes;
	int alen;
	char buf[1000];
	char *ND = "NOTDONE";
	long bytes_recvd = 0;
	int pckts_recvd = 0;
	int flag = 0; 
	out_fd = open("/home/jawknee/Test_Response_UDP.txt", O_WRONLY | O_APPEND | O_CREAT, S_IRUSR); //output file

	fcntl(pfd[0], F_SETFD, O_NONBLOCK); //alter output fd of pipe to be non-blocking
	int piped_total = 0;

	alen = sizeof(cad);
	memset(buf, 0, sizeof(buf)); //set initial buffer to all \00

	while(nIncomingBytes = recvfrom(sd, buf, sizeof(buf), MSG_DONTWAIT, (struct sockaddr *)&cad, &alen))
	{
		if(nIncomingBytes>0)
		{
			write(out_fd, buf, nIncomingBytes); //write only as much as is read (use nIncomingBytes)
			bytes_recvd += nIncomingBytes;
			pckts_recvd++;	
			memset(buf, 0, sizeof(buf));
			read(pfd[0], &piped_total, sizeof(piped_total));
			printf("Piped total: %d\n", piped_total); //DIAG
			printf("pckts_recvd: %d\n", pckts_recvd); //DIAG
			if((piped_total > 0) && (pckts_recvd == piped_total)) 
			{
				break;
			}
		}
	}

	printf("Recieved %d packets, constituting %ld bits\n", pckts_recvd, (bytes_recvd*8));
	close(sd);
	printf("End of Recievable packets function\n"); //DIAG
	return 0;
}

Packets sent: 2, comprising 8056 bits.
Piped total: 2
pckts_recvd: 1
<both processes block for 5 seconds here>
End of Sendable packets function
Piped total: 2
pckts_recvd: 2
Recieved 2 packets, constituting 8056 bits

JawKnee fucked around with this message at 23:53 on Jun 1, 2015

rjmccall fucked around with this message at 01:21 on Jun 4, 2015

VikingofRock fucked around with this message at 01:20 on Jun 4, 2015

o.m. 94 fucked around with this message at 07:46 on Jun 4, 2015