Lines Matching refs:rb
126 struct read_buffer *rb; in xenbus_file_read() local
144 rb = list_entry(u->read_buffers.next, struct read_buffer, list); in xenbus_file_read()
147 unsigned sz = min((unsigned)len - i, rb->len - rb->cons); in xenbus_file_read()
149 ret = copy_to_user(ubuf + i, &rb->msg[rb->cons], sz); in xenbus_file_read()
152 rb->cons += sz - ret; in xenbus_file_read()
161 if (rb->cons == rb->len) { in xenbus_file_read()
162 list_del(&rb->list); in xenbus_file_read()
163 kfree(rb); in xenbus_file_read()
166 rb = list_entry(u->read_buffers.next, in xenbus_file_read()
187 struct read_buffer *rb; in queue_reply() local
192 rb = kmalloc(sizeof(*rb) + len, GFP_KERNEL); in queue_reply()
193 if (rb == NULL) in queue_reply()
196 rb->cons = 0; in queue_reply()
197 rb->len = len; in queue_reply()
199 memcpy(rb->msg, data, len); in queue_reply()
201 list_add_tail(&rb->list, queue); in queue_reply()
211 struct read_buffer *rb; in queue_cleanup() local
214 rb = list_entry(list->next, struct read_buffer, list); in queue_cleanup()
216 kfree(rb); in queue_cleanup()
561 struct read_buffer *rb, *tmp_rb; in xenbus_file_release() local
580 list_for_each_entry_safe(rb, tmp_rb, &u->read_buffers, list) { in xenbus_file_release()
581 list_del(&rb->list); in xenbus_file_release()
582 kfree(rb); in xenbus_file_release()