From: Aleš Křenek <ljocha@ics.muni.cz>
Date: Tue, 21 Apr 2009 12:15:37 +0000 (+0000)
Subject: untested implementation of WS NotifNew
X-Git-Tag: glite-lbjp-common-db_R_1_0_0_7~9
X-Git-Url: http://scientific.zcu.cz/git/?a=commitdiff_plain;h=dea2f535feac5fce8a3c881bce193e9a5ff6fed2;p=jra1mw.git

untested implementation of WS NotifNew
---

diff --git a/org.glite.lb.server/src/ws_query.c b/org.glite.lb.server/src/ws_query.c
index 983c8ef..754950e 100644
--- a/org.glite.lb.server/src/ws_query.c
+++ b/org.glite.lb.server/src/ws_query.c
@@ -256,6 +256,49 @@ cleanup:
 	return ret;
 }
 
+SOAP_FMAC5 int SOAP_FMAC6 __lb__NotifNew(
+	struct soap *soap,
+	struct _lbe__NotifNew *in,
+	struct _lbe__NotifNewResponse *out
+) {
+	edg_wll_Context		ctx = (edg_wll_Context) glite_gsplugin_get_udata(soap);
+	edg_wll_QueryRec 	**conditions = NULL;
+	int			flags;
+	edg_wll_NotifId		nid = NULL;
+	int			ret = SOAP_OK;
+
+	dprintf(("[%d] WS call %s\n",getpid(),__FUNCTION__));
+
+	edg_wll_ResetError(ctx);
+	if ( edg_wll_SoapToQueryCondsExt(in->conditions, in->__sizeconditions, &conditions) )
+	{
+		edg_wll_SetError(ctx, ENOMEM, "Couldn't create internal structures");
+		edg_wll_ErrToFault(ctx, soap);
+		ret = SOAP_FAULT;
+		goto cleanup;
+	}
+	edg_wll_SoapToJobStatFlags(in->flags, &flags);
+
+	if (edg_wll_NotifIdParse(in->notifId,&nid)) {
+		edg_wll_SetError(ctx,EINVAL,"Parse notifid");
+		edg_wll_ErrToFault(ctx, soap);
+		ret = SOAP_FAULT;
+		goto cleanup;
+	}
+
+	if (edg_wll_NotifNewServer(ctx,conditions,flags,in->addressOverride,nid,&out->valid)) {
+		edg_wll_ErrToFault(ctx, soap);
+		ret = SOAP_FAULT;
+		goto cleanup;
+	}
+
+
+cleanup:
+	edg_wll_NotifIdFree(nid);
+	freeQueryRecsExt(conditions);
+	return ret;
+}
+
 
 static void freeQueryRecsExt(edg_wll_QueryRec **qr) {
 	int i, j;