X-Git-Url: https://codewiz.org/gitweb?a=blobdiff_plain;f=drv%2Fser.c;h=59ab1fea388e72114593093af0ef92739b3c4eff;hb=c5049d7bb6178222c952030c2f2a6f52a43ddda1;hp=4da6c5bc7da2139237a0480d60e60cd767028ddb;hpb=f530f9a7018684f5ad744076220f845ed7732244;p=bertos.git diff --git a/drv/ser.c b/drv/ser.c index 4da6c5bc..59ab1fea 100755 --- a/drv/ser.c +++ b/drv/ser.c @@ -28,6 +28,15 @@ /*#* *#* $Log$ + *#* Revision 1.25 2005/04/11 19:10:27 bernie + *#* Include top-level headers from cfg/ subdir. + *#* + *#* Revision 1.24 2005/01/21 20:13:15 aleph + *#* Fix drain at ser_close() + *#* + *#* Revision 1.23 2005/01/14 00:47:07 aleph + *#* ser_drain(): Wait for hw transmission complete. + *#* *#* Revision 1.22 2004/12/08 08:56:14 bernie *#* Rename time_t to mtime_t. *#* @@ -96,9 +105,9 @@ #include "ser.h" #include "ser_p.h" #include -#include +#include #include -#include +#include /* * Sanity check for config parameters required by this module. @@ -178,7 +187,7 @@ int ser_putchar(int c, struct Serial *port) fifo_push_locked(&port->txfifo, (unsigned char)c); /* (re)trigger tx interrupt */ - port->hw->table->enabletxirq(port->hw); + port->hw->table->txStart(port->hw); /* Avoid returning signed extended char */ return (int)((unsigned char)c); @@ -409,13 +418,13 @@ void ser_resync(struct Serial *port, mtime_t delay) void ser_setbaudrate(struct Serial *port, unsigned long rate) { - port->hw->table->setbaudrate(port->hw, rate); + port->hw->table->setBaudrate(port->hw, rate); } void ser_setparity(struct Serial *port, int parity) { - port->hw->table->setparity(port->hw, parity); + port->hw->table->setParity(port->hw, parity); } @@ -439,7 +448,12 @@ void ser_purge(struct Serial *port) */ void ser_drain(struct Serial *ser) { - while (!fifo_isempty(&ser->txfifo)) + /* + * Wait until the FIFO is empty, and then until the byte currently in + * the hardware register gets shifted out. + */ + while (!fifo_isempty(&ser->txfifo) + || ser->hw->table->txSending(ser->hw)) { #if CONFIG_KERNEL && CONFIG_KERN_SCHED /* Give up timeslice to other processes. */ @@ -497,6 +511,15 @@ void ser_close(struct Serial *port) ASSERT(port->is_open); DB(port->is_open = false;) + // Wait until we finish sending everything + ser_drain(port); + port->hw->table->cleanup(port->hw); - port->hw = NULL; + DB(port->hw = NULL;) + + /* + * We purge the FIFO buffer only after the low-level cleanup, so that + * we are sure that there are no more interrupts. + */ + ser_purge(port); }