Commit c216187b authored by Ramon Nou's avatar Ramon Nou
Browse files

debug

parent e5aa1417

src/client/gkfs_libc.cpp

+4 −5
Original line number Diff line number Diff line
@@ -305,11 +305,11 @@ DLSYM_WRAPPER(int, closedir, (DIR * dirp), (dirp), "closedir") 
DLSYM_WRAPPER(void, seekdir, (DIR * dirp, long loc), (dirp, loc), "seekdir")

DLSYM_WRAPPER(long, telldir, (DIR * dirp), (dirp), "telldir")





/*

static pid_t (*real_fork)(void) = NULL;

static pid_t (*real_vfork)(void) = NULL;

static pid_t (*real_clone)(int (*fn)(void*), void*, int, void*, ...) = NULL;

/*



pid_t

vfork(void) {

    if(!real_vfork)
@@ -834,7 +834,6 @@ pread(int fd, void* buf, size_t count, off_t offset) { 
ssize_t

pwrite(int fd, const void* buf, size_t count, off_t offset) {

    initializeGekko();

    DEBUG_INFO("[GKFS] PWRITE BEFORE {}", fd);

    GKFS_OPERATION(pwrite, fd, buf, count, offset);

    GKFS_FALLBACK(pwrite, fd, buf, count, offset);

}
@@ -2266,7 +2265,7 @@ pwritev2(int fd, const struct iovec* iov, int iovcnt, off_t offset, int flags) { 


//            */



DLSYM_WRAPPER(int, aio_write, (struct aiocb * aiocbp), (aiocbp), "aio_write");

DLSYM_WRAPPER(int, aio_write, (struct aiocb * aiocbp), (aiocbp), "aio_write")

int

aio_write(struct aiocb* aiocbp) {

    initializeGekko();
@@ -2283,7 +2282,7 @@ aio_write(struct aiocb* aiocbp) { 
    GKFS_FALLBACK(aio_write, aiocbp)

}



DLSYM_WRAPPER(int, aio_read, (struct aiocb * aiocbp), (aiocbp), "aio_read");

DLSYM_WRAPPER(int, aio_read, (struct aiocb * aiocbp), (aiocbp), "aio_read")

int

aio_read(struct aiocb* aiocbp) {

    initializeGekko();

src/client/preload.cpp

+10 −9
Original line number Diff line number Diff line
@@ -334,7 +334,8 @@ init_environment() { 
    //   if(!gkfs::rpc::forward_get_fs_config()) {

    //       exit_error_msg(

    //               EXIT_FAILURE,

 //               "Unable to fetch file system configurations from daemon process through RPC.");

    //               "Unable to fetch file system configurations from daemon

    //               process through RPC.");

    //   }

    // Initialize random number generator and seed for replica selection

    // in case of failure, a new replica will be selected