ReadFiles.cpp

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

/*
 * ReadFiles.cpp
 *
 *  Created on: 14.06.2011
 *      Author: nick
 */

#include <errno.h>

#include "ReadFiles.h"

ReadFiles::ReadFiles(Protocol &protocol, ServerConfig* sc, BinaryProtocol* bp) {
    this->sc = sc;
    this->bp = bp;
    this->protocol = &protocol;    
    this->max_readsize=sc->getModuleAttributeInt(L"lib_file_opertion",L"max_read_size",409600);
    cout<<"max_readsize"<<max_readsize<<endl;
    protocol.addIQHandler(this, ReadFile_xmlns);
}

void ReadFiles::handleTag(TagIQ &tag) {
    //Node* parent=NULL,string from="", string to="", IQType type=TagIQ::Get, string id=""
    TagIQ::IQType t = tag.getType();
    //
    #ifdef debug_output
    cout << "STEP1 read" << endl;
    #endif
    if (t == TagIQ::Set) {
        //==============
        string path;
        size_t size;
        size_t offset;
        fuse_file_info fi;
        //================
        int fDesc;
        struct stat fb;

        //Открыть файл перейти в опредиленную позицию,
        //посчитать сколько можно прочесть, вернуть ответ(Запрос на чтение)
        ReadFile rf(tag);
        #ifdef debug_output
        cout << "STEP2 read" << endl;
        #endif
        //ReadFile(Node* parent=NULL,string from="", string to="", IQType type=TagIQ::Get, string id="");
        ReadFile rfResp(NULL, "server", "client", TagIQ::Get, tag.getID());
        rf.getFileData(path, offset, size, fi);
        #ifdef debug_output
        cout << "path:" << path << " offset:" << offset << "size:" << size << endl;
        #endif
        string dpath = sc->getSharedDir() + path;
        //const char* dpath=(sc->getSharedDir()+path).c_str();
        fDesc = open(dpath.c_str(), O_RDONLY/*fi.flags*/);
        if (fDesc == -1) {
            cout << "erroropenfile!" << errno << endl;
            cout << "filename" << dpath << endl;
        }

        if (fstat(fDesc, &fb) == -1) {
            cout << "fstat error" << errno << endl;
        }
        size_t szforread = fb.st_size - offset;
        #ifdef debug_output
        cout << "szforread" << szforread << "file size" << fb.st_size << endl;
        #endif
        if (szforread < 0) {
            #ifdef debug_output
            cout << "ELSE1 READ" << endl;
            #endif
            szforread = 0;
        } else if (size < szforread) {
            #ifdef debug_output
            cout << "ELSE2 READ" << endl;
            #endif
            szforread = size;
        }
        #ifdef debug_output
        cout << "STEP3 read" << endl;
        #endif
        unsigned long int pktID = bp->getNextId();
        rfResp.setResult(pktID, szforread);
        if (szforread == 0) {
            protocol->sendNode(rfResp);
        } else {
            //protocol->sendNode(rfResp);
            #ifdef debug_output
            cout << "lalal1" << endl;
            #endif
            TagIQ rt = protocol->sendIQResp(rfResp, ReadFile_xmlns, QUERY_TAG);
            #ifdef debug_output
            cout << "!!!!lalalal!!! namespace:" << rt.getNamesapace() << "typeIQ:" << rt.getType() << endl;
            #endif
            if ((rt.getKind(ReadFile_xmlns) != NULL) && (rt.getType() == TagIQ::Result)) {

                /*lseek(fDesc,offset,SEEK_SET);
                ssize_t sr1=szforread;
                ssize_t sr=0;//Результат чтения за под раз
                void* buf=malloc(szforread);
                char* buf1=(char*)buf;
                do{
                        cout<<"цикл1"<<endl;
                        sr=read(fDesc,buf1,sr1);
                        if(sr!=-1){
                                sr1-=sr;
                                buf1+=sr;
                        }
                        if(sr==0){
                                cout<<"конец файла"<<endl;
                        }
                }while ((sr1>0)&&(sr>0));
                bp->setSendBufferData(buf,szforread-sr1,pktID);
                free(buf);*/
                #ifdef debug_output
                cout << "OK, sending file data" << endl;
                #endif
                //TODO нечать передачу по бинарному протоколу
                //Максимальный размер который можно с диска прочитать за раз
                //size_t max_readSize = 4096000;
                //Размер яитаемый за раз, если он больше максимального, присвоить максимальный
                size_t rzize = szforread;
                if (rzize > max_readsize) {
                    rzize = max_readsize;
                }

                //Выделяем буфер для чтения за раз
                void* buf = malloc(rzize);
                //Перемещаем на нужное место указатель в файле
                lseek(fDesc, offset, SEEK_SET);

                //Сколько надо всего прочитать
                size_t rzizeall = szforread;
                while (rzizeall > 0) {
                    //Текущая позиция в буфере
                    char* buf1 = (char*) buf;
                    ssize_t sr = 0; //Результат чтения за под раз
                    ssize_t sr1 = rzize; //сколько нужно прочесть за раз
                    do {//Читаем по подразу пока не прочтем за раз
                        #ifdef debug_output
                        cout << "цикл1" << endl;
                        #endif
                        sr = read(fDesc, buf1, sr1);
                        if (sr != -1) {
                            sr1 -= sr;
                            buf1 += sr;
                        }
                    } while ((sr1 > 0) && (sr > 0));
                    //отправлеяем пакет который прочли за раз
                    //Сколько нужно прочесть - сколько прочесть не вышло
                    bp->setSendBufferData(buf, rzize - sr1, pktID);
                    rzizeall -= (rzize - sr1);
                    #ifdef debug_output
                    cout << "sr1" << sr1 << endl;
                    #endif
                    if (sr == -1) {
                        cout << "ОШИБКА ЧТЕНИЯ!" << errno << endl;
                        //Если была ошибка чтения то нужно прервать чтение
                        break;
                    }
                    if (sr == 0) {
                        cout << "Конец файла!" << endl;
                        break;
                    }
                    #ifdef debug_output
                    cout << "цикл2" << endl;
                    #endif
                }
                free(buf);
            } else {
                cout << "!!Нет ответа от клиента о подетверждении передачи содержимого!!!!" << endl;
            }
        }
        close(fDesc);
        #ifdef debug_output
        cout << "STEPFINAL read" << endl;
        #endif
    }
    #ifdef debug_output
    cout << "STEP END read" << endl;
    #endif
}

ReadFiles::ReadFiles() {
    // TODO Auto-generated constructor stub

}

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