github.com/simh.simh
1
0
Fork 0
mirror of https://github.com/simh/simh.git synced 2026-02-27 09:09:46 +00:00
Code Releases Activity

TMXR: Be sure to flush pending output data when enabling logging on a line

Browse Source
This commit is contained in:
Mark Pizzolato
2022-12-20 16:26:48 -10:00
parent 47582da35f
commit 6f1538de9c
1 changed files with 26 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
sim_tmxr.c
View File

@@ -5489,30 +5489,35 @@ if ((r != SCPE_OK) || (lp->txlog == NULL)) { /* error? */
}
if (mp->uptr) /* attached?, then update attach string */
lp->mp->uptr->filename = tmxr_mux_attach_string (lp->mp->uptr->filename, lp->mp);
/* If we've got pending buffered data, write it to the log now */
if (lp->txcnt > lp->txbsz) {
boffset = (lp->txbpi + 1) % lp->txbsz;
nbytes = lp->txbsz; /* avail buffered bytes */
if (lp->conn) { /* If we're connected, flush the buffer out now */
while (tmxr_send_buffered_data (lp) > 0)
sim_os_ms_sleep (10);
}
else {
boffset = 0;
nbytes = lp->txbpi;
}
while (nbytes) { /* >0? write */
int32 sbytes;
if (boffset < lp->txbpi) /* no wrap? */
sbytes = fwrite (&(lp->txb[boffset]), 1, nbytes, lp->txlog);/* write all data */
else
sbytes = fwrite (&(lp->txb[boffset]), 1, lp->txbsz - boffset, lp->txlog);/* write to end buf */
if (sbytes >= 0) { /* ok? */
boffset += sbytes; /* update remove ptr */
if (boffset >= lp->txbsz) /* wrap? */
boffset = 0;
nbytes -= sbytes; /* update remaining count */
if (lp->txcnt > lp->txbsz) {
boffset = (lp->txbpi + 1) % lp->txbsz;
nbytes = lp->txbsz; /* avail buffered bytes */
}
else {
boffset = 0;
nbytes = lp->txbpi;
}
while (nbytes) { /* >0? write */
int32 sbytes;
if (boffset < lp->txbpi) /* no wrap? */
sbytes = fwrite (&(lp->txb[boffset]), 1, nbytes, lp->txlog);/* write all data */
else
sbytes = fwrite (&(lp->txb[boffset]), 1, lp->txbsz - boffset, lp->txlog);/* write to end buf */
if (sbytes >= 0) { /* ok? */
boffset += sbytes; /* update remove ptr */
if (boffset >= lp->txbsz) /* wrap? */
boffset = 0;
nbytes -= sbytes; /* update remaining count */
}
else
break;
}
else
break;
}
return SCPE_OK;
}