diff options
Diffstat (limited to 'ratox.c')
| -rw-r--r-- | ratox.c | 44 |
1 files changed, 23 insertions, 21 deletions
@@ -149,6 +149,7 @@ static char *ustate[] = { enum { TRANSFER_NONE, TRANSFER_INITIATED, + TRANSFER_PENDING, TRANSFER_INPROGRESS, TRANSFER_PAUSED, }; @@ -881,7 +882,7 @@ cbfilesendreq(Tox *m, int32_t frnum, uint8_t fnum, uint64_t fsz, ftruncate(f->fd[FFILE_PENDING], 0); lseek(f->fd[FFILE_PENDING], 0, SEEK_SET); dprintf(f->fd[FFILE_PENDING], "%s\n", filename); - f->rxstate = TRANSFER_INPROGRESS; + f->rxstate = TRANSFER_PENDING; printout(": %s : Rx > Pending %s\n", f->name, filename); } @@ -919,32 +920,32 @@ cbfiledata(Tox *m, int32_t frnum, uint8_t fnum, const uint8_t *data, uint16_t le static void canceltxtransfer(struct friend *f) { - if (f->tx.state != TRANSFER_NONE) { - printout(": %s : Tx > Cancelling\n", f->name); - if (tox_file_send_control(tox, f->num, 0, 0, TOX_FILECONTROL_KILL, NULL, 0) < 0) - weprintf("Failed to kill Tx transfer\n"); - f->tx.state = TRANSFER_NONE; - free(f->tx.buf); - f->tx.buf = NULL; - fiforeset(f->dirfd, &f->fd[FFILE_IN], ffiles[FFILE_IN]); - } + if (f->tx.state == TRANSFER_NONE) + return; + printout(": %s : Tx > Cancelling\n", f->name); + if (tox_file_send_control(tox, f->num, 0, 0, TOX_FILECONTROL_KILL, NULL, 0) < 0) + weprintf("Failed to kill Tx transfer\n"); + f->tx.state = TRANSFER_NONE; + free(f->tx.buf); + f->tx.buf = NULL; + fiforeset(f->dirfd, &f->fd[FFILE_IN], ffiles[FFILE_IN]); } static void cancelrxtransfer(struct friend *f) { - if (f->rxstate == TRANSFER_INPROGRESS) { - printout(": %s : Rx > Cancelling\n", f->name); - if (tox_file_send_control(tox, f->num, 1, 0, TOX_FILECONTROL_KILL, NULL, 0) < 0) - weprintf("Failed to kill Rx transfer\n"); - if (f->fd[FFILE_OUT] != -1) { - close(f->fd[FFILE_OUT]); - f->fd[FFILE_OUT] = -1; - } - ftruncate(f->fd[FFILE_PENDING], 0); - lseek(f->fd[FFILE_PENDING], 0, SEEK_SET); - f->rxstate = TRANSFER_NONE; + if (f->rxstate == TRANSFER_NONE) + return; + printout(": %s : Rx > Cancelling\n", f->name); + if (tox_file_send_control(tox, f->num, 1, 0, TOX_FILECONTROL_KILL, NULL, 0) < 0) + weprintf("Failed to kill Rx transfer\n"); + if (f->fd[FFILE_OUT] != -1) { + close(f->fd[FFILE_OUT]); + f->fd[FFILE_OUT] = -1; } + ftruncate(f->fd[FFILE_PENDING], 0); + lseek(f->fd[FFILE_PENDING], 0, SEEK_SET); + f->rxstate = TRANSFER_NONE; } static void @@ -1734,6 +1735,7 @@ loop(void) cancelrxtransfer(f); } else { printout(": %s : Rx > Accepted\n", f->name); + f->rxstate = TRANSFER_INPROGRESS; } } } |