Method sendto

source/kernel/knativesocket.cpp:1539–1570

}

U32 KNativeSocketObject::sendto(KThread* thread, const KFileDescriptorPtr& fd, U32 message, U32 length, U32 flags, U32 dest_addr, U32 dest_len) {
    KMemory* memory = thread->memory;
    U32 nativeFlags = 0;
    struct sockaddr_in dest = { 0 };
    int len=sizeof(struct sockaddr_in);
  

    if (flags & K_MSG_OOB) {
        nativeFlags |= MSG_OOB;
        flags &= ~K_MSG_OOB;
    }
    if (flags & K_MSG_NOSIGNAL) {
        flags &= ~K_MSG_NOSIGNAL;
    }
    if (flags) {
        kwarn_fmt("KNativeSocketObject::sendto unsupported flags: %d", flags);
    }
    if (dest_addr) {
        readSockAddrIn(&dest, memory, dest_addr);
    }
    S8* tmp = new S8[length];
    memory->memcpy(tmp, message, length);
    U32 result = (U32)::sendto(this->nativeSocket, (char*)tmp, length, nativeFlags, dest_addr ? (struct sockaddr*)&dest : nullptr, dest_addr ? len : 0);
    LOG_SOCK("%x native socket: %x sendto dest_addr=%x dest_len=%x result=%x", thread->id, nativeSocket, dest_addr, dest_len, result);
    delete[] tmp;
    if ((S32)result>=0) {
        this->error = 0;
        return result;
    }
    std::shared_ptr< KNativeSocketObject> t = std::dynamic_pointer_cast<KNativeSocketObject>(shared_from_this());
    return handleNativeSocketError(t, true);
}

U32 KNativeSocketObject::recvfrom(KThread* thread, const KFileDescriptorPtr& fd, U32 buffer, U32 length, U32 flags, U32 address, U32 address_len) {
    BOXEDWINE_CRITICAL_SECTION_WITH_CONDITION(readingCond);