229 	void *pdu = NULL;  in fio_net_recv_cmd()  local
275 		pdu = (void *) cmdret->payload + pdu_offset;  in fio_net_recv_cmd()
276 		ret = fio_recv_data(sk, pdu, cmd.pdu_len);  in fio_net_recv_cmd()
281 		crc = fio_crc16(pdu, cmd.pdu_len);  in fio_net_recv_cmd()
351 void fio_net_cmd_crc_pdu(struct fio_net_cmd *cmd, const void *pdu)  in fio_net_cmd_crc_pdu()  argument
358 	cmd->pdu_crc16 = __cpu_to_le16(fio_crc16(pdu, pdu_len));  in fio_net_cmd_crc_pdu()
569 	struct cmd_load_file_pdu *pdu = (struct cmd_load_file_pdu *) cmd->payload;  in handle_load_file_cmd()  local
570 	void *file_name = pdu->file;  in handle_load_file_cmd()
575 	pdu->name_len = le16_to_cpu(pdu->name_len);  in handle_load_file_cmd()
576 	pdu->client_type = le16_to_cpu(pdu->client_type);  in handle_load_file_cmd()
578 	if (parse_jobs_ini(file_name, 0, 0, pdu->client_type)) {  in handle_load_file_cmd()
610 	struct cmd_job_pdu *pdu = (struct cmd_job_pdu *) cmd->payload;  in handle_job_cmd()  local
611 	void *buf = pdu->buf;  in handle_job_cmd()
614 	pdu->buf_len = le32_to_cpu(pdu->buf_len);  in handle_job_cmd()
615 	pdu->client_type = le32_to_cpu(pdu->client_type);  in handle_job_cmd()
617 	if (parse_jobs_ini(buf, 1, 0, pdu->client_type)) {  in handle_job_cmd()
630 	void *pdu = cmd->payload;  in handle_jobline_cmd()  local
638 	clp = pdu;  in handle_jobline_cmd()
647 		cslp = pdu + offset;  in handle_jobline_cmd()
670 	struct cmd_client_probe_pdu *pdu = (struct cmd_client_probe_pdu *) cmd->payload;  in handle_probe_cmd()  local
676 	strcpy(me, (char *) pdu->server);  in handle_probe_cmd()
693 	if (has_zlib && le64_to_cpu(pdu->flags) & FIO_PROBE_FLAG_ZLIB) {  in handle_probe_cmd()
754 	struct cmd_add_job_pdu *pdu = (struct cmd_add_job_pdu *) cmd->payload;  in handle_update_job_cmd()  local
758 	tnumber = le32_to_cpu(pdu->thread_number);  in handle_update_job_cmd()
768 	convert_thread_options_to_cpu(&td->o, &pdu->top);  in handle_update_job_cmd()
775 	struct cmd_vtrigger_pdu *pdu = (struct cmd_vtrigger_pdu *) cmd->payload;  in handle_trigger_cmd()  local
776 	char *buf = (char *) pdu->cmd;  in handle_trigger_cmd()
780 	pdu->len = le16_to_cpu(pdu->len);  in handle_trigger_cmd()
781 	buf[pdu->len] = '\0';  in handle_trigger_cmd()
1018 	struct cmd_text_pdu *pdu;  in fio_server_text_output()  local
1025 	tlen = sizeof(*pdu) + len;  in fio_server_text_output()
1026 	pdu = malloc(tlen);  in fio_server_text_output()
1028 	pdu->level	= __cpu_to_le32(level);  in fio_server_text_output()
1029 	pdu->buf_len	= __cpu_to_le32(len);  in fio_server_text_output()
1032 	pdu->log_sec	= __cpu_to_le64(tv.tv_sec);  in fio_server_text_output()
1033 	pdu->log_usec	= __cpu_to_le64(tv.tv_usec);  in fio_server_text_output()
1035 	memcpy(pdu->buf, buf, len);  in fio_server_text_output()
1037 	fio_net_send_cmd(server_fd, FIO_NET_CMD_TEXT, pdu, tlen, NULL, NULL);  in fio_server_text_output()
1038 	free(pdu);  in fio_server_text_output()
1216 	struct cmd_du_pdu pdu;  in fio_server_send_du()  local
1220 	memset(&pdu, 0, sizeof(pdu));  in fio_server_send_du()
1225 		convert_dus(&pdu.dus, &du->dus);  in fio_server_send_du()
1226 		convert_agg(&pdu.agg, &du->agg);  in fio_server_send_du()
1228 		fio_net_send_cmd(server_fd, FIO_NET_CMD_DU, &pdu, sizeof(pdu), NULL, NULL);  in fio_server_send_du()
1253 static int fio_send_iolog_gz(struct cmd_iolog_pdu *pdu, struct io_log *log)  in fio_send_iolog_gz()  argument
1310 	struct cmd_iolog_pdu pdu;  in fio_send_iolog()  local
1313 	pdu.nr_samples = cpu_to_le64(log->nr_samples);  in fio_send_iolog()
1314 	pdu.thread_number = cpu_to_le32(td->thread_number);  in fio_send_iolog()
1315 	pdu.log_type = cpu_to_le32(log->log_type);  in fio_send_iolog()
1316 	pdu.compressed = cpu_to_le32(use_zlib);  in fio_send_iolog()
1318 	strncpy((char *) pdu.name, name, FIO_NET_NAME_MAX);  in fio_send_iolog()
1319 	pdu.name[FIO_NET_NAME_MAX - 1] = '\0';  in fio_send_iolog()
1339 	ret = fio_send_cmd_ext_pdu(server_fd, FIO_NET_CMD_IOLOG, &pdu,  in fio_send_iolog()
1340 					sizeof(pdu), 0, FIO_NET_CMD_F_MORE);  in fio_send_iolog()
1348 		return fio_send_iolog_gz(&pdu, log);  in fio_send_iolog()
1356 	struct cmd_add_job_pdu pdu;  in fio_server_send_add_job()  local
1358 	memset(&pdu, 0, sizeof(pdu));  in fio_server_send_add_job()
1359 	pdu.thread_number = cpu_to_le32(td->thread_number);  in fio_server_send_add_job()
1360 	pdu.groupid = cpu_to_le32(td->groupid);  in fio_server_send_add_job()
1361 	convert_thread_options_to_net(&pdu.top, &td->o);  in fio_server_send_add_job()
1363 	fio_net_send_cmd(server_fd, FIO_NET_CMD_ADD_JOB, &pdu, sizeof(pdu), NULL, NULL);  in fio_server_send_add_job()