Commit 23bca485 authored by Alberto Miranda's avatar Alberto Miranda ♨️
Browse files

First working implementation of remote pushes

parent e2a5c0fb

include/norns/norns_error.h

+4 −0
Original line number Diff line number Diff line
@@ -77,6 +77,10 @@ extern "C" { 
#define NORNS_EFINISHED         -102

#define NORNS_EFINISHEDWERROR   -103



/* errors resources */

#define NORNS_ERESOURCEEXISTS   -110

#define NORNS_ENOSUCHRESOURCE   -111



/* misc errors */

#define NORNS_ENOTSUPPORTED     -200

#define NORNS_ESYSTEMERROR      -201

lib/errors.c

+4 −0
Original line number Diff line number Diff line
@@ -61,6 +61,10 @@ const char* const norns_errlist[NORNS_ERRMAX + 1] = { 
    [ERR_REMAP(NORNS_ETOOMANYTASKS)] = "Too many pending tasks",

    [ERR_REMAP(NORNS_ETASKSPENDING)] = "There are still pending tasks",



    /* resource errors */

    [ERR_REMAP(NORNS_ERESOURCEEXISTS)] = "Resource already exists",

    [ERR_REMAP(NORNS_ENOSUCHRESOURCE)] =  "Resource does not exist",



    /* misc errors */

    [ERR_REMAP(NORNS_ENOTSUPPORTED)] = "Not supported",

    [ERR_REMAP(NORNS_ESYSTEMERROR)] = "Operating system error",

src/common/types.cpp

+4 −0
Original line number Diff line number Diff line
@@ -109,6 +109,10 @@ std::string to_string(urd_error ecode) { 
            return "NORNS_ETASKSPENDING";

        case urd_error::accept_paused:

            return "NORNS_EACCEPTPAUSED";

        case urd_error::resource_exists:

            return "NORNS_ERESOURCEEXISTS";

        case urd_error::no_such_resource:

            return "NORNS_ENOSUCHRESOURCE";

        default:

            return "UNKNOWN_ERROR";

    }

src/common/types.hpp

+4 −0
Original line number Diff line number Diff line
@@ -107,6 +107,10 @@ enum class urd_error : norns_error_t { 
    no_such_task      = NORNS_ENOSUCHTASK,

    too_many_tasks    = NORNS_ETOOMANYTASKS,

    tasks_pending     = NORNS_ETASKSPENDING,



    /* errors about resources */

    resource_exists   = NORNS_ERESOURCEEXISTS,

    no_such_resource  = NORNS_ENOSUCHRESOURCE,

};



namespace utils {

src/io/task-remote-transfer.hpp

+2 −2
Original line number Diff line number Diff line
@@ -61,8 +61,8 @@ task<iotask_type::remote_transfer>::operator()() { 


    LOGGER_WARN("[{}] Starting I/O task", tid);

    LOGGER_WARN("[{}]   TYPE: {}", tid, utils::to_string(type));

    LOGGER_WARN("[{}]   FROM: {}", tid, src_backend->to_string());

    LOGGER_WARN("[{}]     TO: {}", tid, dst_backend->to_string());

    LOGGER_WARN("[{}]   FROM: {}", tid, src_rinfo->to_string());//src_backend->to_string());

    LOGGER_WARN("[{}]     TO: {}", tid, dst_rinfo->to_string());//dst_backend->to_string());



    m_task_info->update_status(task_status::running);