Cross Reference: /external/fio/server.c

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