libaitrpc/src/srv.c - diff

Return to srv.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src

Diff for /libaitrpc/src/srv.c between versions 1.1.1.1.2.13 and 1.1.1.1.2.16

version 1.1.1.1.2.13, 2010/06/28 15:18:43	version 1.1.1.1.2.16, 2010/07/08 07:16:36
Line 93 rpc_srv_dispatchCall(void *arg)	Line 93 rpc_srv_dispatchCall(void *arg)
ret = -6;	ret = -6;
} else	} else
if ((ret = rpc_srv_execCall(f, rpc, v)) == -1)	if ((ret = rpc_srv_execCall(f, rpc, v)) == -1)
ret = -6;	ret = -9;
else	else
argc = rpc_srv_getValsCall(f, &vals);	argc = rpc_srv_getValsCall(f, &vals);

	printf("finish func %d\n", argc);
makeReply:	makeReply:
memcpy(&rrpc.ret_session, &rpc->call_session, sizeof rrpc.ret_session);	memcpy(&rrpc.ret_session, &rpc->call_session, sizeof rrpc.ret_session);
rrpc.ret_tag = rpc->call_tag;	rrpc.ret_tag = rpc->call_tag;
Line 237 rpc_srv_dispatchVars(void *arg)	Line 238 rpc_srv_dispatchVars(void *arg)
ret = -6;	ret = -6;
break;	break;
}	}
	printf("++++++ %p\n", b);

if (rpc_srv_blobMap(s, b) != -1) {	if (rpc_srv_blobMap(s, b) != -1) {
ret = rpc_srv_sendBLOB(c, b);	ret = rpc_srv_sendBLOB(c, b);
Line 264 rpc_srv_dispatchVars(void *arg)	Line 266 rpc_srv_dispatchVars(void *arg)
blob->hdr_cmd);	blob->hdr_cmd);
ret = -7;	ret = -7;
}	}
	cx++;

makeReply:	makeReply:
// Replay to client!	// Replay to client!
Line 280 makeReply:	Line 283 makeReply:
ret = -9;	ret = -9;
break;	break;
}	}
	cx = -1;

} while (ret > -1);	} while (ret > -1);

shutdown(c->cli_sock, SHUT_RDWR);	shutdown(c->cli_sock, SHUT_RDWR);
Line 407 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)	Line 412 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
pthread_mutex_lock(&srv->srv_blob.mtx);	pthread_mutex_lock(&srv->srv_blob.mtx);
while ((f = srv->srv_blob.blobs)) {	while ((f = srv->srv_blob.blobs)) {
srv->srv_blob.blobs = f->blob_next;	srv->srv_blob.blobs = f->blob_next;
	rpc_srv_blobFree(srv, f);
free(f);	free(f);
}	}
pthread_mutex_unlock(&srv->srv_blob.mtx);	pthread_mutex_unlock(&srv->srv_blob.mtx);

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

Removed from v.1.1.1.1.2.13
changed lines
	Added in v.1.1.1.1.2.16