virNetServerProgramProcPtr dispatcher;
virNetMessageError rerr;
size_t i;
+ virIdentityPtr identity = NULL;
memset(&rerr, 0, sizeof(rerr));
if (virNetMessageDecodePayload(msg, dispatcher->arg_filter, arg) < 0)
goto error;
+ if (!(identity = virNetServerClientGetIdentity(client)))
+ goto error;
+
+ if (virIdentitySetCurrent(identity) < 0)
+ goto error;
+
/*
* When the RPC handler is called:
*
*/
rv = (dispatcher->func)(server, client, msg, &rerr, arg, ret);
+ if (virIdentitySetCurrent(NULL) < 0)
+ goto error;
+
/*
* If rv == 1, this indicates the dispatch func has
* populated 'msg' with a list of FDs to return to
VIR_FREE(arg);
VIR_FREE(ret);
+ virObjectUnref(identity);
/* Put reply on end of tx queue to send out */
return virNetServerClientSendMessage(client, msg);
VIR_FREE(arg);
VIR_FREE(ret);
+ virObjectUnref(identity);
return rv;
}