Lines Matching refs:ws

186 destroy_cache_mp_write_session(struct cache_mp_write_session_ *ws)  in destroy_cache_mp_write_session()  argument
192 assert(ws != NULL); in destroy_cache_mp_write_session()
193 while (!TAILQ_EMPTY(&ws->items)) { in destroy_cache_mp_write_session()
194 data_item = TAILQ_FIRST(&ws->items); in destroy_cache_mp_write_session()
195 TAILQ_REMOVE(&ws->items, data_item, entries); in destroy_cache_mp_write_session()
200 free(ws); in destroy_cache_mp_write_session()
220 struct cache_mp_write_session_ *ws; in destroy_cache_entry() local
258 ws = TAILQ_FIRST(&mp_entry->ws_head); in destroy_cache_entry()
259 TAILQ_REMOVE(&mp_entry->ws_head, ws, entries); in destroy_cache_entry()
260 destroy_cache_mp_write_session(ws); in destroy_cache_entry()
958 cache_mp_write(struct cache_mp_write_session_ *ws, char *data, in cache_mp_write() argument
964 assert(ws != NULL); in cache_mp_write()
965 assert(ws->parent_entry != NULL); in cache_mp_write()
966 assert(ws->parent_entry->params->entry_type == CET_MULTIPART); in cache_mp_write()
968 if ((ws->parent_entry->mp_params.max_elemsize > 0) && in cache_mp_write()
969 (ws->parent_entry->mp_params.max_elemsize == ws->items_size)) { in cache_mp_write()
983 TAILQ_INSERT_TAIL(&ws->items, new_item, entries); in cache_mp_write()
984 ++ws->items_size; in cache_mp_write()
994 abandon_cache_mp_write_session(struct cache_mp_write_session_ *ws) in abandon_cache_mp_write_session() argument
998 assert(ws != NULL); in abandon_cache_mp_write_session()
999 assert(ws->parent_entry != NULL); in abandon_cache_mp_write_session()
1000 assert(ws->parent_entry->params->entry_type == CET_MULTIPART); in abandon_cache_mp_write_session()
1002 TAILQ_REMOVE(&ws->parent_entry->ws_head, ws, entries); in abandon_cache_mp_write_session()
1003 --ws->parent_entry->ws_size; in abandon_cache_mp_write_session()
1005 destroy_cache_mp_write_session(ws); in abandon_cache_mp_write_session()
1013 close_cache_mp_write_session(struct cache_mp_write_session_ *ws) in close_cache_mp_write_session() argument
1017 assert(ws != NULL); in close_cache_mp_write_session()
1018 assert(ws->parent_entry != NULL); in close_cache_mp_write_session()
1019 assert(ws->parent_entry->params->entry_type == CET_MULTIPART); in close_cache_mp_write_session()
1021 TAILQ_REMOVE(&ws->parent_entry->ws_head, ws, entries); in close_cache_mp_write_session()
1022 --ws->parent_entry->ws_size; in close_cache_mp_write_session()
1024 if (ws->parent_entry->completed_write_session == NULL) { in close_cache_mp_write_session()
1028 ws->parent_entry->get_time_func( in close_cache_mp_write_session()
1029 &ws->parent_entry->creation_time); in close_cache_mp_write_session()
1030 ws->parent_entry->completed_write_session = ws; in close_cache_mp_write_session()
1037 if (ws->parent_entry->pending_write_session != NULL) in close_cache_mp_write_session()
1039 ws->parent_entry->pending_write_session); in close_cache_mp_write_session()
1041 ws->parent_entry->pending_write_session = ws; in close_cache_mp_write_session()