Lines Matching refs:rb
130 struct read_buffer *rb; in xenbus_file_read() local
148 rb = list_entry(u->read_buffers.next, struct read_buffer, list); in xenbus_file_read()
151 unsigned sz = min((unsigned)len - i, rb->len - rb->cons); in xenbus_file_read()
153 ret = copy_to_user(ubuf + i, &rb->msg[rb->cons], sz); in xenbus_file_read()
156 rb->cons += sz - ret; in xenbus_file_read()
165 if (rb->cons == rb->len) { in xenbus_file_read()
166 list_del(&rb->list); in xenbus_file_read()
167 kfree(rb); in xenbus_file_read()
170 rb = list_entry(u->read_buffers.next, in xenbus_file_read()
191 struct read_buffer *rb; in queue_reply() local
198 rb = kmalloc(sizeof(*rb) + len, GFP_KERNEL); in queue_reply()
199 if (rb == NULL) in queue_reply()
202 rb->cons = 0; in queue_reply()
203 rb->len = len; in queue_reply()
205 memcpy(rb->msg, data, len); in queue_reply()
207 list_add_tail(&rb->list, queue); in queue_reply()
217 struct read_buffer *rb; in queue_cleanup() local
220 rb = list_entry(list->next, struct read_buffer, list); in queue_cleanup()
222 kfree(rb); in queue_cleanup()
311 struct read_buffer *rb, *tmp_rb; in xenbus_worker() local
332 list_for_each_entry_safe(rb, tmp_rb, &u->read_buffers, list) { in xenbus_worker()
333 list_del(&rb->list); in xenbus_worker()
334 kfree(rb); in xenbus_worker()