--- libaitrpc/src/blob.c 2011/08/29 22:37:06 1.3 +++ libaitrpc/src/blob.c 2011/08/29 23:26:56 1.3.2.1 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: blob.c,v 1.3 2011/08/29 22:37:06 misho Exp $ +* $Id: blob.c,v 1.3.2.1 2011/08/29 23:26:56 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -274,7 +274,7 @@ rpc_srv_recvBLOB(rpc_cli_t * __restrict cli, rpc_blob_ * return: -1 error, 0 ok, 1 remote error */ int -rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, rpc_val_t * __restrict var, void * __restrict data) +rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var, void * __restrict data) { int ret, len; uint8_t *pos; @@ -291,13 +291,13 @@ rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, rpc_val_t hdr.hdr_cmd = set; hdr.hdr_var = 0; hdr.hdr_ret = 0; - hdr.hdr_len = var->val_len; + hdr.hdr_len = AIT_LEN(var); if (send(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) { LOGERR; return -1; } - for (ret = var->val_len, pos = data; ret > 0; ret -= len, pos += len) + for (ret = AIT_LEN(var), pos = data; ret > 0; ret -= len, pos += len) if ((len = send(cli->cli_sock, pos, ret, 0)) == -1) { LOGERR; return -1; @@ -318,7 +318,7 @@ rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, rpc_val_t return -1; } if (hdr.hdr_cmd != error) { - if (hdr.hdr_len != var->val_len) { + if (hdr.hdr_len != AIT_LEN(var)) { rpc_SetErr(ECANCELED, "Error:: Bad return length packet ...\n"); return -1; } @@ -337,7 +337,7 @@ rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, rpc_val_t * return: -1 error, 0 ok, 1 remote error */ int -rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, rpc_val_t * __restrict var, void ** data) +rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var, void ** data) { int ret, len; uint8_t *pos; @@ -350,16 +350,16 @@ rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, rpc_val_t return -1; } - *data = malloc(var->val_len); + *data = malloc(AIT_LEN(var)); if (!*data) { LOGERR; return -1; } else - memset(*data, 0, var->val_len); + memset(*data, 0, AIT_LEN(var)); memcpy(&hdr.hdr_session, cli->cli_parent, sizeof(rpc_sess_t)); hdr.hdr_cmd = get; - hdr.hdr_var = (uint32_t) RPC_GET_BLOB(var); + hdr.hdr_var = (uint32_t) AIT_GET_BLOB(var); hdr.hdr_ret = 0; hdr.hdr_len = 0; if (send(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) { @@ -369,7 +369,7 @@ rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, rpc_val_t return -1; } - for (ret = var->val_len, pos = *data; ret > 0; ret -= len, pos += len) { + for (ret = AIT_LEN(var), pos = *data; ret > 0; ret -= len, pos += len) { FD_ZERO(&fds); FD_SET(cli->cli_sock, &fds); len = select(cli->cli_sock + 1, &fds, NULL, NULL, &tv); @@ -409,7 +409,7 @@ rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, rpc_val_t return -1; } if (hdr.hdr_cmd != error) { - if (hdr.hdr_len != var->val_len) { + if (hdr.hdr_len != AIT_LEN(var)) { rpc_SetErr(ECANCELED, "Error:: Bad return length packet ...\n"); free(*data); *data = NULL; @@ -427,7 +427,7 @@ rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, rpc_val_t * return: -1 error, 0 ok, 1 remote error */ int -rpc_cli_delBLOB(rpc_cli_t * __restrict cli, rpc_val_t * __restrict var) +rpc_cli_delBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var) { struct tagBLOBHdr hdr; fd_set fds; @@ -440,7 +440,7 @@ rpc_cli_delBLOB(rpc_cli_t * __restrict cli, rpc_val_t memcpy(&hdr.hdr_session, cli->cli_parent, sizeof(rpc_sess_t)); hdr.hdr_cmd = unset; - hdr.hdr_var = (uint32_t) RPC_GET_BLOB(var); + hdr.hdr_var = (uint32_t) AIT_GET_BLOB(var); hdr.hdr_ret = 0; hdr.hdr_len = 0; if (send(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) { @@ -474,7 +474,7 @@ rpc_cli_delBLOB(rpc_cli_t * __restrict cli, rpc_val_t * return: -1 error, 0 ok, 1 remote error */ inline int -rpc_cli_getBLOB(rpc_cli_t * __restrict cli, rpc_val_t * __restrict var, void ** data) +rpc_cli_getBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var, void ** __restrict data) { int ret;