Lines Matching refs:id
64 WRITE_LOG(LOG_FATAL, "uv_accept id:%u type:%d remoteParamenters:%s",
65 ctxListen->id, ctxListen->type, ctxListen->remoteParamenters.c_str());
76 WRITE_LOG(LOG_DEBUG, "OnAccept id:%u type:%d remoteParamenters:%s",
77 ctxClient->id, ctxClient->type, ctxClient->remoteParamenters.c_str());
78 SendToTask(ctxClient->id, CMD_FORWARD_ACTIVE_SLAVE, reinterpret_cast<uint8_t *>(buf),
95 WRITE_LOG(LOG_FATAL, "ListenCallback status:%d id:%u ready:%d",
96 status, ctxListen->id, ctxListen->ready);
122 ctx->id = Base::GetRandomU32();
128 AdminContext(OP_ADD, ctx->id, ctx);
137 AdminContext(OP_REMOVE, ctx->id, nullptr);
139 WRITE_LOG(LOG_DEBUG, "Finally to delete id:%u", ctx->id);
172 void HdcForwardBase::FreeContext(HCtxForward ctxIn, const uint32_t id, bool bNotifyRemote)
177 if (!(ctx = (HCtxForward)AdminContext(OP_QUERY, id, nullptr))) {
178 WRITE_LOG(LOG_DEBUG, "Query id:%u failed", id);
184 WRITE_LOG(LOG_DEBUG, "FreeContext id:%u, bNotifyRemote:%d, finish:%d",
185 ctx->id, bNotifyRemote, ctx->finish);
190 SendToTask(ctx->id, CMD_FORWARD_FREE_CONTEXT, nullptr, 0);
259 WRITE_LOG(LOG_INFO, "ReadForwardBuf nread:%zd id:%u", nread, ctx->id);
265 WRITE_LOG(LOG_INFO, "ReadForwardBuf nread:0 id:%u", ctx->id);
269 ctx->thisClass->SendToTask(ctx->id, CMD_FORWARD_DATA, (uint8_t *)buf->base, nread);
322 SendToTask(ctx->id, CMD_FORWARD_CHECK_RESULT, &flag, 1);
331 if (!SendToTask(ctx->id, CMD_FORWARD_ACTIVE_MASTER, nullptr, 0)) {
332 WRITE_LOG(LOG_FATAL, "SetupPointContinue SendToTask failed id:%u", ctx->id);
407 return SendToTask(ctx->id, CMD_FORWARD_DATA, b, c);
411 WRITE_LOG(LOG_DEBUG, "funcFinish id:%u ret:%d reason:%s", ctx->id, b, c.c_str());
589 SendToTask(ctxPoint->id, CMD_FORWARD_CHECK, reinterpret_cast<uint8_t *>(bufString),
619 idSlaveOld = ctxPoint->id;
621 // refresh another id,8byte param
622 FilterCommand(bufCmd, &ctxPoint->id, reinterpret_cast<uint8_t **>(&content));
633 WRITE_LOG(LOG_DEBUG, "id:%u type:%d", ctxPoint->id, ctxPoint->type);
673 WRITE_LOG(LOG_DEBUG, "DoForwardBegin ark socketpair id:%u fds[0]:%d", ctx->id, fds[0]);
695 void *HdcForwardBase::AdminContext(const uint8_t op, const uint32_t id, HCtxForward hInput)
702 mapCtx[id] = hInput;
705 mapCtx.erase(id);
708 if (mapCtx.count(id)) {
709 hRet = mapCtx[id];
713 mapCtx.erase(id);
714 mapCtx[hInput->id] = hInput;
740 WRITE_LOG(LOG_WARN, "SendForwardBuf size:%d > HDC_BUF_MAX_BYTES, ctxId:%u", size, ctx->id);
744 WRITE_LOG(LOG_WARN, "SendForwardBuf failed size:%d, ctxId:%u", size, ctx->id);
749 WRITE_LOG(LOG_WARN, "SendForwardBuf new DynBuf failed size:%d, ctxId:%u", size, ctx->id);
758 WRITE_LOG(LOG_WARN, "SendForwardBuf new ContextForwardIO failed, ctxId:%u", ctx->id);
774 nRet, size, ctx->id, ctx->type);
808 uint32_t id = 0;
810 FilterCommand(payload, &id, &pContent);
812 if (!(ctx = (HCtxForward)AdminContext(OP_QUERY, id, nullptr))) {
813 WRITE_LOG(LOG_WARN, "Query id:%u failed", id);
830 WRITE_LOG(LOG_WARN, "ForwardCommandDispatch SendForwardBuf rc < 0, ctxid:%u", ctx->id);