diff options
| author | Prasanna Kumar Kalever <prasanna.kalever@redhat.com> | 2017-08-22 16:48:32 +0530 |
|---|---|---|
| committer | Prasanna Kumar Kalever <prasanna.kalever@redhat.com> | 2017-08-28 20:56:04 +0530 |
| commit | 64ba10f39774607b32e1f71b2852d4f34fde378f (patch) | |
| tree | e3cb7290442e5b68aff6064757a7dbcba878842f /utils | |
| parent | 1316624066cc1ff821f892ea6601a63ca2d0094a (diff) | |
gluster-block: parse remote command outputs
Change-Id: Ic2317843a8bd882fc26233373a4b4c35b13f24c6
Signed-off-by: Prasanna Kumar Kalever <prasanna.kalever@redhat.com>
Diffstat (limited to 'utils')
| -rw-r--r-- | utils/utils.h | 49 |
1 files changed, 49 insertions, 0 deletions
diff --git a/utils/utils.h b/utils/utils.h index 6cb4abc..9bb9cc4 100644 --- a/utils/utils.h +++ b/utils/utils.h @@ -234,6 +234,55 @@ extern struct gbConf gbConf; } \ } while (0) +# define GB_CMD_EXEC_AND_VALIDATE(cmd, sr, blk, vol, opt) \ + do { \ + FILE *fp; \ + char tmp[1024]; \ + LOG("mgmt", GB_LOG_DEBUG, "command, %s", cmd); \ + fp = popen(cmd, "r"); \ + if (vol) \ + snprintf(tmp, 1024, "%s/%s", vol, blk->block_name); \ + else \ + snprintf(tmp, 1024, "%s", blk->block_name); \ + if (fp) { \ + size_t newLen = fread(sr->out, sizeof(char), 8192, fp); \ + if (ferror( fp ) != 0) \ + LOG("mgmt", GB_LOG_ERROR, \ + "reading command %s output for %s failed", tmp, \ + cmd, strerror(errno)); \ + else \ + sr->out[newLen++] = '\0'; \ + sr->exit = blockValidateCommandOutput(sr->out, opt, \ + (void*)blk); \ + pclose(fp); \ + } else { \ + LOG("mgmt", GB_LOG_ERROR, \ + "popen(): for %s executing command %s failed(%s)", \ + tmp, cmd, strerror(errno)); \ + } \ + LOG("mgmt", GB_LOG_DEBUG, "raw output, %s", sr->out); \ + LOG("mgmt", GB_LOG_INFO, "command exit code, %d", \ + sr->exit); \ + } while (0) + +# define GB_OUT_VALIDATE_OR_GOTO(out, label, errStr, blk, vol, fmt ...)\ + do { \ + char *tmp; \ + char vol_blk[1024]; \ + if (vol) \ + snprintf(vol_blk, 1024, "%s/%s", vol, blk->block_name); \ + else \ + snprintf(vol_blk, 1024, "%s", blk->block_name); \ + if (GB_ASPRINTF(&tmp, fmt) == -1) \ + goto label; \ + if (!strstr(out, tmp)) { \ + GB_FREE(tmp); \ + LOG("mgmt", GB_LOG_ERROR, errStr, vol_blk); \ + goto label; \ + } \ + GB_FREE(tmp); \ + } while (0) + # define CALLOC(x) \ calloc(1, x) |