/*
 * File      : zdevice.c
 * the implemention of zmodem proctocol.
 * Change Logs:
 * Date           Author       Notes
 * 2011-03-29     itspy       
 */

#include <rtthread.h>
#include <finsh.h>
#include <shell.h>
#include <rtdef.h>
#include <dfs.h>
#include <dfs_file.h>
#include <dfs_posix.h>
#include "zdef.h"

										  
rt_uint32_t Line_left  = 0;		     /* left number of data in the read line buffer*/ 
rt_uint32_t Left_sizes = 0;			 /* left file sizes */
rt_uint32_t Baudrate   = BITRATE; 	 /* console baudrate */
 


rt_uint32_t get_device_speed(void)
{
    return(Baudrate);
}

rt_uint32_t get_sys_time(void)
{
    return(0L);
}

void zsend_byte(rt_uint16_t ch)
{
    rt_device_write(zmodem.device,0,&ch,1);  
    return;
}

void zsend_line(rt_uint16_t c)
{
    rt_uint16_t ch;
	ch = (c & 0377);
    rt_device_write(zmodem.device,0,&ch,1);   
    return;
}

static char buf[RX_BUFFER_SIZE + 1];

rt_int16_t zread_line(rt_uint16_t timeout)
{
	char *str;	 
	
	if (Line_left > 0)
	{
	    Line_left -= 1;
		return (*str++ & 0377);
	}
	Line_left = 0;
	timeout/=5;
	while (1)
	{
     	if (rt_sem_take(&zmodem.zsem, RT_TICK_PER_SECOND*timeout) != RT_EOK) continue;
     	Line_left = rt_device_read(shell->device, 0, buf, 1);
		if (Line_left)
		{
		     Line_left = Line_left;
		     str = buf;
			 break;
		}
	}
	if (Line_left < 1) return TIMEOUT;
	Line_left -=1;
	return (*str++ & 0377);
}

/*
 * send a string to the modem, processing for \336 (sleep 1 sec)
 *   and \335 (break signal)
 */
void zsend_break(char *cmd)
{
   
	while (*cmd++) 
	{
		switch (*cmd) 
		{
		case '\336':
			 continue;
		case '\335':
		     rt_thread_delay(RT_TICK_PER_SECOND);
			 continue;
		default:
			 zsend_line(*cmd);
			 break;
		}
	}
}
/* send cancel string to get the other end to shut up */
void zsend_can(void)
{
	static char cmd[] = {24,24,24,24,24,24,24,24,24,24,0};
	zsend_break(cmd);
	rt_kprintf("\x0d");
	Line_left=0;	       /* clear Line_left */
}

/* end of rbsb.c */