Lines Matching defs:rs
207 destroy_cache_mp_read_session(struct cache_mp_read_session_ *rs)
211 assert(rs != NULL);
212 free(rs);
221 struct cache_mp_read_session_ *rs;
266 rs = TAILQ_FIRST(&mp_entry->rs_head);
267 TAILQ_REMOVE(&mp_entry->rs_head, rs, entries);
268 destroy_cache_mp_read_session(rs);
1102 cache_mp_read(struct cache_mp_read_session_ *rs, char *data, size_t *data_size)
1106 assert(rs != NULL);
1108 if (rs->current_item == NULL) {
1113 if (rs->current_item->value_size > *data_size) {
1114 *data_size = rs->current_item->value_size;
1124 *data_size = rs->current_item->value_size;
1125 memcpy(data, rs->current_item->value, rs->current_item->value_size);
1126 rs->current_item = TAILQ_NEXT(rs->current_item, entries);
1138 close_cache_mp_read_session(struct cache_mp_read_session_ *rs)
1142 assert(rs != NULL);
1143 assert(rs->parent_entry != NULL);
1145 TAILQ_REMOVE(&rs->parent_entry->rs_head, rs, entries);
1146 --rs->parent_entry->rs_size;
1148 if ((rs->parent_entry->rs_size == 0) &&
1149 (rs->parent_entry->pending_write_session != NULL)) {
1151 rs->parent_entry->completed_write_session);
1152 rs->parent_entry->completed_write_session =
1153 rs->parent_entry->pending_write_session;
1154 rs->parent_entry->pending_write_session = NULL;
1157 destroy_cache_mp_read_session(rs);