UDPServerIOThread.h

Go to the documentation of this file.

#pragma once
 
#include <stdint.h>
 
#include <map>
#include <queue>
#include <utility>
 
#include <tdme/network/udpserver/fwd-tdme.h>
 
#include <tdme/tdme.h>
#include <tdme/os/network/KernelEventMechanism.h>
#include <tdme/os/network/UDPSocket.h>
#include <tdme/os/threading/Mutex.h>
#include <tdme/os/threading/Thread.h>
 
#include <tdme/network/udpserver/UDPServer.h>
#include <tdme/network/udpserver/UDPServerClient.h>
 
using std::map;
using std::queue;
 
using tdme::network::udpserver::UDPServer;
using tdme::network::udpserver::UDPServerClient;
using tdme::os::network::KernelEventMechanism;
using tdme::os::network::UDPSocket;
using tdme::os::threading::Mutex;
using tdme::os::threading::Thread;
 
/**
 * UDP Network server IO thread
 * @author Andreas Drewke
 */
class tdme::network::udpserver::UDPServerIOThread : private Thread {
    friend class UDPServer;
    friend class UDPServerClient;
 
private:
    const static int MESSAGEACK_RESENDTIMES_TRIES = 7;
    const static uint64_t MESSAGEACK_RESENDTIMES[MESSAGEACK_RESENDTIMES_TRIES];
    const static int MESSAGEQUEUE_SEND_BATCH_SIZE = 100;
    const static uint64_t MESSAGEACK_KEEPTIME = 5000L;
    struct Message {
        string ip;
        unsigned int port;
        uint64_t time;
        uint8_t messageType;
        uint32_t clientId;
        uint32_t messageId;
        uint8_t retries;
        char message[512];
        size_t bytes;
    };
    typedef queue<Message*> MessageQueue;
    typedef map<uint32_t, Message*> MessageMapAck;
 
    /**
     * @brief public constructor should be called in TCPServer
     * @param id id
     * @param *server server
     * @param maxCCU max ccu
     */
    UDPServerIOThread(const unsigned int id, UDPServer *server, const unsigned int maxCCU);
 
    /**
     * @brief thread program
     */
    virtual void run();
 
    /**
     * @brief pushes a message to be send, takes over ownership of frame
     * @param client client
     * @param messageType message type
     * @param messageId message id
     * @param frame frame to be send
     * @param safe safe, requires ack and retransmission
     * @param deleteFrame delete frame
     * @throws tdme::network::udpserver::NetworkServerException
     */
    void sendMessage(const UDPServerClient* client, const uint8_t messageType, const uint32_t messageId, stringstream* frame, const bool safe, const bool deleteFrame);
 
    /**
     * @brief Processes an acknowlegdement reception
     * @param client client
     * @param messageId message id
     * @throws tdme::network::udpserver::NetworkServerException
     */
    void processAckReceived(UDPServerClient* client, const uint32_t messageId);
 
    /**
     * @brief Clean up timed out safe messages, reissue messages not beeing acknowlegded from client
     */
    void processAckMessages();
 
    //
    unsigned int id;
    UDPServer* server;
    unsigned int maxCCU;
    KernelEventMechanism kem;
 
    Mutex messageQueueMutex;
    MessageQueue messageQueue;
 
    Mutex messageMapAckMutex;
    MessageMapAck messageMapAck;
 
    UDPSocket socket;
};