Skip to content
Snippets Groups Projects
Commit 5a829068 authored by Utz-Uwe Haus's avatar Utz-Uwe Haus
Browse files

add CDO buffer debugging in failed GFS writes

parent 644a0b1c
Branches
Tags
No related merge requests found
Pipeline #61481 failed
......@@ -69,7 +69,7 @@ mstro_transport_gfs_src_execute(mstro_cdo src, Mstro__Pool__TransferTicket* tick
FILE *f = NULL;
char* path = ticket->gfs->path;
INFO("Path src app will use for transport: %s\n", path);
DEBUG("Path src app will use for transport: %s\n", path);
if (path == NULL) {
ERR("Ticket for GFS transport does not contain a path\n");
return MSTRO_INVARG;
......@@ -83,8 +83,8 @@ mstro_transport_gfs_src_execute(mstro_cdo src, Mstro__Pool__TransferTicket* tick
}
if (fwrite(dl.data, sizeof(char), dl.len/sizeof(char), f) != dl.len) {
ERR("Partial write on %s for GFS transport (errno: %d -- %s)\n",
path, errno, strerror(errno));
ERR("Partial write on %s (buf: %p) for GFS transport (errno: %d -- %s)\n",
path, dl.data, errno, strerror(errno));
return MSTRO_FAIL;
}
......@@ -94,7 +94,7 @@ mstro_transport_gfs_src_execute(mstro_cdo src, Mstro__Pool__TransferTicket* tick
return MSTRO_FAIL;
}
INFO("src app successfully executed transport CDO %s\n",
DEBUG("src app successfully executed transport CDO %s\n",
src->name);
return MSTRO_OK;
}
......@@ -129,11 +129,11 @@ mstro_transport_gfs_dst_execute(mstro_cdo dst,
/* data is the raw-ptr or freshly allocated, CDO attribute is correct */
FILE *f = NULL;
char* path = ticket->gfs->path;
INFO("Path src app will use for transport: %s\n", path);
if (path == NULL) {
ERR("Ticket for GFS transport does not contain a path\n");
return MSTRO_INVARG;
}
DEBUG("Path dst app will use for transport: %s\n", path);
f = fopen(path,"rb");
if (f == NULL) {
ERR("Failed to open %s for GFS transport: %d (%s)\n",
......@@ -176,7 +176,7 @@ mstro_transport_gfs_dst_execute(mstro_cdo dst,
/* abort(); */
/* } */
INFO("dst app successfully executed transport CDO %s\n", dst->name);
DEBUG("dst app successfully executed transport CDO %s\n", dst->name);
if (! (ticket->gfs->keep_file)) {
int s = unlink(ticket->gfs->path);
......@@ -184,7 +184,7 @@ mstro_transport_gfs_dst_execute(mstro_cdo dst,
WARN("Couldn't unlink file used for gfs transfer (%s): %d (%s)\n",
ticket->gfs->path, s, strerror(s));
} else {
INFO("Removed the transfer file from GFS\n");
DEBUG("Removed the transfer file\n");
}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment