zheiling/BBS-Server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixes packages processing on file load

Browse Source
This commit is contained in:
zheiling
2026-05-19 13:53:50 +03:00
parent 111a81618f
commit 1810b02cfd
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/file_p.c
+9 -5
View File
@@ -327,14 +327,18 @@ void file_upload(session *sess) {
} }
if (sess->file->package_rest < rlen) { if (sess->file->package_rest < rlen) {
write(dest_d, buf, sess->file->package_rest); write(dest_d, buf, sess->file->package_rest);
s_file_pd_t *fpd = (s_file_pd_t *)buf + sess->file->package_rest; rlen -= sess->file->package_rest;
sess->file->rest -= sess->file->package_rest;
if (rlen == 0) return;
s_file_pd_t *fpd = (s_file_pd_t *) (buf + sess->file->package_rest);
switch (fpd->signal) { switch (fpd->signal) {
case sig_continue: case sig_continue:
sess->file->package_rest = fpd->package_size;
rlen -= sizeof(s_file_pd_t); rlen -= sizeof(s_file_pd_t);
if (rlen > 0) { if (rlen > 0) {
write(dest_d, buf + sizeof(s_file_pd_t), rlen); write(dest_d, buf + sess->file->package_rest + sizeof(s_file_pd_t), rlen);
sess->file->rest -= rlen;
} }
sess->file->package_rest = fpd->package_size - rlen;
break; break;
case sig_cancel: case sig_cancel:
fprintf(stderr, "Upload of %s is cancelled!\n", sess->file->name); fprintf(stderr, "Upload of %s is cancelled!\n", sess->file->name);
@@ -350,10 +354,10 @@ void file_upload(session *sess) {
} }
} else { } else {
write(dest_d, buf, rlen); write(dest_d, buf, rlen);
}
sess->file->rest -= rlen; sess->file->rest -= rlen;
sess->file->package_rest -= rlen; sess->file->package_rest -= rlen;
}
if (!sess->file->rest) { if (!sess->file->rest) {
printf("File %s is uploaded to the server\n", sess->file->name); printf("File %s is uploaded to the server\n", sess->file->name);
session_send_string(sess, "finished\n"); session_send_string(sess, "finished\n");