throughput_input_queue.cc

int count(struct sk_buff* skb)
{
	struct iphdr *iph; //IP header
	struct tcphdr *tcph; //TCP header
	struct udphdr *udph; //UDP header
	struct timeval tv; //time struct(second & micro second)
	static int totalpacket=0;
	do_gettimeofday(&tv); //get now time
	_kernel_seconds_t intime=(tv.tv_sec*1000000)+tv.tv_usec; // intime = micro second
	iph = ip_hdr(skb); //get IP header

	if(iph->protocal==6){ //TCP packet
		tcph=(struct tcphdr *)((char *)iph+(iph->ihl*4));
		if(ntohs(tcph->source) == 8888) // TCP header, port number = 8888(change to your port number)
		{
			totalpacket++;
			printk("Socket_i\t%ld\t%d\t%d\n",intime,ntohs(iph-> tot_len),totalpacket); // time, total length, total packet
		}
	}
	if(iph->protocal==17) //UDP packet
	{
		udph=(struct udphdr*)((char *)iph+(iph->ihl*4)); //get UDP header
		if(ntohs(udph->source) == 6970) // RTP header, port number = 6970(change to your port number)
		{
			totalpacket++;
			printk("Darwin \t%ld\t%d\t%d\n",intime,ntohs(iph-> tot_len),totalpacket); // time, total length, total packet
		}	
		else if(ntohs(udph->source)==7078) //linphne audio
		{
			totalpacket++;
			printk("Socket_i\t%ld\t%d\t%d\n",intime,ntohs(iph-> tot_len),totalpacket); // time, total length, total packet			
		}
	}
	return 0;
}