/*
 * Copyright 2002-2003, Thomas Kurschel. All rights reserved.
 * Copyright 2024, Haiku, Inc. All rights reserved.
 * Distributed under the terms of the MIT License.
 */

/*
	Part of Open SCSI bus manager

	CCB manager

	As allocation of ccb can be on the paging path we must use a
	locked pool.
*/

#include "scsi_internal.h"

#include <slab/Slab.h>



static object_cache* sCcbPool = NULL;


scsi_ccb *
scsi_alloc_ccb(scsi_device_info *device)
{
	SHOW_FLOW0( 3, "" );

	scsi_ccb* ccb = (scsi_ccb*)object_cache_alloc(sCcbPool, CACHE_DONT_WAIT_FOR_MEMORY);
	if (ccb == NULL)
		return NULL;

	ccb->completion_cond.Init(ccb, "scsi ccb");

	ccb->bus = device->bus;
	ccb->path_id = device->bus->path_id;

	ccb->state = SCSI_STATE_FINISHED;
	ccb->device = device;
	ccb->target_id = device->target_id;
	ccb->target_lun = device->target_lun;

	// reset some very important fields
	// TODO: should we better omit that to find bugs easier?
	ccb->sg_list = NULL;
	ccb->io_operation = NULL;
	ccb->sort = -1;

	SHOW_FLOW(3, "path=%d", ccb->path_id);

	return ccb;
}


void
scsi_free_ccb(scsi_ccb *ccb)
{
	SHOW_FLOW0( 3, "" );

	if (ccb->state != SCSI_STATE_FINISHED)
		panic("Tried to free ccb that's still in use (state %d)\n", ccb->state);

	// Ensure no other thread still holds the condition variable's spinlock.
	ccb->completion_cond.NotifyAll(B_ERROR);

	object_cache_free(sCcbPool, ccb, 0);
}


status_t
init_ccb_alloc()
{
	sCcbPool = create_object_cache("scsi ccb", sizeof(scsi_ccb), 0);
	if (sCcbPool == NULL)
		return B_NO_MEMORY;

	// it must be at least 1 for normal use and 1 for stand-by autosense request
	object_cache_set_minimum_reserve(sCcbPool, 2);

	return B_OK;
}


void
uninit_ccb_alloc()
{
	delete_object_cache(sCcbPool);
}