File:  [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src / blob.c
Revision 1.13.2.1: download - view: text, annotated - select for diffs - revision graph
Mon Jul 15 13:32:15 2013 UTC (10 years, 11 months ago) by misho
Branches: rpc5_3
Diff to: branchpoint 1.13: preferred, unified
add drop blob if found error

    1: /*************************************************************************
    2: * (C) 2010 AITNET ltd - Sofia/Bulgaria - <misho@aitbg.com>
    3: *  by Michael Pounov <misho@openbsd-bg.org>
    4: *
    5: * $Author: misho $
    6: * $Id: blob.c,v 1.13.2.1 2013/07/15 13:32:15 misho Exp $
    7: *
    8: **************************************************************************
    9: The ELWIX and AITNET software is distributed under the following
   10: terms:
   11: 
   12: All of the documentation and software included in the ELWIX and AITNET
   13: Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>
   14: 
   15: Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013
   16: 	by Michael Pounov <misho@elwix.org>.  All rights reserved.
   17: 
   18: Redistribution and use in source and binary forms, with or without
   19: modification, are permitted provided that the following conditions
   20: are met:
   21: 1. Redistributions of source code must retain the above copyright
   22:    notice, this list of conditions and the following disclaimer.
   23: 2. Redistributions in binary form must reproduce the above copyright
   24:    notice, this list of conditions and the following disclaimer in the
   25:    documentation and/or other materials provided with the distribution.
   26: 3. All advertising materials mentioning features or use of this software
   27:    must display the following acknowledgement:
   28: This product includes software developed by Michael Pounov <misho@elwix.org>
   29: ELWIX - Embedded LightWeight unIX and its contributors.
   30: 4. Neither the name of AITNET nor the names of its contributors
   31:    may be used to endorse or promote products derived from this software
   32:    without specific prior written permission.
   33: 
   34: THIS SOFTWARE IS PROVIDED BY AITNET AND CONTRIBUTORS ``AS IS'' AND
   35: ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
   36: IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
   37: ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
   38: FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
   39: DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
   40: OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
   41: HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
   42: LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
   43: OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
   44: SUCH DAMAGE.
   45: */
   46: #include "global.h"
   47: 
   48: 
   49: /*
   50:  * rpc_srv_blobCreate() - Create and map blob to memory region and return object
   51:  *
   52:  * @srv = RPC Server instance
   53:  * @len = BLOB length object
   54:  * return: NULL error or !=NULL allocated BLOB object
   55:  */
   56: rpc_blob_t *
   57: rpc_srv_blobCreate(rpc_srv_t * __restrict srv, int len)
   58: {
   59: 	rpc_blob_t *blob = NULL;
   60: 	char szFName[MAXPATHLEN];
   61: 	int f;
   62: 	u_int rnd;
   63: 
   64: again:
   65: 	rnd = random() % UINT_MAX;
   66: 
   67: 	memset(szFName, 0, sizeof szFName);
   68: 	snprintf(szFName, sizeof szFName, BLOB_FILE, AIT_GET_STRZ(&srv->srv_blob.dir), rnd);
   69: 	f = open(szFName, O_CREAT | O_EXCL | O_RDWR, 0600);
   70: 	if (f == -1) {
   71: 		if (errno == EEXIST)
   72: 			goto again;
   73: 
   74: 		LOGERR;
   75: 		return NULL;
   76: 	}
   77: 	if (ftruncate(f, len) == -1) {
   78: 		LOGERR;
   79: 		close(f);
   80: 		unlink(szFName);
   81: 		return NULL;
   82: 	}
   83: 
   84: 	blob = e_malloc(sizeof(rpc_blob_t));
   85: 	if (!blob) {
   86: 		LOGERR;
   87: 		close(f);
   88: 		unlink(szFName);
   89: 		return NULL;
   90: 	}
   91: 
   92: 	blob->blob_data = mmap(NULL, len, PROT_READ | PROT_WRITE, MAP_SHARED, f, 0);
   93: 	if (blob->blob_data == MAP_FAILED) {
   94: 		LOGERR;
   95: 		e_free(blob);
   96: 		close(f);
   97: 		unlink(szFName);
   98: 		return NULL;
   99: 	} else
  100: 		close(f);
  101: 
  102: 	blob->blob_len = len;
  103: 	blob->blob_var = rnd;
  104: 	return blob;
  105: }
  106: 
  107: /*
  108:  * rpc_srv_blobMap() - Map blob to memory region 
  109:  *
  110:  * @srv = RPC Server instance
  111:  * @blob = Map to this BLOB element
  112:  * return: -1 error or 0 ok
  113:  */
  114: int
  115: rpc_srv_blobMap(rpc_srv_t * __restrict srv, rpc_blob_t * __restrict blob)
  116: {
  117: 	int f;
  118: 	char szFName[MAXPATHLEN];
  119: 
  120: 	if (!blob) {
  121: 		rpc_SetErr(EINVAL, "Invalid argument BLOB");
  122: 		return -1;
  123: 	}
  124: 	if (blob->blob_data) {
  125: 		rpc_SetErr(EPERM, "Already mmapped object found!");
  126: 		return -1;
  127: 	}
  128: 
  129: 	memset(szFName, 0, sizeof szFName);
  130: 	snprintf(szFName, sizeof szFName, BLOB_FILE, AIT_GET_STRZ(&srv->srv_blob.dir), blob->blob_var);
  131: 	f = open(szFName, O_RDWR);
  132: 	if (f == -1) {
  133: 		LOGERR;
  134: 		return -1;
  135: 	}
  136: 
  137: 	blob->blob_data = mmap(NULL, blob->blob_len, PROT_READ | PROT_WRITE, MAP_SHARED, f, 0);
  138: 	if (blob->blob_data == MAP_FAILED) {
  139: 		LOGERR;
  140: 		close(f);
  141: 		blob->blob_data = NULL;
  142: 		return -1;
  143: 	} else {
  144: 		close(f);
  145: 
  146: 		madvise(blob->blob_data, blob->blob_len, MADV_SEQUENTIAL);
  147: 	}
  148: 
  149: 	return 0;
  150: }
  151: 
  152: /*
  153:  * rpc_srv_blobUnmap() - Unmap blob memory region 
  154:  *
  155:  * @blob = Mapped BLOB element
  156:  * return: none
  157:  */
  158: void
  159: rpc_srv_blobUnmap(rpc_blob_t * __restrict blob)
  160: {
  161: 	if (blob && blob->blob_data) {
  162: 		munmap(blob->blob_data, blob->blob_len);
  163: 		blob->blob_data = NULL;
  164: 	}
  165: }
  166: 
  167: /*
  168:  * rpc_srv_blobFree() - Free blob from disk & memory
  169:  *
  170:  * @srv = RPC Server instance
  171:  * @blob = Mapped BLOB element
  172:  * return: -1 error or 0 ok
  173:  */
  174: int
  175: rpc_srv_blobFree(rpc_srv_t * __restrict srv, rpc_blob_t * __restrict blob)
  176: {
  177: 	char szFName[MAXPATHLEN];
  178: 
  179: 	if (!blob) {
  180: 		rpc_SetErr(EINVAL, "Invalid argument BLOB");
  181: 		return -1;
  182: 	} else
  183: 		rpc_srv_blobUnmap(blob);
  184: 
  185: 	memset(szFName, 0, sizeof szFName);
  186: 	snprintf(szFName, sizeof szFName, BLOB_FILE, AIT_GET_STRZ(&srv->srv_blob.dir), blob->blob_var);
  187: 	if (unlink(szFName) == -1) {
  188: 		LOGERR;
  189: 		return -1;
  190: 	}
  191: 
  192: 	return 0;
  193: }
  194: 
  195: /* ------------------------------------------------------------ */
  196: 
  197: /*
  198:  * rpc_srv_sendBLOB() - Send mapped BLOB to client
  199:  *
  200:  * @cli = Client instance
  201:  * @blob = Mapped BLOB element
  202:  * return: -1 error, 0 ok
  203:  */
  204: int
  205: rpc_srv_sendBLOB(rpc_cli_t * __restrict cli, rpc_blob_t * __restrict blob)
  206: {
  207: 	int ret, len;
  208: 	uint8_t *pos;
  209: 
  210: 	if (!cli || !blob || !blob->blob_data) {
  211: 		rpc_SetErr(EINVAL, "Invalid arguments");
  212: 		return -1;
  213: 	}
  214: 
  215: 	for (ret = blob->blob_len, pos = blob->blob_data; ret > 0; ret -= len, pos += len) {
  216: 		len = send(cli->cli_sock, pos, ret, MSG_NOSIGNAL);
  217: 		if (len == -1) {
  218: 			LOGERR;
  219: 			return -1;
  220: 		}
  221: 	}
  222: 
  223: 	return ret;
  224: }
  225: 
  226: /*
  227:  * rpc_srv_recvBLOB() - Receive BLOB from client
  228:  *
  229:  * @cli = Client instance
  230:  * @blob = Mapped BLOB element
  231:  * return: -1 error, 0 ok, >0 unreceived data from client, may be error?
  232:  */
  233: int
  234: rpc_srv_recvBLOB(rpc_cli_t * __restrict cli, rpc_blob_t * __restrict blob)
  235: {
  236: 	int ret, len;
  237: 	uint8_t *pos;
  238: 	struct pollfd pfd;
  239: 
  240: 	if (!cli || !blob || !blob->blob_data) {
  241: 		rpc_SetErr(EINVAL, "Invalid arguments");
  242: 		return -1;
  243: 	}
  244: 
  245: 	pfd.fd = cli->cli_sock;
  246: 	pfd.events = POLLIN | POLLPRI;
  247: 	for (ret = blob->blob_len, pos = blob->blob_data; ret > 0; ret -= len, pos += len) {
  248: 		if ((len = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 || 
  249: 				pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
  250: 			if (len)
  251: 				LOGERR;
  252: 			else
  253: 				rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond");
  254: 			return -1;
  255: 		}
  256: 
  257: 		len = recv(cli->cli_sock, pos, ret, 0);
  258: 		if (len == -1) {
  259: 			LOGERR;
  260: 			return -1;
  261: 		}
  262: 	}
  263: 
  264: 	return ret;
  265: }
  266: 
  267: /* ------------------------------------------------------------ */
  268: 
  269: /*
  270:  * rpc_cli_sendBLOB() - Send BLOB to server
  271:  *
  272:  * @cli = Client instance
  273:  * @var = BLOB variable
  274:  * @data = BLOB data
  275:  * return: -1 error, 0 ok, 1 remote error
  276:  */
  277: int
  278: rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var, void * __restrict data)
  279: {
  280: 	int ret, len;
  281: 	uint8_t *pos;
  282: 	struct tagBLOBHdr hdr;
  283: 	struct pollfd pfd;
  284: 
  285: 	if (!cli || !var || !data) {
  286: 		rpc_SetErr(EINVAL, "Invalid arguments");
  287: 		return -1;
  288: 	} else
  289: 		memset(&hdr, 0, sizeof hdr);
  290: 
  291: 	rpc_addPktSession(&hdr.hdr_session, cli->cli_parent);
  292: 	hdr.hdr_cmd = set;
  293: 	hdr.hdr_var = 0;
  294: 	hdr.hdr_ret = 0;
  295: 	hdr.hdr_len = htonl(AIT_LEN(var));
  296: 
  297: 	/* send SET request */
  298: 	pfd.fd = cli->cli_sock;
  299: 	pfd.events = POLLOUT;
  300: 	if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) == -1 || 
  301: 			pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
  302: 		LOGERR;
  303: 		return -1;
  304: 	}
  305: 	if (send(cli->cli_sock, &hdr, sizeof hdr, MSG_NOSIGNAL) == -1) {
  306: 		LOGERR;
  307: 		return -1;
  308: 	}
  309: 
  310: 	/* send BLOB to server */
  311: 	for (ret = AIT_LEN(var), pos = data; ret > 0; ret -= len, pos += len)
  312: 		if ((len = send(cli->cli_sock, pos, ret, MSG_NOSIGNAL)) == -1) {
  313: 			LOGERR;
  314: 			return -1;
  315: 		}
  316: 
  317: 	/* wait for reply */
  318: 	pfd.events = POLLIN | POLLPRI;
  319: 	if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 || 
  320: 			pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
  321: 		if (ret)
  322: 			LOGERR;
  323: 		else
  324: 			rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond");
  325: 		return -1;
  326: 	}
  327: 	if (recv(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) {
  328: 		LOGERR;
  329: 		return 1;
  330: 	}
  331: 
  332: 	if (hdr.hdr_cmd != error) {
  333: 		AIT_SET_BLOB(var, ntohl(hdr.hdr_var), ntohl(hdr.hdr_len));
  334: 
  335: 		if (ntohl(hdr.hdr_len) != AIT_LEN(var)) {
  336: 			rpc_cli_delBLOB(cli, var);
  337: 			AIT_NEW_BLOB(var, ntohl(hdr.hdr_len));
  338: 
  339: 			rpc_SetErr(ECANCELED, "Bad return length packet");
  340: 			return 1;
  341: 		}
  342: 	}
  343: 
  344: 	return hdr.hdr_cmd == error;
  345: }
  346: 
  347: /*
  348:  * rpc_cli_recvBLOB() - Receive BLOB from server
  349:  *
  350:  * @cli = Client instance
  351:  * @var = BLOB variable
  352:  * @data = BLOB data, must be e_free after use!
  353:  * return: -1 error, 0 ok, 1 remote error
  354:  */
  355: int
  356: rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var, void ** __restrict data)
  357: {
  358: 	int ret, len;
  359: 	uint8_t *pos;
  360: 	struct pollfd pfd;
  361: 	struct tagBLOBHdr hdr;
  362: 
  363: 	if (!cli || !var || !data) {
  364: 		rpc_SetErr(EINVAL, "Invalid arguments");
  365: 		return -1;
  366: 	}
  367: 
  368: 	*data = e_malloc(AIT_LEN(var));
  369: 	if (!*data) {
  370: 		LOGERR;
  371: 		return -1;
  372: 	} else {
  373: 		memset(&hdr, 0, sizeof hdr);
  374: 		memset(*data, 0, AIT_LEN(var));
  375: 	}
  376: 
  377: 	rpc_addPktSession(&hdr.hdr_session, cli->cli_parent);
  378: 	hdr.hdr_cmd = get;
  379: 	hdr.hdr_var = htonl((uint32_t) AIT_GET_BLOB(var));
  380: 	hdr.hdr_ret = 0;
  381: 	hdr.hdr_len = 0;
  382: 
  383: 	/* send GET request */
  384: 	pfd.fd = cli->cli_sock;
  385: 	pfd.events = POLLOUT;
  386: 	if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) == -1 || 
  387: 			pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
  388: 		LOGERR;
  389: 		e_free(*data);
  390: 		*data = NULL;
  391: 		return -1;
  392: 	}
  393: 	if (send(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) {
  394: 		LOGERR;
  395: 		e_free(*data);
  396: 		*data = NULL;
  397: 		return -1;
  398: 	}
  399: 
  400: 	/* receive BLOB from server */
  401: 	pfd.events = POLLIN | POLLPRI;
  402: 	for (ret = AIT_LEN(var), pos = *data; ret > 0; ret -= len, pos += len) {
  403: 		if ((len = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 || 
  404: 				pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
  405: 			LOGERR;
  406: 			e_free(*data);
  407: 			*data = NULL;
  408: 			return -1;
  409: 		}
  410: 
  411: 		if ((len = recv(cli->cli_sock, pos, ret, 0)) == -1) {
  412: 			LOGERR;
  413: 			e_free(*data);
  414: 			*data = NULL;
  415: 			return -1;
  416: 		}
  417: 	}
  418: 
  419: 	/* wait for reply */
  420: 	if ((len = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 || 
  421: 			pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
  422: 		if (len)
  423: 			LOGERR;
  424: 		else
  425: 			rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond");
  426: 		e_free(*data);
  427: 		*data = NULL;
  428: 		return 1;
  429: 	}
  430: 	if (recv(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) {
  431: 		LOGERR;
  432: 		e_free(*data);
  433: 		*data = NULL;
  434: 		return 1;
  435: 	}
  436: 	if (hdr.hdr_cmd != error) {
  437: 		if (ntohl(hdr.hdr_len) != AIT_LEN(var)) {
  438: 			rpc_SetErr(ECANCELED, "Bad return length packet");
  439: 			e_free(*data);
  440: 			*data = NULL;
  441: 			return 1;
  442: 		}
  443: 	}
  444: 
  445: 	return hdr.hdr_cmd == error;
  446: }
  447: 
  448: /*
  449:  * rpc_cli_delBLOB() - Delete BLOB from server
  450:  *
  451:  * @cli = Client instance
  452:  * @var = BLOB variable
  453:  * return: -1 error, 0 ok, 1 remote error
  454:  */
  455: int
  456: rpc_cli_delBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var)
  457: {
  458: 	struct tagBLOBHdr hdr;
  459: 	struct pollfd pfd;
  460: 	int ret;
  461: 
  462: 	if (!cli || !var) {
  463: 		rpc_SetErr(EINVAL, "Invalid arguments");
  464: 		return -1;
  465: 	} else
  466: 		memset(&hdr, 0, sizeof hdr);
  467: 
  468: 	rpc_addPktSession(&hdr.hdr_session, cli->cli_parent);
  469: 	hdr.hdr_cmd = unset;
  470: 	hdr.hdr_var = htonl((uint32_t) AIT_GET_BLOB(var));
  471: 	hdr.hdr_ret = 0;
  472: 	hdr.hdr_len = 0;
  473: 
  474: 	/* send UNSET request */
  475: 	pfd.fd = cli->cli_sock;
  476: 	pfd.events = POLLOUT;
  477: 	if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) == -1 || 
  478: 			pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
  479: 		LOGERR;
  480: 		return -1;
  481: 	}
  482: 	if (send(cli->cli_sock, &hdr, sizeof hdr, MSG_NOSIGNAL) == -1) {
  483: 		LOGERR;
  484: 		return -1;
  485: 	}
  486: 
  487: 	/* wait for reply */
  488: 	pfd.events = POLLIN | POLLPRI;
  489: 	if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 || 
  490: 			pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) {
  491: 		if (ret)
  492: 			LOGERR;
  493: 		else
  494: 			rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond");
  495: 		return 1;
  496: 	}
  497: 	if (recv(cli->cli_sock, &hdr, sizeof hdr, 0) == -1) {
  498: 		LOGERR;
  499: 		return 1;
  500: 	}
  501: 
  502: 	return hdr.hdr_cmd == error;
  503: }
  504: 
  505: /*
  506:  * rpc_cli_getBLOB() - Receive BLOB from server and Delete after that
  507:  *
  508:  * @cli = Client instance
  509:  * @var = BLOB variable
  510:  * @data = BLOB data, must be e_free after use!
  511:  * return: -1 error, 0 ok, 1 remote error
  512:  */
  513: int
  514: rpc_cli_getBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var, void ** __restrict data)
  515: {
  516: 	int ret;
  517: 
  518: 	ret = rpc_cli_recvBLOB(cli, var, data);
  519: 	ret |= rpc_cli_delBLOB(cli, var) > 0 ? 2 : 0;
  520: 
  521: 	return ret;
  522: }

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>