zsospnfs.cpp

Go to the documentation of this file.

//Grzegorz Wierzowiecki
#include <cstdio>
#include <unistd.h> 
#include <string>
#include <cstring>
#include "ZSO-SPNFS_csv_coding.hpp"
#include "ZSO-SPNFS_helper.hpp"

#include "zsospnfs.h"

class encoded{ public:
    std::string s;
    inline encoded(std::string news){ s = make_csv_string(news); };
    inline encoded(long long l){ s = make_csv_string(l); };
    inline encoded(const char *news){ s = make_csv_string(news); };
    inline encoded(std::string news,int){ s = news; };
};

inline long long getll(int c){
    write(c,"\n--------------------------------------------------\n");//flushing output buffer
    return get_integer_from_string(read_csv_string(c));
};

inline std::string getstr(int c){
    write(c,"\n----------------------------------------------------\n");//flushing output buffer
    return read_csv_string(c);
};

inline int snd(int fd, encoded a=encoded("",0), encoded b=encoded("",0), encoded c=encoded("",0), encoded d=encoded("",0), encoded e=encoded("",0) ){
    //printf("snd() -> %s\n", (a.s+b.s+c.s+d.s+e.s).c_str());
    return write(fd,a.s+b.s+c.s+d.s+e.s 
 + "\n--------------------------------------------------\n");//flushing output buffer
};

int spnfs_connect(int c, const char *user, const char *password){
    snd(c,"login",user,password);
    int ret = getll(c);
    read_csv_string(c); //read also comment
    return ret;
};

int spnfs_disconnect(int c){
    snd(c,"bye","quit","exit","ciao"); // ;)
    return 0;
};

int spnfs_new(int c, const char *path){
    snd(c,"new",path);
    std::string s = getstr(c);
    if(s[0]=='O') return 0;
    getstr(c); //receive error description
    return -1;
};

int spnfs_open(int c, const char *path){
    snd(c,"open",path);
    int fid = getll(c);
    if(c<0) getstr(c); //receive error desc.
    return fid;
};

int spnfs_read(int c, int fid, void *buf, int len){
    snd(c,"read",fid,len);
    int retint   =  getll(c);
    std::string s = getstr(c);
    if(retint>len) retint=len;
    if(retint>0) memcpy(buf, s.c_str(), retint);
    return retint;
};

int spnfs_write(int c, int fid, const void *buf, size_t count){
    snd(c,"write",fid); write(c,make_csv_string((const char*)buf,count));
    count = getll(c);
    if(c<0) getstr(c); //receive error desc.
    return 0;
};

long long spnfs_size(int c, const char *path){
    snd(c, "size", path);
    long long ret = getll(c);
    if(ret<0) getstr(c); //receive error desc.
    return ret;
};

int spnfs_seek(int c, int fid, off_t offset, int whence){
    snd(c,"seek",fid,offset,whence);
    int ret = getll(c);
    if(ret<0) getstr(c); //receive erro desc.
    return ret;
};

int spnfs_pos(int c, int fid){
    snd(c,"pos",fid);
    int ret = getll(c);
    if(ret<0) getstr(c); //receive error desc.
    return ret;
};

int spnfs_trunc(int c, int fid){
    snd(c,"trunc",fid);
    int ret = getll(c);
    if(ret!=0) getstr(c); //receive error desc.
    return ret;
};

int spnfs_close(int c, int fid){
    snd(c,"close",fid);
    std::string s = getstr(c);
    if(s[0] == 'O') return 0;
    getstr(c); //receive error desc.
    return -1;
};

---