Lines Matching refs:amt
69 ssize_t amt; in write_padding_for() local
76 amt = write(m_fd, &padding, paddingSize); in write_padding_for()
77 if (amt != paddingSize) { in write_padding_for()
81 m_pos += amt; in write_padding_for()
93 ssize_t amt; in WriteEntityHeader() local
95 amt = write_padding_for(m_pos); in WriteEntityHeader()
96 if (amt != 0) { in WriteEntityHeader()
97 return amt; in WriteEntityHeader()
123 amt = write(m_fd, &header, sizeof(entity_header_v1)); in WriteEntityHeader()
124 if (amt != sizeof(entity_header_v1)) { in WriteEntityHeader()
128 m_pos += amt; in WriteEntityHeader()
131 amt = write(m_fd, k.string(), keyLen+1); in WriteEntityHeader()
132 if (amt != keyLen+1) { in WriteEntityHeader()
136 m_pos += amt; in WriteEntityHeader()
138 amt = write_padding_for(keyLen+1); in WriteEntityHeader()
142 return amt; in WriteEntityHeader()
160 ssize_t amt = write(m_fd, data, size); in WriteEntityData() local
161 if (amt != (ssize_t)size) { in WriteEntityData()
166 m_pos += amt; in WriteEntityData()
230 int amt; in ReadNextHeader() local
232 amt = skip_padding(); in ReadNextHeader()
233 if (amt == EIO) { in ReadNextHeader()
237 else if (amt != NO_ERROR) { in ReadNextHeader()
238 return amt; in ReadNextHeader()
240 amt = read(m_fd, &m_header, sizeof(m_header)); in ReadNextHeader()
241 *done = m_done = (amt == 0); in ReadNextHeader()
245 CHECK_SIZE(amt, sizeof(m_header)); in ReadNextHeader()
273 int amt = read(m_fd, buf, size+1); in ReadNextHeader() local
274 CHECK_SIZE(amt, (int)size+1); in ReadNextHeader()
351 int amt = read(m_fd, data, size); in ReadEntityData() local
352 if (amt < 0) { in ReadEntityData()
356 if (amt == 0) { in ReadEntityData()
360 m_pos += amt; in ReadEntityData()
361 return amt; in ReadEntityData()
367 ssize_t amt; in skip_padding() local
373 amt = read(m_fd, &padding, paddingSize); in skip_padding()
374 CHECK_SIZE(amt, paddingSize); in skip_padding()
375 m_pos += amt; in skip_padding()