Lines Matching refs:hdr
859 struct io_file_hdr hdr;
865 memset(&hdr, 0, sizeof(hdr));
879 if (buf.st_size < (off_t)sizeof(hdr)) {
885 if (read(tip->ifd, &hdr, sizeof(hdr)) != sizeof(hdr)) {
890 if (hdr.version != my_version) {
892 (long long unsigned)hdr.version,
893 (long long unsigned)hdr.genesis,
894 (long long unsigned)hdr.nbunches,
895 (long long unsigned)hdr.total_pkts);
898 (long)hdr.version, (long)my_version);
902 if (hdr.nbunches == 0) {
909 if (hdr.genesis < genesis) {
912 du64_to_sec(hdr.genesis),
913 du64_to_nsec(hdr.genesis));
914 genesis = hdr.genesis;
924 (long long)hdr.genesis);
1122 result = read(tip->ifd, &bunch->hdr, sizeof(bunch->hdr));
1123 if (result != sizeof(bunch->hdr)) {
1127 fatal(tip->file_name, ERR_SYSCALL, "Short hdr(%ld)\n",
1131 assert(bunch->hdr.npkts <= BT_MAX_PKTS);
1133 count = bunch->hdr.npkts * sizeof(struct io_pkt);
1255 struct iocb *list[bunch->hdr.npkts];
1257 assert(0 < bunch->hdr.npkts && bunch->hdr.npkts <= BT_MAX_PKTS);
1258 while (!is_send_done(tip) && (i < bunch->hdr.npkts)) {
1260 int ntodo = min(nfree_current(tip), bunch->hdr.npkts - i);
1265 stall(tip, bunch->hdr.time_stamp - genesis);
1289 assert(i <= bunch->hdr.npkts);
1302 struct io_file_hdr hdr;
1306 if (read(tip->ifd, &hdr, sizeof(hdr)) != sizeof(hdr)) {
