concreteconnection.h

Go to the documentation of this file.

/*
 * concreteconnection.h,v 1.16 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 __CONCRETE_CONNECTION_H
#define __CONCRETE_CONNECTION_H

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

#include "serversession.h"

// forward declarations
class CAsynchSend;
class CAsynchReceive;
class CAsynchListen;

class CConcreteConnection : public CBase
{
    public:
        enum TConnectionFailure {
            ENoSocket = 67000,
            ESocketClosed,
            EBadMessage
        };

        enum TInitError {
            ENullSocket = 68000,
            ENullSocketServ
        };

        static CConcreteConnection * NewL(RSocket *aSocket, 
                                          CServerSession &aSession,
                      TInt aMtu);
        static CConcreteConnection * NewListeningL(RSocket *aSocket,
                                                   RSocketServ *aSocketServ,
                                                   CServerSession &aSession);

        CServerSession& GetSession() { return iSession; }
        ~CConcreteConnection();

        TBool IsListening() { return iIsListening; }

        void ReceiveL(const RMessage &aMessage);
        void CancelReceive();

        void Close(TBool aImmediately = EFalse);

        void SendL(TDesC8 *aBuf);
        void ListenL(const RMessage &aMessage);
        void CancelListen();
    TInt GetMTU();

    protected:
        void ConstructL(TBool aIsListening);
        CConcreteConnection(RSocket* aSocket,
                            RSocketServ *aSocketServ, 
                            CServerSession &aSession,
                TInt aMtu);

        // asynchronous send handler
        CAsynchSend *iSender;

        // asynchronous listen handler
        CAsynchListen *iListener;

    // asynchronous receive handler
    CAsynchReceive *iReceiver;

    private:
        RSocket& GetSocket() { return *iSocket; }
        RSocketServ& GetSocketServ() { return *iSocketServ; }

        // whether this connection is a listening connection
        TBool iIsListening;

        // whether this connection has already been closed
        TBool iIsClosed;

        // the session that owns this connection
        CServerSession &iSession;

        // actual socket resources
        RSocket* iSocket;
        RSocketServ *iSocketServ;
    
    // Maximum transfer unit of this connection
    TInt iMtu;

        friend class CAsynchSend;
        friend class CAsynchListen;
    friend class CAsynchReceive;
};

#endif

---