KjClientConn.h

Go to the documentation of this file.

#pragma once

#include "../KjSslSocket/KjSslServer.h"
#include "../KjSslSocket/KjSslConnection.h"
#include <pthread.h>    // For threads

class KjClientConn
{
        KjSslServer *m_pServer;         
        KjSslConnection *m_pSslConn;    
        pthread_t m_iThreadId;          
        pthread_t *m_pThread;           
        bool m_bIsConnected;            
        bool m_bIsLockNewThread;        
        string m_strReadMsg;            
        string m_strWriteMsg;           
        bool m_bCanRead;                        
        
        bool ChatWithClient();
        void ParseClientRequest(string &_strMsg);
        void DeleteEndMsg(string &_strMsg);
public:
        KjClientConn(KjSslServer *_pServer, pthread_t *_pThread);
        ~KjClientConn();

        void NewClient();
        string &ReadMsg();              
        void WriteMsg(const string &_strMsg);   

        KjSslConnection *GetConn()
        {
                return m_pSslConn;
        }

        pthread_t &GetThreadId()
        {
                return m_iThreadId;
        }

        pthread_t *GetThread()
        {
                return m_pThread;
        }

        bool &GetIsConnected()
        {
                return m_bIsConnected;
        }

        bool &GetIsLockNewThread()
        {
                return m_bIsLockNewThread;
        }

        bool &GetCanRead()
        {
                return m_bCanRead;
        }
};

---