ReleaseFiles.cpp

См. документацию.

/* 
 * File:   ReleaseFile.cpp
 * Author: nick
 * 
 * Created on 5 Сентябрь 2011 г., 18:01
 */

#include "ReleaseFiles.h"
//#include "main.h"

/*ReleaseFile::ReleaseFile() {
}

ReleaseFile::ReleaseFile(const ReleaseFile& orig) {
}

ReleaseFile::~ReleaseFile() {
}*/


ReleaseFiles::ReleaseFiles(Server &protocol,ServerConfig* sc) {
        // TODO Auto-generated constructor stub
        this->sc=sc;
        this->protocol=&protocol;
        protocol.addIQHandler(this,ReleaseFile_xmlns);
}

void ReleaseFiles::handleTag(TagIQ &tag){
        if (tag.getType()==TagIQ::Get){

                cout<<"Закрытие файла"<<endl;
                ReleaseFile t(tag);
                string dir;
                fuse_file_info fi;
                #ifdef debug_output
                cout <<"GET FILE!!!"<<endl;
                #endif
                t.getFile(dir,fi);

                #ifdef debug_output
                cout <<"GET FILE OK!!!"<<endl;
                #endif
                ReleaseFile resrf(protocol->getCurNodeSend() ,"server",tag.getFrom(),TagIQ::Result,tag.getID());
                //Если в списке файлов такой есть
                int result=-1;
                pthread_mutex_t* openedFiles_mutex=GlobalData::get_Instance()->get_openedFiles_mutex();
                pthread_mutex_lock(openedFiles_mutex);
                map<string,OpenedFilesInfo>* openedFiles=GlobalData::get_Instance()->get_OpenedFiles();

                cout<<"Имя файла "<<dir<<endl;
                cout<<"Все открытые файлы"<<endl;
                map<string,OpenedFilesInfo>::iterator bi=openedFiles->begin();
                while(bi!=openedFiles->end()){
                    cout<<"filename"<< bi->first<<endl;
                    ++bi;
                }
                cout<<"=================="<<endl;
                map<string,OpenedFilesInfo>::iterator it= openedFiles->find(dir);
                if(it!=openedFiles->end()){
                    cout<<"Файл найден в списке открытых файлов"<<endl;
                    //Если текущий клиент его открыл
                    map<unsigned int, unsigned int>::iterator ito=it->second.file_info.find(protocol->getClientID());
                    if(ito!=it->second.file_info.end()){
                        cout<<"Файл был открыт текущим клиентом, уменьшаем счетчик"<<endl;
                        result=0;                        
                        ito->second--;
                        cout <<"Файл открыт "<<ito->second<<" раз"<<endl;
                        //Если файл больше не открыт клиентом
                        if(ito->second==0){
                            cout <<"т.юк. Файл открыт 0 раз, этим клиентом, удаляем"<<endl;
                            it->second.file_info.erase(ito);
                            //Если файл не откыт ни одним клиентом
                            if(it->second.file_info.begin()==it->second.file_info.end()){
                                cout <<"т.юк. Файл открыт 0 всеми клиентами удаляем его вообще"<<endl;
                                openedFiles->erase(it);
                            }
                        }
                    }
                }
                pthread_mutex_unlock(openedFiles_mutex);
/*                if (openedFiles.erase(dir)>0){
                    resrf.setResult(0);
                }else{
                    resrf.setResult(-1);
                }*/
                resrf.setResult(result);
                protocol->sendNode(resrf);
        }
}

ReleaseFiles::~ReleaseFiles() {
// TODO Auto-generated destructor stub
    this->protocol->removeIQHandler(this);

    pthread_mutex_t* openedFiles_mutex=GlobalData::get_Instance()->get_openedFiles_mutex();
    pthread_mutex_lock(openedFiles_mutex);
    map<string,OpenedFilesInfo>* openedFiles=GlobalData::get_Instance()->get_OpenedFiles();

    map<string,OpenedFilesInfo>::iterator itb;//= openedFiles.begin();
    map<string,OpenedFilesInfo>::iterator itbb= openedFiles->begin();
    while(itbb!=openedFiles->end()){
        itb=itbb;
        ++itbb;
        map<unsigned int,unsigned int>::iterator itf=itb->second.file_info.find(protocol->getClientID());
        if(itf!=itb->second.file_info.end()){
            itb->second.file_info.erase(itf);
            if(itb->second.file_info.begin()==itb->second.file_info.end()){
                openedFiles->erase(itb);
            }
        }
    }
    pthread_mutex_unlock(openedFiles_mutex);
}