serialsource.c File Reference

#include <sys/types.h>
#include <sys/stat.h>
#include <termios.h>
#include <unistd.h>
#include <stdint.h>
#include <errno.h>
#include <fcntl.h>
#include <stdlib.h>
#include <string.h>
#include <sys/time.h>
#include <stdio.h>
#include "serialsource.h"
#include "OscopeMsg.h"

Go to the source code of this file.

Classes

struct tos_header

struct packet_list

struct serial_source

Defines

#define DEBUG   1

Typedefs

typedef int bool

Enumerations

enum {
  FALSE = 0, TRUE = 1, BUFSIZE = 256, MTU = 256,
  ACK_TIMEOUT = 1000000, SYNC_BYTE = 0x7e, ESCAPE_BYTE = 0x7d, P_ACK = 64,
  P_PACKET_ACK = 65, P_PACKET_NO_ACK = 66, P_UNKNOWN = 255
}

Functions

static tcflag_t parse_baudrate (int requested)

static void dump (const char *msg, const uint8_t *packet, int len)

static void message (serial_source src, serial_source_msg msg)

static int buggyread (serial_source src, void *buffer, int n)

serial_source open_serial_source (const char *device, int baud_rate, int non_blocking, void(*message)(serial_source_msg problem))

int serial_source_fd (serial_source src)

int close_serial_source (serial_source src)

static int source_wait (serial_source src, struct timeval *deadline)

static int source_write (serial_source src, const void *buffer, int count)

static void push_protocol_packet (serial_source src, uint8_t type, uint8_t *packet, uint8_t len)

static struct packet_list * pop_protocol_packet (serial_source src, uint8_t type)

static bool packet_available (serial_source src, uint8_t type)

int serial_source_empty (serial_source src)

static uint16_t crc_byte (uint16_t crc, uint8_t b)

static uint16_t crc_packet (uint8_t *data, int len)

static int read_byte (serial_source src)

static void process_packet (serial_source src, uint8_t *packet, int len)

static int write_framed_packet (serial_source src, uint8_t packet_type, uint8_t first_byte, const uint8_t *packet, int count)

static void read_and_process (serial_source src)

void * read_serial_packet (serial_source src, int *len)

static void escape_add (serial_source src, uint8_t b)

static int init_escaper (serial_source src, int count)

static void terminate_escaper (serial_source src)

static void escape_byte (serial_source src, uint8_t b)

static void free_escaper (serial_source src)

static void add_timeval (struct timeval *tv, long us)

int write_serial_packet (serial_source src, const void *packet, int len)

Define Documentation

#define DEBUG 1

Definition at line 20 of file serialsource.c.

Referenced by read_and_process(), and read_byte().

Typedef Documentation

typedef int bool

Definition at line 33 of file serialsource.c.

Enumeration Type Documentation

anonymous enum

Enumerator:

FALSE
TRUE
BUFSIZE
MTU
ACK_TIMEOUT
SYNC_BYTE
ESCAPE_BYTE
P_ACK
P_PACKET_ACK
P_PACKET_NO_ACK
P_UNKNOWN

Definition at line 35 of file serialsource.c.

Function Documentation

static void add_timeval	(	struct timeval *	tv,
		long	us
	)			`[static]`

Definition at line 788 of file serialsource.c.

Referenced by write_serial_packet().

static int buggyread	(	serial_source	src,
		void *	buffer,
		int	n
	)			`[static]`

Definition at line 203 of file serialsource.c.

References errno, serial_source::fd, serial_source::non_blocking, and src.

Referenced by read_byte().

int close_serial_source ( serial_source src )

Definition at line 303 of file serialsource.c.

References serial_source::fd, and src.

static uint16_t crc_byte	(	uint16_t	crc,
		uint8_t	b
	)			`[static]`

Definition at line 450 of file serialsource.c.

Referenced by crc_packet(), and escape_byte().

static uint16_t crc_packet	(	uint8_t *	data,
		int	len
	)			`[static]`

Definition at line 466 of file serialsource.c.

References crc_byte().

Referenced by read_and_process().

static void dump	(	const char *	msg,
		const uint8_t *	packet,
		int	len
	)			`[static]`

Definition at line 184 of file serialsource.c.

Referenced by process_packet(), read_byte(), write_framed_packet(), and write_serial_packet().

static void escape_add	(	serial_source	src,
		uint8_t	b
	)			`[static]`

Definition at line 705 of file serialsource.c.

References serial_source::escaped, serial_source::escapeptr, serial_source::send, and src.

Referenced by escape_byte(), init_escaper(), and terminate_escaper().

static void escape_byte	(	serial_source	src,
		uint8_t	b
	)			`[static]`

Definition at line 731 of file serialsource.c.

References serial_source::crc, crc_byte(), escape_add(), ESCAPE_BYTE, serial_source::send, src, and SYNC_BYTE.

Referenced by write_framed_packet().

static void free_escaper ( serial_source src ) [static]

Definition at line 743 of file serialsource.c.

References serial_source::escaped, serial_source::send, and src.

Referenced by write_framed_packet().

static int init_escaper	(	serial_source	src,
		int	count
	)			`[static]`

Definition at line 710 of file serialsource.c.

References serial_source::crc, escape_add(), serial_source::escaped, serial_source::escapeptr, message(), msg_no_memory, serial_source::send, src, and SYNC_BYTE.

Referenced by write_framed_packet().

static void message	(	serial_source	src,
		serial_source_msg	msg
	)			`[static]`

Definition at line 195 of file serialsource.c.

References serial_source::message, and src.

Referenced by oasys::SMTP::client_session(), init_escaper(), push_protocol_packet(), read_and_process(), read_byte(), source_wait(), and source_write().

serial_source open_serial_source	(	const char *	device,
		int	baud_rate,
		int	non_blocking,
		void(*)(serial_source_msg problem)	message
	)

Definition at line 233 of file serialsource.c.

References fd, handle, parse_baudrate(), and src.

Referenced by init_motes().

static bool packet_available	(	serial_source	src,
		uint8_t	type
	)			`[static]`

Definition at line 429 of file serialsource.c.

References serial_source::queue, serial_source::recv, and src.

Referenced by serial_source_empty().

static tcflag_t parse_baudrate ( int requested ) [static]

Definition at line 81 of file serialsource.c.

Referenced by open_serial_source().

static struct packet_list* pop_protocol_packet	(	serial_source	src,
		uint8_t	type
	)			`[static]`

Definition at line 419 of file serialsource.c.

References packet_list::next, serial_source::queue, serial_source::recv, and src.

Referenced by read_serial_packet(), and write_serial_packet().

static void process_packet	(	serial_source	src,
		uint8_t *	packet,
		int	len
	)			`[static]`

Definition at line 627 of file serialsource.c.

References AM_OSCOPEACK, AM_OSCOPEMSG, OscopeMsg::channel, OscopeAck::channel, tos_header::dest_id, dump(), tos_header::group_id, tos_header::handler, OscopeMsg::lastSampleNumber, OscopeAck::lastSampleNumber, tos_header::length, P_ACK, P_PACKET_ACK, P_PACKET_NO_ACK, push_protocol_packet(), OscopeMsg::sourceMoteID, OscopeAck::sourceMoteID, src, write_framed_packet(), and write_serial_packet().

Referenced by read_and_process().

static void push_protocol_packet	(	serial_source	src,
		uint8_t	type,
		uint8_t *	packet,
		uint8_t	len
	)			`[static]`

Definition at line 396 of file serialsource.c.

References packet_list::len, message(), msg_no_memory, packet_list::next, packet_list::packet, serial_source::queue, serial_source::recv, and src.

Referenced by process_packet().

static void read_and_process ( serial_source src ) [static]

Definition at line 517 of file serialsource.c.

References count, serial_source::count, crc_packet(), DEBUG, ESCAPE_BYTE, serial_source::escaped, FALSE, serial_source::in_sync, message(), msg_bad_crc, msg_bad_sync, msg_no_memory, msg_sync, msg_too_long, MTU, serial_source::packet, packet_list::packet, process_packet(), read_byte(), serial_source::recv, src, SYNC_BYTE, and TRUE.

Referenced by read_serial_packet(), and write_serial_packet().

static int read_byte ( serial_source src ) [static]

Definition at line 476 of file serialsource.c.

References serial_source::buffer, serial_source::bufpos, serial_source::bufused, buggyread(), DEBUG, dump(), errno, message(), msg_closed, msg_unix_error, serial_source::recv, and src.

Referenced by read_and_process().

void* read_serial_packet	(	serial_source	src,
		int *	len
	)

Definition at line 674 of file serialsource.c.

References P_PACKET_NO_ACK, packet_list::packet, pop_protocol_packet(), read_and_process(), serial_source_empty(), source_wait(), and src.

Referenced by read_packet().

int serial_source_empty ( serial_source src )

Definition at line 434 of file serialsource.c.

References serial_source::bufpos, serial_source::bufused, P_PACKET_NO_ACK, packet_available(), serial_source::recv, and src.

Referenced by read_serial_packet().

int serial_source_fd ( serial_source src )

Definition at line 295 of file serialsource.c.

References serial_source::fd, and src.

static int source_wait	(	serial_source	src,
		struct timeval *	deadline
	)			`[static]`

Definition at line 316 of file serialsource.c.

References serial_source::bufpos, serial_source::bufused, errno, serial_source::fd, dtnsim::gettimeofday(), message(), msg_unix_error, serial_source::recv, and src.

Referenced by read_serial_packet(), and write_serial_packet().

static int source_write	(	serial_source	src,
		const void *	buffer,
		int	count
	)			`[static]`

Definition at line 362 of file serialsource.c.

References errno, serial_source::fd, message(), msg_unix_error, and src.

Referenced by write_framed_packet().

static void terminate_escaper ( serial_source src ) [static]

Definition at line 726 of file serialsource.c.

References escape_add(), src, and SYNC_BYTE.

Referenced by write_framed_packet().

static int write_framed_packet	(	serial_source	src,
		uint8_t	packet_type,
		uint8_t	first_byte,
		const uint8_t *	packet,
		int	count
	)			`[static]`

Definition at line 750 of file serialsource.c.

References serial_source::crc, dump(), escape_byte(), serial_source::escaped, serial_source::escapeptr, free_escaper(), init_escaper(), serial_source::send, source_write(), src, and terminate_escaper().

Referenced by process_packet(), and write_serial_packet().

int write_serial_packet	(	serial_source	src,
		const void *	packet,
		int	len
	)

Definition at line 800 of file serialsource.c.

References ACK_TIMEOUT, add_timeval(), dump(), dtnsim::gettimeofday(), P_ACK, P_PACKET_ACK, pop_protocol_packet(), read_and_process(), serial_source::send, serial_source::seqno, source_wait(), src, and write_framed_packet().

Referenced by process_packet().

Generated on Fri Dec 22 14:48:02 2006 for DTN Reference Implementation by

1.5.1


Classes
struct	tos_header
struct	packet_list
struct	serial_source
Defines
#define	DEBUG 1
Typedefs
typedef int	bool
Enumerations
enum	{ FALSE = 0, TRUE = 1, BUFSIZE = 256, MTU = 256, ACK_TIMEOUT = 1000000, SYNC_BYTE = 0x7e, ESCAPE_BYTE = 0x7d, P_ACK = 64, P_PACKET_ACK = 65, P_PACKET_NO_ACK = 66, P_UNKNOWN = 255 }
Functions
static tcflag_t	parse_baudrate (int requested)
static void	dump (const char msg, const uint8_t packet, int len)
static void	message (serial_source src, serial_source_msg msg)
static int	buggyread (serial_source src, void *buffer, int n)
serial_source	open_serial_source (const char device, int baud_rate, int non_blocking, void(message)(serial_source_msg problem))
int	serial_source_fd (serial_source src)
int	close_serial_source (serial_source src)
static int	source_wait (serial_source src, struct timeval *deadline)
static int	source_write (serial_source src, const void *buffer, int count)
static void	push_protocol_packet (serial_source src, uint8_t type, uint8_t *packet, uint8_t len)
static struct packet_list *	pop_protocol_packet (serial_source src, uint8_t type)
static bool	packet_available (serial_source src, uint8_t type)
int	serial_source_empty (serial_source src)
static uint16_t	crc_byte (uint16_t crc, uint8_t b)
static uint16_t	crc_packet (uint8_t *data, int len)
static int	read_byte (serial_source src)
static void	process_packet (serial_source src, uint8_t *packet, int len)
static int	write_framed_packet (serial_source src, uint8_t packet_type, uint8_t first_byte, const uint8_t *packet, int count)
static void	read_and_process (serial_source src)
void *	read_serial_packet (serial_source src, int *len)
static void	escape_add (serial_source src, uint8_t b)
static int	init_escaper (serial_source src, int count)
static void	terminate_escaper (serial_source src)
static void	escape_byte (serial_source src, uint8_t b)
static void	free_escaper (serial_source src)
static void	add_timeval (struct timeval *tv, long us)
int	write_serial_packet (serial_source src, const void *packet, int len)