ejung/bsb2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

send seems to work, the stress test has weird unmotivated lines originally

Browse Source
This commit is contained in:
user
2026-03-01 01:03:21 +01:00
parent 3302149422
commit 170c29bdb5
2 changed files with 21 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
kernel/syscall/skeleton.cc
View File

@@ -224,13 +224,22 @@ bool send(Vault& v, int pid, const void* sbuffer, size_t ssize, void* rbuffer, s
} }
DBG_VERBOSE << "" << endl; DBG_VERBOSE << "" << endl;
} }
uint8_t num_pages = (rsize/4096)+1;
// Kopiere Antwort // Kopiere Antwort size kann mehr sein
if (!copy_from_phys(v, isMapped(msg.ptr, target_thread->paging_tree->l4), rbuffer, rsize)) { for(uint8_t i=0;i<num_pages;i++){
return false; uintptr_t paddr = isMapped(msg.ptr, target_thread->paging_tree->l4); //always page aligned
} if(rsize-i*4096>4096){ // ganze pages
if (!copy_from_phys(v,paddr,(void*)((uintptr_t) rbuffer+ (4096*i)),4096)) {
return true; return false;
}
} else { //teil von pages
if (!copy_from_phys(v,paddr,(void*)((uintptr_t)rbuffer+ 4096*i), rsize-i*4096)) {
return false;
}
}
}
return true;
} }
int receive(Vault& v, void* buffer, size_t size) { int receive(Vault& v, void* buffer, size_t size) {
@@ -254,9 +263,9 @@ int receive(Vault& v, void* buffer, size_t size) {
uintptr_t offset = i==0?Page::offset(ipc->ptr):0; //apply offset only on first page uintptr_t offset = i==0?Page::offset(ipc->ptr):0; //apply offset only on first page
uintptr_t paddr = isMapped((ipc->ptr)+(i*4096), v.thread_list[ipc->pid]->paging_tree->l4); uintptr_t paddr = isMapped((ipc->ptr)+(i*4096), v.thread_list[ipc->pid]->paging_tree->l4);
if(total_len - (i*4096) > 4096) if(total_len - (i*4096) > 4096)
copy_from_phys(v, paddr+offset, buffer, 4096-offset); copy_from_phys(v, paddr+offset,(void*)((uintptr_t)buffer+i*4096), 4096-offset);
else else
copy_from_phys(v, paddr, buffer, total_len - (i*4096)); //last page copy_from_phys(v, paddr, (void*)((uintptr_t)buffer+i*4096), total_len - (i*4096)); //last page
} }
return ipc->pid; return ipc->pid;
@@ -282,7 +291,7 @@ bool reply(Vault& v, const void* buffer, size_t size) {
ipc->is_answer = true; ipc->is_answer = true;
// Sender aufwecken // Sender aufwecken
other_thread->ipc_sem.v(v); other_thread->ipc_sem.v(v);
return true; return true;
} }

5
user/app1/appl.cc
View File

@@ -18,12 +18,13 @@ void main() {
char msg[] = "REPLY: AA\n"; char msg[] = "REPLY: AA\n";
msg[7] += rbuf[0] + sbuf[8193]; msg[7] += rbuf[0] + sbuf[8193];
msg[8] += 4 + ppid; msg[8] += 4 + ppid;
write(0, msg, 10,0, ppid); write(0, msg, 10);
} else { // parent } else { // parent
int X = recv(rbuf, 8193);
receive(rbuf, 8193); receive(rbuf, 8193);
rbuf[0] = rbuf[0] + rbuf[8192]; rbuf[0] = rbuf[0] + rbuf[8192];
rbuf[8193] = 7; rbuf[8193] = 7;
reply(rbuf, 8193); reply(X,rbuf, 8193);
} }
sys_exit(); sys_exit();