serversideasynch.h

Go to the documentation of this file.

/*
 * serversideasynch.h,v 1.10 2003/12/27 19:46:23 matti Exp
 *
 * COBAIN - Communications API for EPOC Environments
 * Copyright (C) 2002-2003 Matti Dahlbom, Matti Kokkola
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 * Contact: Matti Dahlbom <matti@777-team.org>
 *          Matti Kokkola <matti.kokkola@iki.fi>
 */

#ifndef __SERVERSIDEASYNCH_H
#define __SERVERSIDEASYNCH_H 

#include <e32base.h>
#include <es_sock.h>

#include "clientservercommon.h"

// forward declarations
class CConcreteConnection;

// base class for asynchronous call handlers
class CAsynchBase : public CActive
{
    public:
        CAsynchBase(CConcreteConnection *aConnection);
        virtual ~CAsynchBase();

    protected:

        // reference to the concrete connection (socket wrapper)
        CConcreteConnection *iConnection;

        // current pending client call message
        RMessage iMessage;
};

// asynchronous Send handler
class CAsynchSend : public CAsynchBase
{
    public:
        CAsynchSend(CConcreteConnection *aConnection);
        //~CAsynchSend();

        void SendL(TDesC8 *aBuf);
    void SendL(RPointerArray<TDesC8> *aFragments);

        // from CActive
        void RunL();
        void DoCancel();
        TInt RunError(TInt aError);

    private:
    void SendFragmentL(TDesC8 *aBuf);
    void CleanBuffers();

        // buffer being sent, class holds a reference to it
    // as it is responsible for deleting it.
        TDesC8 *iSendBuf;

    // An array containing all fragments of the given
    // buffer if its size exceeds the MTU
    RPointerArray<TDesC8> *iFragments;

    // Amount of fragments waiting for sending
    TInt iFragmentCount;
};

// asynchronous Receive handler
class CAsynchReceive : public CAsynchBase
{
    public:
        CAsynchReceive(CConcreteConnection *aConnection);
       // ~CAsynchReceive();

        void Receive(const RMessage &aMessage);

        // from CActive
        void RunL();
        void DoCancel();
        TInt RunError(TInt aError);
    private:
        // receive buffer
        TBuf8<KRecvBufSize> iRecvBuf; 
        TSockXfrLength iRecvLen;
};

// asynchronous Listen handler
class CAsynchListen : public CAsynchBase
{
    public:
        CAsynchListen(CConcreteConnection *aConnection);
        ~CAsynchListen();

        void ListenL(const RMessage &aMessage);

        // from CActive
        void RunL();
        void DoCancel();
        TInt RunError(TInt aError);

    private:
        RSocket *iIncomingSocket;
};

#endif

---