VsnetDownload::Client::Manager Class Reference

#include <vsnet_dloadmgr.h>

Public Member Functions
	Manager (SocketSet &set, const char **local_search_paths)
	Manager (SocketSet &set)
void	addItem (Item *item)
void	addItems (std::list< Item * > &items)
void	processCmdDownload (SOCKETALT sock, NetBuffer &buffer)
void	lower_check_queues ()

Detailed Description

The download manager works in the networking thread. New requests are added from all threads, and notifications may interfere with the Items that are owned by other threads, but the management of files and buffers is handled entirely in the networking threads.

Definition at line 53 of file vsnet_dloadmgr.h.

Constructor & Destructor Documentation

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

Definition at line 59 of file vsnet_dloadmgr.cpp.

References c, and COUT.

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

    const char **c = local_search_paths;
    while (*c != NULL) {
        _local_search_paths.push_back( *c );
        c++;
    }
}

VsnetDownload::Client::Manager::Manager

(

SocketSet &

set)

Definition at line 71 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::Client::Manager::addItem

(

Item *

item)

Definition at line 79 of file vsnet_dloadmgr.cpp.

References addItems().

{
    list< Item* >l;
    l.push_back( item );
    addItems( l );
}

void VsnetDownload::Client::Manager::addItems

(

std::list< Item * > &

items)

Definition at line 86 of file vsnet_dloadmgr.cpp.

References VsnetDownload::Client::Item::changeState(), VsnetDownload::Client::Completed, COUT, VSFileSystem::FileNotFound, VsnetDownload::Client::Item::getFilename(), VSMutex::lock(), VsnetDownload::Client::Queued, VSMutex::unlock(), and SocketSet::wakeup().

Referenced by addItem().

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

    list< Item* >::iterator it;

    _pending_mx.lock();
    for (it = items.begin(); it != items.end(); it++) {
        Item *item = (*it);
        if (item->getFilename() != "") {
            COUT<<"adding item: "<<item->getFilename()<<endl;
            _pending.push( item );
        }
    }
    _pending_mx.unlock();
    for (it = items.begin(); it != items.end(); it++) {
        Item *item = (*it);
        if (item->getFilename() == "")
            item->changeState( Completed, FileNotFound );
        else
            item->changeState( Queued );
    }
    _set.wakeup();
}

void VsnetDownload::Client::Manager::lower_check_queues

(

)

Called by SocketSet after each round.

Definition at line 140 of file vsnet_dloadmgr.cpp.

{
    private_lower_poll();
}

void VsnetDownload::Client::Manager::processCmdDownload	(	SOCKETALT	sock,
		NetBuffer &	buffer
	)

NetClient::recvMsg calls this for answers from a server mgr (currently only from the server because no other socket is checked).

Definition at line 111 of file vsnet_dloadmgr.cpp.

References c, COUT, VsnetDownload::Download, VsnetDownload::DownloadError, VsnetDownload::DownloadFirstFragment, VsnetDownload::DownloadFragment, VsnetDownload::DownloadLastFragment, VsnetDownload::DownloadRequest, NetBuffer::getChar(), VsnetDownload::ResolveRequest, VsnetDownload::ResolveResponse, and VsnetDownload::UnexpectedSubcommand.

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

    char c = buffer.getChar();
    Subcommand sc = (Subcommand) c;
    switch (sc)
    {
    case ResolveResponse:
        private_eval_resolve_response( sock, buffer );
        break;
    case DownloadError:
        private_eval_download_error( sock, buffer );
        break;
    case Download:
    case DownloadFirstFragment:
    case DownloadFragment:
    case DownloadLastFragment:
        private_eval_download( sock, buffer, sc );
        break;
    case DownloadRequest:
    case UnexpectedSubcommand:
    case ResolveRequest:
    default:
        COUT<<"unexpected subcommand "<<sc<<", ignoring"<<endl;
        break;
    }
}

---

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

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