OpenFiles.cpp

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

/*
 * OpenFiles.cpp
 *
 *  Created on: 11.06.2011
 *      Author: nick
 */

#include "OpenFiles.h"


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

void OpenFiles::handleTag(TagIQ &tag) {
    if (tag.getType() == TagIQ::Get) {
        OpenFile t(tag);
        string dir;
        fuse_file_info fi;
#ifdef debug_output
        cout << "GET FILE!!!" << endl;
#endif
        mode_t mode;
        t.getFile(dir, fi,mode);
        string d(dir);
#ifdef debug_output
        cout << "GET FILE OK!!!" << endl;
#endif
        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 it = openedFiles->find(d);
        if (it == openedFiles->end()) {
            cout<<"Открываем новый файл и вставляем его в список "<<d<<endl;
            OpenedFilesInfo oi;
            oi.flags = 0;
            it = openedFiles->insert(make_pair(d, oi)).first;
        }
        bool is_write=(((fi.flags & O_RDWR) == O_RDWR) || ((fi.flags & O_WRONLY) == O_WRONLY) || ((fi.flags & O_RDWR) == O_APPEND));
        if(is_write){
            cout<<"Открываем файл на запись"<<endl;
        }
        int resultO;
        if (
                (((it->second.flags & O_RDWR) == O_RDWR) || ((it->second.flags & O_WRONLY) == O_WRONLY) ||
                ((it->second.flags & O_APPEND) == O_APPEND)) || //Если у нас файл уже открыт на изменение, то не надо его открывать больше
                //Если файл уже открыт, не важно как, а мы пытаемся его открыть на запись, то нельзя
                ((it->second.file_info.begin() != it->second.file_info.end()) && is_write)
                /*(((fi.flags | O_RDWR) == O_RDWR) ||
                ((fi.flags | O_WRONLY) == O_WRONLY) || ((fi.flags | O_RDWR) == O_APPEND)
                )*/
                //Если мы зотим открыть на запись, а он уже открыт
            ) {
            cout<<"Файл уже открыт для записи, и мы пытаемся открыть еще раз - нельзя"<<endl;
            resultO = -1;
        } else {
            cout<<"Открываем файл 1"<<endl;
            int fd=0;
            if (is_write){
                cout<<"Собираемся писать в файл, но ранее он открыт небыл 1"<<endl;
                string path=sc->getSharedDir()+dir;
                fd = open(path.data(), fi.flags,mode);
                if (fd > 0) {
                    cout<<"Файл открыть на запись удалось"<<endl;
                    close(fd);                    
                }else{
                    resultO=fd;
                    cout<<"Файл открыть на запись не удалось"<<endl;
                    //Если открыли файл в первый раз, а он не открылся, то убрали
                    if (it->second.flags==0){//Похоже это условие лишнее, т.к. только в первый раз можно писать
                        cout<<"Файл открыть на запись не удалось, Открыт первый раз, удаляем файл из списка открытых"<<endl;
                        openedFiles->erase(it);
                    }
                }
            }
            if ((fd > 0)||(!is_write)) {//TO DOD разобр
                cout<<"Файл удалось открыть, для записи, либо открытие для чтения"<<endl;
                resultO = 0;
                map<unsigned int, unsigned int>::iterator itf = it->second.file_info.find(protocol->getClientID());
                if (itf == it->second.file_info.end()) {
                    itf = it->second.file_info.insert(make_pair(protocol->getClientID(), 0)).first;
                }
                string path = sc->getSharedDir() + dir;
                if (it->second.flags == 0) {
                    cout<<"Если флаги 0, то открытие в первый раз присваиваем флаги"<<endl;
                    it->second.flags = fi.flags;
                }
                cout<<"Увеличиваем счетчик файлов"<<endl;
                itf->second++;
            }
            
        }
        cout<<"Результат открыия"<<resultO<<endl;
        pthread_mutex_unlock(openedFiles_mutex);
        OpenFile resof(protocol->getCurNodeSend(), "server", tag.getFrom(), TagIQ::Result, tag.getID());
        resof.setResult(resultO);
        protocol->sendNode(resof);
    }
}

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