[BACK]Return to srv.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / tftpd / src

Diff for /tftpd/src/srv.c between versions 1.6 and 1.7.2.2

version 1.6, 2014/02/21 09:09:15 version 1.7.2.2, 2014/02/24 22:02:19
Line 45  SUCH DAMAGE. Line 45  SUCH DAMAGE.
 */  */
 #include "global.h"  #include "global.h"
 #include "exec.h"  #include "exec.h"
   #include "buf.h"
 #include "srv.h"  #include "srv.h"
   
   
Line 55  timeoutSession(sched_task_t *task) Line 56  timeoutSession(sched_task_t *task)
   
         ETRACE();          ETRACE();
   
           if (bf)
                   flushBuffer(cli.fd);
   
         /* drop session */          /* drop session */
         if (cli.fd > 2)          if (cli.fd > 2)
                 close(cli.fd);                  close(cli.fd);
Line 167  txAck(sched_task_t *task) Line 171  txAck(sched_task_t *task)
                 schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_CALL, timeoutSession, NULL);                  schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_CALL, timeoutSession, NULL);
                 schedEvent(TASK_ROOT(task), timeoutSession, NULL, 0, TASK_DATA(task), 0);                  schedEvent(TASK_ROOT(task), timeoutSession, NULL, 0, TASK_DATA(task), 0);
                 EVERBOSE(2, "Finish WRQ request");                  EVERBOSE(2, "Finish WRQ request");
                   schedResumeby(TASK_ROOT(task), CRITERIA_ID, 0);
         }          }
         taskExit(task, NULL);          taskExit(task, NULL);
 }  }
Line 214  getOpts(rpack_t * __restrict pkt, int rlen) Line 219  getOpts(rpack_t * __restrict pkt, int rlen)
                 }                  }
         } while (rlen > 0);          } while (rlen > 0);
   
        EVERBOSE(4, "blksize=%u tsize=%llu timeout=%u rollover=%u",         EVERBOSE(4, "blksize=%u tsize=%llu timeout=%d rollover=%u", 
                        cli.siz, cli.tsiz, cli.tout.tv_sec, cli.roll - 1);                        cli.siz, cli.tsiz, (int) cli.tout.tv_sec, cli.roll - 1);
         return 0;          return 0;
 }  }
   
Line 250  txOack(sched_task_t *task) Line 255  txOack(sched_task_t *task)
         }          }
         if (cli.tout.tv_sec) {          if (cli.tout.tv_sec) {
                 memset(szStr, 0, sizeof szStr);                  memset(szStr, 0, sizeof szStr);
                snprintf(szStr, sizeof szStr, "%u", cli.tout.tv_sec);                snprintf(szStr, sizeof szStr, "%d", (int) cli.tout.tv_sec);
                 rpack_rdata(pkt, TFTP_OPT_TIMEOUT, strlen(TFTP_OPT_TIMEOUT) + 1);                  rpack_rdata(pkt, TFTP_OPT_TIMEOUT, strlen(TFTP_OPT_TIMEOUT) + 1);
                 rpack_rdata(pkt, szStr, strlen(szStr) + 1);                  rpack_rdata(pkt, szStr, strlen(szStr) + 1);
         }          }
Line 261  txOack(sched_task_t *task) Line 266  txOack(sched_task_t *task)
                 rpack_rdata(pkt, szStr, strlen(szStr) + 1);                  rpack_rdata(pkt, szStr, strlen(szStr) + 1);
         }          }
   
        EVERBOSE(4, "blksize=%u tsize=%llu timeout=%u rollover=%u",         EVERBOSE(4, "blksize=%u tsize=%llu timeout=%d rollover=%u", 
                        cli.siz, cli.tsiz, cli.tout.tv_sec, cli.roll - 1);                        cli.siz, cli.tsiz, (int) cli.tout.tv_sec, cli.roll - 1);
         schedCallOnce(TASK_ROOT(task), txPkt, NULL, TASK_FD(task),           schedCallOnce(TASK_ROOT(task), txPkt, NULL, TASK_FD(task), 
                         TASK_DATA(task), RPACK_OFF(pkt));                          TASK_DATA(task), RPACK_OFF(pkt));
         taskExit(task, NULL);          taskExit(task, NULL);
Line 281  RQ(sched_task_t *task) Line 286  RQ(sched_task_t *task)
   
         cli.siz = TFTP_LOAD_MAX;          cli.siz = TFTP_LOAD_MAX;
         cli.opc = ntohs(rpack_uint16(pkt, NULL, 0));          cli.opc = ntohs(rpack_uint16(pkt, NULL, 0));
           if (!RW && cli.opc == TFTP_OPC_WRQ) {
                   code = 2;
                   goto end;
           }
         len = str_getString(RPACK_NEXT(pkt), rlen, &str);          len = str_getString(RPACK_NEXT(pkt), rlen, &str);
         if (len == -1)          if (len == -1)
                 goto end;                  goto end;
Line 331  RQ(sched_task_t *task) Line 340  RQ(sched_task_t *task)
                         code = htons(3);                          code = htons(3);
                 else if (errno == EEXIST)                  else if (errno == EEXIST)
                         code = htons(6);                          code = htons(6);
                   else if (errno == ENOENT)
                           code = htons(1);
                 else                  else
                         code = htons(0);                          code = htons(0);
                 ESYSERR(0);                  ESYSERR(0);
Line 467  DATA(sched_task_t *task) Line 478  DATA(sched_task_t *task)
   
         EVERBOSE(3, "DATA:: seq=%hu; len=%d", cli.seq, len);          EVERBOSE(3, "DATA:: seq=%hu; len=%d", cli.seq, len);
   
        len = pwrite(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz);        if (!bf)
                 len = pwrite(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz);
         else
                 len = bfwrite(cli.fd, RPACK_NEXT(pkt), len);
         if (len == -1) {          if (len == -1) {
                 ESYSERR(0);                  ESYSERR(0);
                 code = htons(3);                  code = htons(3);
Removed from v.1.6  
changed lines
  Added in v.1.7.2.2

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>