include/segment.h

/*
 * \file
 * Segment module
 */

#ifndef _SEGMENT_H_H_
#define _SEGMENT_H_H_

#ifdef __cplusplus
extern "C" {
#endif

#include "dvr_types.h"

/**\brief Segment handle*/
typedef void* Segment_Handle_t;

/**\brief Segment open mode*/
typedef enum {
  SEGMENT_MODE_READ,            /**< Segment open read mode*/
  SEGMENT_MODE_WRITE,           /**< Segment open write mode*/
  SEGMENT_MODE_MAX              /**< Segment invalid open mode*/
} Segment_OpenMode_t;

/**\brief Segment open parameters*/
typedef struct Segment_OpenParams_s {
  char                  location[DVR_MAX_LOCATION_SIZE];        /**< Segment file location*/
  uint64_t              segment_id;                             /**< Segment index*/
  Segment_OpenMode_t    mode;                                   /**< Segment open mode*/
} Segment_OpenParams_t;

/**\brief Open a segment for a target giving some open parameters
 * \param[out] p_handle, Return the handle of the newly created segment
 * \param[in] params, Segment open parameters
 * \return DVR_SUCCESS on success
 * \return error code on failure
 */
int segment_open(Segment_OpenParams_t *params, Segment_Handle_t *p_handle);

/**\brief Close a segment
 * \param[in] handle, Segment handle
 * \return DVR_SUCCESS on success
 * \return error code on failure
 */
int segment_close(Segment_Handle_t handle);

/**\brief Read data from the giving segment
 * \param[out] buf, The buffer of data
 * \param[in] handle, Segment handle
 * \param[in] count, The data count
 * \return The number of bytes read on success
 * \return error code on failure
 */
ssize_t segment_read(Segment_Handle_t handle, void *buf, size_t count);

/**\brief Write data from the giving segment
 * \param[in] buf, The buffer of data
 * \param[in] handle, Segment handle
 * \param[in] count, The data count
 * \return The number of bytes write on success
 * \return error code on failure
 */
ssize_t segment_write(Segment_Handle_t handle, void *buf, size_t count);

/**\brief Update the pts and offset when record
 * \param[in] handle, Segment handle
 * \param[in] pts, Current pts
 * \param[in] offset, Current segment offset
 * \return DVR_SUCCESS on success
 * \return error code on failure
 */
int segment_update_pts(Segment_Handle_t handle, uint64_t pts, off_t offset);

/**\brief Seek the segment to the correct position which match the giving time
 * \param[in] handle, Segment handle
 * \param[in] time, The time offset
 * \return The segment current read position on success
 * \return error code on failure
 */
off_t segment_seek(Segment_Handle_t handle, uint64_t time);

/**\brief Tell the position for the giving segment
 * \param[in] handle, Segment handle
 * \return The segment current read position on success
 * \return error code on failure
 */
off_t segment_tell(Segment_Handle_t handle);

/**\brief Store the segment information to a file
 * \param[in] handle, The segment handle
 * \param[in] p_info, The segment information pointer
 * \return DVR_SUCCESS On success
 * \return Error code On failure
 */
int segment_store_info(Segment_Handle_t handle, Segment_StoreInfo_t *p_info);

/**\brief Load the segment information from a file
 * \param[in] handle, The segment handle
 * \param[out] p_info, The segment information pointer
 * \return DVR_SUCCESS On success
 * \return Error code On failure
 */
int segment_load_info(Segment_Handle_t handle, Segment_StoreInfo_t *p_info);

/**\brief Delete the segment information file
 * \param[in] location, The record file's location
 * \param[in] segment_id, The segment's index
 * \return DVR_SUCCESS On success
 * \return Error code On failure
 */
int segment_delete(const char *location, uint64_t segment_id);

#ifdef __cplusplus
}
#endif

#endif /*END _SEGMENT_H_H_*/