Lines Matching refs:worker

87 static int SendResponseMsg(ParamTaskPtr worker, const ParamMessage *msg, int result)  in SendResponseMsg()  argument
95 ParamTaskSendMsg(worker, (ParamMessage *)response); in SendResponseMsg()
161 static int HandleParamSet(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamSet() argument
169 if (getsockopt(LE_GetSocketFd(worker), SOL_SOCKET, SO_PEERCRED, &cr, &crSize) < 0) { in HandleParamSet()
172 return SendResponseMsg(worker, msg, -1); in HandleParamSet()
175 srcLabel.sockFd = LE_GetSocketFd(worker); in HandleParamSet()
181 return SendResponseMsg(worker, msg, ret); in HandleParamSet()
234 static int HandleParamWaitAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWaitAdd() argument
255 extData.stream = worker; in HandleParamWaitAdd()
287 static int HandleParamWatcherAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWatcherAdd() argument
291 (g_paramService.watcherTask == worker), return -1, "Invalid watcher worker"); in HandleParamWatcherAdd()
292 g_paramService.watcherTask = worker; in HandleParamWatcherAdd()
296 extData.stream = worker; in HandleParamWatcherAdd()
301 return SendResponseMsg(worker, msg, -1); in HandleParamWatcherAdd()
304 return SendResponseMsg(worker, msg, 0); in HandleParamWatcherAdd()
307 static int HandleParamWatcherDel(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWatcherDel() argument
312 return SendResponseMsg(worker, msg, 0); in HandleParamWatcherDel()
315 static int HandleParamSave(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamSave() argument
320 if (getsockopt(LE_GetSocketFd(worker), SOL_SOCKET, SO_PEERCRED, &cr, &crSize) < 0) { in HandleParamSave()
323 return SendResponseMsg(worker, msg, -1); in HandleParamSave()
328 …PARAM_CHECK(ret == 0, return SendResponseMsg(worker, msg, -1), "Failed to process save parameters … in HandleParamSave()
330 return SendResponseMsg(worker, msg, 0); in HandleParamSave()
333 PARAM_STATIC int ProcessMessage(const ParamTaskPtr worker, const ParamMessage *msg) in ProcessMessage() argument
336 PARAM_CHECK(worker != NULL, return -1, "Invalid worker"); in ProcessMessage()
340 ret = HandleParamSet(worker, msg); in ProcessMessage()
343 ret = HandleParamWaitAdd(worker, msg); in ProcessMessage()
346 ret = HandleParamWatcherAdd(worker, msg); in ProcessMessage()
349 ret = HandleParamWatcherDel(worker, msg); in ProcessMessage()
352 ret = HandleParamSave(worker, msg); in ProcessMessage()