Lines Matching refs:data_raw

411           char *data_raw = reinterpret_cast<char *>(mh_full) + sizeof(MgmtMessageHdr);  in pollMgmtProcessServer()  local
412 if ((res = mgmt_read_pipe(watched_process_fd, data_raw, mh_hdr.data_len)) > 0) { in pollMgmtProcessServer()
486 char *data_raw = reinterpret_cast<char *>(mh) + sizeof(MgmtMessageHdr); in handleMgmtMsgFromProcesses() local
489 watched_process_pid = *(reinterpret_cast<pid_t *>(data_raw)); in handleMgmtMsgFromProcesses()
500 alarm_keeper->signalAlarm(MGMT_ALARM_PROXY_CONFIG_ERROR, data_raw); in handleMgmtMsgFromProcesses()
503 alarm_keeper->signalAlarm(MGMT_ALARM_PROXY_SYSTEM_ERROR, data_raw); in handleMgmtMsgFromProcesses()
506 alarm_keeper->signalAlarm(MGMT_ALARM_PROXY_CACHE_ERROR, data_raw); in handleMgmtMsgFromProcesses()
509 alarm_keeper->signalAlarm(MGMT_ALARM_PROXY_CACHE_WARNING, data_raw); in handleMgmtMsgFromProcesses()
512 alarm_keeper->signalAlarm(MGMT_ALARM_PROXY_LOGGING_ERROR, data_raw); in handleMgmtMsgFromProcesses()
515 alarm_keeper->signalAlarm(MGMT_ALARM_PROXY_LOGGING_WARNING, data_raw); in handleMgmtMsgFromProcesses()
522 …int tokens = sscanf(data_raw, "%255s %d %255s", var_name, reinterpret_cast<int *>(&stype), var_val… in handleMgmtMsgFromProcesses()
537 data_raw); in handleMgmtMsgFromProcesses()
543 executeMgmtCallback(MGMT_SIGNAL_LIBRECORDS, {data_raw, static_cast<size_t>(mh->data_len)}); in handleMgmtMsgFromProcesses()
552 … if (mgmt_message_parse(data_raw, mh->data_len, fields, countof(fields), &parent, &child) != -1) { in handleMgmtMsgFromProcesses()
576 LocalManager::sendMgmtMsgToProcesses(int msg_id, const char *data_raw, int data_len) in sendMgmtMsgToProcesses() argument
583 memcpy(reinterpret_cast<char *>(mh) + sizeof(MgmtMessageHdr), data_raw, data_len); in sendMgmtMsgToProcesses()
611 char *data_raw; in sendMgmtMsgToProcesses() local
613 data_raw = reinterpret_cast<char *>(mh) + sizeof(MgmtMessageHdr); in sendMgmtMsgToProcesses()
614 fname = REC_readString(data_raw, &found); in sendMgmtMsgToProcesses()
617 if (RecGetRecordType(data_raw, &rec_type) == REC_ERR_OKAY && rec_type == RECT_CONFIG) { in sendMgmtMsgToProcesses()
618 RecSetSyncRequired(data_raw); in sendMgmtMsgToProcesses()
620 mgmt_log("[LocalManager:sendMgmtMsgToProcesses] Unknown file change: '%s'\n", data_raw); in sendMgmtMsgToProcesses()
624 (strcmp(data_raw, "proxy.config.body_factory.template_sets_dir") != 0) && in sendMgmtMsgToProcesses()
625 (strcmp(data_raw, "proxy.config.ssl.server.ticket_key.filename") != 0)) { in sendMgmtMsgToProcesses()
708 LocalManager::signalEvent(int msg_id, const char *data_raw, int data_len) in signalEvent() argument
717 memcpy(payload.data(), data_raw, data_len); in signalEvent()