param_service.c - OpenGrok cross reference for /base/startup/init/services/param/linux/param

Lines Matching refs:worker
87 static int SendResponseMsg(ParamTaskPtr worker, const ParamMessage *msg, int result)

95     ParamTaskSendMsg(worker, (ParamMessage *)response);

161 static int HandleParamSet(const ParamTaskPtr worker, const ParamMessage *msg)

169     if (getsockopt(LE_GetSocketFd(worker), SOL_SOCKET, SO_PEERCRED, &cr, &crSize) < 0) {

172         return SendResponseMsg(worker, msg, -1);

175     srcLabel.sockFd = LE_GetSocketFd(worker);

181     return SendResponseMsg(worker, msg, ret);

234 static int HandleParamWaitAdd(const ParamTaskPtr worker, const ParamMessage *msg)

255     extData.stream = worker;

287 static int HandleParamWatcherAdd(const ParamTaskPtr worker, const ParamMessage *msg)

291         (g_paramService.watcherTask == worker), return -1, "Invalid watcher worker");

292     g_paramService.watcherTask = worker;

296     extData.stream = worker;

301         return SendResponseMsg(worker, msg, -1);

304     return SendResponseMsg(worker, msg, 0);

307 static int HandleParamWatcherDel(const ParamTaskPtr worker, const ParamMessage *msg)

312     return SendResponseMsg(worker, msg, 0);

315 static int HandleParamSave(const ParamTaskPtr worker, const ParamMessage *msg)

320     if (getsockopt(LE_GetSocketFd(worker), SOL_SOCKET, SO_PEERCRED, &cr, &crSize) < 0) {

323         return SendResponseMsg(worker, msg, -1);

328     PARAM_CHECK(ret == 0, return SendResponseMsg(worker, msg, -1), "Failed to process save parameters : ret %d", ret);

330     return SendResponseMsg(worker, msg, 0);

333 PARAM_STATIC int ProcessMessage(const ParamTaskPtr worker, const ParamMessage *msg)

336     PARAM_CHECK(worker != NULL, return -1, "Invalid worker");

340             ret = HandleParamSet(worker, msg);

343             ret = HandleParamWaitAdd(worker, msg);

346             ret = HandleParamWatcherAdd(worker, msg);

349             ret = HandleParamWatcherDel(worker, msg);

352             ret = HandleParamSave(worker, msg);