VsnetDownload::Server::Manager Class Reference

#include <vsnet_dloadmgr.h>

Public Member Functions
	Manager (SocketSet &set, const char **local_search_paths)
	Manager (SocketSet &set)
void	addCmdDownload (SOCKETALT sock, NetBuffer &buffer)
void	cleanDownload (SOCKETALT s)
void	lower_check_queues ()

Detailed Description

The download manager on the server side works in the networking thread as well. It does not catch CMD_DOWNLOAD messages from the client, but it is handed these requests by NetServer::processPacket. It doesn't care about the client, but only about the socket that connects the server to the client. The download manager could run in a separate process, but that would make it very difficult to manage the connection bandwidth.

Definition at line 177 of file vsnet_dloadmgr.h.

Constructor & Destructor Documentation

VsnetDownload::Server::Manager::Manager	(	SocketSet &	set,
		const char **	local_search_paths
	)

VsnetDownload::Server::Manager::Manager

(

SocketSet &

set)

Definition at line 491 of file vsnet_dloadmgr.cpp.

References COUT, and VSFileSystem::datadir.

                                  :
    _set( sets )
{
    COUT<<"Enter "<<__PRETTY_FUNCTION__<<endl;

    _local_search_paths.push_back( VSFileSystem::datadir );
}

Member Function Documentation

void VsnetDownload::Server::Manager::addCmdDownload	(	SOCKETALT	sock,
		NetBuffer &	buffer
	)

NetServer::processPacket calls this. NetServer doesn't care, but we process the NetBuffer actually already in the main thread before triggering wakeup.

Definition at line 499 of file vsnet_dloadmgr.cpp.

References NetBuffer::addChar(), NetBuffer::addShort(), NetBuffer::addString(), VsnetDownload::RecvCmdDownload::asDownloadRequest(), VsnetDownload::RecvCmdDownload::asResolveRequest(), c, CMD_DOWNLOAD, COMPRESSED, COUT, VsnetDownload::DownloadRequest, f, accountXML::file, VsnetDownload::Adapter::ResolveRequest::files, VsnetDownload::Adapter::DownloadRequest::files, NetBuffer::getData(), NetBuffer::getDataLength(), getZoneInfoBuffer(), VSMutex::lock(), LOPRI, VsnetDownload::Adapter::ResolveRequest::num, VsnetDownload::Adapter::DownloadRequest::num, VsnetDownload::RecvCmdDownload::parse(), PSEUDO__LINE__, VsnetOSS::recv(), VsnetDownload::ResolveResponse, Packet::send(), SENDRELIABLE, VSFileSystem::VSFile::Size(), VsnetDownload::UnexpectedSubcommand, VSMutex::unlock(), SocketSet::wakeup(), and VSFileSystem::ZoneBuffer.

{
    COUT<<"Enter "<<__PRETTY_FUNCTION__<<endl;

    RecvCmdDownload recv( buffer );
    Subcommand c = recv.parse();

    COUT<<"   *** "<<" cmd "<<c<<endl;
    switch (c)
    {
    case ResolveRequest:
        {
            Adapter::ResolveRequest *r = recv.asResolveRequest();

            short     num = r->num;

            NetBuffer respbuffer;
            respbuffer.addChar( ResolveResponse );
            respbuffer.addShort( num );

            Adapter::ResolveRequest::iterator iter;
            for (iter = r->files.begin(); iter != r->files.end(); iter++) {
                bool   ok;
                char   ft   = iter->ft;
                string file = iter->file;
                //If we want to download a memory buffer from server access is considered ok
                if (ft == VSFileSystem::ZoneBuffer) {
                    //We receive a filename containing a zone id so we test it exists
                    int zoneid = atoi( file.c_str() );
                    ok = true;
                } else {
                    ok = private_test_access( file, (VSFileSystem::VSFileType) ft );
                }
                respbuffer.addString( file );
                respbuffer.addChar( ok ? 1 : 0 );
            }
            Packet packet;
            packet.send( CMD_DOWNLOAD, 0,
                        respbuffer.getData(), respbuffer.getDataLength(),
                        COMPRESSED|SENDRELIABLE|LOPRI,
                        NULL, sock,
                        __FILE__, PSEUDO__LINE__( 334 ) );
            break;
        }
    case DownloadRequest:
        {
            Adapter::DownloadRequest *r = recv.asDownloadRequest();
            short num = r->num;
            if (num > 0) {
                Adapter::DownloadRequest::iterator iter;
                for (iter = r->files.begin(); iter != r->files.end(); iter++) {
                    char   ft   = iter->ft;
                    string file = iter->file;
                    string path = file;
                    DownloadItemPtr di;
                    VSFileSystem::VSFile *f;
                    //If a request for ZoneBuffer we create a VSFile based on a memory buffer
                    if (ft == VSFileSystem::ZoneBuffer) {
                        NetBuffer netbuf;
                        getZoneInfoBuffer( atoi( file.c_str() ), netbuf );
                        //f = new VSFile( netbuf.getData(), netbuf.getDataLength());

                        DownloadItemBuf *buf;
                        buf = new DownloadItemBuf( sock, file, netbuf.getData(), netbuf.getDataLength() );
                        di.reset( buf );
                    } else {
                        f = private_access( path, (VSFileSystem::VSFileType) ft );
                        if (f) {
                            size_t bytes = f->Size();
                            di.reset( new DownloadItemFile( sock, file, f, bytes ) );
                        } else {
                            //Couldn't open for reading, maybe removed since resolve?
                            di.reset( new DownloadItemFile( sock, file ) );
                        }
                    }
                    _download_mx.lock();
                    _download.push( di );
                    _download_mx.unlock();
                }
                _set.wakeup();
            }
            break;
        }
    default:
        {
            NetBuffer respbuffer;

            respbuffer.addChar( UnexpectedSubcommand );
            respbuffer.addChar( c );
            Packet packet;
            packet.send( CMD_DOWNLOAD, 0,
                        respbuffer.getData(), respbuffer.getDataLength(),
                        COMPRESSED|SENDRELIABLE|LOPRI,
                        NULL, sock,
                        __FILE__, PSEUDO__LINE__( 334 ) );
            break;
        }
    }
}

void VsnetDownload::Server::Manager::cleanDownload

(

SOCKETALT

s)

The NetServer must tell the download manager that a socket has been closed or is otherwise expired. : function needs cleanup (via mutex or private_lower*) - there is a bad race right now.

Definition at line 599 of file vsnet_dloadmgr.cpp.

References COUT.

{
    COUT<<"Enter "<<__PRETTY_FUNCTION__<<endl;

    _lower_download.erase( s );
}

void VsnetDownload::Server::Manager::lower_check_queues

(

)

Called by SocketSet after each round.

Definition at line 606 of file vsnet_dloadmgr.cpp.

References COUT, done, VSMutex::lock(), q, and VSMutex::unlock().

{
    _download_mx.lock();
    while (_download.empty() == false) {
        COUT<<"Enter "<<__PRETTY_FUNCTION__<<endl;

        DownloadItemPtr item = _download.front();
        _download.pop();
        ItemMap_I it = _lower_download.find( item->getSock() );
        if ( it == _lower_download.end() ) {
            ItemQueuePtr q( new ItemQueue );
            _lower_download.insert( ItemMapPair( item->getSock(), q ) );
            it = _lower_download.find( item->getSock() );
        }
        it->second->push( item );
    }
    _download_mx.unlock();

    list< SOCKETALT >tbd;                    //to be deleted
    list< SOCKETALT >::const_iterator tbdi;

    ItemMap_I it;
    for (it = _lower_download.begin(); it != _lower_download.end(); it++) {
        COUT<<"Enter "<<__PRETTY_FUNCTION__<<endl;

        bool done = private_lower_try_push_queue( it->first, it->second );
        if (done)
            tbd.push_back( it->first );
        /* This is expensive but I don't dare to call erase() here
         * because I don't know whether the STL standard allows iterator
         * invalidation for map<>. And anyway, MSVC doesn't care about
         * standards, so better safe than sorry.
         */
    }
    for (tbdi = tbd.begin(); tbdi != tbd.end(); tbdi++)
        _lower_download.erase( *tbdi );
}

---

The documentation for this class was generated from the following files:

• src/networking/lowlevel/vsnet_dloadmgr.h
• src/networking/lowlevel/vsnet_dloadmgr.cpp