net/9p/protocol.c

194 p9pdu_writef(struct p9_fcall *pdu, int proto_version, const char *fmt, ...);
211 size_t pdu_read(struct p9_fcall *pdu, void *data, size_t size)
213 	size_t len = min(pdu->size - pdu->offset, size);
215 	memcpy(data, &pdu->sdata[pdu->offset], len);
216 	pdu->offset += len;
220 static size_t pdu_write(struct p9_fcall *pdu, const void *data, size_t size)
222 	size_t len = min(pdu->capacity - pdu->size, size);
224 	memcpy(&pdu->sdata[pdu->size], data, len);
225 	pdu->size += len;
230 pdu_write_u(struct p9_fcall *pdu, struct iov_iter *from, size_t size)
232 	size_t len = min(pdu->capacity - pdu->size, size);
234 	if (!copy_from_iter_full(&pdu->sdata[pdu->size], len, from))
237 	pdu->size += len;
258 p9pdu_vreadf(struct p9_fcall *pdu, int proto_version, const char *fmt,
268 				if (pdu_read(pdu, val, sizeof(*val))) {
277 				if (pdu_read(pdu, &le_val, sizeof(le_val))) {
287 				if (pdu_read(pdu, &le_val, sizeof(le_val))) {
297 				if (pdu_read(pdu, &le_val, sizeof(le_val))) {
308 				errcode = p9pdu_readf(pdu, proto_version,
318 				if (pdu_read(pdu, *sptr, len)) {
329 				if (pdu_read(pdu, &le_val, sizeof(le_val))) {
339 				if (pdu_read(pdu, &le_val, sizeof(le_val))) {
350 				errcode = p9pdu_readf(pdu, proto_version, "bdq",
364 				    p9pdu_readf(pdu, proto_version,
384 				    p9pdu_readf(pdu, proto_version, "d", count);
388 						  pdu->size - pdu->offset);
389 					*data = &pdu->sdata[pdu->offset];
399 				errcode = p9pdu_readf(pdu, proto_version,
417 						    p9pdu_readf(pdu,
451 				    p9pdu_readf(pdu, proto_version, "w", nwqid);
466 						    p9pdu_readf(pdu,
487 				    p9pdu_readf(pdu, proto_version,
526 p9pdu_vwritef(struct p9_fcall *pdu, int proto_version, const char *fmt,
536 				if (pdu_write(pdu, &val, sizeof(val)))
542 				if (pdu_write(pdu, &val, sizeof(val)))
548 				if (pdu_write(pdu, &val, sizeof(val)))
554 				if (pdu_write(pdu, &val, sizeof(val)))
565 				errcode = p9pdu_writef(pdu, proto_version,
567 				if (!errcode && pdu_write(pdu, sptr, len))
575 				if (pdu_write(pdu, &val, sizeof(val)))
582 				if (pdu_write(pdu, &val, sizeof(val)))
589 				    p9pdu_writef(pdu, proto_version, "bdq",
597 				    p9pdu_writef(pdu, proto_version,
612 				errcode = p9pdu_writef(pdu, proto_version, "d",
614 				if (!errcode && pdu_write_u(pdu, from, count))
622 				errcode = p9pdu_writef(pdu, proto_version, "w",
629 						    p9pdu_writef(pdu,
644 				errcode = p9pdu_writef(pdu, proto_version, "w",
651 						    p9pdu_writef(pdu,
665 				errcode = p9pdu_writef(pdu, proto_version,
695 int p9pdu_readf(struct p9_fcall *pdu, int proto_version, const char *fmt, ...)
701 	ret = p9pdu_vreadf(pdu, proto_version, fmt, ap);
708 p9pdu_writef(struct p9_fcall *pdu, int proto_version, const char *fmt, ...)
714 	ret = p9pdu_vwritef(pdu, proto_version, fmt, ap);
741 int p9pdu_prepare(struct p9_fcall *pdu, int16_t tag, int8_t type)
743 	pdu->id = type;
744 	return p9pdu_writef(pdu, 0, "dbw", 0, type, tag);
747 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu)
749 	int size = pdu->size;
752 	pdu->size = 0;
753 	err = p9pdu_writef(pdu, 0, "d", size);
754 	pdu->size = size;
756 	trace_9p_protocol_dump(clnt, pdu);
758 		 pdu->size, pdu->id, pdu->tag);
763 void p9pdu_reset(struct p9_fcall *pdu)
765 	pdu->offset = 0;
766 	pdu->size = 0;