void *mysql;
edg_wll_ConnPool *connPool;
+ edg_wll_ConnPool *connPoolNotif; /* hold _one_ connection from notif-interlogger */
int semaphores,semset;
edg_wll_QueryRec **job_index;
int connOpened; /* number of opened connections */
int connToUse; /* index of connection that will *
* be used by low-level f-cions */
+ // XXX similar variables will be needed for connPoolNotif
+
+
/* other client stuff */
int notifSock; /* default client socket *
* for receiving notifications */
#Thu Oct 07 13:51:56 CEST 2004
-module.version=0.1.0
+module.version=0.2.0
module.build=33
module.age=0
for (i=0; i<EDG_WLL_PARAM__LAST; i++) edg_wll_SetParam(out,i,NULL);
out->connPool = (edg_wll_ConnPool *) calloc(out->poolSize, sizeof(edg_wll_ConnPool));
+ out->connPoolNotif = (edg_wll_ConnPool *) calloc(1, sizeof(edg_wll_ConnPool));
*ctx = out;
return 0;
"Bad URL format",
"MD5 key clash",
"GSSAPI Error",
- "DNS resolver error",
"No JobId specified in context",
"No indexed condition in query",
"Interlogger protocol error",
"Interlogger internal error",
"Interlogger has events pending"
+ "DNS resolver error",
};
const char *edg_wll_GetErrorText(int code) {
pomA = strdup("");
edg_wll_add_string_to_XMLBody(&pomA, edg_wll_NotifIdUnparse(notifId), "notifId", NULL);
edg_wll_add_string_to_XMLBody(&pomA, address, "clientAddress", NULL);
- edg_wll_add_int_to_XMLBody(&pomA, op, "notifChangeOp", EDG_WLL_NOTIF_NOOP);
+ edg_wll_add_string_to_XMLBody(&pomA, edg_wll_NotifChangeOpToString(op), "notifChangeOp", NULL);
if (conditions && conditions[0] && conditions[0][0].attr != EDG_WLL_QUERY_ATTR_UNDEF)
edg_wll_JobQueryRecToXML(ctx, conditions, &pomB);