Function ksocketpair

source/kernel/ksocket.cpp:161–208

}

U32 ksocketpair(KThread* thread, U32 af, U32 type, U32 protocol, U32 socks, U32 flags) {
    FD fd1 = 0;
    FD fd2 = 0;
    KFileDescriptorPtr f1;
    KFileDescriptorPtr f2;
    std::shared_ptr<KUnixSocketObject> s1;
    std::shared_ptr<KUnixSocketObject> s2;
    KMemory* memory = thread->memory;

    BOXEDWINE_CRITICAL_SECTION_WITH_MUTEX(thread->process->fdsMutex);

    if (af!=K_AF_UNIX) {
        kwarn_fmt("socketpair with adress family %d not implemented", af);
        return -1;
    }
    if (type!=K_SOCK_DGRAM && type!=K_SOCK_STREAM) {
        kwarn_fmt("socketpair with type %d not implemented", type);
        return -1;
    }
    fd1 = ksocket(af, type, protocol);
    fd2 = ksocket(af, type, protocol);
    f1 = thread->process->getFileDescriptor(fd1);
    f2 = thread->process->getFileDescriptor(fd2);
    s1 = std::dynamic_pointer_cast<KUnixSocketObject>(f1->kobject);
    s2 = std::dynamic_pointer_cast<KUnixSocketObject>(f2->kobject);
    
    s1->connection = s2;
    s2->connection = s1;
    s1->connected = true;
    s2->connected = true;
    f1->accessFlags = K_O_RDWR;
    f2->accessFlags = K_O_RDWR;
    memory->writed(socks, fd1);
    memory->writed(socks + 4, fd2);

    if ((flags & K_O_CLOEXEC)!=0) {
        thread->process->fcntrl(thread, fd1, K_F_SETFD, FD_CLOEXEC);
        thread->process->fcntrl(thread, fd2, K_F_SETFD, FD_CLOEXEC);
    }
    if ((flags & K_O_NONBLOCK)!=0) {
        thread->process->fcntrl(thread, fd1, K_F_SETFL, K_O_NONBLOCK);
        thread->process->fcntrl(thread, fd2, K_F_SETFL, K_O_NONBLOCK);
    }
    if (flags & ~(K_O_CLOEXEC|K_O_NONBLOCK)) {
        kwarn_fmt("Unknow flags sent to pipe2: %X", flags);
    }
    return 0;
}

U32 ksend(KThread* thread, U32 socket, U32 buffer, U32 len, U32 flags) {
    KFileDescriptorPtr fd = thread->process->getFileDescriptor(socket);