sysdeps/managarm: Implement getsockopt()
This commit is contained in:
parent
be4167cd93
commit
4ce89c86d4
|
@ -72,6 +72,8 @@ int sys_epoll_ctl(int epfd, int mode, int fd, struct epoll_event *ev);
|
|||
int sys_epoll_wait(int epfd, struct epoll_event *evnts, int n, int timeout);
|
||||
int sys_inotify_create(int flags, int *fd);
|
||||
int sys_ioctl(int fd, unsigned long request, void *arg);
|
||||
int sys_getsockopt(int fd, int layer, int number,
|
||||
void *__restrict buffer, socklen_t *__restrict size);
|
||||
int sys_setsockopt(int fd, int layer, int number,
|
||||
const void *buffer, socklen_t size);
|
||||
int sys_waitpid(pid_t pid, int *status, int flags);
|
||||
|
|
|
@ -42,21 +42,7 @@ int getsockname(int fd, struct sockaddr *__restrict addr_ptr, socklen_t *__restr
|
|||
|
||||
int getsockopt(int fd, int layer, int number,
|
||||
void *__restrict buffer, socklen_t *__restrict size) {
|
||||
if(layer == SOL_SOCKET && number == SO_PEERCRED) {
|
||||
__ensure(*size == sizeof(struct ucred));
|
||||
frigg::infoLogger() << "\e[31mmlibc: getsockopt(SO_PEERCRED) returns all zeros\e[39m"
|
||||
<< frigg::endLog;
|
||||
|
||||
struct ucred creds;
|
||||
creds.pid = 0;
|
||||
creds.uid = 0;
|
||||
creds.gid = 0;
|
||||
memcpy(buffer, &creds, sizeof(struct ucred));
|
||||
return 0;
|
||||
}else{
|
||||
frigg::panicLogger() << "\e[31mmlibc: Unexpected getsockopt() call\e[39m" << frigg::endLog;
|
||||
__builtin_unreachable();
|
||||
}
|
||||
return mlibc::sys_getsockopt(fd, layer, number, buffer, size);
|
||||
}
|
||||
|
||||
int listen(int, int) {
|
||||
|
|
|
@ -193,6 +193,58 @@ int sys_sockname(int fd, struct sockaddr *addr_ptr, socklen_t max_addr_length,
|
|||
return 0;
|
||||
}
|
||||
|
||||
int sys_getsockopt(int fd, int layer, int number,
|
||||
void *__restrict buffer, socklen_t *__restrict size) {
|
||||
if(layer == SOL_SOCKET && number == SO_PEERCRED) {
|
||||
__ensure(*size == sizeof(struct ucred));
|
||||
HelAction actions[3];
|
||||
globalQueue.trim();
|
||||
|
||||
auto handle = cacheFileTable()[fd];
|
||||
__ensure(handle);
|
||||
|
||||
managarm::fs::CntRequest<MemoryAllocator> req(getAllocator());
|
||||
req.set_req_type(managarm::fs::CntReqType::PT_GET_OPTION);
|
||||
req.set_command(SO_PEERCRED);
|
||||
|
||||
frigg::String<MemoryAllocator> ser(getAllocator());
|
||||
req.SerializeToString(&ser);
|
||||
actions[0].type = kHelActionOffer;
|
||||
actions[0].flags = kHelItemAncillary;
|
||||
actions[1].type = kHelActionSendFromBuffer;
|
||||
actions[1].flags = kHelItemChain;
|
||||
actions[1].buffer = ser.data();
|
||||
actions[1].length = ser.size();
|
||||
actions[2].type = kHelActionRecvInline;
|
||||
actions[2].flags = 0;
|
||||
HEL_CHECK(helSubmitAsync(handle, actions, 3,
|
||||
globalQueue.getQueue(), 0, 0));
|
||||
|
||||
auto element = globalQueue.dequeueSingle();
|
||||
auto offer = parseSimple(element);
|
||||
auto send_req = parseSimple(element);
|
||||
auto recv_resp = parseInline(element);
|
||||
|
||||
HEL_CHECK(offer->error);
|
||||
HEL_CHECK(send_req->error);
|
||||
HEL_CHECK(recv_resp->error);
|
||||
|
||||
managarm::fs::SvrResponse<MemoryAllocator> resp(getAllocator());
|
||||
resp.ParseFromArray(recv_resp->data, recv_resp->length);
|
||||
__ensure(resp.error() == managarm::fs::Errors::SUCCESS);
|
||||
|
||||
struct ucred creds;
|
||||
creds.pid = resp.pid();
|
||||
creds.uid = resp.uid();
|
||||
creds.gid = resp.gid();
|
||||
memcpy(buffer, &creds, sizeof(struct ucred));
|
||||
return 0;
|
||||
}else{
|
||||
frigg::panicLogger() << "\e[31mmlibc: Unexpected getsockopt() call\e[39m" << frigg::endLog;
|
||||
__builtin_unreachable();
|
||||
}
|
||||
}
|
||||
|
||||
int sys_setsockopt(int fd, int layer, int number,
|
||||
const void *buffer, socklen_t size) {
|
||||
if(layer == SOL_SOCKET && number == SO_PASSCRED) {
|
||||
|
|
Loading…
Reference in a new issue