Lines Matching refs:pdu
44 p9pdu_writef(struct p9_fcall *pdu, int proto_version, const char *fmt, ...);
56 size_t pdu_read(struct p9_fcall *pdu, void *data, size_t size) in pdu_read() argument
58 size_t len = min(pdu->size - pdu->offset, size); in pdu_read()
59 memcpy(data, &pdu->sdata[pdu->offset], len); in pdu_read()
60 pdu->offset += len; in pdu_read()
64 static size_t pdu_write(struct p9_fcall *pdu, const void *data, size_t size) in pdu_write() argument
66 size_t len = min(pdu->capacity - pdu->size, size); in pdu_write()
67 memcpy(&pdu->sdata[pdu->size], data, len); in pdu_write()
68 pdu->size += len; in pdu_write()
73 pdu_write_u(struct p9_fcall *pdu, struct iov_iter *from, size_t size) in pdu_write_u() argument
75 size_t len = min(pdu->capacity - pdu->size, size); in pdu_write_u()
77 if (copy_from_iter(&pdu->sdata[pdu->size], len, &i) != len) in pdu_write_u()
80 pdu->size += len; in pdu_write_u()
102 p9pdu_vreadf(struct p9_fcall *pdu, int proto_version, const char *fmt, in p9pdu_vreadf() argument
112 if (pdu_read(pdu, val, sizeof(*val))) { in p9pdu_vreadf()
121 if (pdu_read(pdu, &le_val, sizeof(le_val))) { in p9pdu_vreadf()
131 if (pdu_read(pdu, &le_val, sizeof(le_val))) { in p9pdu_vreadf()
141 if (pdu_read(pdu, &le_val, sizeof(le_val))) { in p9pdu_vreadf()
152 errcode = p9pdu_readf(pdu, proto_version, in p9pdu_vreadf()
162 if (pdu_read(pdu, *sptr, len)) { in p9pdu_vreadf()
173 if (pdu_read(pdu, &le_val, sizeof(le_val))) { in p9pdu_vreadf()
183 if (pdu_read(pdu, &le_val, sizeof(le_val))) { in p9pdu_vreadf()
194 errcode = p9pdu_readf(pdu, proto_version, "bdq", in p9pdu_vreadf()
208 p9pdu_readf(pdu, proto_version, in p9pdu_vreadf()
228 p9pdu_readf(pdu, proto_version, "d", count); in p9pdu_vreadf()
232 pdu->size - pdu->offset); in p9pdu_vreadf()
233 *data = &pdu->sdata[pdu->offset]; in p9pdu_vreadf()
241 errcode = p9pdu_readf(pdu, proto_version, in p9pdu_vreadf()
256 p9pdu_readf(pdu, in p9pdu_vreadf()
285 p9pdu_readf(pdu, proto_version, "w", nwqid); in p9pdu_vreadf()
300 p9pdu_readf(pdu, in p9pdu_vreadf()
321 p9pdu_readf(pdu, proto_version, in p9pdu_vreadf()
360 p9pdu_vwritef(struct p9_fcall *pdu, int proto_version, const char *fmt, in p9pdu_vwritef() argument
370 if (pdu_write(pdu, &val, sizeof(val))) in p9pdu_vwritef()
376 if (pdu_write(pdu, &val, sizeof(val))) in p9pdu_vwritef()
382 if (pdu_write(pdu, &val, sizeof(val))) in p9pdu_vwritef()
388 if (pdu_write(pdu, &val, sizeof(val))) in p9pdu_vwritef()
399 errcode = p9pdu_writef(pdu, proto_version, in p9pdu_vwritef()
401 if (!errcode && pdu_write(pdu, sptr, len)) in p9pdu_vwritef()
409 if (pdu_write(pdu, &val, sizeof(val))) in p9pdu_vwritef()
416 if (pdu_write(pdu, &val, sizeof(val))) in p9pdu_vwritef()
423 p9pdu_writef(pdu, proto_version, "bdq", in p9pdu_vwritef()
431 p9pdu_writef(pdu, proto_version, in p9pdu_vwritef()
446 errcode = p9pdu_writef(pdu, proto_version, "d", in p9pdu_vwritef()
448 if (!errcode && pdu_write_u(pdu, from, count)) in p9pdu_vwritef()
456 errcode = p9pdu_writef(pdu, proto_version, "w", in p9pdu_vwritef()
463 p9pdu_writef(pdu, in p9pdu_vwritef()
478 errcode = p9pdu_writef(pdu, proto_version, "w", in p9pdu_vwritef()
485 p9pdu_writef(pdu, in p9pdu_vwritef()
499 errcode = p9pdu_writef(pdu, proto_version, in p9pdu_vwritef()
529 int p9pdu_readf(struct p9_fcall *pdu, int proto_version, const char *fmt, ...) in p9pdu_readf() argument
535 ret = p9pdu_vreadf(pdu, proto_version, fmt, ap); in p9pdu_readf()
542 p9pdu_writef(struct p9_fcall *pdu, int proto_version, const char *fmt, ...) in p9pdu_writef() argument
548 ret = p9pdu_vwritef(pdu, proto_version, fmt, ap); in p9pdu_writef()
574 int p9pdu_prepare(struct p9_fcall *pdu, int16_t tag, int8_t type) in p9pdu_prepare() argument
576 pdu->id = type; in p9pdu_prepare()
577 return p9pdu_writef(pdu, 0, "dbw", 0, type, tag); in p9pdu_prepare()
580 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu) in p9pdu_finalize() argument
582 int size = pdu->size; in p9pdu_finalize()
585 pdu->size = 0; in p9pdu_finalize()
586 err = p9pdu_writef(pdu, 0, "d", size); in p9pdu_finalize()
587 pdu->size = size; in p9pdu_finalize()
589 trace_9p_protocol_dump(clnt, pdu); in p9pdu_finalize()
591 pdu->size, pdu->id, pdu->tag); in p9pdu_finalize()
596 void p9pdu_reset(struct p9_fcall *pdu) in p9pdu_reset() argument
598 pdu->offset = 0; in p9pdu_reset()
599 pdu->size = 0; in p9pdu_reset()