peerlistpump.h

Go to the documentation of this file.

/*
 * peerlistpump.h,v 1.1 2003/11/25 19:29:56 mattid 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 __PEERLISTPUMP_H
#define __PEERLISTPUMP_H

#include <e32base.h>

#include "cobain.h"

class CPeerListPump : public CActive
{
    public:
        CPeerListPump(TProtocol aProtocol, RCobainClientSession &aClientSession);
        ~CPeerListPump();

        void DiscoverPeers(TUint aServiceClassID, MNetworkDriverListener *aListener);

        // from CActive
        void RunL();
        void DoCancel();

    private:
        void AddPeerToListL();

        // reference to client session
        RCobainClientSession &iClientSession;

        // protocol to use
        TProtocol iProtocol;

        // service class ID of the service
        TUint iServiceClassID;

        // listener
        MNetworkDriverListener *iListener;

        // operation status codes
        enum TOperationStatus {
            ENone,
            ECountPeers,
            EFetchPeer
        };

        // current operation status
        TOperationStatus iOperationStatus;

        // number of peers
        TInt iNumPeers;

        // ordinal of next peer to fetch
        TInt iNextPeerOrdinal;

        // buffer for fetching the number of peers
        TPckgBuf<TInt> iPeerCountBuffer;

        // buffer for fetching peer data
        TPeerDataBuf iPeerDataBuffer;

        // peer list 
        TPeerList *iPeerList;
};

#endif

---