Lines Matching defs:pcline
169 auto pcline = reinterpret_cast<DistributedMsg *>(buff);
170 pcline->cmdTestType = ntohs(pcline->cmdTestType);
171 pcline->len = ntohs(pcline->len);
172 HiLog::Info(DistributedAgent::LABEL, "test agent get message type:%d .\n", pcline->cmdTestType);
173 if (pcline->len > 0 && static_cast<unsigned long>(pcline->len) <= (MAX_BUFF_LEN - DST_COMMAND_HEAD_LEN)) {
174 receiveLen = recv(clientSockFd_, pcline->alignmentCmd, static_cast<size_t>(pcline->len), 0);
175 HiLog::Info(DistributedAgent::LABEL, "agent get message cmd=%s .\n", pcline->alignmentCmd);
176 switch (pcline->cmdTestType) {
179 unsigned int cmdLen = ntohs(*reinterpret_cast<int *>(pcline->alignmentCmd));
183 ret = memcpy_s(pAlignmentCmd, cmdLen + 1, pcline->alignmentCmd + rlen, cmdLen);
190 unsigned int eValueLen = ntohs(*reinterpret_cast<int *>(pcline->alignmentCmd + rlen));
193 ret = memcpy_s(pszEValue, eValueLen + 1, pcline->alignmentCmd + rlen, eValueLen);
208 pclinereturn->no = pcline->no;
228 pclinereturn->no = pcline->no;
232 nresult = OnProcessMsg(pcline->alignmentCmd, pcline->len, resultcmd, pclinereturn->len);
244 OnNotifyImf(pcline);
261 void DistributedAgent::OnNotifyImf(DistributedMsg *pcline)
275 if (pcline->alignmentCmd[cmdNo] == ':') {
283 ret = memcpy_s(alignmentCmd, sizeof(alignmentCmd), pcline->alignmentCmd, cmdNo);
288 pcline->alignmentCmd + cmdNo + 1, pcline->len - cmdNo - 1);
292 OnNotify(alignmentCmd, szMsg, pcline->len - cmdNo);