WriteFiles.cpp

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

/* 
 * File:   WriteFiles.cpp
 * Author: nick
 * 
 * Created on 9 Сентябрь 2011 г., 16:29
 */

#include "WriteFiles.h"
#include <errno.h>

WriteFiles::WriteFiles(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, WriteFile_xmlns);
}

void WriteFiles::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;

        //Открыть файл перейти в опредиленную позицию,
        //посчитать сколько можно прочесть, вернуть ответ(Запрос на чтение)
        WriteFile wf(tag);
        #ifdef debug_output
        cout << "STEP2 read" << endl;
        #endif
        //ReadFile(Node* parent=NULL,string from="", string to="", IQType type=TagIQ::Get, string id="");
        WriteFile wfResp(NULL, "server", "client", TagIQ::Set, tag.getID());
        wf.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_RDWR/*fi.flags*/ );
       if (fDesc == -1) {
            cout << "erroropenfile!" << errno << endl;
            cout << "filename" << dpath << endl;
        }
        
        lseek(fDesc,offset,SEEK_SET);
        
        unsigned int pktID=bp->getNextId();
//        size_t szforread=size;
//        while(szforread>0){
//        size_t szoneread=szforread;
//            if (szoneread>max_readsize){
//                szoneread=max_readsize;
//            }
            void* buf1= malloc(size);
            if (buf1==NULL){
                cout<<"Не могу выделить памяти!!!"<<errno<<endl;
            }
            bp->setFillBuffer(buf1,size,pktID);

            wfResp.setResult(pktID,size);
            protocol->sendNode(wfResp);
            bp->waiteFillBuffer(pktID);
            size_t wres=0;
            size_t wbts=0;
            char* buf=(char*)buf1;
            while (wbts<size){
               wres=write(fDesc,buf,size);
               if (wres>0){
                   buf+=wres;
                   wbts+=wres;
               }else{
                   break;
               }
            }
            close(fDesc);
            free(buf1);


            //szoneread-=szoneread;
        //}
        //write()

/*        if (fstat(fDesc, &fb) == -1) {
            cout << "fstat error" << errno << endl;
        }*/
//        size_t szforrwrite = max_readsize;
/*        #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 << "STEP END read" << endl;
    #endif

}

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

}

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