Lines Matching refs:iip
84 * @iip: Input file this is associated with
94 struct ifile_info *iip;
289 * @iip: Per-input file information
291 static void rem_input_file(struct ifile_info *iip)
293 list_del(&iip->head);
295 close(iip->ifd);
296 free(iip->file_name);
297 free(iip->devnm);
298 free(iip);
309 struct ifile_info *iip = malloc(sizeof(*iip));
311 iip->cpu = cpu;
312 iip->tpkts = 0;
313 iip->genesis = 0;
314 iip->devnm = strdup(devnm);
315 iip->file_name = strdup(file_name);
316 iip->ifd = open(file_name, O_RDONLY);
317 if (iip->ifd < 0) {
322 list_add_tail(&iip->head, &input_files);
335 struct ifile_info *iip = list_entry(p, struct ifile_info, head);
336 if (strcmp(iip->devnm, devnm) == 0)
481 * @iip: Per-input file information
486 static int next_io(struct ifile_info *iip, struct io_spec *spec)
494 ret = read(iip->ifd, &t, sizeof(t));
496 fatal(iip->file_name, ERR_SYSCALL, "Read failed\n");
503 iip->file_name, (int)ret);
530 ret = read(iip->ifd, buf, pdu_len);
532 fatal(iip->file_name, ERR_SYSCALL, "Read PDU failed\n");
537 iip->file_name, (int)ret);
542 iip->tpkts++;
549 iip->cpu, (long long unsigned)spec->sector,
553 if (iip->genesis == 0) {
554 iip->genesis = spec->time;
557 (long long unsigned)iip->genesis, iip->cpu);
559 else if (iip->genesis > spec->time)
562 (long long unsigned )iip->genesis,
582 __u64 off = hdrp->time_stamp - stream->iip->genesis;
677 * @iip: Per-input file information
679 static struct io_stream *stream_open(struct ifile_info *iip)
691 sprintf(ofile_name, "%s/%s.%s.%d", odir, iipiip->cpu);
698 stream->iip = iip;
709 sprintf(vfile_name, "%s/%s.%s.%d.rec", odir, iip->devnm,
710 obase, iip->cpu);
731 .genesis = stream->iip->genesis,
744 stream->iip->devnm, stream->iip->cpu,
745 (unsigned long long)stream->iip->tpkts,
760 * @iip: Per-input file information
762 static void process(struct ifile_info *iip)
767 stream = stream_open(iip);
768 while (next_io(iip, &spec))
772 rem_input_file(iip);
