diff --git a/trunk/cmake_modules/FindLibAFF.cmake b/trunk/cmake_modules/FindLibAFF.cmake index 5418a9a..7f938c8 100644 --- a/trunk/cmake_modules/FindLibAFF.cmake +++ b/trunk/cmake_modules/FindLibAFF.cmake @@ -1,21 +1,41 @@ +# Try pkg-config first find_package(PkgConfig) -pkg_check_modules(PC_LIBAFF QUIET afflib) -set(LIBAFF_DEFINITIONS ${PC_LIBAFF_CFLAGS_OTHER}) +pkg_check_modules(PKGC_LIBAFF QUIET afflib) -find_path(LIBAFF_INCLUDE_DIR afflib/afflib.h - HINTS ${PC_LIBAFF_INCLUDEDIR} ${PC_LIBAFF_INCLUDE_DIRS} - PATH_SUFFIXES afflib) +if(PKGC_LIBAFF_FOUND) + # Found lib using pkg-config. + if(CMAKE_DEBUG) + message(STATUS "\${PKGC_LIBAFF_LIBRARIES} = ${PKGC_LIBAFF_LIBRARIES}") + message(STATUS "\${PKGC_LIBAFF_LIBRARY_DIRS} = ${PKGC_LIBAFF_LIBRARY_DIRS}") + message(STATUS "\${PKGC_LIBAFF_LDFLAGS} = ${PKGC_LIBAFF_LDFLAGS}") + message(STATUS "\${PKGC_LIBAFF_LDFLAGS_OTHER} = ${PKGC_LIBAFF_LDFLAGS_OTHER}") + message(STATUS "\${PKGC_LIBAFF_INCLUDE_DIRS} = ${PKGC_LIBAFF_INCLUDE_DIRS}") + message(STATUS "\${PKGC_LIBAFF_CFLAGS} = ${PKGC_LIBAFF_CFLAGS}") + message(STATUS "\${PKGC_LIBAFF_CFLAGS_OTHER} = ${PKGC_LIBAFF_CFLAGS_OTHER}") + endif(CMAKE_DEBUG) -find_library(LIBAFF_LIBRARY NAMES afflib libafflib - HINTS ${PC_LIBAFF_LIBDIR} ${PC_LIBAFF_LIBRARY_DIRS} ) + set(LIBAFF_LIBRARIES ${PKGC_LIBAFF_LIBRARIES}) + set(LIBAFF_INCLUDE_DIRS ${PKGC_LIBAFF_INCLUDE_DIRS}) + #set(LIBAFF_DEFINITIONS ${PKGC_LIBAFF_CFLAGS_OTHER}) +else(PKGC_LIBAFF_FOUND) + # Didn't find lib using pkg-config. Try to find it manually + message(WARNING "Unable to find LibAFF using pkg-config! If compilation fails, make sure pkg-config is installed and PKG_CONFIG_PATH is set correctly") -set(LIBAFF_LIBRARIES ${LIBAFF_LIBRARY}) -set(LIBAFF_INCLUDE_DIRS ${LIBAFF_INCLUDE_DIR}) + find_path(LIBAFF_INCLUDE_DIR afflib/afflib.h + PATH_SUFFIXES afflib) + find_library(LIBAFF_LIBRARY NAMES afflib libafflib) -include(FindPackageHandleStandardArgs) -# handle the QUIETLY and REQUIRED arguments and set LIBXML2_FOUND to TRUE -# if all listed variables are TRUE -find_package_handle_standard_args(LibAFF DEFAULT_MSG LIBAFF_LIBRARY LIBAFF_INCLUDE_DIR) + if(CMAKE_DEBUG) + message(STATUS "\${LIBAFF_LIBRARY} = ${LIBAFF_LIBRARY}") + message(STATUS "\${LIBAFF_INCLUDE_DIR} = ${LIBAFF_INCLUDE_DIR}") + endif(CMAKE_DEBUG) + + set(LIBAFF_LIBRARIES ${LIBAFF_LIBRARY}) + set(LIBAFF_INCLUDE_DIRS ${LIBAFF_INCLUDE_DIR}) +endif(PKGC_LIBAFF_FOUND) -mark_as_advanced(LIBAFF_INCLUDE_DIR LIBAFF_LIBRARY) +include(FindPackageHandleStandardArgs) +# Handle the QUIETLY and REQUIRED arguments and set _FOUND to TRUE if +# all listed variables are TRUE +find_package_handle_standard_args(LibAFF DEFAULT_MSG LIBAFF_LIBRARIES) diff --git a/trunk/cmake_modules/FindLibEWF.cmake b/trunk/cmake_modules/FindLibEWF.cmake index eddf49d..f5857f8 100644 --- a/trunk/cmake_modules/FindLibEWF.cmake +++ b/trunk/cmake_modules/FindLibEWF.cmake @@ -1,20 +1,41 @@ +# Try pkg-config first find_package(PkgConfig) -pkg_check_modules(PC_LIBEWF QUIET libewf) -set(LIBEWF_DEFINITIONS ${PC_LIBEWF_CFLAGS_OTHER}) +pkg_check_modules(PKGC_LIBEWF QUIET libewf) -find_path(LIBEWF_INCLUDE_DIR libewf.h - HINTS ${PC_LIBEWF_INCLUDEDIR} ${PC_LIBEWF_INCLUDE_DIRS} - PATH_SUFFIXES libewf ) +if(PKGC_LIBEWF_FOUND) + # Found lib using pkg-config. + if(CMAKE_DEBUG) + message(STATUS "\${PKGC_LIBEWF_LIBRARIES} = ${PKGC_LIBEWF_LIBRARIES}") + message(STATUS "\${PKGC_LIBEWF_LIBRARY_DIRS} = ${PKGC_LIBEWF_LIBRARY_DIRS}") + message(STATUS "\${PKGC_LIBEWF_LDFLAGS} = ${PKGC_LIBEWF_LDFLAGS}") + message(STATUS "\${PKGC_LIBEWF_LDFLAGS_OTHER} = ${PKGC_LIBEWF_LDFLAGS_OTHER}") + message(STATUS "\${PKGC_LIBEWF_INCLUDE_DIRS} = ${PKGC_LIBEWF_INCLUDE_DIRS}") + message(STATUS "\${PKGC_LIBEWF_CFLAGS} = ${PKGC_LIBEWF_CFLAGS}") + message(STATUS "\${PKGC_LIBEWF_CFLAGS_OTHER} = ${PKGC_LIBEWF_CFLAGS_OTHER}") + endif(CMAKE_DEBUG) -find_library(LIBEWF_LIBRARY NAMES ewf libewf - HINTS ${PC_LIBEWF_LIBDIR} ${PC_LIBEWF_LIBRARY_DIRS} ) + set(LIBEWF_LIBRARIES ${PKGC_LIBEWF_LIBRARIES}) + set(LIBEWF_INCLUDE_DIRS ${PKGC_LIBEWF_INCLUDE_DIRS}) + #set(LIBEWF_DEFINITIONS ${PKGC_LIBEWF_CFLAGS_OTHER}) +else(PKGC_LIBEWF_FOUND) + # Didn't find lib using pkg-config. Try to find it manually + message(WARNING "Unable to find LibEWF using pkg-config! If compilation fails, make sure pkg-config is installed and PKG_CONFIG_PATH is set correctly") -set(LIBEWF_LIBRARIES ${LIBEWF_LIBRARY}) -set(LIBEWF_INCLUDE_DIRS ${LIBEWF_INCLUDE_DIR}) + find_path(LIBEWF_INCLUDE_DIR libewf.h + PATH_SUFFIXES libewf) + find_library(LIBEWF_LIBRARY NAMES ewf libewf) + + if(CMAKE_DEBUG) + message(STATUS "\${LIBEWF_LIBRARY} = ${LIBEWF_LIBRARY}") + message(STATUS "\${LIBEWF_INCLUDE_DIR} = ${LIBEWF_INCLUDE_DIR}") + endif(CMAKE_DEBUG) + + set(LIBEWF_LIBRARIES ${LIBEWF_LIBRARY}) + set(LIBEWF_INCLUDE_DIRS ${LIBEWF_INCLUDE_DIR}) +endif(PKGC_LIBEWF_FOUND) include(FindPackageHandleStandardArgs) -# handle the QUIETLY and REQUIRED arguments and set LIBXML2_FOUND to TRUE -# if all listed variables are TRUE -find_package_handle_standard_args(LibEWF DEFAULT_MSG LIBEWF_LIBRARY LIBEWF_INCLUDE_DIR) +# Handle the QUIETLY and REQUIRED arguments and set _FOUND to TRUE if +# all listed variables are TRUE +find_package_handle_standard_args(LibEWF DEFAULT_MSG LIBEWF_LIBRARIES) -mark_as_advanced(LIBEWF_INCLUDE_DIR LIBEWF_LIBRARY) diff --git a/trunk/cmake_modules/FindLibFUSE.cmake b/trunk/cmake_modules/FindLibFUSE.cmake index 22c6e55..c022f16 100644 --- a/trunk/cmake_modules/FindLibFUSE.cmake +++ b/trunk/cmake_modules/FindLibFUSE.cmake @@ -1,22 +1,41 @@ +# Try pkg-config first find_package(PkgConfig) -pkg_check_modules(PC_LIBFUSE QUIET libfuse) -set(LIBFUSE_DEFINITIONS ${PC_LIBFUSE_CFLAGS_OTHER}) +pkg_check_modules(PKGC_LIBFUSE QUIET fuse) -find_path(LIBFUSE_INCLUDE_DIR fuse.h - HINTS ${PC_LIBFUSE_INCLUDEDIR} ${PC_LIBFUSE_INCLUDE_DIRS} - PATH_SUFFIXES fuse) +if(PKGC_LIBFUSE_FOUND) + # Found lib using pkg-config. + if(CMAKE_DEBUG) + message(STATUS "\${PKGC_LIBFUSE_LIBRARIES} = ${PKGC_LIBFUSE_LIBRARIES}") + message(STATUS "\${PKGC_LIBFUSE_LIBRARY_DIRS} = ${PKGC_LIBFUSE_LIBRARY_DIRS}") + message(STATUS "\${PKGC_LIBFUSE_LDFLAGS} = ${PKGC_LIBFUSE_LDFLAGS}") + message(STATUS "\${PKGC_LIBFUSE_LDFLAGS_OTHER} = ${PKGC_LIBFUSE_LDFLAGS_OTHER}") + message(STATUS "\${PKGC_LIBFUSE_INCLUDE_DIRS} = ${PKGC_LIBFUSE_INCLUDE_DIRS}") + message(STATUS "\${PKGC_LIBFUSE_CFLAGS} = ${PKGC_LIBFUSE_CFLAGS}") + message(STATUS "\${PKGC_LIBFUSE_CFLAGS_OTHER} = ${PKGC_LIBFUSE_CFLAGS_OTHER}") + endif(CMAKE_DEBUG) -find_library(LIBFUSE_LIBRARY NAMES fuse libfuse - HINTS ${PC_LIBFUSE_LIBDIR} ${PC_LIBFUSE_LIBRARY_DIRS}) + set(LIBFUSE_LIBRARIES ${PKGC_LIBFUSE_LIBRARIES}) + set(LIBFUSE_INCLUDE_DIRS ${PKGC_LIBFUSE_INCLUDE_DIRS}) + #set(LIBFUSE_DEFINITIONS ${PKGC_LIBFUSE_CFLAGS_OTHER}) +else(PKGC_LIBFUSE_FOUND) + # Didn't find lib using pkg-config. Try to find it manually + message(WARNING "Unable to find LibFUSE using pkg-config! If compilation fails, make sure pkg-config is installed and PKG_CONFIG_PATH is set correctly") -set(LIBFUSE_LIBRARIES ${LIBFUSE_LIBRARY}) -set(LIBFUSE_INCLUDE_DIRS ${LIBFUSE_INCLUDE_DIR}) + find_path(LIBFUSE_INCLUDE_DIR fuse.h + PATH_SUFFIXES fuse) + find_library(LIBFUSE_LIBRARY NAMES fuse libfuse) -include(FindPackageHandleStandardArgs) -find_package_handle_standard_args(LibFUSE - DEFAULT_MSG - LIBFUSE_LIBRARY - LIBFUSE_INCLUDE_DIR) + if(CMAKE_DEBUG) + message(STATUS "\${LIBFUSE_LIBRARY} = ${LIBFUSE_LIBRARY}") + message(STATUS "\${LIBFUSE_INCLUDE_DIR} = ${LIBFUSE_INCLUDE_DIR}") + endif(CMAKE_DEBUG) + + set(LIBFUSE_LIBRARIES ${LIBFUSE_LIBRARY}) + set(LIBFUSE_INCLUDE_DIRS ${LIBFUSE_INCLUDE_DIR}) +endif(PKGC_LIBFUSE_FOUND) -mark_as_advanced(LIBFUSE_INCLUDE_DIR LIBFUSE_LIBRARY) +include(FindPackageHandleStandardArgs) +# Handle the QUIETLY and REQUIRED arguments and set _FOUND to TRUE if +# all listed variables are TRUE +find_package_handle_standard_args(LibFUSE DEFAULT_MSG LIBFUSE_LIBRARIES) diff --git a/trunk/cmake_modules/FindLibOSXFUSE.cmake b/trunk/cmake_modules/FindLibOSXFUSE.cmake index 39fc74f..46cf8dc 100644 --- a/trunk/cmake_modules/FindLibOSXFUSE.cmake +++ b/trunk/cmake_modules/FindLibOSXFUSE.cmake @@ -1,22 +1,41 @@ +# Try pkg-config first find_package(PkgConfig) -pkg_check_modules(PC_LIBOSXFUSE QUIET libosxfuse) -set(LIBOSXFUSE_DEFINITIONS ${PC_LIBOSXFUSE_CFLAGS_OTHER}) +pkg_check_modules(PKGC_LIBOSXFUSE QUIET libosxfuse) -find_path(LIBOSXFUSE_INCLUDE_DIR fuse.h - HINTS ${PC_LIBOSXFUSE_INCLUDEDIR} ${PC_LIBOSXFUSE_INCLUDE_DIRS} - PATH_SUFFIXES osxfuse) +if(PKGC_LIBOSXFUSE_FOUND) + # Found lib using pkg-config. + if(CMAKE_DEBUG) + message(STATUS "\${PKGC_LIBOSXFUSE_LIBRARIES} = ${PKGC_LIBOSXFUSE_LIBRARIES}") + message(STATUS "\${PKGC_LIBOSXFUSE_LIBRARY_DIRS} = ${PKGC_LIBOSXFUSE_LIBRARY_DIRS}") + message(STATUS "\${PKGC_LIBOSXFUSE_LDFLAGS} = ${PKGC_LIBOSXFUSE_LDFLAGS}") + message(STATUS "\${PKGC_LIBOSXFUSE_LDFLAGS_OTHER} = ${PKGC_LIBOSXFUSE_LDFLAGS_OTHER}") + message(STATUS "\${PKGC_LIBOSXFUSE_INCLUDE_DIRS} = ${PKGC_LIBOSXFUSE_INCLUDE_DIRS}") + message(STATUS "\${PKGC_LIBOSXFUSE_CFLAGS} = ${PKGC_LIBOSXFUSE_CFLAGS}") + message(STATUS "\${PKGC_LIBOSXFUSE_CFLAGS_OTHER} = ${PKGC_LIBOSXFUSE_CFLAGS_OTHER}") + endif(CMAKE_DEBUG) -find_library(LIBOSXFUSE_LIBRARY NAMES osxfuse libosxfuse - HINTS ${PC_LIBOSXFUSE_LIBDIR} ${PC_LIBOSXFUSE_LIBRARY_DIRS}) + set(LIBOSXFUSE_LIBRARIES ${PKGC_LIBOSXFUSE_LIBRARIES}) + set(LIBOSXFUSE_INCLUDE_DIRS ${PKGC_LIBOSXFUSE_INCLUDE_DIRS}) + #set(LIBOSXFUSE_DEFINITIONS ${PKGC_LIBOSXFUSE_CFLAGS_OTHER}) +else(PKGC_LIBOSXFUSE_FOUND) + # Didn't find lib using pkg-config. Try to find it manually + message(WARNING "Unable to find LibOSXFUSE using pkg-config! If compilation fails, make sure pkg-config is installed and PKG_CONFIG_PATH is set correctly") -set(LIBOSXFUSE_LIBRARIES ${LIBOSXFUSE_LIBRARY}) -set(LIBOSXFUSE_INCLUDE_DIRS ${LIBOSXFUSE_INCLUDE_DIR}) + find_path(LIBOSXFUSE_INCLUDE_DIR fuse.h + PATH_SUFFIXES fuse) + find_library(LIBOSXFUSE_LIBRARY NAMES osxfuse libosxfuse) -include(FindPackageHandleStandardArgs) -find_package_handle_standard_args(LibOSXFUSE - DEFAULT_MSG - LIBOSXFUSE_LIBRARY - LIBOSXFUSE_INCLUDE_DIR) + if(CMAKE_DEBUG) + message(STATUS "\${LIBOSXFUSE_LIBRARY} = ${LIBOSXFUSE_LIBRARY}") + message(STATUS "\${LIBOSXFUSE_INCLUDE_DIR} = ${LIBOSXFUSE_INCLUDE_DIR}") + endif(CMAKE_DEBUG) + + set(LIBOSXFUSE_LIBRARIES ${LIBOSXFUSE_LIBRARY}) + set(LIBOSXFUSE_INCLUDE_DIRS ${LIBOSXFUSE_INCLUDE_DIR}) +endif(PKGC_LIBOSXFUSE_FOUND) -mark_as_advanced(LIBOSXFUSE_INCLUDE_DIR LIBOSXFUSE_LIBRARY) +include(FindPackageHandleStandardArgs) +# Handle the QUIETLY and REQUIRED arguments and set _FOUND to TRUE if +# all listed variables are TRUE +find_package_handle_standard_args(LibOSXFUSE DEFAULT_MSG LIBOSXFUSE_LIBRARIES) diff --git a/trunk/cmake_modules/FindLibZ.cmake b/trunk/cmake_modules/FindLibZ.cmake index 634b2d7..9d2c7d0 100644 --- a/trunk/cmake_modules/FindLibZ.cmake +++ b/trunk/cmake_modules/FindLibZ.cmake @@ -1,18 +1,41 @@ +# Try pkg-config first find_package(PkgConfig) -pkg_check_modules(PC_LIBZ QUIET zlib) -set(LIBZ_DEFINITIONS ${PC_LIBZ_CFLAGS_OTHER}) +pkg_check_modules(PKGC_LIBZ QUIET zlib) -find_path(LIBZ_INCLUDE_DIR zlib.h - HINTS ${PC_LIBZ_INCLUDEDIR} ${PC_LIBZ_INCLUDE_DIRS} - PATH_SUFFIXES zlib) +if(PKGC_LIBZ_FOUND) + # Found lib using pkg-config. + if(CMAKE_DEBUG) + message(STATUS "\${PKGC_LIBZ_LIBRARIES} = ${PKGC_LIBZ_LIBRARIES}") + message(STATUS "\${PKGC_LIBZ_LIBRARY_DIRS} = ${PKGC_LIBZ_LIBRARY_DIRS}") + message(STATUS "\${PKGC_LIBZ_LDFLAGS} = ${PKGC_LIBZ_LDFLAGS}") + message(STATUS "\${PKGC_LIBZ_LDFLAGS_OTHER} = ${PKGC_LIBZ_LDFLAGS_OTHER}") + message(STATUS "\${PKGC_LIBZ_INCLUDE_DIRS} = ${PKGC_LIBZ_INCLUDE_DIRS}") + message(STATUS "\${PKGC_LIBZ_CFLAGS} = ${PKGC_LIBZ_CFLAGS}") + message(STATUS "\${PKGC_LIBZ_CFLAGS_OTHER} = ${PKGC_LIBZ_CFLAGS_OTHER}") + endif(CMAKE_DEBUG) -find_library(LIBZ_LIBRARY NAMES z libz - HINTS ${PC_LIBZ_LIBDIR} ${PC_LIBZ_LIBRARY_DIRS} ) + set(LIBZ_LIBRARIES ${PKGC_LIBZ_LIBRARIES}) + set(LIBZ_INCLUDE_DIRS ${PKGC_LIBZ_INCLUDE_DIRS}) + #set(LIBZ_DEFINITIONS ${PKGC_LIBZ_CFLAGS_OTHER}) +else(PKGC_LIBZ_FOUND) + # Didn't find lib using pkg-config. Try to find it manually + message(WARNING "Unable to find LibZ using pkg-config! If compilation fails, make sure pkg-config is installed and PKG_CONFIG_PATH is set correctly") -set(LIBZ_LIBRARIES ${LIBZ_LIBRARY}) -set(LIBZ_INCLUDE_DIRS ${LIBZ_INCLUDE_DIR}) + find_path(LIBZ_INCLUDE_DIR zlib.h + PATH_SUFFIXES zlib) + find_library(LIBZ_LIBRARY NAMES z libz) + + if(CMAKE_DEBUG) + message(STATUS "\${LIBZ_LIBRARY} = ${LIBZ_LIBRARY}") + message(STATUS "\${LIBZ_INCLUDE_DIR} = ${LIBZ_INCLUDE_DIR}") + endif(CMAKE_DEBUG) + + set(LIBZ_LIBRARIES ${LIBZ_LIBRARY}) + set(LIBZ_INCLUDE_DIRS ${LIBZ_INCLUDE_DIR}) +endif(PKGC_LIBZ_FOUND) include(FindPackageHandleStandardArgs) -find_package_handle_standard_args(LibZ DEFAULT_MSG LIBZ_LIBRARY LIBZ_INCLUDE_DIR) +# Handle the QUIETLY and REQUIRED arguments and set _FOUND to TRUE if +# all listed variables are TRUE +find_package_handle_standard_args(LibZ DEFAULT_MSG LIBZ_LIBRARIES) -mark_as_advanced(LIBZ_INCLUDE_DIR LIBZ_LIBRARY) diff --git a/trunk/libxmount_input/CMakeLists.txt b/trunk/libxmount_input/CMakeLists.txt index b6b8293..f8b8e27 100644 --- a/trunk/libxmount_input/CMakeLists.txt +++ b/trunk/libxmount_input/CMakeLists.txt @@ -1,29 +1,28 @@ add_subdirectory(libxmount_input_dd) if(NOT STATIC_EWF) find_package(LibEWF) if(LIBEWF_FOUND) add_subdirectory(libxmount_input_ewf) endif(LIBEWF_FOUND) else(NOT STATIC_EWF) - message("-- Not checking for LibEWF (STATIC_EWF = 1)") + message(STATUS "Not checking for LibEWF (STATIC_EWF = 1)") add_subdirectory(libxmount_input_ewf) endif(NOT STATIC_EWF) if(NOT STATIC_AFF) find_package(LibAFF) - find_package(OpenSSL) - if(LIBAFF_FOUND AND OPENSSL_FOUND) + if(LIBAFF_FOUND) add_subdirectory(libxmount_input_aff) - endif(LIBAFF_FOUND AND OPENSSL_FOUND) + endif(LIBAFF_FOUND) else(NOT STATIC_AFF) - message("-- Not checking for LibAFF (STATIC_AFF = 1)") + message(STATUS "Not checking for LibAFF (STATIC_AFF = 1)") add_subdirectory(libxmount_input_aff) endif(NOT STATIC_AFF) #find_package(LibZ) #if(LIBZ_FOUND) # add_subdirectory(libxmount_input_aewf) # add_subdirectory(libxmount_input_aaff) #endif(LIBZ_FOUND) diff --git a/trunk/libxmount_input/libxmount_input.h b/trunk/libxmount_input/libxmount_input.h index 6622aa6..732df80 100644 --- a/trunk/libxmount_input/libxmount_input.h +++ b/trunk/libxmount_input/libxmount_input.h @@ -1,221 +1,223 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #ifndef LIBXMOUNT_INPUT_H #define LIBXMOUNT_INPUT_H #define LIBXMOUNT_INPUT_API_VERSION 1 #include #include // For int*_t and uint*_t #include // For PRI* #include "../libxmount/libxmount.h" //! Structure containing pointers to the lib's functions typedef struct s_LibXmountInputFunctions { //! Function to initialize handle /*! * This function is called once to allow the lib to alloc any needed * structures before other functions that rely upon a valid handle are called * (for ex. OptionsParse or Open). * * The p_format parameter specifies one of the formats returned by * LibXmount_Input_GetSupportedFormats() which should be used for this handle. * * \param pp_handle Pointer to handle * \param p_format Input image format + * \param debug If set to 1, print debugging infos to stdout * \return 0 on success or error code */ int (*CreateHandle)(void **pp_handle, - const char *p_format); + const char *p_format, + uint8_t debug); //! Function to destroy handle /*! * In this function, any structures allocated with CreateHandle should be * freed. It is generally the last function called before unloading of lib * happens. * * By convention, after this function has been called, *pp_handle must be * NULL. * * \param pp_handle Pointer to handle * \return 0 on success or error code */ int (*DestroyHandle)(void **pp_handle); //! Function to open input image /*! * Opens the specified image for reading. * * \param p_handle Handle * \param pp_filename_arr Array containing all specified input images * \param filename_arr_len Length of pp_filename_arr * \return 0 on success or error code */ int (*Open)(void *p_handle, const char **pp_filename_arr, uint64_t filename_arr_len); //! Function to close opened input image /*! * Closes input image and frees any memory allocaed during opening but does * not invalidate the main handle. Further calls to for ex. Open() must still * be possible without first calling CreateHandle again! * * \param p_handle Handle * \return 0 on success or error code */ int (*Close)(void *p_handle); //! Function to get the input image's size /*! * Returns the real size of the input image. Real means the size of the * uncompressed or otherwise made available data contained inside the input * image. * * \param p_handle Handle * \param p_size Pointer to store input image's size to * \return 0 on success or error code */ int (*Size)(void *p_handle, uint64_t *p_size); //! Function to read data from input image /*! * Reads count bytes at offset from input image and copies them into memory * starting at the address of p_buf. Memory is pre-allocated to as much bytes * as should be read. * * \param p_handle Handle * \param p_buf Buffer to store read data to * \param offset Position at which to start reading * \param count Amount of bytes to read * \param p_read Amount of bytes read * \return 0 on success or error code */ int (*Read)(void *p_handle, char *p_buf, off_t offset, size_t count, size_t *p_read); //! Function to get a help message for any supported lib-specific options /*! * Calling this function should return a string containing help messages for * any supported lib-specific options. Lines should be formated as follows: * * " option : description\n" * * Returned string will be freed by the caller using FreeBuffer(). * * If there is no help text, this function must return NULL in pp_help. * * \param Pointer to a string to return help text * \return 0 on success or error code on error */ int (*OptionsHelp)(const char **pp_help); //! Function to parse any lib-specific options /*! * This function is called with the options given with the --inopts parameter. * For all options that are valid for the lib, the option's valid member * must be set to 1. If errors are encountered, this function should fail and * return an error message in pp_error. pp_error will be freed by the caller * by using FreeBuffer. * * \param p_handle Handle * \param options_count Count of elements in pp_options * \param pp_options Input library options * \param pp_error Pointer to a string with error message * \return 0 on success or error code and error message on error */ int (*OptionsParse)(void *p_handle, uint32_t options_count, const pts_LibXmountOptions *pp_options, const char **pp_error); //! Function to get content to add to the info file /*! * The returned string is added to xmount's info file. This function is only * called once when the info file is generated. The returned string is then * freed with a call to FreeBuffer(). * * \param p_handle Handle * \param pp_info_buf Pointer to store the null-terminated content * \return 0 on success or error code */ int (*GetInfofileContent)(void *p_handle, const char **pp_info_buf); //! Function to get an error message /*! * This function should translate an error code that was previously returned * by one of the library functions into a human readable error message. * * By convention, this function must always return a valid pointer to a * NULL-terminated string! * * \param err_num Error code as returned by lib */ const char* (*GetErrorMessage)(int err_num); //! Function to free buffers that were allocated by lib /*! * \param p_buf Buffer to free * \return 0 on success or error code */ int (*FreeBuffer)(void *p_buf); } ts_LibXmountInputFunctions, *pts_LibXmountInputFunctions; //! Get library API version /*! * This function should return the value of LIBXMOUNT_INPUT_API_VERSION * * \return Supported version */ uint8_t LibXmount_Input_GetApiVersion(); typedef uint8_t (*t_LibXmount_Input_GetApiVersion)(); //! Get a list of supported formats /*! * Gets a list of supported input image formats. These are the strings * specified with xmount's --in command line option. The returned * string must be a constant vector of image formats split by \0 chars. To mark * the end of the vector, a single \0 must be used. * * As an example, "first\0second\0\0" would be a correct vector to return for * a lib supporting two input image formats. * * \return Vector containing supported format strings */ const char* LibXmount_Input_GetSupportedFormats(); typedef const char* (*t_LibXmount_Input_GetSupportedFormats)(); //! Get the lib's s_LibXmountInputFunctions structure /*! * This function should set the members of the given s_LibXmountInputFunctions * structure to the internal lib functions. All members have to be set. * * \param p_functions s_LibXmountInputFunctions structure to fill */ void LibXmount_Input_GetFunctions(pts_LibXmountInputFunctions p_functions); typedef void (*t_LibXmount_Input_GetFunctions)(pts_LibXmountInputFunctions); #endif // LIBXMOUNT_INPUT_H diff --git a/trunk/libxmount_input/libxmount_input_aff/libxmount_input_aff.c b/trunk/libxmount_input/libxmount_input_aff/libxmount_input_aff.c index e67e867..5306421 100644 --- a/trunk/libxmount_input/libxmount_input_aff/libxmount_input_aff.c +++ b/trunk/libxmount_input/libxmount_input_aff/libxmount_input_aff.c @@ -1,256 +1,259 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #include #include #include // For O_RDONLY #include "../libxmount_input.h" #ifndef HAVE_LIBAFF_STATIC #include #else #include "libaff/lib/afflib.h" #endif #include "libxmount_input_aff.h" /******************************************************************************* * LibXmount_Input API implementation ******************************************************************************/ /* * LibXmount_Input_GetApiVersion */ uint8_t LibXmount_Input_GetApiVersion() { return LIBXMOUNT_INPUT_API_VERSION; } /* * LibXmount_Input_GetSupportedFormats */ const char* LibXmount_Input_GetSupportedFormats() { return "aff\0\0"; } /* * LibXmount_Input_GetFunctions */ void LibXmount_Input_GetFunctions(ts_LibXmountInputFunctions *p_functions) { p_functions->CreateHandle=&AffCreateHandle; p_functions->DestroyHandle=&AffDestroyHandle; p_functions->Open=&AffOpen; p_functions->Close=&AffClose; p_functions->Size=&AffSize; p_functions->Read=&AffRead; p_functions->OptionsHelp=&AffOptionsHelp; p_functions->OptionsParse=&AffOptionsParse; p_functions->GetInfofileContent=&AffGetInfofileContent; p_functions->GetErrorMessage=&AffGetErrorMessage; p_functions->FreeBuffer=&AffFreeBuffer; } /******************************************************************************* * Private ******************************************************************************/ /* * AffCreateHandle */ -static int AffCreateHandle(void **pp_handle, const char *p_format) { +static int AffCreateHandle(void **pp_handle, + const char *p_format, + uint8_t debug) +{ (void)p_format; pts_AffHandle p_aff_handle; // Alloc new lib handle p_aff_handle=(pts_AffHandle)malloc(sizeof(ts_AffHandle)); if(p_aff_handle==NULL) return AFF_MEMALLOC_FAILED; // Init lib handle p_aff_handle->h_aff=NULL; *pp_handle=p_aff_handle; return AFF_OK; } /* * AffDestroyHandle */ static int AffDestroyHandle(void **pp_handle) { pts_AffHandle p_aff_handle=(pts_AffHandle)*pp_handle; // Free lib handle if(p_aff_handle!=NULL) free(p_aff_handle); *pp_handle=NULL; return AFF_OK; } /* * AffOpen */ static int AffOpen(void *p_handle, const char **pp_filename_arr, uint64_t filename_arr_len) { pts_AffHandle p_aff_handle=(pts_AffHandle)p_handle; // We need exactly one file if(filename_arr_len==0) return AFF_NO_INPUT_FILES; if(filename_arr_len>1) return AFF_TOO_MANY_INPUT_FILES; // Open AFF file p_aff_handle->h_aff=af_open(pp_filename_arr[0],O_RDONLY,0); if(p_aff_handle->h_aff==NULL) { // LOG_ERROR("Couldn't open AFF file!\n") return AFF_OPEN_FAILED; } // Encrypted images aren't supported for now // TODO: Add support trough lib params, f. ex. aff_password=xxxx if(af_cannot_decrypt(p_aff_handle->h_aff)) { af_close(p_aff_handle->h_aff); return AFF_ENCRYPTION_UNSUPPORTED; } return AFF_OK; } /* * AffClose */ static int AffClose(void *p_handle) { pts_AffHandle p_aff_handle=(pts_AffHandle)p_handle; // Close AFF handle if(af_close(p_aff_handle->h_aff)!=0) return AFF_CLOSE_FAILED; return AFF_OK; } /* * AffSize */ static int AffSize(void *p_handle, uint64_t *p_size) { pts_AffHandle p_aff_handle=(pts_AffHandle)p_handle; // TODO: Check for error. Unfortunately, I don't know how :( *p_size=af_seek(p_aff_handle->h_aff,0,SEEK_END); return AFF_OK; } /* * AffRead */ static int AffRead(void *p_handle, char *p_buf, off_t offset, size_t count, size_t *p_read) { pts_AffHandle p_aff_handle=(pts_AffHandle)p_handle; size_t bytes_read; // Seek to requested position if(af_seek(p_aff_handle->h_aff,offset,SEEK_SET)!=offset) { return AFF_SEEK_FAILED; } // Read data // TODO: Check for errors bytes_read=af_read(p_aff_handle->h_aff,(unsigned char*)p_buf,count); if(bytes_read!=count) return AFF_READ_FAILED; *p_read=bytes_read; return AFF_OK; } /* * AffOptionsHelp */ static int AffOptionsHelp(const char **pp_help) { *pp_help=NULL; return AFF_OK; } /* * AffOptionsParse */ static int AffOptionsParse(void *p_handle, uint32_t options_count, const pts_LibXmountOptions *pp_options, const char **pp_error) { return AFF_OK; } /* * AffGetInfofileContent */ static int AffGetInfofileContent(void *p_handle, const char **pp_info_buf) { // TODO *pp_info_buf=NULL; return AFF_OK; } /* * AffGetErrorMessage */ static const char* AffGetErrorMessage(int err_num) { switch(err_num) { case AFF_MEMALLOC_FAILED: return "Unable to allocate memory"; break; case AFF_NO_INPUT_FILES: return "No input file(s) specified"; break; case AFF_TOO_MANY_INPUT_FILES: return "Too many input files specified"; break; case AFF_OPEN_FAILED: return "Unable to open EWF file(s)"; break; case AFF_CLOSE_FAILED: return "Unable to close EWF file(s)"; break; case AFF_ENCRYPTION_UNSUPPORTED: return "Encrypted AFF files are currently not supported"; break; case AFF_SEEK_FAILED: return "Unable to seek into EWF data"; break; case AFF_READ_FAILED: return "Unable to read EWF data"; break; default: return "Unknown error"; } } /* * AffFreeBuffer */ static int AffFreeBuffer(void *p_buf) { free(p_buf); return AFF_OK; } /* ----- Change log ----- 20140724: * Initial version implementing AffOpen, AffSize, AffRead, AffClose, AffOptionsHelp, AffOptionsParse and AffFreeBuffer 20140804: * Added error handling and AffGetErrorMessage */ diff --git a/trunk/libxmount_input/libxmount_input_aff/libxmount_input_aff.h b/trunk/libxmount_input/libxmount_input_aff/libxmount_input_aff.h index 9492f7b..a58f7fa 100644 --- a/trunk/libxmount_input/libxmount_input_aff/libxmount_input_aff.h +++ b/trunk/libxmount_input/libxmount_input_aff/libxmount_input_aff.h @@ -1,71 +1,72 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #ifndef LIBXMOUNT_INPUT_AFF_H #define LIBXMOUNT_INPUT_AFF_H /******************************************************************************* * Enums, Typedefs, etc... ******************************************************************************/ //! Possible error return codes enum { AFF_OK=0, AFF_MEMALLOC_FAILED, AFF_NO_INPUT_FILES, AFF_TOO_MANY_INPUT_FILES, AFF_OPEN_FAILED, AFF_CLOSE_FAILED, AFF_ENCRYPTION_UNSUPPORTED, AFF_SEEK_FAILED, AFF_READ_FAILED }; //! Library handle typedef struct s_AffHandle { //! AFF handle AFFILE *h_aff; } ts_AffHandle, *pts_AffHandle; /******************************************************************************* * Forward declarations ******************************************************************************/ static int AffCreateHandle(void **pp_handle, - const char *p_format); + const char *p_format, + uint8_t debug); static int AffDestroyHandle(void **pp_handle); static int AffOpen(void *p_handle, const char **pp_filename_arr, uint64_t filename_arr_len); static int AffClose(void *p_handle); static int AffSize(void *p_handle, uint64_t *p_size); static int AffRead(void *p_handle, char *p_buf, off_t seek, size_t count, size_t *p_read); static int AffOptionsHelp(const char **pp_help); static int AffOptionsParse(void *p_handle, uint32_t options_count, const pts_LibXmountOptions *pp_options, const char **pp_error); static int AffGetInfofileContent(void *p_handle, const char **pp_info_buf); static const char* AffGetErrorMessage(int err_num); static int AffFreeBuffer(void *p_buf); #endif // LIBXMOUNT_INPUT_AFF_H diff --git a/trunk/libxmount_input/libxmount_input_dd/libxmount_input_dd.c b/trunk/libxmount_input/libxmount_input_dd/libxmount_input_dd.c index cb9c974..d14cc27 100644 --- a/trunk/libxmount_input/libxmount_input_dd/libxmount_input_dd.c +++ b/trunk/libxmount_input/libxmount_input_dd/libxmount_input_dd.c @@ -1,408 +1,411 @@ /******************************************************************************* * xmount Copyright (c) 2008-2013 by Gillen Daniel * * * * This module has been written by Guy Voncken. It contains the functions for * * accessing dd images. Split dd is supported as well. * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #include #include #include #include "../libxmount_input.h" #include "libxmount_input_dd.h" /******************************************************************************* * LibXmount_Input API implementation ******************************************************************************/ /* * LibXmount_Input_GetApiVersion */ uint8_t LibXmount_Input_GetApiVersion() { return LIBXMOUNT_INPUT_API_VERSION; } /* * LibXmount_Input_GetSupportedFormats */ const char* LibXmount_Input_GetSupportedFormats() { return "dd\0\0"; } /* * LibXmount_Input_GetFunctions */ void LibXmount_Input_GetFunctions(ts_LibXmountInputFunctions *p_functions) { p_functions->CreateHandle=&DdCreateHandle; p_functions->DestroyHandle=&DdDestroyHandle; p_functions->Open=&DdOpen; p_functions->Close=&DdClose; p_functions->Size=&DdSize; p_functions->Read=&DdRead; p_functions->OptionsHelp=&DdOptionsHelp; p_functions->OptionsParse=&DdOptionsParse; p_functions->GetInfofileContent=&DdGetInfofileContent; p_functions->GetErrorMessage=&DdGetErrorMessage; p_functions->FreeBuffer=&DdFreeBuffer; } /******************************************************************************* * Private ******************************************************************************/ // --------------------------- // Internal static functions // --------------------------- static inline uint64_t DdGetCurrentSeekPos (t_pPiece pPiece) { return ftello (pPiece->pFile); } static inline int DdSetCurrentSeekPos (t_pPiece pPiece, uint64_t Val, int Whence) { if (fseeko (pPiece->pFile, Val, Whence) != 0) return DD_CANNOT_SEEK; return DD_OK; } static int DdRead0 (t_pdd pdd, char *pBuffer, uint64_t Seek, uint32_t *pCount) { t_pPiece pPiece; uint64_t i; // Find correct piece to read from // ------------------------------- for (i=0; iPieces; i++) { pPiece = &pdd->pPieceArr[i]; if (Seek < pPiece->FileSize) break; Seek -= pPiece->FileSize; } if (i >= pdd->Pieces) return DD_READ_BEYOND_END_OF_IMAGE; // Read from this piece // -------------------- CHK (DdSetCurrentSeekPos (pPiece, Seek, SEEK_SET)) *pCount = GETMIN (*pCount, pPiece->FileSize - Seek); if (fread (pBuffer, *pCount, 1, pPiece->pFile) != 1) { return DD_CANNOT_READ_DATA; } return DD_OK; } // --------------- // API functions // --------------- /* * DdCreateHandle */ -static int DdCreateHandle(void **pp_handle, const char *p_format) { +static int DdCreateHandle(void **pp_handle, + const char *p_format, + uint8_t debug) +{ (void)p_format; t_pdd p_dd=NULL; p_dd=(t_pdd)malloc(sizeof(t_dd)); if(p_dd==NULL) return DD_MEMALLOC_FAILED; memset(p_dd,0,sizeof(t_dd)); *pp_handle=p_dd; return DD_OK; } /* * DdDestroyHandle */ static int DdDestroyHandle(void **pp_handle) { free(*pp_handle); *pp_handle=NULL; return DD_OK; } /* * DdOpen */ static int DdOpen(void *p_handle, const char **pp_filename_arr, uint64_t filename_arr_len) { t_pdd pdd=(t_pdd)p_handle; t_pPiece pPiece; pdd->Pieces = filename_arr_len; pdd->pPieceArr = (t_pPiece) malloc (pdd->Pieces * sizeof(t_Piece)); if (pdd->pPieceArr == NULL) return DD_MEMALLOC_FAILED; // Need to set everything to 0 in case an error occurs later and DdClose is // called memset(pdd->pPieceArr,0,pdd->Pieces * sizeof(t_Piece)); pdd->TotalSize = 0; for (uint64_t i=0; i < pdd->Pieces; i++) { pPiece = &pdd->pPieceArr[i]; pPiece->pFilename = strdup (pp_filename_arr[i]); if (pPiece->pFilename == NULL) { DdClose(p_handle); return DD_MEMALLOC_FAILED; } pPiece->pFile = fopen (pPiece->pFilename, "r"); if (pPiece->pFile == NULL) { DdClose(p_handle); return DD_FILE_OPEN_FAILED; } CHK(DdSetCurrentSeekPos(pPiece, 0, SEEK_END)) pPiece->FileSize = DdGetCurrentSeekPos (pPiece); pdd->TotalSize += pPiece->FileSize; } return DD_OK; } /* * DdClose */ static int DdClose(void *p_handle) { t_pdd pdd = (t_pdd)p_handle; t_pPiece pPiece; int CloseErrors = 0; if (pdd->pPieceArr) { for (uint64_t i=0; i < pdd->Pieces; i++) { pPiece = &pdd->pPieceArr[i]; if (pPiece->pFile) { if (fclose (pPiece->pFile)) CloseErrors=1; } if (pPiece->pFilename) free (pPiece->pFilename); } free (pdd->pPieceArr); } if (CloseErrors) return DD_CANNOT_CLOSE_FILE; return DD_OK; } /* * DdSize */ static int DdSize(void *p_handle, uint64_t *p_size) { t_pdd p_dd_handle=(t_pdd)p_handle; *p_size=p_dd_handle->TotalSize; return DD_OK; } /* * DdRead */ static int DdRead(void *p_handle, char *p_buf, off_t seek, size_t count, size_t *p_read) { t_pdd p_dd_handle=(t_pdd)p_handle; uint32_t remaining=count; uint32_t to_read; if((seek+count)>p_dd_handle->TotalSize) { return DD_READ_BEYOND_END_OF_IMAGE; } do { to_read=remaining; CHK(DdRead0(p_dd_handle,p_buf,seek,&to_read)) remaining-=to_read; p_buf+=to_read; seek+=to_read; } while(remaining); *p_read=count; return DD_OK; } /* * DdOptionsHelp */ static int DdOptionsHelp(const char **pp_help) { *pp_help=NULL; return DD_OK; } /* * DdOptionsParse */ static int DdOptionsParse(void *p_handle, uint32_t options_count, const pts_LibXmountOptions *pp_options, const char **pp_error) { return DD_OK; } /* * DdGetInfofileContent */ static int DdGetInfofileContent(void *p_handle, const char **pp_info_buf) { t_pdd p_dd_handle=(t_pdd)p_handle; int ret; char *p_info_buf; // TODO: TotalSize seems to be incorrect here??? ret=asprintf(&p_info_buf, "DD image assembled of %" PRIu64 " piece(s)\n" "%" PRIu64 " bytes in total (%0.3f GiB)\n", p_dd_handle->Pieces, p_dd_handle->TotalSize, p_dd_handle->TotalSize/(1024.0*1024.0*1024.0)); if(ret<0 || *pp_info_buf==NULL) return DD_MEMALLOC_FAILED; *pp_info_buf=p_info_buf; return DD_OK; } /* * DdGetErrorMessage */ static const char* DdGetErrorMessage(int err_num) { switch(err_num) { case DD_MEMALLOC_FAILED: return "Unable to allocate memory"; break; case DD_FILE_OPEN_FAILED: return "Unable to open DD file(s)"; break; case DD_CANNOT_READ_DATA: return "Unable to read DD data"; break; case DD_CANNOT_CLOSE_FILE: return "Unable to close DD file(s)"; break; case DD_CANNOT_SEEK: return "Unable to seek into DD data"; break; case DD_READ_BEYOND_END_OF_IMAGE: return "Unable to read DD data: Attempt to read past EOF"; break; default: return "Unknown error"; } } /* * DdFreeBuffer */ static int DdFreeBuffer(void *p_buf) { free(p_buf); return DD_OK; } // ----------------------------------------------------- // Small main routine for testing // It a split dd file to non-split dd // ----------------------------------------------------- #ifdef DD_MAIN_FOR_TESTING int main(int argc, const char *argv[]) { t_pdd pdd; uint64_t TotalSize; uint64_t Remaining; uint64_t Read; uint64_t Pos; uint32_t BuffSize = 1024; char Buff[BuffSize]; FILE *pFile; int Percent; int PercentOld; int rc; printf ("Split DD to DD converter\n"); if (argc < 3) { printf ("Usage: %s
<...>
\n", argv[0]); exit (1); } if (DdOpen ((void**)&pdd, argc-2, &argv[1]) != DD_OK) { printf ("Cannot open split dd file\n"); exit (1); } CHK (DdSize ((void*)pdd, &TotalSize)) printf ("Total size: %llu bytes\n", TotalSize); Remaining = TotalSize; pFile = fopen (argv[argc-1], "w"); if (pFile == NULL) { printf ("Cannot open destination file\n"); exit (1); } Remaining = TotalSize; Pos = 0; PercentOld = -1; while (Remaining) { Read = GETMIN (Remaining, BuffSize); rc = DdRead ((void*)pdd, Pos, &Buff[0], Read); if (rc != DD_OK) { printf ("Error %d while calling DdRead\n", rc); exit (1); } if (fwrite (Buff, Read, 1, pFile) != 1) { printf ("Could not write to destinationfile\n"); exit (2); } Remaining -= Read; Pos += Read; Percent = (100*Pos) / TotalSize; if (Percent != PercentOld) { printf ("\r%d%% done...", Percent); PercentOld = Percent; } } if (fclose (pFile)) { printf ("Error while closing destinationfile\n"); exit (3); } printf ("\n"); return 0; } #endif // DD_MAIN_FOR_TESTING diff --git a/trunk/libxmount_input/libxmount_input_dd/libxmount_input_dd.h b/trunk/libxmount_input/libxmount_input_dd/libxmount_input_dd.h index c20cb53..7320dda 100644 --- a/trunk/libxmount_input/libxmount_input_dd/libxmount_input_dd.h +++ b/trunk/libxmount_input/libxmount_input_dd/libxmount_input_dd.h @@ -1,117 +1,118 @@ /******************************************************************************* * xmount Copyright (c) 2008-2013 by Gillen Daniel * * * * This module has been written by Guy Voncken. It contains the functions for * * accessing dd images. Split dd is supported as well. * * * * xmount is a small tool to "fuse mount" various harddisk image formats as dd, * * vdi, vhd or vmdk files and enable virtual write access to them. * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #ifndef LIBXMOUNT_INPUT_DD_H #define LIBXMOUNT_INPUT_DD_H /******************************************************************************* * Error codes etc... ******************************************************************************/ enum { DD_OK=0, DD_MEMALLOC_FAILED, DD_FILE_OPEN_FAILED, DD_CANNOT_READ_DATA, DD_CANNOT_CLOSE_FILE, DD_CANNOT_SEEK, DD_READ_BEYOND_END_OF_IMAGE }; // ---------------------- // Constant definitions // ---------------------- #define GETMAX(a,b) ((a)>(b)?(a):(b)) #define GETMIN(a,b) ((a)<(b)?(a):(b)) // --------------------- // Types and strutures // --------------------- typedef struct { char *pFilename; uint64_t FileSize; FILE *pFile; } t_Piece, *t_pPiece; typedef struct { t_pPiece pPieceArr; uint64_t Pieces; uint64_t TotalSize; } t_dd, *t_pdd; // ---------------- // Error handling // ---------------- #ifdef DD_DEBUG #define CHK(ChkVal) \ { \ int ChkValRc; \ if ((ChkValRc=(ChkVal)) != DD_OK) \ { \ printf ("Err %d in %s, %d\n", ChkValRc, __FILE__, __LINE__); \ return ChkValRc; \ } \ } #define DEBUG_PRINTF(pFormat, ...) \ printf (pFormat, ##__VA_ARGS__); #else #define CHK(ChkVal) \ { \ int ChkValRc; \ if ((ChkValRc=(ChkVal)) != DD_OK) \ return ChkValRc; \ } #define DEBUG_PRINTF(...) #endif /******************************************************************************* * Forward declarations ******************************************************************************/ static int DdCreateHandle(void **pp_handle, - const char *p_format); + const char *p_format, + uint8_t debug); static int DdDestroyHandle(void **pp_handle); static int DdOpen(void *p_handle, const char **pp_filename_arr, uint64_t filename_arr_len); static int DdClose(void *p_handle); static int DdSize(void *p_handle, uint64_t *p_size); static int DdRead(void *p_handle, char *p_buf, off_t seek, size_t count, size_t *p_read); static int DdOptionsHelp(const char **pp_help); static int DdOptionsParse(void *p_handle, uint32_t options_count, const pts_LibXmountOptions *pp_options, const char **pp_error); static int DdGetInfofileContent(void *p_handle, const char **pp_info_buf); static const char* DdGetErrorMessage(int err_num); static int DdFreeBuffer(void *p_buf); #endif // LIBXMOUNT_INPUT_DD_H diff --git a/trunk/libxmount_input/libxmount_input_ewf/libxmount_input_ewf.c b/trunk/libxmount_input/libxmount_input_ewf/libxmount_input_ewf.c index af04603..ee8c063 100644 --- a/trunk/libxmount_input/libxmount_input_ewf/libxmount_input_ewf.c +++ b/trunk/libxmount_input/libxmount_input_ewf/libxmount_input_ewf.c @@ -1,481 +1,484 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #include #include #include "../libxmount_input.h" #ifndef HAVE_LIBEWF_STATIC #include #else #include "libewf/include/libewf.h" #endif #ifndef LIBEWF_HANDLE // libewf version 2 no longer defines LIBEWF_HANDLE #define HAVE_LIBEWF_V2_API #endif #include "libxmount_input_ewf.h" /******************************************************************************* * LibXmount_Input API implementation ******************************************************************************/ /* * LibXmount_Input_GetApiVersion */ uint8_t LibXmount_Input_GetApiVersion() { return LIBXMOUNT_INPUT_API_VERSION; } /* * LibXmount_Input_GetSupportedFormats */ const char* LibXmount_Input_GetSupportedFormats() { return "ewf\0\0"; } /* * LibXmount_Input_GetFunctions */ void LibXmount_Input_GetFunctions(ts_LibXmountInputFunctions *p_functions) { p_functions->CreateHandle=&EwfCreateHandle; p_functions->DestroyHandle=&EwfDestroyHandle; p_functions->Open=&EwfOpen; p_functions->Size=&EwfSize; p_functions->Read=&EwfRead; p_functions->Close=&EwfClose; p_functions->OptionsHelp=&EwfOptionsHelp; p_functions->OptionsParse=&EwfOptionsParse; p_functions->GetInfofileContent=&EwfGetInfofileContent; p_functions->GetErrorMessage=&EwfGetErrorMessage; p_functions->FreeBuffer=&EwfFreeBuffer; } /******************************************************************************* * Private ******************************************************************************/ /* * EwfCreateHandle */ -static int EwfCreateHandle(void **pp_handle, const char *p_format) { +static int EwfCreateHandle(void **pp_handle, + const char *p_format, + uint8_t debug) +{ (void)p_format; pts_EwfHandle p_ewf_handle; // Alloc new lib handle p_ewf_handle=(pts_EwfHandle)malloc(sizeof(ts_EwfHandle)); if(p_ewf_handle==NULL) return EWF_MEMALLOC_FAILED; // Init lib handle #ifdef HAVE_LIBEWF_V2_API if(libewf_handle_initialize(&(p_ewf_handle->h_ewf),NULL)!=1) { return EWF_HANDLE_CREATION_FAILED; } #else p_ewf_handle->h_ewf=NULL; #endif *pp_handle=p_ewf_handle; return EWF_OK; } /* * EwfDestroyHandle */ static int EwfDestroyHandle(void **pp_handle) { pts_EwfHandle p_ewf_handle=(pts_EwfHandle)*pp_handle; int ret=EWF_OK; if(p_ewf_handle!=NULL) { // Free EWF handle #ifdef HAVE_LIBEWF_V2_API if(libewf_handle_free(&(p_ewf_handle->h_ewf),NULL)!=1) { ret=EWF_HANDLE_DESTRUCTION_FAILED; } #endif // Free lib handle free(p_ewf_handle); p_ewf_handle=NULL; } *pp_handle=p_ewf_handle; return ret; } /* * EwfOpen */ static int EwfOpen(void *p_handle, const char **pp_filename_arr, uint64_t filename_arr_len) { pts_EwfHandle p_ewf_handle=(pts_EwfHandle)p_handle; // We need at least one file if(filename_arr_len==0) return EWF_NO_INPUT_FILES; // Make sure all files are EWF files for(uint64_t i=0;ih_ewf, (char* const*)pp_filename_arr, filename_arr_len, libewf_get_access_flags_read(), NULL)!=1) #else p_ewf_handle->h_ewf=libewf_open((char* const*)pp_filename_arr, filename_arr_len, libewf_get_flags_read()); if(p_ewf_handle->h_ewf==NULL) #endif { return EWF_OPEN_FAILED; } #ifndef HAVE_LIBEWF_V2_API // Parse EWF header if(libewf_parse_header_values(p_ewf_handle->h_ewf, LIBEWF_DATE_FORMAT_ISO8601)!=1) { return EWF_HEADER_PARSING_FAILED; } #endif return EWF_OK; } /* * EwfClose */ static int EwfClose(void *p_handle) { pts_EwfHandle p_ewf_handle=(pts_EwfHandle)p_handle; // Close EWF handle #ifdef HAVE_LIBEWF_V2_API if(libewf_handle_close(p_ewf_handle->h_ewf,NULL)!=0) #else if(libewf_close(p_ewf_handle->h_ewf)!=0) #endif { return EWF_CLOSE_FAILED; } return EWF_OK; } /* * EwfSize */ static int EwfSize(void *p_handle, uint64_t *p_size) { pts_EwfHandle p_ewf_handle=(pts_EwfHandle)p_handle; #ifdef HAVE_LIBEWF_V2_API if(libewf_handle_get_media_size(p_ewf_handle->h_ewf,p_size,NULL)!=1) { #else if(libewf_get_media_size(p_ewf_handle->h_ewf,p_size)!=1) { #endif return EWF_GET_SIZE_FAILED; } return EWF_OK; } /* * EwfRead */ static int EwfRead(void *p_handle, char *p_buf, off_t offset, size_t count, size_t *p_read) { pts_EwfHandle p_ewf_handle=(pts_EwfHandle)p_handle; size_t bytes_read; #ifdef HAVE_LIBEWF_V2_API if(libewf_handle_seek_offset(p_ewf_handle->h_ewf, offset, SEEK_SET, NULL)!=-1) #else if(libewf_seek_offset(p_ewf_handle->h_ewf,offset)!=-1) #endif { #ifdef HAVE_LIBEWF_V2_API bytes_read=libewf_handle_read_buffer(p_ewf_handle->h_ewf, p_buf, count, NULL); #else bytes_read=libewf_read_buffer(p_ewf_handle->h_ewf,p_buf,count); #endif if(bytes_read!=count) return EWF_READ_FAILED; } else { return EWF_SEEK_FAILED; } *p_read=bytes_read; return EWF_OK; } /* * EwfOptionsHelp */ static int EwfOptionsHelp(const char **pp_help) { *pp_help=NULL; return EWF_OK; } /* * EwfOptionsParse */ static int EwfOptionsParse(void *p_handle, uint32_t options_count, const pts_LibXmountOptions *pp_options, const char **pp_error) { return EWF_OK; } /* * EwfGetInfofileContent */ static int EwfGetInfofileContent(void *p_handle, const char **pp_info_buf) { pts_EwfHandle p_ewf_handle=(pts_EwfHandle)p_handle; char *p_infobuf=NULL; int ret; char buf[512]; uint8_t uint8value; uint32_t uint32value; uint64_t uint64value; #define EWF_INFOBUF_REALLOC(size) { \ p_infobuf=(char*)realloc(p_infobuf,size); \ if(p_infobuf==NULL) return EWF_MEMALLOC_FAILED; \ } #define EWF_INFOBUF_APPEND_STR(str) { \ if(p_infobuf!=NULL) { \ EWF_INFOBUF_REALLOC(strlen(p_infobuf)+strlen(str)+1); \ strcpy(p_infobuf+strlen(p_infobuf),str); \ } else { \ EWF_INFOBUF_REALLOC(strlen(str)+1); \ strcpy(p_infobuf,str); \ } \ } #define EWF_INFOBUF_APPEND_VALUE(desc) { \ if(ret==1) { \ EWF_INFOBUF_APPEND_STR(desc); \ EWF_INFOBUF_APPEND_STR(buf); \ EWF_INFOBUF_APPEND_STR("\n"); \ } \ } EWF_INFOBUF_APPEND_STR("_Acquiry information_\n"); #ifdef HAVE_LIBEWF_V2_API #define EWF_GET_HEADER_VALUE(fun) { \ ret=fun(p_ewf_handle->h_ewf,(uint8_t*)buf,sizeof(buf),NULL); \ } EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_case_number); EWF_INFOBUF_APPEND_VALUE("Case number: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_description); EWF_INFOBUF_APPEND_VALUE("Description: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_examiner_name); EWF_INFOBUF_APPEND_VALUE("Examiner: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_evidence_number); EWF_INFOBUF_APPEND_VALUE("Evidence number: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_notes); EWF_INFOBUF_APPEND_VALUE("Notes: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_acquiry_date); EWF_INFOBUF_APPEND_VALUE("Acquiry date: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_system_date); EWF_INFOBUF_APPEND_VALUE("System date: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_acquiry_operating_system); EWF_INFOBUF_APPEND_VALUE("Acquiry os: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_acquiry_software_version); EWF_INFOBUF_APPEND_VALUE("Acquiry sw version: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_model); EWF_INFOBUF_APPEND_VALUE("Model: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_header_value_serial_number); EWF_INFOBUF_APPEND_VALUE("Serial number: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_hash_value_md5); EWF_INFOBUF_APPEND_VALUE("MD5 hash: "); EWF_GET_HEADER_VALUE(libewf_handle_get_utf8_hash_value_sha1); EWF_INFOBUF_APPEND_VALUE("SHA1 hash: "); #undef EWF_GET_HEADER_VALUE #else #define EWF_GET_HEADER_VALUE(fun) { \ ret=fun(p_ewf_handle->h_ewf,buf,sizeof(buf)); \ } EWF_GET_HEADER_VALUE(libewf_get_header_value_case_number); EWF_INFOBUF_APPEND_VALUE("Case number: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_description); EWF_INFOBUF_APPEND_VALUE("Description: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_examiner_name); EWF_INFOBUF_APPEND_VALUE("Examiner: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_evidence_number); EWF_INFOBUF_APPEND_VALUE("Evidence number: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_notes); EWF_INFOBUF_APPEND_VALUE("Notes: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_acquiry_date); EWF_INFOBUF_APPEND_VALUE("Acquiry date: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_system_date); EWF_INFOBUF_APPEND_VALUE("System date: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_acquiry_operating_system); EWF_INFOBUF_APPEND_VALUE("Acquiry os: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_acquiry_software_version); EWF_INFOBUF_APPEND_VALUE("Acquiry sw version: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_model); EWF_INFOBUF_APPEND_VALUE("Model: "); EWF_GET_HEADER_VALUE(libewf_get_header_value_serial_number); EWF_INFOBUF_APPEND_VALUE("Serial number: "); EWF_GET_HEADER_VALUE(libewf_get_hash_value_md5); EWF_INFOBUF_APPEND_VALUE("MD5 hash: "); EWF_GET_HEADER_VALUE(libewf_get_hash_value_sha1); EWF_INFOBUF_APPEND_VALUE("SHA1 hash: "); #undef EWF_GET_HEADER_VALUE #endif EWF_INFOBUF_APPEND_STR("\n_Media information_\n"); #ifdef HAVE_LIBEWF_V2_API ret=libewf_handle_get_media_type(p_ewf_handle->h_ewf,&uint8value,NULL); #else ret=libewf_get_media_type(p_ewf_handle->h_ewf,&uint8value); #endif if(ret==1) { EWF_INFOBUF_APPEND_STR("Media type: "); switch(uint8value) { case LIBEWF_MEDIA_TYPE_REMOVABLE: EWF_INFOBUF_APPEND_STR("removable disk\n"); break; case LIBEWF_MEDIA_TYPE_FIXED: EWF_INFOBUF_APPEND_STR("fixed disk\n"); break; case LIBEWF_MEDIA_TYPE_OPTICAL: EWF_INFOBUF_APPEND_STR("optical\n"); break; case LIBEWF_MEDIA_TYPE_SINGLE_FILES: EWF_INFOBUF_APPEND_STR("single files\n"); break; case LIBEWF_MEDIA_TYPE_MEMORY: EWF_INFOBUF_APPEND_STR("memory\n"); break; default: EWF_INFOBUF_APPEND_STR("unknown\n"); } } #ifdef HAVE_LIBEWF_V2_API ret=libewf_handle_get_bytes_per_sector(p_ewf_handle->h_ewf,&uint32value,NULL); sprintf(buf,"%" PRIu32,uint32value); EWF_INFOBUF_APPEND_VALUE("Bytes per sector: "); ret=libewf_handle_get_number_of_sectors(p_ewf_handle->h_ewf,&uint64value,NULL); sprintf(buf,"%" PRIu64,uint64value); EWF_INFOBUF_APPEND_VALUE("Number of sectors: "); #else ret=libewf_get_bytes_per_sector(p_ewf_handle->h_ewf,&uint32value); sprintf(buf,"%" PRIu32,uint32value); EWF_INFOBUF_APPEND_VALUE("Bytes per sector: "); ret=libewf_handle_get_amount_of_sectors(p_ewf_handle->h_ewf,&uint64value); sprintf(buf,"%" PRIu64,uint64value); EWF_INFOBUF_APPEND_VALUE("Number of sectors: "); #endif #undef EWF_INFOBUF_APPEND_VALUE #undef EWF_INFOBUF_APPEND_STR #undef EWF_INFOBUF_REALLOC *pp_info_buf=p_infobuf; return EWF_OK; } /* * EwfGetErrorMessage */ static const char* EwfGetErrorMessage(int err_num) { switch(err_num) { case EWF_MEMALLOC_FAILED: return "Unable to allocate memory"; break; case EWF_HANDLE_CREATION_FAILED: return "Unable to create EWF handle"; break; case EWF_HANDLE_DESTRUCTION_FAILED: return "Unable to destroy EWF handle"; break; case EWF_NO_INPUT_FILES: return "No input file(s) specified"; break; case EWF_INVALID_INPUT_FILES: return "The specified input file(s) are not valid EWF files"; break; case EWF_OPEN_FAILED: return "Unable to open EWF file(s)"; break; case EWF_HEADER_PARSING_FAILED: return "Unable to parse EWF header values"; break; case EWF_CLOSE_FAILED: return "Unable to close EWF file(s)"; break; case EWF_GET_SIZE_FAILED: return "Unable to get EWF data size"; break; case EWF_SEEK_FAILED: return "Unable to seek into EWF data"; break; case EWF_READ_FAILED: return "Unable to read EWF data"; break; default: return "Unknown error"; } } /* * EwfFreeBuffer */ static int EwfFreeBuffer(void *p_buf) { free(p_buf); return EWF_OK; } /* ----- Change log ----- 20140724: * Initial version implementing EwfOpen, EwfSize, EwfRead, EwfClose, EwfOptionsHelp, EwfOptionsParse and EwfFreeBuffer. 20140731: * Added support for libewf v1 API. 20140803: * Added EwfCreateHandle, EwfDestroyHandle and EwfGetInfofileContent. */ diff --git a/trunk/libxmount_input/libxmount_input_ewf/libxmount_input_ewf.h b/trunk/libxmount_input/libxmount_input_ewf/libxmount_input_ewf.h index 2d53c31..ba467fd 100644 --- a/trunk/libxmount_input/libxmount_input_ewf/libxmount_input_ewf.h +++ b/trunk/libxmount_input/libxmount_input_ewf/libxmount_input_ewf.h @@ -1,79 +1,80 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #ifndef LIBXMOUNT_INPUT_EWF_H #define LIBXMOUNT_INPUT_EWF_H /******************************************************************************* * Enums, Typedefs, etc... ******************************************************************************/ //! Possible error return codes enum { EWF_OK=0, EWF_MEMALLOC_FAILED, EWF_HANDLE_CREATION_FAILED, EWF_HANDLE_DESTRUCTION_FAILED, EWF_NO_INPUT_FILES, EWF_INVALID_INPUT_FILES, EWF_OPEN_FAILED, EWF_HEADER_PARSING_FAILED, EWF_CLOSE_FAILED, EWF_GET_SIZE_FAILED, EWF_SEEK_FAILED, EWF_READ_FAILED }; //! Library handle typedef struct s_EwfHandle { #ifdef HAVE_LIBEWF_V2_API //! EWF handle libewf_handle_t *h_ewf; #else //! EWF handle LIBEWF_HANDLE *h_ewf; #endif } ts_EwfHandle, *pts_EwfHandle; /******************************************************************************* * Forward declarations ******************************************************************************/ static int EwfCreateHandle(void **pp_handle, - const char *p_format); + const char *p_format, + uint8_t debug); static int EwfDestroyHandle(void **pp_handle); static int EwfOpen(void *p_handle, const char **pp_filename_arr, uint64_t filename_arr_len); static int EwfClose(void *p_handle); static int EwfSize(void *p_handle, uint64_t *p_size); static int EwfRead(void *p_handle, char *p_buf, off_t seek, size_t count, size_t *p_read); static int EwfOptionsHelp(const char **pp_help); static int EwfOptionsParse(void *p_handle, uint32_t options_count, const pts_LibXmountOptions *pp_options, const char **pp_error); static int EwfGetInfofileContent(void *p_handle, const char **pp_info_buf); static const char* EwfGetErrorMessage(int err_num); static int EwfFreeBuffer(void *p_buf); #endif // LIBXMOUNT_INPUT_EWF_H diff --git a/trunk/libxmount_morphing/CMakeLists.txt b/trunk/libxmount_morphing/CMakeLists.txt index 5279a00..2c44991 100644 --- a/trunk/libxmount_morphing/CMakeLists.txt +++ b/trunk/libxmount_morphing/CMakeLists.txt @@ -1,4 +1,4 @@ add_subdirectory(libxmount_morphing_combine) add_subdirectory(libxmount_morphing_raid) -add_subdirectory(libxmount_morphing_freespace) +add_subdirectory(libxmount_morphing_unallocated) diff --git a/trunk/libxmount_morphing/libxmount_morphing.h b/trunk/libxmount_morphing/libxmount_morphing.h index cd11343..2d5bfa6 100644 --- a/trunk/libxmount_morphing/libxmount_morphing.h +++ b/trunk/libxmount_morphing/libxmount_morphing.h @@ -1,272 +1,274 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #ifndef LIBXMOUNT_MORPHING_H #define LIBXMOUNT_MORPHING_H #define LIBXMOUNT_MORPHING_API_VERSION 1 #include #include // For printf #include // For int*_t and uint*_t #include // For va_*, vprintf #include // For PRI* #include "../libxmount/libxmount.h" /******************************************************************************* * Type defs ******************************************************************************/ //! Struct containing pointers to input image functions typedef struct s_LibXmountMorphingInputFunctions { //! Function to get the amount of input images /*! * \param p_count Count of input images * \return 0 on success */ int (*ImageCount)(uint64_t *p_count); //! Function to get the size of the morphed data /*! * \param image Image number * \param p_size Pointer to store input image's size to * \return 0 on success */ int (*Size)(uint64_t image, uint64_t *p_size); //! Function to read data from input image /*! * \param image Image number * \param p_buf Buffer to store read data to * \param offset Position at which to start reading * \param count Amount of bytes to read * \param p_read Number of read bytes on success * \return 0 on success or negated error code on error */ int (*Read)(uint64_t image, char *p_buf, off_t offset, size_t count, size_t *p_read); } ts_LibXmountMorphingInputFunctions, *pts_LibXmountMorphingInputFunctions; //! Structure containing pointers to the lib's functions typedef struct s_LibXmountMorphingFunctions { //! Function to initialize handle /*! * This function is called once to allow the lib to alloc any needed * structures before other functions that rely upon a valid handle are called * (for ex. OptionsParse or Morph). * * The p_format parameter specifies one of the morphing functions returned by * LibXmount_Morphing_GetSupportedMorphFunctions() which should be used for * this handle. * * \param pp_handle Pointer to store handle to * \param p_type Morph type to use * \param debug If set to 1, print debugging infos to stdout * \return 0 on success or error code */ int (*CreateHandle)(void **pp_handle, - char *p_type, + const char *p_type, uint8_t debug); //! Function to destroy handle /*! * In this function, any structures allocated with CreateHandle should be * freed. It is generally the last function called before unloading of lib * happens. * * By convention, after this function has been called, *pp_handle must be * NULL. * * \param pp_handle Pointer to store handle to * \return 0 on success or error code */ int (*DestroyHandle)(void **pp_handle); //! Function to start morphing /*! * Begins to morph input image * * \param p_handle Handle * \param p_input_functions ts_LibXmountInputFunctions structure * \return 0 on success or error code */ int (*Morph)(void *p_handle, pts_LibXmountMorphingInputFunctions p_input_functions); //! Function to get the size of the morphed data /*! * \param p_handle Handle to the opened image * \param p_size Pointer to store input image's size to * \return 0 on success or error code */ int (*Size)(void *p_handle, uint64_t *p_size); //! Function to read data from an input image /*! * Reads count bytes at offset from input image and copies them into memory * starting at the address of p_buf. Memory is pre-allocated to as much bytes * as should be read. * * \param p_handle Handle to the opened image * \param p_buf Buffer to store read data to * \param offset Position at which to start reading * \param count Amount of bytes to read * \param p_read Number of read bytes on success * \return 0 on success or negated error code on error */ int (*Read)(void *p_handle, char *p_buf, off_t offset, size_t count, size_t *p_read); //! Function to get a help message for any supported lib-specific options /*! * Calling this function should return a string containing help messages for - * any supported lib-specific options. Every line of this text must be - * prepended with 6 spaces. + * any supported lib-specific options. Lines should be formated as follows: * - * Returned string must be constant. It won't be freed! + * " option : description\n" * - * If there is no help text, this function must return NULL. + * Returned string will be freed by the caller using FreeBuffer(). * - * \return Pointer to a null-terminated string containing the help text + * If there is no help text, this function must return NULL in pp_help. + * + * \param Pointer to a string to return help text + * \return 0 on success or error code on error */ - const char* (*OptionsHelp)(); + int (*OptionsHelp)(const char **pp_help); //! Function to parse any lib-specific options /*! * This function is called with the options given with the --inopts parameter. * All contained options are for the lib. If errors or unknown options are * found, this function should fail and return an error message in pp_error. * pp_error will be freed by the caller by using FreeBuffer. * * \param p_handle Handle to the opened image * \param p_options String with specified options * \param pp_error Pointer to a string with error message * \return 0 on success or error code and error message */ int (*OptionsParse)(void *p_handle, uint32_t options_count, - pts_LibXmountOptions *pp_options, - char **pp_error); + const pts_LibXmountOptions *pp_options, + const char **pp_error); //! Function to get content to add to the info file /*! * The returned string is added to xmount's info file. This function is only * called once when the info file is generated. The returned string is then * freed with a call to FreeBuffer. * * \param p_handle Handle to the opened image * \param pp_info_buf Pointer to store the null-terminated content * \return 0 on success or error code */ int (*GetInfofileContent)(void *p_handle, - char **pp_info_buf); + const char **pp_info_buf); //! Function to get an error message /*! * This function should translate an error code that was previously returned * by one of the library functions into a human readable error message. * * By convention, this function must always return a valid pointer to a * NULL-terminated string! * * \param err_num Error code as returned by lib */ const char* (*GetErrorMessage)(int err_num); //! Function to free buffers that were allocated by lib /*! * \param p_buf Buffer to free */ void (*FreeBuffer)(void *p_buf); } ts_LibXmountMorphingFunctions, *pts_LibXmountMorphingFunctions; /******************************************************************************* * API functions ******************************************************************************/ //! Get library API version /*! * This function should return the value of LIBXMOUNT_MORPHING_API_VERSION * * \return Supported version */ uint8_t LibXmount_Morphing_GetApiVersion(); typedef uint8_t (*t_LibXmount_Morphing_GetApiVersion)(); //! Get a list of supported morphing functions /*! * Gets a list of supported morphing functions. These is the string * specified with xmount's --morph command line option. The returned * string must be a constant vector of morphing functions split by \0 chars. To * mark the end of the vector, a single \0 must be used. * * As an example, "first\0second\0\0" would be a correct string to return for * a lib supporting two morphing functions. * * \return Vector containing supported morphing functions */ const char* LibXmount_Morphing_GetSupportedTypes(); typedef const char* (*t_LibXmount_Morphing_GetSupportedTypes)(); //! Get the lib's s_LibXmountMorphingFunctions structure /*! * This function should set the members of the given * s_LibXmountMorphingFunctions structure to the internal lib functions. All * members have to be set. * * \param p_functions s_LibXmountMorphingFunctions structure to fill */ void LibXmount_Morphing_GetFunctions(pts_LibXmountMorphingFunctions p_functions); typedef void (*t_LibXmount_Morphing_GetFunctions)(pts_LibXmountMorphingFunctions); /******************************************************************************* * Helper functions ******************************************************************************/ //! Print error and debug messages to stdout /*! * \param p_msg_type "ERROR" or "DEBUG" * \param p_calling_fun Name of calling function * \param line Line number of call * \param p_msg Message string * \param ... Variable params with values to include in message string */ static inline void LibXmount_Morphing_LogMessage(char *p_msg_type, char *p_calling_fun, int line, char *p_msg, ...) { va_list var_list; // Print message "header" printf("%s: %s.%s@%u : ",p_msg_type,p_calling_fun,XMOUNT_VERSION,line); // Print message with variable parameters va_start(var_list,p_msg); vprintf(p_msg,var_list); va_end(var_list); } #endif // LIBXMOUNT_MORPHING_H diff --git a/trunk/libxmount_morphing/libxmount_morphing_combine/libxmount_morphing_combine.c b/trunk/libxmount_morphing/libxmount_morphing_combine/libxmount_morphing_combine.c index b8ee6bf..98ee218 100644 --- a/trunk/libxmount_morphing/libxmount_morphing_combine/libxmount_morphing_combine.c +++ b/trunk/libxmount_morphing/libxmount_morphing_combine/libxmount_morphing_combine.c @@ -1,290 +1,293 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #include #include #include #include "../libxmount_morphing.h" #include "libxmount_morphing_combine.h" /******************************************************************************* * LibXmount_Morphing API implementation ******************************************************************************/ /* * LibXmount_Morphing_GetApiVersion */ uint8_t LibXmount_Morphing_GetApiVersion() { return LIBXMOUNT_MORPHING_API_VERSION; } /* * LibXmount_Morphing_GetSupportedFormats */ const char* LibXmount_Morphing_GetSupportedTypes() { return "combine\0\0"; } /* * LibXmount_Morphing_GetFunctions */ void LibXmount_Morphing_GetFunctions(ts_LibXmountMorphingFunctions *p_functions) { p_functions->CreateHandle=&CombineCreateHandle; p_functions->DestroyHandle=&CombineDestroyHandle; p_functions->Morph=&CombineMorph; p_functions->Size=&CombineSize; p_functions->Read=&CombineRead; p_functions->OptionsHelp=&CombineOptionsHelp; p_functions->OptionsParse=&CombineOptionsParse; p_functions->GetInfofileContent=&CombineGetInfofileContent; p_functions->GetErrorMessage=&CombineGetErrorMessage; p_functions->FreeBuffer=&CombineFreeBuffer; } /******************************************************************************* * Private ******************************************************************************/ /* * CombineCreateHandle */ static int CombineCreateHandle(void **pp_handle, - char *p_format, + const char *p_format, uint8_t debug) { pts_CombineHandle p_combine_handle; // Alloc new handle p_combine_handle=malloc(sizeof(ts_CombineHandle)); if(p_combine_handle==NULL) return COMBINE_MEMALLOC_FAILED; // Init handle values p_combine_handle->debug=debug; p_combine_handle->input_images_count=0; p_combine_handle->p_input_functions=NULL; p_combine_handle->morphed_image_size=0; LOG_DEBUG("Created new LibXmount_Morphing_Combine handle\n"); // Return new handle *pp_handle=p_combine_handle; return COMBINE_OK; } /* * CombineDestroyHandle */ static int CombineDestroyHandle(void **pp_handle) { pts_CombineHandle p_combine_handle=(pts_CombineHandle)*pp_handle; LOG_DEBUG("Destroying LibXmount_Morphing_Combine handle\n"); // Free handle free(p_combine_handle); *pp_handle=NULL; return COMBINE_OK; } /* * CombineMorph */ static int CombineMorph(void *p_handle, pts_LibXmountMorphingInputFunctions p_input_functions) { pts_CombineHandle p_combine_handle=(pts_CombineHandle)p_handle; int ret; uint64_t input_image_size; LOG_DEBUG("Initializing LibXmount_Morphing_Combine\n"); // Set input functions and get image count p_combine_handle->p_input_functions=p_input_functions; if(p_combine_handle-> p_input_functions-> ImageCount(&p_combine_handle->input_images_count)!=0) { return COMBINE_CANNOT_GET_IMAGECOUNT; } // Calculate morphed image size for(uint64_t i=0;iinput_images_count;i++) { ret=p_combine_handle-> p_input_functions-> Size(i,&input_image_size); if(ret!=0) return COMBINE_CANNOT_GET_IMAGESIZE; LOG_DEBUG("Adding %" PRIu64 " bytes from image %" PRIu64 "\n", input_image_size, i); p_combine_handle->morphed_image_size+=input_image_size; } LOG_DEBUG("Total morphed image size is %" PRIu64 " bytes\n", p_combine_handle->morphed_image_size); return COMBINE_OK; } /* * CombineSize */ static int CombineSize(void *p_handle, uint64_t *p_size) { *p_size=((pts_CombineHandle)(p_handle))->morphed_image_size; return COMBINE_OK; } /* * CombineRead */ static int CombineRead(void *p_handle, char *p_buf, off_t offset, size_t count, size_t *p_read) { pts_CombineHandle p_combine_handle=(pts_CombineHandle)p_handle; uint64_t cur_input_image=0; uint64_t cur_input_image_size=0; off_t cur_offset=offset; int ret; size_t cur_count; size_t read; LOG_DEBUG("Reading %zu bytes at offset %zu from morphed image\n", count, offset); // Make sure read parameters are within morphed image bounds if(offset>=p_combine_handle->morphed_image_size || offset+count>p_combine_handle->morphed_image_size) { return COMBINE_READ_BEYOND_END_OF_IMAGE; } // Search starting image to read from ret=p_combine_handle->p_input_functions->Size(cur_input_image, &cur_input_image_size); while(ret==0 && cur_offset>=cur_input_image_size) { cur_offset-=cur_input_image_size; cur_input_image++; ret=p_combine_handle->p_input_functions->Size(cur_input_image, &cur_input_image_size); } if(ret!=0) return COMBINE_CANNOT_GET_IMAGESIZE; // Init p_read *p_read=0; // Read data while(cur_input_imageinput_images_count && count!=0) { // Get current input image size ret=p_combine_handle->p_input_functions->Size(cur_input_image, &cur_input_image_size); if(ret!=0) return COMBINE_CANNOT_GET_IMAGESIZE; // Calculate how many bytes to read from current input image if(cur_offset+count>cur_input_image_size) { cur_count=cur_input_image_size-cur_offset; } else { cur_count=count; } LOG_DEBUG("Reading %zu bytes at offset %zu from input image %" PRIu64 "\n", cur_count, cur_offset, cur_input_image); // Read bytes ret=p_combine_handle->p_input_functions-> Read(cur_input_image, p_buf, cur_offset, cur_count, &read); if(ret!=0 || read!=cur_count) return COMBINE_CANNOT_READ_DATA; p_buf+=cur_count; cur_offset=0; count-=cur_count; cur_input_image++; (*p_read)+=cur_count; } if(count!=0) return COMBINE_CANNOT_READ_DATA; return COMBINE_OK; } /* * CombineOptionsHelp */ -static const char* CombineOptionsHelp() { - return NULL; +static int CombineOptionsHelp(const char **pp_help) { + *pp_help=NULL; + return COMBINE_OK; } /* * CombineOptionsParse */ static int CombineOptionsParse(void *p_handle, uint32_t options_count, - pts_LibXmountOptions *pp_options, - char **pp_error) + const pts_LibXmountOptions *pp_options, + const char **pp_error) { return COMBINE_OK; } /* * CombineGetInfofileContent */ -static int CombineGetInfofileContent(void *p_handle, char **pp_info_buf) { +static int CombineGetInfofileContent(void *p_handle, + const char **pp_info_buf) +{ *pp_info_buf=NULL; return COMBINE_OK; } /* * CombineGetErrorMessage */ static const char* CombineGetErrorMessage(int err_num) { switch(err_num) { case COMBINE_MEMALLOC_FAILED: return "Unable to allocate memory"; break; case COMBINE_CANNOT_GET_IMAGECOUNT: return "Unable to get input image count"; break; case COMBINE_CANNOT_GET_IMAGESIZE: return "Unable to get input image size"; break; case COMBINE_READ_BEYOND_END_OF_IMAGE: return "Unable to read data: Attempt to read past EOF"; break; case COMBINE_CANNOT_READ_DATA: return "Unable to read data"; break; default: return "Unknown error"; } } /* * CombineFreeBuffer */ static void CombineFreeBuffer(void *p_buf) { free(p_buf); } diff --git a/trunk/libxmount_morphing/libxmount_morphing_combine/libxmount_morphing_combine.h b/trunk/libxmount_morphing/libxmount_morphing_combine/libxmount_morphing_combine.h index a8f75a6..529d0f3 100644 --- a/trunk/libxmount_morphing/libxmount_morphing_combine/libxmount_morphing_combine.h +++ b/trunk/libxmount_morphing/libxmount_morphing_combine/libxmount_morphing_combine.h @@ -1,87 +1,87 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #ifndef LIBXMOUNT_MORPHING_COMBINE_H #define LIBXMOUNT_MORPHING_COMBINE_H #define LOG_ERROR(...) { \ LibXmount_Morphing_LogMessage("ERROR", \ (char*)__FUNCTION__, \ __LINE__, \ __VA_ARGS__); \ } #define LOG_WARNING(...) { \ LibXmount_Morphing_LogMessage("WARNING", \ (char*)__FUNCTION__, \ __LINE__, \ __VA_ARGS__); \ } #define LOG_DEBUG(...) { \ if(p_combine_handle->debug==1) \ LibXmount_Morphing_LogMessage("DEBUG", \ (char*)__FUNCTION__, \ __LINE__, \ __VA_ARGS__); \ } /******************************************************************************* * Enums, type defs, etc... ******************************************************************************/ enum { COMBINE_OK=0, COMBINE_MEMALLOC_FAILED, COMBINE_CANNOT_GET_IMAGECOUNT, COMBINE_CANNOT_GET_IMAGESIZE, COMBINE_READ_BEYOND_END_OF_IMAGE, COMBINE_CANNOT_READ_DATA }; typedef struct s_CombineHandle { uint8_t debug; uint64_t input_images_count; pts_LibXmountMorphingInputFunctions p_input_functions; uint64_t morphed_image_size; } ts_CombineHandle, *pts_CombineHandle; /******************************************************************************* * Forward declarations ******************************************************************************/ static int CombineCreateHandle(void **pp_handle, - char *p_format, + const char *p_format, uint8_t debug); static int CombineDestroyHandle(void **pp_handle); static int CombineMorph(void *p_handle, pts_LibXmountMorphingInputFunctions p_input_functions); static int CombineSize(void *p_handle, uint64_t *p_size); static int CombineRead(void *p_handle, char *p_buf, off_t offset, size_t count, size_t *p_read); -static const char* CombineOptionsHelp(); +static int CombineOptionsHelp(const char **pp_help); static int CombineOptionsParse(void *p_handle, uint32_t options_count, - pts_LibXmountOptions *pp_options, - char **pp_error); + const pts_LibXmountOptions *pp_options, + const char **pp_error); static int CombineGetInfofileContent(void *p_handle, - char **pp_info_buf); + const char **pp_info_buf); static const char* CombineGetErrorMessage(int err_num); static void CombineFreeBuffer(void *p_buf); #endif // LIBXMOUNT_MORPHING_COMBINE_H diff --git a/trunk/libxmount_morphing/libxmount_morphing_freespace/CMakeLists.txt b/trunk/libxmount_morphing/libxmount_morphing_freespace/CMakeLists.txt deleted file mode 100644 index 3cb055b..0000000 --- a/trunk/libxmount_morphing/libxmount_morphing_freespace/CMakeLists.txt +++ /dev/null @@ -1,10 +0,0 @@ -if(POLICY CMP0042) - cmake_policy(SET CMP0042 NEW) # CMake 3.0 -endif(POLICY CMP0042) - -project(libxmount_morphing_freespace C) - -add_library(xmount_morphing_freespace SHARED libxmount_morphing_freespace.c ../../libxmount/libxmount.c) - -install(TARGETS xmount_morphing_freespace DESTINATION lib/xmount) - diff --git a/trunk/libxmount_morphing/libxmount_morphing_raid/libxmount_morphing_raid.c b/trunk/libxmount_morphing/libxmount_morphing_raid/libxmount_morphing_raid.c index 1987744..a1d3bd5 100644 --- a/trunk/libxmount_morphing/libxmount_morphing_raid/libxmount_morphing_raid.c +++ b/trunk/libxmount_morphing/libxmount_morphing_raid/libxmount_morphing_raid.c @@ -1,350 +1,370 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #include #include #include #include "../libxmount_morphing.h" #include "libxmount_morphing_raid.h" /******************************************************************************* * LibXmount_Morphing API implementation ******************************************************************************/ /* * LibXmount_Morphing_GetApiVersion */ uint8_t LibXmount_Morphing_GetApiVersion() { return LIBXMOUNT_MORPHING_API_VERSION; } /* * LibXmount_Morphing_GetSupportedFormats */ const char* LibXmount_Morphing_GetSupportedTypes() { return "raid0\0\0"; } /* * LibXmount_Morphing_GetFunctions */ void LibXmount_Morphing_GetFunctions(ts_LibXmountMorphingFunctions *p_functions) { p_functions->CreateHandle=&RaidCreateHandle; p_functions->DestroyHandle=&RaidDestroyHandle; p_functions->Morph=&RaidMorph; p_functions->Size=&RaidSize; p_functions->Read=&RaidRead; p_functions->OptionsHelp=&RaidOptionsHelp; p_functions->OptionsParse=&RaidOptionsParse; p_functions->GetInfofileContent=&RaidGetInfofileContent; p_functions->GetErrorMessage=&RaidGetErrorMessage; p_functions->FreeBuffer=&RaidFreeBuffer; } /******************************************************************************* * Private ******************************************************************************/ /* * RaidCreateHandle */ -static int RaidCreateHandle(void **pp_handle, char *p_format, uint8_t debug) { +static int RaidCreateHandle(void **pp_handle, + const char *p_format, + uint8_t debug) +{ pts_RaidHandle p_raid_handle; // Alloc new handle p_raid_handle=malloc(sizeof(ts_RaidHandle)); if(p_raid_handle==NULL) return RAID_MEMALLOC_FAILED; // Init handle values p_raid_handle->debug=debug; p_raid_handle->input_images_count=0; p_raid_handle->chunk_size=RAID_DEFAULT_CHUNKSIZE; p_raid_handle->chunks_per_image=0; p_raid_handle->p_input_functions=NULL; p_raid_handle->morphed_image_size=0; LOG_DEBUG("Created new LibXmount_Morphing_Raid handle\n"); // Return new handle *pp_handle=p_raid_handle; return RAID_OK; } /* * RaidDestroyHandle */ static int RaidDestroyHandle(void **pp_handle) { pts_RaidHandle p_raid_handle=(pts_RaidHandle)*pp_handle; LOG_DEBUG("Destroying LibXmount_Morphing_Raid handle\n"); // Free handle free(p_raid_handle); *pp_handle=NULL; return RAID_OK; } /* * RaidMorph */ static int RaidMorph(void *p_handle, pts_LibXmountMorphingInputFunctions p_input_functions) { pts_RaidHandle p_raid_handle=(pts_RaidHandle)p_handle; int ret; uint64_t input_image_size; uint64_t chunks_per_image; LOG_DEBUG("Initializing LibXmount_Morphing_Raid\n"); // Set input functions and get image count p_raid_handle->p_input_functions=p_input_functions; if(p_raid_handle-> p_input_functions-> ImageCount(&p_raid_handle->input_images_count)!=0) { return RAID_CANNOT_GET_IMAGECOUNT; } // Calculate chunks per image for(uint64_t i=0;iinput_images_count;i++) { ret=p_raid_handle-> p_input_functions-> Size(i,&input_image_size); if(ret!=0) return RAID_CANNOT_GET_IMAGESIZE; chunks_per_image=input_image_size/p_raid_handle->chunk_size; LOG_DEBUG("Image %" PRIu64 " can hold a maximum of %" PRIu64 " chunks of %" PRIu32 " bytes\n", i, chunks_per_image, p_raid_handle->chunk_size); // The smallest image determines how many chunks are availbale on all images if(p_raid_handle->chunks_per_image==0) { p_raid_handle->chunks_per_image=chunks_per_image; } else if(chunks_per_imagechunks_per_image) { p_raid_handle->chunks_per_image=chunks_per_image; } } LOG_DEBUG("Smallest image holds %" PRIu64 " chunks of %" PRIu32 " bytes\n", p_raid_handle->chunks_per_image, p_raid_handle->chunk_size); // Calculate total raid capacity based on smallest disk p_raid_handle->morphed_image_size= p_raid_handle->chunks_per_image* p_raid_handle->chunk_size*p_raid_handle->input_images_count; LOG_DEBUG("Total raid capacity is %" PRIu64 " bytes\n", p_raid_handle->morphed_image_size); return RAID_OK; } /* * RaidSize */ static int RaidSize(void *p_handle, uint64_t *p_size) { *p_size=((pts_RaidHandle)(p_handle))->morphed_image_size; return RAID_OK; } /* * RaidRead */ static int RaidRead(void *p_handle, char *p_buf, off_t offset, size_t count, size_t *p_read) { pts_RaidHandle p_raid_handle=(pts_RaidHandle)p_handle; uint64_t cur_chunk; uint64_t cur_image; off_t cur_chunk_offset; off_t cur_image_offset; size_t cur_count; int ret; size_t read; LOG_DEBUG("Reading %zu bytes at offset %zu from morphed image\n", count, offset); // Make sure read parameters are within morphed image bounds if(offset>=p_raid_handle->morphed_image_size || offset+count>p_raid_handle->morphed_image_size) { return RAID_READ_BEYOND_END_OF_IMAGE; } // Calculate starting chunk, and chunk offset cur_chunk=offset/p_raid_handle->chunk_size; cur_chunk_offset=offset-(cur_chunk*p_raid_handle->chunk_size); // Init p_read *p_read=0; while(count!=0) { // Calculate image and image offset to read from cur_image=cur_chunk%p_raid_handle->input_images_count; cur_image_offset= (cur_chunk/p_raid_handle->input_images_count)*p_raid_handle->chunk_size; // Calculate how many bytes to read from current chunk if(cur_chunk_offset+count>p_raid_handle->chunk_size) { cur_count=p_raid_handle->chunk_size-cur_chunk_offset; } else { cur_count=count; } LOG_DEBUG("Reading %zu bytes at offset %zu from image %" PRIu64 " (chunk %" PRIu64 ")\n", cur_count, cur_image_offset+cur_chunk_offset, cur_image, cur_chunk); // Read bytes ret=p_raid_handle->p_input_functions-> Read(cur_image, p_buf, cur_image_offset+cur_chunk_offset, cur_count, &read); if(ret!=0 || read!=cur_count) return RAID_CANNOT_READ_DATA; p_buf+=cur_count; cur_chunk_offset=0; count-=cur_count; cur_chunk++; (*p_read)+=cur_count; } return RAID_OK; } /* * RaidOptionsHelp */ -static const char* RaidOptionsHelp() { - return " raid_chunksize : Specify the chunk size to use in bytes. " - "Defaults to 524288 (512k)."; +static int RaidOptionsHelp(const char **pp_help) { + int ok; + char *p_buf; + + ok=asprintf(&p_buf, + " raid_chunksize : Specify the chunk size to use in bytes. " + "Defaults to 524288 (512k)."); + if(ok<0 || p_buf==NULL) { + *pp_help=NULL; + return RAID_MEMALLOC_FAILED; + } + + *pp_help=p_buf; + return RAID_OK; } /* * RaidOptionsParse */ static int RaidOptionsParse(void *p_handle, uint32_t options_count, - pts_LibXmountOptions *pp_options, - char **pp_error) + const pts_LibXmountOptions *pp_options, + const char **pp_error) { pts_RaidHandle p_raid_handle=(pts_RaidHandle)p_handle; int ok; uint32_t uint32value; + char *p_buf; for(uint32_t i=0;ip_key,"raid_chunksize")) { // Convert value to uint32 uint32value=StrToUint32(pp_options[i]->p_value,&ok); if(ok==0 || uint32value==0) { // Conversion failed, generate error message and return - ok=asprintf(pp_error, + ok=asprintf(&p_buf, "Unable to parse value '%s' of '%s' as valid 32bit number", pp_options[i]->p_value, pp_options[i]->p_key); if(ok<0 || *pp_error==NULL) { *pp_error=NULL; return RAID_MEMALLOC_FAILED; } + *pp_error=p_buf; return RAID_CANNOT_PARSE_OPTION; } LOG_DEBUG("Setting chunk size to %" PRIu32 " bytes\n",uint32value); // Conversion ok, save value and mark option as valid p_raid_handle->chunk_size=uint32value; pp_options[i]->valid=1; continue; } } return RAID_OK; } /* * RaidGetInfofileContent */ -static int RaidGetInfofileContent(void *p_handle, char **pp_info_buf) { +static int RaidGetInfofileContent(void *p_handle, + const char **pp_info_buf) +{ pts_RaidHandle p_raid_handle=(pts_RaidHandle)p_handle; int ret; + char *p_buf; - ret=asprintf(pp_info_buf, + ret=asprintf(&p_buf, "Simulating RAID level 0 over %" PRIu64 " disks.\n" "Chunk size: %" PRIu32 " bytes\n" "Chunks per disk: %" PRIu64 "\n" "Total capacity: %" PRIu64 " bytes (%0.3f GiB)\n", p_raid_handle->input_images_count, p_raid_handle->chunk_size, p_raid_handle->chunks_per_image, p_raid_handle->morphed_image_size, p_raid_handle->morphed_image_size/(1024.0*1024.0*1024.0)); if(ret<0 || *pp_info_buf==NULL) return RAID_MEMALLOC_FAILED; + *pp_info_buf=p_buf; return RAID_OK; } /* * RaidGetErrorMessage */ static const char* RaidGetErrorMessage(int err_num) { switch(err_num) { case RAID_MEMALLOC_FAILED: return "Unable to allocate memory"; break; case RAID_CANNOT_GET_IMAGECOUNT: return "Unable to get input image count"; break; case RAID_CANNOT_GET_IMAGESIZE: return "Unable to get input image size"; break; case RAID_READ_BEYOND_END_OF_IMAGE: return "Unable to read data: Attempt to read past EOF"; break; case RAID_CANNOT_READ_DATA: return "Unable to read data"; break; case RAID_CANNOT_PARSE_OPTION: return "Unable to parse library option"; break; default: return "Unknown error"; } } /* * RaidFreeBuffer */ static void RaidFreeBuffer(void *p_buf) { free(p_buf); } diff --git a/trunk/libxmount_morphing/libxmount_morphing_raid/libxmount_morphing_raid.h b/trunk/libxmount_morphing/libxmount_morphing_raid/libxmount_morphing_raid.h index 1fbbab6..cbbf766 100644 --- a/trunk/libxmount_morphing/libxmount_morphing_raid/libxmount_morphing_raid.h +++ b/trunk/libxmount_morphing/libxmount_morphing_raid/libxmount_morphing_raid.h @@ -1,91 +1,91 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #ifndef LIBXMOUNT_MORPHING_RAID_H #define LIBXMOUNT_MORPHING_RAID_H #define LOG_ERROR(...) { \ LibXmount_Morphing_LogMessage("ERROR", \ (char*)__FUNCTION__, \ __LINE__, \ __VA_ARGS__); \ } #define LOG_WARNING(...) { \ LibXmount_Morphing_LogMessage("WARNING", \ (char*)__FUNCTION__, \ __LINE__, \ __VA_ARGS__); \ } #define LOG_DEBUG(...) { \ if(p_raid_handle->debug==1) \ LibXmount_Morphing_LogMessage("DEBUG", \ (char*)__FUNCTION__, \ __LINE__, \ __VA_ARGS__); \ } /******************************************************************************* * Enums, type defs, etc... ******************************************************************************/ enum { RAID_OK=0, RAID_MEMALLOC_FAILED, RAID_CANNOT_GET_IMAGECOUNT, RAID_CANNOT_GET_IMAGESIZE, RAID_READ_BEYOND_END_OF_IMAGE, RAID_CANNOT_READ_DATA, RAID_CANNOT_PARSE_OPTION }; #define RAID_DEFAULT_CHUNKSIZE 512*1024 typedef struct s_RaidHandle { uint8_t debug; uint64_t input_images_count; uint32_t chunk_size; uint64_t chunks_per_image; pts_LibXmountMorphingInputFunctions p_input_functions; uint64_t morphed_image_size; } ts_RaidHandle, *pts_RaidHandle; /******************************************************************************* * Forward declarations ******************************************************************************/ static int RaidCreateHandle(void **pp_handle, - char *p_format, + const char *p_format, uint8_t debug); static int RaidDestroyHandle(void **pp_handle); static int RaidMorph(void *p_handle, pts_LibXmountMorphingInputFunctions p_input_functions); static int RaidSize(void *p_handle, uint64_t *p_size); static int RaidRead(void *p_handle, char *p_buf, off_t offset, size_t count, size_t *p_read); -static const char* RaidOptionsHelp(); +static int RaidOptionsHelp(const char **pp_help); static int RaidOptionsParse(void *p_handle, uint32_t options_count, - pts_LibXmountOptions *pp_options, - char **pp_error); + const pts_LibXmountOptions *pp_options, + const char **pp_error); static int RaidGetInfofileContent(void *p_handle, - char **pp_info_buf); + const char **pp_info_buf); static const char* RaidGetErrorMessage(int err_num); static void RaidFreeBuffer(void *p_buf); #endif // LIBXMOUNT_MORPHING_RAID_H diff --git a/trunk/libxmount_morphing/libxmount_morphing_unallocated/CMakeLists.txt b/trunk/libxmount_morphing/libxmount_morphing_unallocated/CMakeLists.txt new file mode 100644 index 0000000..fadff86 --- /dev/null +++ b/trunk/libxmount_morphing/libxmount_morphing_unallocated/CMakeLists.txt @@ -0,0 +1,10 @@ +if(POLICY CMP0042) + cmake_policy(SET CMP0042 NEW) # CMake 3.0 +endif(POLICY CMP0042) + +project(libxmount_morphing_unallocated C) + +add_library(xmount_morphing_unallocated SHARED libxmount_morphing_unallocated.c ../../libxmount/libxmount.c) + +install(TARGETS xmount_morphing_unallocated DESTINATION lib/xmount) + diff --git a/trunk/libxmount_morphing/libxmount_morphing_freespace/libxmount_morphing_freespace.c b/trunk/libxmount_morphing/libxmount_morphing_unallocated/libxmount_morphing_unallocated.c similarity index 56% rename from trunk/libxmount_morphing/libxmount_morphing_freespace/libxmount_morphing_freespace.c rename to trunk/libxmount_morphing/libxmount_morphing_unallocated/libxmount_morphing_unallocated.c index 5593843..87c27f8 100644 --- a/trunk/libxmount_morphing/libxmount_morphing_freespace/libxmount_morphing_freespace.c +++ b/trunk/libxmount_morphing/libxmount_morphing_unallocated/libxmount_morphing_unallocated.c @@ -1,605 +1,629 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #include #include #include #include "../libxmount_morphing.h" -#include "libxmount_morphing_freespace.h" +#include "libxmount_morphing_unallocated.h" /******************************************************************************* * LibXmount_Morphing API implementation ******************************************************************************/ /* * LibXmount_Morphing_GetApiVersion */ uint8_t LibXmount_Morphing_GetApiVersion() { return LIBXMOUNT_MORPHING_API_VERSION; } /* * LibXmount_Morphing_GetSupportedFormats */ const char* LibXmount_Morphing_GetSupportedTypes() { - return "freespace\0\0"; + return "unallocated\0\0"; } /* * LibXmount_Morphing_GetFunctions */ void LibXmount_Morphing_GetFunctions(ts_LibXmountMorphingFunctions *p_functions) { - p_functions->CreateHandle=&FreespaceCreateHandle; - p_functions->DestroyHandle=&FreespaceDestroyHandle; - p_functions->Morph=&FreespaceMorph; - p_functions->Size=&FreespaceSize; - p_functions->Read=&FreespaceRead; - p_functions->OptionsHelp=&FreespaceOptionsHelp; - p_functions->OptionsParse=&FreespaceOptionsParse; - p_functions->GetInfofileContent=&FreespaceGetInfofileContent; - p_functions->GetErrorMessage=&FreespaceGetErrorMessage; - p_functions->FreeBuffer=&FreespaceFreeBuffer; + p_functions->CreateHandle=&UnallocatedCreateHandle; + p_functions->DestroyHandle=&UnallocatedDestroyHandle; + p_functions->Morph=&UnallocatedMorph; + p_functions->Size=&UnallocatedSize; + p_functions->Read=&UnallocatedRead; + p_functions->OptionsHelp=&UnallocatedOptionsHelp; + p_functions->OptionsParse=&UnallocatedOptionsParse; + p_functions->GetInfofileContent=&UnallocatedGetInfofileContent; + p_functions->GetErrorMessage=&UnallocatedGetErrorMessage; + p_functions->FreeBuffer=&UnallocatedFreeBuffer; } /******************************************************************************* * Private ******************************************************************************/ /* - * FreespaceCreateHandle + * UnallocatedCreateHandle */ -static int FreespaceCreateHandle(void **pp_handle, - char *p_format, - uint8_t debug) +static int UnallocatedCreateHandle(void **pp_handle, + const char *p_format, + uint8_t debug) { - pts_FreespaceHandle p_freespace_handle; + pts_UnallocatedHandle p_unallocated_handle; // Alloc new handle - p_freespace_handle=malloc(sizeof(ts_FreespaceHandle)); - if(p_freespace_handle==NULL) return FREESPACE_MEMALLOC_FAILED; + p_unallocated_handle=malloc(sizeof(ts_UnallocatedHandle)); + if(p_unallocated_handle==NULL) return UNALLOCATED_MEMALLOC_FAILED; // Init handle values - p_freespace_handle->debug=debug; - //p_freespace_handle->fs_type=FreespaceFsType_Unknown; + p_unallocated_handle->debug=debug; + p_unallocated_handle->fs_type=UnallocatedFsType_Unknown; // DEBUG - p_freespace_handle->fs_type=FreespaceFsType_HfsPlus; - p_freespace_handle->p_input_functions=NULL; - p_freespace_handle->morphed_image_size=0; - p_freespace_handle->hfsplus.p_vh=NULL; - p_freespace_handle->hfsplus.p_alloc_file=NULL; - p_freespace_handle->hfsplus.free_block_map_size=0; - p_freespace_handle->hfsplus.p_free_block_map=NULL; + //p_unallocated_handle->fs_type=UnallocatedFsType_HfsPlus; + p_unallocated_handle->p_input_functions=NULL; + p_unallocated_handle->morphed_image_size=0; + p_unallocated_handle->hfsplus.p_vh=NULL; + p_unallocated_handle->hfsplus.p_alloc_file=NULL; + p_unallocated_handle->hfsplus.free_block_map_size=0; + p_unallocated_handle->hfsplus.p_free_block_map=NULL; - LOG_DEBUG("Created new LibXmount_Morphing_Freespace handle\n"); + LOG_DEBUG("Created new LibXmount_Morphing_Unallocated handle\n"); // Return new handle - *pp_handle=p_freespace_handle; - return FREESPACE_OK; + *pp_handle=p_unallocated_handle; + return UNALLOCATED_OK; } /* - * FreespaceDestroyHandle + * UnallocatedDestroyHandle */ -static int FreespaceDestroyHandle(void **pp_handle) { - pts_FreespaceHandle p_freespace_handle=(pts_FreespaceHandle)*pp_handle; +static int UnallocatedDestroyHandle(void **pp_handle) { + pts_UnallocatedHandle p_unallocated_handle=(pts_UnallocatedHandle)*pp_handle; - LOG_DEBUG("Destroying LibXmount_Morphing_Freespace handle\n"); + LOG_DEBUG("Destroying LibXmount_Morphing_Unallocated handle\n"); // Free fs data - switch(p_freespace_handle->fs_type) { - case FreespaceFsType_HfsPlus: { - if(p_freespace_handle->hfsplus.p_vh!=NULL) - free(p_freespace_handle->hfsplus.p_vh); - if(p_freespace_handle->hfsplus.p_alloc_file!=NULL) - free(p_freespace_handle->hfsplus.p_alloc_file); - if(p_freespace_handle->hfsplus.p_free_block_map!=NULL) - free(p_freespace_handle->hfsplus.p_free_block_map); + switch(p_unallocated_handle->fs_type) { + case UnallocatedFsType_HfsPlus: { + if(p_unallocated_handle->hfsplus.p_vh!=NULL) + free(p_unallocated_handle->hfsplus.p_vh); + if(p_unallocated_handle->hfsplus.p_alloc_file!=NULL) + free(p_unallocated_handle->hfsplus.p_alloc_file); + if(p_unallocated_handle->hfsplus.p_free_block_map!=NULL) + free(p_unallocated_handle->hfsplus.p_free_block_map); break; } - case FreespaceFsType_Unknown: + case UnallocatedFsType_Unknown: default: break; } // Free handle - free(p_freespace_handle); + free(p_unallocated_handle); *pp_handle=NULL; - return FREESPACE_OK; + return UNALLOCATED_OK; } /* - * FreespaceMorph + * UnallocatedMorph */ -static int FreespaceMorph(void *p_handle, - pts_LibXmountMorphingInputFunctions p_input_functions) +static int UnallocatedMorph( + void *p_handle, + pts_LibXmountMorphingInputFunctions p_input_functions) { - pts_FreespaceHandle p_freespace_handle=(pts_FreespaceHandle)p_handle; + pts_UnallocatedHandle p_unallocated_handle=(pts_UnallocatedHandle)p_handle; uint64_t input_images_count; int ret; - LOG_DEBUG("Initializing LibXmount_Morphing_Raid\n"); + LOG_DEBUG("Initializing LibXmount_Morphing_Unallocated\n"); - // Make sure freespace_fs was given - if(p_freespace_handle->fs_type==FreespaceFsType_Unknown) { - return FREESPACE_NO_FS_SPECIFIED; + // Make sure unallocated_fs was given + if(p_unallocated_handle->fs_type==UnallocatedFsType_Unknown) { + return UNALLOCATED_NO_FS_SPECIFIED; } // Set input functions and get image count - p_freespace_handle->p_input_functions=p_input_functions; - if(p_freespace_handle-> + p_unallocated_handle->p_input_functions=p_input_functions; + if(p_unallocated_handle-> p_input_functions-> ImageCount(&input_images_count)!=0) { - return FREESPACE_CANNOT_GET_IMAGECOUNT; + return UNALLOCATED_CANNOT_GET_IMAGECOUNT; } // Make sure there is exactly one input image if(input_images_count==0 || input_images_count>1) { - return FREESPACE_WRONG_INPUT_IMAGE_COUNT; + return UNALLOCATED_WRONG_INPUT_IMAGE_COUNT; } // Extract unallocated blocks from input image - switch(p_freespace_handle->fs_type) { - case FreespaceFsType_HfsPlus: { + switch(p_unallocated_handle->fs_type) { + case UnallocatedFsType_HfsPlus: { // Read HFS+ VH - ret=FreespaceReadHfsPlusHeader(p_freespace_handle); - if(ret!=FREESPACE_OK) return ret; + ret=UnallocatedReadHfsPlusHeader(p_unallocated_handle); + if(ret!=UNALLOCATED_OK) return ret; // Read HFS+ alloc file - ret=FreespaceReadHfsPlusAllocFile(p_freespace_handle); - if(ret!=FREESPACE_OK) return ret; + ret=UnallocatedReadHfsPlusAllocFile(p_unallocated_handle); + if(ret!=UNALLOCATED_OK) return ret; // Build free block map - ret=FreespaceBuildHfsPlusBlockMap(p_freespace_handle); - if(ret!=FREESPACE_OK) return ret; + ret=UnallocatedBuildHfsPlusBlockMap(p_unallocated_handle); + if(ret!=UNALLOCATED_OK) return ret; // Calculate morphed image size - p_freespace_handle->morphed_image_size= - p_freespace_handle->hfsplus.p_vh->block_size* - p_freespace_handle->hfsplus.free_block_map_size; + p_unallocated_handle->morphed_image_size= + p_unallocated_handle->hfsplus.p_vh->block_size* + p_unallocated_handle->hfsplus.free_block_map_size; break; } - case FreespaceFsType_Unknown: + case UnallocatedFsType_Unknown: default: - return FREESPACE_UNSUPPORTED_FS_SPECIFIED; + return UNALLOCATED_UNSUPPORTED_FS_SPECIFIED; } LOG_DEBUG("Total size of unallocated blocks is %" PRIu64 " bytes\n", - p_freespace_handle->morphed_image_size); + p_unallocated_handle->morphed_image_size); - return FREESPACE_OK; + return UNALLOCATED_OK; } /* - * FreespaceSize + * UnallocatedSize */ -static int FreespaceSize(void *p_handle, uint64_t *p_size) { - *p_size=((pts_FreespaceHandle)(p_handle))->morphed_image_size; - return FREESPACE_OK; +static int UnallocatedSize(void *p_handle, uint64_t *p_size) { + *p_size=((pts_UnallocatedHandle)(p_handle))->morphed_image_size; + return UNALLOCATED_OK; } /* - * FreespaceRead + * UnallocatedRead */ -static int FreespaceRead(void *p_handle, - char *p_buf, - off_t offset, - size_t count, - size_t *p_read) +static int UnallocatedRead(void *p_handle, + char *p_buf, + off_t offset, + size_t count, + size_t *p_read) { - pts_FreespaceHandle p_freespace_handle=(pts_FreespaceHandle)p_handle; + pts_UnallocatedHandle p_unallocated_handle=(pts_UnallocatedHandle)p_handle; int ret; LOG_DEBUG("Reading %zu bytes at offset %zu from morphed image\n", count, offset); // Make sure read parameters are within morphed image bounds - if(offset>=p_freespace_handle->morphed_image_size || - offset+count>p_freespace_handle->morphed_image_size) + if(offset>=p_unallocated_handle->morphed_image_size || + offset+count>p_unallocated_handle->morphed_image_size) { - return FREESPACE_READ_BEYOND_END_OF_IMAGE; + return UNALLOCATED_READ_BEYOND_END_OF_IMAGE; } // Read data - switch(p_freespace_handle->fs_type) { - case FreespaceFsType_HfsPlus: { - ret=FreespaceReadHfsPlusBlock(p_freespace_handle, + switch(p_unallocated_handle->fs_type) { + case UnallocatedFsType_HfsPlus: { + ret=UnallocatedReadHfsPlusBlock(p_unallocated_handle, p_buf, offset, count, p_read); - if(ret!=FREESPACE_OK) return ret; + if(ret!=UNALLOCATED_OK) return ret; break; } - case FreespaceFsType_Unknown: + case UnallocatedFsType_Unknown: default: - return FREESPACE_UNSUPPORTED_FS_SPECIFIED; + return UNALLOCATED_UNSUPPORTED_FS_SPECIFIED; } - return FREESPACE_OK; + return UNALLOCATED_OK; } /* - * FreespaceOptionsHelp + * UnallocatedOptionsHelp */ -static const char* FreespaceOptionsHelp() { - return " freespace_fs : Specify the filesystem to extract unallocated " - "blocks from. Supported filesystems are: 'hfs+'"; +static int UnallocatedOptionsHelp(const char **pp_help) { + int ok; + char *p_buf; + + ok=asprintf(&p_buf, + " unallocated_fs : Specify the filesystem to extract " + "unallocated blocks from. Supported filesystems are: 'hfs+'"); + if(ok<0 || p_buf==NULL) { + *pp_help=NULL; + return UNALLOCATED_MEMALLOC_FAILED; + } + + *pp_help=p_buf; + return UNALLOCATED_OK; } /* - * FreespaceOptionsParse + * UnallocatedOptionsParse */ -static int FreespaceOptionsParse(void *p_handle, - uint32_t options_count, - pts_LibXmountOptions *pp_options, - char **pp_error) +static int UnallocatedOptionsParse(void *p_handle, + uint32_t options_count, + const pts_LibXmountOptions *pp_options, + const char **pp_error) { - pts_FreespaceHandle p_freespace_handle=(pts_FreespaceHandle)p_handle; + pts_UnallocatedHandle p_unallocated_handle=(pts_UnallocatedHandle)p_handle; int ok; + char *p_buf; for(uint32_t i=0;ip_key,"freespace_fs")==0) { + if(strcmp(pp_options[i]->p_key,"unallocated_fs")==0) { if(strcmp(pp_options[i]->p_value,"hfs+")==0) { - p_freespace_handle->fs_type=FreespaceFsType_HfsPlus; + p_unallocated_handle->fs_type=UnallocatedFsType_HfsPlus; } else { - ok=asprintf(pp_error, + ok=asprintf(&p_buf, "Unsupported filesystem '%s' specified", pp_options[i]->p_value); - if(ok<0 || *pp_error==NULL) { + if(ok<0 || p_buf==NULL) { *pp_error=NULL; - return FREESPACE_MEMALLOC_FAILED; + return UNALLOCATED_MEMALLOC_FAILED; } - return FREESPACE_UNSUPPORTED_FS_SPECIFIED; + *pp_error=p_buf; + return UNALLOCATED_UNSUPPORTED_FS_SPECIFIED; } LOG_DEBUG("Setting fs to %s\n",pp_options[i]->p_value); pp_options[i]->valid=1; } } - return FREESPACE_OK; + return UNALLOCATED_OK; } /* - * FreespaceGetInfofileContent + * UnallocatedGetInfofileContent */ -static int FreespaceGetInfofileContent(void *p_handle, char **pp_info_buf) { - pts_FreespaceHandle p_freespace_handle=(pts_FreespaceHandle)p_handle; - pts_FreespaceHfsPlusData p_hfs_data=&(p_freespace_handle->hfsplus); +static int UnallocatedGetInfofileContent(void *p_handle, + const char **pp_info_buf) +{ + pts_UnallocatedHandle p_unallocated_handle=(pts_UnallocatedHandle)p_handle; + pts_UnallocatedHfsPlusData p_hfs_data=&(p_unallocated_handle->hfsplus); int ret; + char *p_buf; - ret=asprintf(pp_info_buf, + ret=asprintf(&p_buf, "HFS+ VH signature: 0x%04X\n" "HFS+ VH version: %" PRIu16 "\n" "HFS+ block size: %" PRIu32 " bytes\n" "HFS+ total blocks: %" PRIu32 "\n" "HFS+ free blocks: %" PRIu32 "\n" "HFS+ allocation file size: %" PRIu64 " bytes\n" "HFS+ allocation file blocks: %" PRIu32 "\n" "Discovered free blocks: %" PRIu64 "\n" "Total unallocated size: %" PRIu64 " bytes (%0.3f GiB)\n", p_hfs_data->p_vh->signature, p_hfs_data->p_vh->version, p_hfs_data->p_vh->block_size, p_hfs_data->p_vh->total_blocks, p_hfs_data->p_vh->free_blocks, p_hfs_data->p_vh->alloc_file_size, p_hfs_data->p_vh->alloc_file_total_blocks, - (uint64_t)(p_hfs_data->free_block_map_size* - p_hfs_data->p_vh->block_size), + p_hfs_data->free_block_map_size, + p_hfs_data->free_block_map_size*p_hfs_data->p_vh->block_size, (p_hfs_data->free_block_map_size*p_hfs_data->p_vh->block_size)/ (1024.0*1024.0*1024.0)); - if(ret<0 || *pp_info_buf==NULL) return FREESPACE_MEMALLOC_FAILED; + if(ret<0 || *pp_info_buf==NULL) return UNALLOCATED_MEMALLOC_FAILED; - return FREESPACE_OK; + *pp_info_buf=p_buf; + return UNALLOCATED_OK; } /* - * FreespaceGetErrorMessage + * UnallocatedGetErrorMessage */ -static const char* FreespaceGetErrorMessage(int err_num) { +static const char* UnallocatedGetErrorMessage(int err_num) { switch(err_num) { - case FREESPACE_MEMALLOC_FAILED: + case UNALLOCATED_MEMALLOC_FAILED: return "Unable to allocate memory"; break; - case FREESPACE_NO_FS_SPECIFIED: - return "No filesystem specified using option freespace_fs"; + case UNALLOCATED_NO_FS_SPECIFIED: + return "No filesystem specified using option unallocated_fs"; break; - case FREESPACE_UNSUPPORTED_FS_SPECIFIED: + case UNALLOCATED_UNSUPPORTED_FS_SPECIFIED: return "Unsupported fs specified"; - case FREESPACE_CANNOT_GET_IMAGECOUNT: + case UNALLOCATED_CANNOT_GET_IMAGECOUNT: return "Unable to get input image count"; break; - case FREESPACE_WRONG_INPUT_IMAGE_COUNT: + case UNALLOCATED_WRONG_INPUT_IMAGE_COUNT: return "Only 1 input image is supported"; break; - case FREESPACE_CANNOT_GET_IMAGESIZE: + case UNALLOCATED_CANNOT_GET_IMAGESIZE: return "Unable to get input image size"; break; - case FREESPACE_READ_BEYOND_END_OF_IMAGE: + case UNALLOCATED_READ_BEYOND_END_OF_IMAGE: return "Unable to read data: Attempt to read past EOF"; break; - case FREESPACE_CANNOT_READ_DATA: + case UNALLOCATED_CANNOT_READ_DATA: return "Unable to read data"; break; - case FREESPACE_CANNOT_PARSE_OPTION: + case UNALLOCATED_CANNOT_PARSE_OPTION: return "Unable to parse library option"; break; - case FREESPACE_CANNOT_READ_HFSPLUS_HEADER: + case UNALLOCATED_CANNOT_READ_HFSPLUS_HEADER: return "Unable to read HFS+ volume header"; break; - case FREESPACE_INVALID_HFSPLUS_HEADER: + case UNALLOCATED_INVALID_HFSPLUS_HEADER: return "Found invalid HFS+ volume header"; break; - case FREESPACE_CANNOT_READ_HFSPLUS_ALLOC_FILE: + case UNALLOCATED_CANNOT_READ_HFSPLUS_ALLOC_FILE: return "Unable to read HFS+ allocation file"; break; - case FREESPACE_ALLOC_FILE_HAS_TOO_MUCH_EXTENDS: - return "HFS+ allocation file has more then 8 extends. This is unsupported"; + case UNALLOCATED_ALLOC_FILE_HAS_TOO_MUCH_EXTENDS: + return "HFS+ allocation file has more then 8 extends. " + "This is unsupported"; break; default: return "Unknown error"; } } /* - * FreespaceFreeBuffer + * UnallocatedFreeBuffer */ -static void FreespaceFreeBuffer(void *p_buf) { +static void UnallocatedFreeBuffer(void *p_buf) { free(p_buf); } /******************************************************************************* * Private helper functions ******************************************************************************/ /* - * FreespaceReadHfsPlusHeader + * UnallocatedReadHfsPlusHeader */ -static int FreespaceReadHfsPlusHeader(pts_FreespaceHandle p_freespace_handle) { - pts_FreespaceHfsPlusData p_hfs_data=&(p_freespace_handle->hfsplus); +static int UnallocatedReadHfsPlusHeader( + pts_UnallocatedHandle p_unallocated_handle) +{ + pts_UnallocatedHfsPlusData p_hfs_data=&(p_unallocated_handle->hfsplus); int ret; size_t bytes_read; - pts_FreespaceHfsPlusExtend p_extend; + pts_UnallocatedHfsPlusExtend p_extend; LOG_DEBUG("Reading HFS+ volume header\n"); // Alloc buffer for header - p_hfs_data->p_vh=calloc(1,sizeof(ts_FreespaceHfsPlusVH)); - if(p_hfs_data->p_vh==NULL) return FREESPACE_MEMALLOC_FAILED; + p_hfs_data->p_vh=calloc(1,sizeof(ts_UnallocatedHfsPlusVH)); + if(p_hfs_data->p_vh==NULL) return UNALLOCATED_MEMALLOC_FAILED; // Read VH from input image - ret=p_freespace_handle-> + ret=p_unallocated_handle-> p_input_functions-> Read(0, (char*)(p_hfs_data->p_vh), - FREESPACE_HFSPLUS_VH_OFFSET, - sizeof(ts_FreespaceHfsPlusVH), + UNALLOCATED_HFSPLUS_VH_OFFSET, + sizeof(ts_UnallocatedHfsPlusVH), &bytes_read); - if(ret!=0 || bytes_read!=sizeof(ts_FreespaceHfsPlusVH)) { + if(ret!=0 || bytes_read!=sizeof(ts_UnallocatedHfsPlusVH)) { free(p_hfs_data->p_vh); p_hfs_data->p_vh=NULL; - return FREESPACE_CANNOT_READ_HFSPLUS_HEADER; + return UNALLOCATED_CANNOT_READ_HFSPLUS_HEADER; } // Convert VH to host endianness p_hfs_data->p_vh->signature=be16toh(p_hfs_data->p_vh->signature); p_hfs_data->p_vh->version=be16toh(p_hfs_data->p_vh->version); p_hfs_data->p_vh->block_size=be32toh(p_hfs_data->p_vh->block_size); p_hfs_data->p_vh->total_blocks=be32toh(p_hfs_data->p_vh->total_blocks); p_hfs_data->p_vh->free_blocks=be32toh(p_hfs_data->p_vh->free_blocks); p_hfs_data->p_vh->alloc_file_size=be64toh(p_hfs_data->p_vh->alloc_file_size); p_hfs_data->p_vh->alloc_file_clump_size= be32toh(p_hfs_data->p_vh->alloc_file_clump_size); p_hfs_data->p_vh->alloc_file_total_blocks= be32toh(p_hfs_data->p_vh->alloc_file_total_blocks); for(int i=0;i<8;i++) { p_extend=&(p_hfs_data->p_vh->alloc_file_extends[i]); p_extend->start_block=be32toh(p_extend->start_block); p_extend->block_count=be32toh(p_extend->block_count); } LOG_DEBUG("HFS+ VH signature: 0x%04X\n",p_hfs_data->p_vh->signature); LOG_DEBUG("HFS+ VH version: %" PRIu16 "\n",p_hfs_data->p_vh->version); LOG_DEBUG("HFS+ block size: %" PRIu32 " bytes\n",p_hfs_data->p_vh->block_size); LOG_DEBUG("HFS+ total blocks: %" PRIu32 "\n",p_hfs_data->p_vh->total_blocks); LOG_DEBUG("HFS+ free blocks: %" PRIu32 "\n",p_hfs_data->p_vh->free_blocks); LOG_DEBUG("HFS+ allocation file size: %" PRIu64 " bytes\n", p_hfs_data->p_vh->alloc_file_size); LOG_DEBUG("HFS+ allocation file blocks: %" PRIu32 "\n", p_hfs_data->p_vh->alloc_file_total_blocks); // Check header signature and version - if(p_hfs_data->p_vh->signature!=FREESPACE_HFSPLUS_VH_SIGNATURE || - p_hfs_data->p_vh->version!=FREESPACE_HFSPLUS_VH_VERSION) + if(p_hfs_data->p_vh->signature!=UNALLOCATED_HFSPLUS_VH_SIGNATURE || + p_hfs_data->p_vh->version!=UNALLOCATED_HFSPLUS_VH_VERSION) { free(p_hfs_data->p_vh); p_hfs_data->p_vh=NULL; - return FREESPACE_INVALID_HFSPLUS_HEADER; + return UNALLOCATED_INVALID_HFSPLUS_HEADER; } - return FREESPACE_OK; + return UNALLOCATED_OK; } /* - * FreespaceReadHfsPlusAllocFile + * UnallocatedReadHfsPlusAllocFile */ -static int FreespaceReadHfsPlusAllocFile(pts_FreespaceHandle p_freespace_handle) +static int UnallocatedReadHfsPlusAllocFile( + pts_UnallocatedHandle p_unallocated_handle) { - pts_FreespaceHfsPlusData p_hfs_data=&(p_freespace_handle->hfsplus); - pts_FreespaceHfsPlusExtend p_extend; + pts_UnallocatedHfsPlusData p_hfs_data=&(p_unallocated_handle->hfsplus); + pts_UnallocatedHfsPlusExtend p_extend; int ret; char *p_buf; size_t bytes_read; uint64_t total_bytes_read=0; LOG_DEBUG("Reading HFS+ allocation file\n"); // Alloc buffer for file p_hfs_data->p_alloc_file=calloc(1,p_hfs_data->p_vh->alloc_file_size); - if(p_hfs_data->p_alloc_file==NULL) return FREESPACE_MEMALLOC_FAILED; + if(p_hfs_data->p_alloc_file==NULL) return UNALLOCATED_MEMALLOC_FAILED; // Loop over extends and read data p_buf=(char*)(p_hfs_data->p_alloc_file); for(int i=0;i<8;i++) { p_extend=&(p_hfs_data->p_vh->alloc_file_extends[i]); // If start_block and block_count are zero, we parsed last extend if(p_extend->start_block==0 && p_extend->block_count==0) break; LOG_DEBUG("Extend %d contains %" PRIu32 " block(s) starting with block %" PRIu32 "\n", i, p_extend->block_count, p_extend->start_block); // Read data for(uint32_t ii=0;iiblock_count;ii++) { LOG_DEBUG("Reading %" PRIu32 " bytes from block %" PRIu32 " at offset %" PRIu64 "\n", p_hfs_data->p_vh->block_size, p_extend->start_block+ii, (uint64_t)((p_extend->start_block+ii)* p_hfs_data->p_vh->block_size)); - ret=p_freespace_handle-> + ret=p_unallocated_handle-> p_input_functions-> Read(0, p_buf, (p_extend->start_block+ii)*p_hfs_data->p_vh->block_size, p_hfs_data->p_vh->block_size, &bytes_read); if(ret!=0 || bytes_read!=p_hfs_data->p_vh->block_size) { free(p_hfs_data->p_alloc_file); p_hfs_data->p_alloc_file=NULL; - return FREESPACE_CANNOT_READ_HFSPLUS_ALLOC_FILE; + return UNALLOCATED_CANNOT_READ_HFSPLUS_ALLOC_FILE; } p_buf+=p_hfs_data->p_vh->block_size; total_bytes_read+=p_hfs_data->p_vh->block_size; } } // Alloc files with more then 8 extends aren't supported yet if(total_bytes_read!=p_hfs_data->p_vh->alloc_file_size) { free(p_hfs_data->p_alloc_file); p_hfs_data->p_alloc_file=NULL; - return FREESPACE_ALLOC_FILE_HAS_TOO_MUCH_EXTENDS; + return UNALLOCATED_ALLOC_FILE_HAS_TOO_MUCH_EXTENDS; } - return FREESPACE_OK; + return UNALLOCATED_OK; } /* - * FreespaceBuildHfsPlusBlockMap + * UnallocatedBuildHfsPlusBlockMap */ -static int FreespaceBuildHfsPlusBlockMap(pts_FreespaceHandle p_freespace_handle) +static int UnallocatedBuildHfsPlusBlockMap( + pts_UnallocatedHandle p_unallocated_handle) { - pts_FreespaceHfsPlusData p_hfs_data=&(p_freespace_handle->hfsplus); + pts_UnallocatedHfsPlusData p_hfs_data=&(p_unallocated_handle->hfsplus); LOG_DEBUG("Searching unallocated HFS+ blocks\n"); // Save offset of every unallocated block in block map for(uint32_t cur_block=0; cur_blockp_vh->total_blocks; cur_block++) { if((p_hfs_data->p_alloc_file[cur_block/8] & (1<<(7-(cur_block%8))))==0) { p_hfs_data->p_free_block_map=realloc(p_hfs_data->p_free_block_map, (p_hfs_data->free_block_map_size+1)* sizeof(uint64_t)); if(p_hfs_data->p_free_block_map==NULL) { p_hfs_data->free_block_map_size=0; - return FREESPACE_MEMALLOC_FAILED; + return UNALLOCATED_MEMALLOC_FAILED; } p_hfs_data->p_free_block_map[p_hfs_data->free_block_map_size]= cur_block*p_hfs_data->p_vh->block_size; p_hfs_data->free_block_map_size++; } } LOG_DEBUG("Found %" PRIu64 " unallocated HFS+ blocks\n", p_hfs_data->free_block_map_size); if(p_hfs_data->p_vh->free_blocks!=p_hfs_data->free_block_map_size) { LOG_WARNING("According to VH, there should be %" PRIu64 " unallocated blocks but I found %" PRIu64 "\n", p_hfs_data->p_vh->free_blocks, p_hfs_data->free_block_map_size); } - return FREESPACE_OK; + return UNALLOCATED_OK; } /* - * FreespaceReadHfsPlusBlock + * UnallocatedReadHfsPlusBlock */ -static int FreespaceReadHfsPlusBlock(pts_FreespaceHandle p_freespace_handle, - char *p_buf, - off_t offset, - size_t count, - size_t *p_read) +static int UnallocatedReadHfsPlusBlock( + pts_UnallocatedHandle p_unallocated_handle, + char *p_buf, + off_t offset, + size_t count, + size_t *p_read) { - pts_FreespaceHfsPlusData p_hfs_data=&(p_freespace_handle->hfsplus); + pts_UnallocatedHfsPlusData p_hfs_data=&(p_unallocated_handle->hfsplus); uint64_t cur_block; off_t cur_block_offset; off_t cur_image_offset; size_t cur_count; int ret; size_t bytes_read; // Calculate starting block and block offset cur_block=offset/p_hfs_data->p_vh->block_size; cur_block_offset=offset-(cur_block*p_hfs_data->p_vh->block_size); // Init p_read *p_read=0; while(count!=0) { // Calculate input image offset to read from cur_image_offset=p_hfs_data->p_free_block_map[cur_block]+cur_block_offset; // Calculate how many bytes to read from current block if(cur_block_offset+count>p_hfs_data->p_vh->block_size) { cur_count=p_hfs_data->p_vh->block_size-cur_block_offset; } else { cur_count=count; } LOG_DEBUG("Reading %zu bytes at offset %zu (block %" PRIu64 ")\n", cur_count, cur_image_offset+cur_block_offset, cur_block); // Read bytes - ret=p_freespace_handle->p_input_functions-> + ret=p_unallocated_handle->p_input_functions-> Read(0, p_buf, cur_image_offset+cur_block_offset, cur_count, &bytes_read); - if(ret!=0 || bytes_read!=cur_count) return FREESPACE_CANNOT_READ_DATA; + if(ret!=0 || bytes_read!=cur_count) return UNALLOCATED_CANNOT_READ_DATA; p_buf+=cur_count; cur_block_offset=0; count-=cur_count; cur_block++; (*p_read)+=cur_count; } - return FREESPACE_OK; + return UNALLOCATED_OK; } diff --git a/trunk/libxmount_morphing/libxmount_morphing_freespace/libxmount_morphing_freespace.h b/trunk/libxmount_morphing/libxmount_morphing_unallocated/libxmount_morphing_unallocated.h similarity index 55% rename from trunk/libxmount_morphing/libxmount_morphing_freespace/libxmount_morphing_freespace.h rename to trunk/libxmount_morphing/libxmount_morphing_unallocated/libxmount_morphing_unallocated.h index afe8cf0..20d4611 100644 --- a/trunk/libxmount_morphing/libxmount_morphing_freespace/libxmount_morphing_freespace.h +++ b/trunk/libxmount_morphing/libxmount_morphing_unallocated/libxmount_morphing_unallocated.h @@ -1,146 +1,151 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ -#ifndef LIBXMOUNT_MORPHING_FREESPACE_H -#define LIBXMOUNT_MORPHING_FREESPACE_H +#ifndef LIBXMOUNT_MORPHING_UNALLOCATED_H +#define LIBXMOUNT_MORPHING_UNALLOCATED_H #define LOG_ERROR(...) { \ LibXmount_Morphing_LogMessage("ERROR", \ (char*)__FUNCTION__, \ __LINE__, \ __VA_ARGS__); \ } #define LOG_WARNING(...) { \ LibXmount_Morphing_LogMessage("WARNING", \ (char*)__FUNCTION__, \ __LINE__, \ __VA_ARGS__); \ } #define LOG_DEBUG(...) { \ - if(p_freespace_handle->debug==1) \ + if(p_unallocated_handle->debug==1) \ LibXmount_Morphing_LogMessage("DEBUG", \ (char*)__FUNCTION__, \ __LINE__, \ __VA_ARGS__); \ } /******************************************************************************* * Enums, type defs, etc... ******************************************************************************/ // Error codes enum { - FREESPACE_OK=0, - FREESPACE_MEMALLOC_FAILED, - FREESPACE_NO_FS_SPECIFIED, - FREESPACE_UNSUPPORTED_FS_SPECIFIED, - FREESPACE_CANNOT_GET_IMAGECOUNT, - FREESPACE_WRONG_INPUT_IMAGE_COUNT, - FREESPACE_CANNOT_GET_IMAGESIZE, - FREESPACE_READ_BEYOND_END_OF_IMAGE, - FREESPACE_CANNOT_READ_DATA, - FREESPACE_CANNOT_PARSE_OPTION, - FREESPACE_CANNOT_READ_HFSPLUS_HEADER, - FREESPACE_INVALID_HFSPLUS_HEADER, - FREESPACE_CANNOT_READ_HFSPLUS_ALLOC_FILE, - FREESPACE_ALLOC_FILE_HAS_TOO_MUCH_EXTENDS + UNALLOCATED_OK=0, + UNALLOCATED_MEMALLOC_FAILED, + UNALLOCATED_NO_FS_SPECIFIED, + UNALLOCATED_UNSUPPORTED_FS_SPECIFIED, + UNALLOCATED_CANNOT_GET_IMAGECOUNT, + UNALLOCATED_WRONG_INPUT_IMAGE_COUNT, + UNALLOCATED_CANNOT_GET_IMAGESIZE, + UNALLOCATED_READ_BEYOND_END_OF_IMAGE, + UNALLOCATED_CANNOT_READ_DATA, + UNALLOCATED_CANNOT_PARSE_OPTION, + UNALLOCATED_CANNOT_READ_HFSPLUS_HEADER, + UNALLOCATED_INVALID_HFSPLUS_HEADER, + UNALLOCATED_CANNOT_READ_HFSPLUS_ALLOC_FILE, + UNALLOCATED_ALLOC_FILE_HAS_TOO_MUCH_EXTENDS }; // Supported fs types -typedef enum e_FreespaceFsType { - FreespaceFsType_Unknown=0, - FreespaceFsType_HfsPlus -} te_FreespaceFsType; +typedef enum e_UnallocatedFsType { + UnallocatedFsType_Unknown=0, + UnallocatedFsType_HfsPlus +} te_UnallocatedFsType; // HFS+ extend -typedef struct s_FreespaceHfsPlusExtend { +typedef struct s_UnallocatedHfsPlusExtend { uint32_t start_block; uint32_t block_count; -} __attribute__ ((packed)) ts_FreespaceHfsPlusExtend, *pts_FreespaceHfsPlusExtend; +} __attribute__ ((packed)) ts_UnallocatedHfsPlusExtend, *pts_UnallocatedHfsPlusExtend; // Needed parts of the HFS+ volume header -#define FREESPACE_HFSPLUS_VH_OFFSET 1024 -#define FREESPACE_HFSPLUS_VH_SIGNATURE 0x482b //"H+" -#define FREESPACE_HFSPLUS_VH_VERSION 4 -typedef struct s_FreespaceHfsPlusVH { +#define UNALLOCATED_HFSPLUS_VH_OFFSET 1024 +#define UNALLOCATED_HFSPLUS_VH_SIGNATURE 0x482b //"H+" +#define UNALLOCATED_HFSPLUS_VH_VERSION 4 +typedef struct s_UnallocatedHfsPlusVH { uint16_t signature; // "H+" uint16_t version; // Currently 4 for HFS+ uint32_t unused01[9]; uint32_t block_size; uint32_t total_blocks; uint32_t free_blocks; uint32_t unused02[15]; uint64_t alloc_file_size; uint32_t alloc_file_clump_size; uint32_t alloc_file_total_blocks; - ts_FreespaceHfsPlusExtend alloc_file_extends[8]; -} __attribute__ ((packed)) ts_FreespaceHfsPlusVH, *pts_FreespaceHfsPlusVH; + ts_UnallocatedHfsPlusExtend alloc_file_extends[8]; +} __attribute__ ((packed)) ts_UnallocatedHfsPlusVH, *pts_UnallocatedHfsPlusVH; // Needed data for HFS+ -typedef struct s_FreespaceHfsPlusData { - pts_FreespaceHfsPlusVH p_vh; +typedef struct s_UnallocatedHfsPlusData { + pts_UnallocatedHfsPlusVH p_vh; uint8_t *p_alloc_file; uint64_t free_block_map_size; uint64_t *p_free_block_map; -} ts_FreespaceHfsPlusData, *pts_FreespaceHfsPlusData; +} ts_UnallocatedHfsPlusData, *pts_UnallocatedHfsPlusData; // Handle -typedef struct s_FreespaceHandle { +typedef struct s_UnallocatedHandle { uint8_t debug; - te_FreespaceFsType fs_type; + te_UnallocatedFsType fs_type; pts_LibXmountMorphingInputFunctions p_input_functions; uint64_t morphed_image_size; - ts_FreespaceHfsPlusData hfsplus; -} ts_FreespaceHandle, *pts_FreespaceHandle; + ts_UnallocatedHfsPlusData hfsplus; +} ts_UnallocatedHandle, *pts_UnallocatedHandle; /******************************************************************************* * Forward declarations ******************************************************************************/ -static int FreespaceCreateHandle(void **pp_handle, - char *p_format, +static int UnallocatedCreateHandle(void **pp_handle, + const char *p_format, uint8_t debug); -static int FreespaceDestroyHandle(void **pp_handle); -static int FreespaceMorph(void *p_handle, - pts_LibXmountMorphingInputFunctions p_input_functions); -static int FreespaceSize(void *p_handle, +static int UnallocatedDestroyHandle(void **pp_handle); +static int UnallocatedMorph( + void *p_handle, + pts_LibXmountMorphingInputFunctions p_input_functions); +static int UnallocatedSize(void *p_handle, uint64_t *p_size); -static int FreespaceRead(void *p_handle, +static int UnallocatedRead(void *p_handle, char *p_buf, off_t offset, size_t count, size_t *p_read); -static const char* FreespaceOptionsHelp(); -static int FreespaceOptionsParse(void *p_handle, +static int UnallocatedOptionsHelp(const char **pp_help); +static int UnallocatedOptionsParse(void *p_handle, uint32_t options_count, - pts_LibXmountOptions *pp_options, - char **pp_error); -static int FreespaceGetInfofileContent(void *p_handle, - char **pp_info_buf); -static const char* FreespaceGetErrorMessage(int err_num); -static void FreespaceFreeBuffer(void *p_buf); + const pts_LibXmountOptions *pp_options, + const char **pp_error); +static int UnallocatedGetInfofileContent(void *p_handle, + const char **pp_info_buf); +static const char* UnallocatedGetErrorMessage(int err_num); +static void UnallocatedFreeBuffer(void *p_buf); // Helper functions -static int FreespaceReadHfsPlusHeader(pts_FreespaceHandle p_freespace_handle); -static int FreespaceReadHfsPlusAllocFile(pts_FreespaceHandle p_freespace_handle); -static int FreespaceBuildHfsPlusBlockMap(pts_FreespaceHandle p_freespace_handle); -static int FreespaceReadHfsPlusBlock(pts_FreespaceHandle p_freespace_handle, - char *p_buf, - off_t offset, - size_t count, - size_t *p_read); +static int UnallocatedReadHfsPlusHeader( + pts_UnallocatedHandle p_unallocated_handle); +static int UnallocatedReadHfsPlusAllocFile( + pts_UnallocatedHandle p_unallocated_handle); +static int UnallocatedBuildHfsPlusBlockMap( + pts_UnallocatedHandle p_unallocated_handle); +static int UnallocatedReadHfsPlusBlock( + pts_UnallocatedHandle p_unallocated_handle, + char *p_buf, + off_t offset, + size_t count, + size_t *p_read); -#endif // LIBXMOUNT_MORPHING_FREESPACE_H +#endif // LIBXMOUNT_MORPHING_UNALLOCATED_H diff --git a/trunk/src/xmount.c b/trunk/src/xmount.c index f60a292..cbd8c43 100755 --- a/trunk/src/xmount.c +++ b/trunk/src/xmount.c @@ -1,3994 +1,4029 @@ /******************************************************************************* * xmount Copyright (c) 2008-2014 by Gillen Daniel * * * * xmount is a small tool to "fuse mount" various harddisk image formats as dd, * * vdi, vhd or vmdk files and enable virtual write access to them. * * * * This program is free software: you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the Free * * Software Foundation, either version 3 of the License, or (at your option) * * any later version. * * * * This program is distributed in the hope that it will be useful, but WITHOUT * * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * * more details. * * * * You should have received a copy of the GNU General Public License along with * * this program. If not, see . * *******************************************************************************/ #include #include #include #include #include #include #include // For PRI* #include #include // For dlopen, dlclose, dlsym #include // For opendir, readdir, closedir #include #include #include // For fstat #include #ifdef HAVE_LINUX_FS_H #include // For SEEK_* ?? #endif #if !defined(__APPLE__) && defined(HAVE_GRP_H) && defined(HAVE_PWD_H) #include // For getgrnam, struct group #include // For getpwuid, struct passwd #endif #include #include // For time #define FUSE_USE_VERSION 26 #include #include "xmount.h" #include "md5.h" #include "endianness.h" #include "macros.h" #define XMOUNT_COPYRIGHT_NOTICE \ "xmount v%s Copyright (c) 2008-2014 by Gillen Daniel " /******************************************************************************* * Global vars ******************************************************************************/ //! Struct that contains various runtime configuration options static ts_XmountData glob_xmount; /******************************************************************************* * Forward declarations ******************************************************************************/ // Helper functions static void LogMessage(char*, char*, int, char*, ...); static void PrintUsage(char*); static void CheckFuseSettings(); static int ParseCmdLine(const int, char**); static int ExtractVirtFileNames(char*); static int GetMorphedImageSize(uint64_t*); static int GetVirtImageSize(uint64_t*); static int GetInputImageData(pts_InputImage, char*, off_t, size_t, size_t*); static int GetMorphedImageData(char*, off_t, size_t, size_t*); static int GetVirtImageData(char*, off_t, size_t); static int SetVdiFileHeaderData(char*, off_t, size_t); static int SetVhdFileHeaderData(char*, off_t, size_t); static int SetVirtImageData(const char*, off_t, size_t); static int CalculateInputImageHash(uint64_t*, uint64_t*); static int InitVirtVdiHeader(); static int InitVirtVhdHeader(); static int InitVirtualVmdkFile(); static int InitVirtImageInfoFile(); static int InitCacheFile(); static int LoadLibs(); static int FindInputLib(pts_InputImage); static int FindMorphingLib(); static void InitResources(); static void FreeResources(); static int SplitLibraryParameters(char*, uint32_t*, pts_LibXmountOptions**); // Functions exported to LibXmount_Morphing static int LibXmount_Morphing_ImageCount(uint64_t*); static int LibXmount_Morphing_Size(uint64_t, uint64_t*); static int LibXmount_Morphing_Read(uint64_t, char*, off_t, size_t, size_t*); // Functions implementing FUSE functions static int FuseGetAttr(const char*, struct stat*); static int FuseMkDir(const char*, mode_t); static int FuseMkNod(const char*, mode_t, dev_t); static int FuseReadDir(const char*, void*, fuse_fill_dir_t, off_t, struct fuse_file_info*); static int FuseOpen(const char*, struct fuse_file_info*); static int FuseRead(const char*, char*, size_t, off_t, struct fuse_file_info*); static int FuseRename(const char*, const char*); static int FuseRmDir(const char*); static int FuseUnlink(const char*); //static int FuseStatFs(const char*, struct statvfs*); static int FuseWrite(const char *p_path, const char*, size_t, off_t, struct fuse_file_info*); /******************************************************************************* * Helper functions ******************************************************************************/ //! Print error and debug messages to stdout /*! * \param p_msg_type "ERROR" or "DEBUG" * \param p_calling_fun Name of calling function * \param line Line number of call * \param p_msg Message string * \param ... Variable params with values to include in message string */ static void LogMessage(char *p_msg_type, char *p_calling_fun, int line, char *p_msg, ...) { va_list var_list; // Print message "header" printf("%s: %s.%s@%u : ",p_msg_type,p_calling_fun,XMOUNT_VERSION,line); // Print message with variable parameters va_start(var_list,p_msg); vprintf(p_msg,var_list); va_end(var_list); } //! Print usage instructions (cmdline options etc..) /*! * \param p_prog_name Program name (argv[0]) */ static void PrintUsage(char *p_prog_name) { char *p_buf; int first; int ret; printf("\n" XMOUNT_COPYRIGHT_NOTICE "\n",XMOUNT_VERSION); printf("\nUsage:\n"); printf(" %s [fopts] \n\n",p_prog_name); printf("Options:\n"); printf(" fopts:\n"); printf(" -d : Enable FUSE's and xmount's debug mode.\n"); printf(" -h : Display this help message.\n"); printf(" -s : Run single threaded.\n"); printf(" -o no_allow_other : Disable automatic addition of FUSE's " "allow_other option.\n"); printf(" -o : Specify fuse mount options. Will also disable " "automatic addition of FUSE's allow_other option!\n"); printf("\n"); printf(" xopts:\n"); printf(" --cache : Enable virtual write support.\n"); printf(" specifies the cache file to use.\n"); printf(" --in : Input image format and source file(s). " "May be specified multiple times.\n"); printf(" can be "); // List supported input formats first=1; for(uint32_t i=0;ip_supported_input_types; while(*p_buf!='\0') { if(first==1) { printf("\"%s\"",p_buf); first=0; } else printf(", \"%s\"",p_buf); p_buf+=(strlen(p_buf)+1); } } printf(".\n"); printf(" specifies the source file. If your image is split into " "multiple files, you have to specify them all!\n"); printf(" --inopts : Specify input library specific options.\n"); printf(" specifies a comma separated list of key=value options. " "See below for details.\n"); printf(" --info : Print out infos about used compiler and libraries.\n"); printf(" --morph : Morphing function to apply to input image(s). " "If not specified, defaults to \"combine\".\n"); printf(" can be "); // List supported morphing functions first=1; for(uint32_t i=0;ip_supported_morphing_types; while(*p_buf!='\0') { if(first==1) { printf("\"%s\"",p_buf); first=0; } else printf(", \"%s\"",p_buf); p_buf+=(strlen(p_buf)+1); } } printf(".\n"); printf(" --morphopts : Specify morphing library specific " "options.\n"); printf(" specifies a comma separated list of key=value options. " "See below for details.\n"); printf(" --offset : Move the output image data start bytes " "into the input image(s).\n"); printf(" --out : Output image format. If not specified, " "defaults to "); #ifdef __APPLE__ printf("\"dmg\".\n"); #else printf("\"dd\".\n"); #endif printf(" can be "); // List supported output formats printf("\"dd\", \"dmg\", \"vdi\", \"vhd\", \"vmdk\", \"vmdks\".\n"); printf(" --owcache : Same as --cache but overwrites " "existing cache file.\n"); printf(" --version : Same as --info.\n"); printf("\n"); printf(" mntp:\n"); printf(" Mount point where output image should be located.\n"); printf("\n"); printf("Infos:\n"); printf(" * One --in option and a mount point are mandatory!\n"); printf(" * If you specify --in multiple times, data from all images is " "morphed into one output image using the specified morphing " "function.\n"); printf(" * For VMDK emulation, you have to uncomment \"user_allow_other\" " "in /etc/fuse.conf or run xmount as root.\n"); printf("\n"); printf("Input / Morphing library specific options:\n"); printf(" Input / Morphing libraries might support an own set of " "options to configure / tune their behaviour.\n"); printf(" Libraries supporting this feature (if any) and and their " "options are listed below.\n"); printf("\n"); // List input and morphing lib options for(uint32_t i=0;i lib_functions.OptionsHelp((const char**)&p_buf); if(ret!=0) { LOG_ERROR("Unable to get options help for library '%s': %s!\n", glob_xmount.input.pp_libs[i]->p_name, glob_xmount.input.pp_libs[i]-> lib_functions.GetErrorMessage(ret)); } if(p_buf==NULL) continue; printf(" - %s\n",glob_xmount.input.pp_libs[i]->p_name); printf("%s\n",p_buf); printf("\n"); ret=glob_xmount.input.pp_libs[i]->lib_functions.FreeBuffer(p_buf); if(ret!=0) { LOG_ERROR("Unable to free options help text from library '%s': %s!\n", glob_xmount.input.pp_libs[i]->p_name, glob_xmount.input.pp_libs[i]-> lib_functions.GetErrorMessage(ret)); } } for(uint32_t i=0;ilib_functions.OptionsHelp()); + ret=glob_xmount.morphing.pp_libs[i]-> + lib_functions.OptionsHelp((const char**)&p_buf); + if(ret!=0) { + LOG_ERROR("Unable to get options help for library '%s': %s!\n", + glob_xmount.morphing.pp_libs[i]->p_name, + glob_xmount.morphing.pp_libs[i]-> + lib_functions.GetErrorMessage(ret)); + } if(p_buf==NULL) continue; printf(" - %s\n",glob_xmount.morphing.pp_libs[i]->p_name); printf("%s\n",p_buf); printf("\n"); } } //! Check fuse settings /*! * Check if FUSE allows us to pass the -o allow_other parameter. This only works * if we are root or user_allow_other is set in /etc/fuse.conf. * * In addition, this function also checks if the user is member of the fuse * group which is generally needed to use fuse at all. */ static void CheckFuseSettings() { #if !defined(__APPLE__) && defined(HAVE_GRP_H) && defined(HAVE_PWD_H) struct group *p_group; struct passwd *p_passwd; #endif int found; FILE *h_fuse_conf; char line[256]; glob_xmount.may_set_fuse_allow_other=FALSE; if(geteuid()==0) { // Running as root, there should be no problems glob_xmount.may_set_fuse_allow_other=TRUE; return; } #if !defined(__APPLE__) && defined(HAVE_GRP_H) && defined(HAVE_PWD_H) // Check if a fuse group exists and if so, make sure user is a member of it. // Makes only sense on Linux because as far as I know osxfuse has no own group p_group=getgrnam("fuse"); if(p_group!=NULL) { // Get effective user name p_passwd=getpwuid(geteuid()); if(p_passwd==NULL) { printf("\nWARNING: Unable to determine your effective user name. If " "mounting works, you can ignore this message.\n\n"); return; } // Check if user is member of fuse group found=FALSE; while(*(p_group->gr_mem)!=NULL) { if(strcmp(*(p_group->gr_mem),p_passwd->pw_name)==0) { found=TRUE; break; } p_group->gr_mem++; } if(found==FALSE) { printf("\nWARNING: You are not a member of the \"fuse\" group. This will " "prevent you from mounting images using xmount. Please add " "yourself to the \"fuse\" group using the command " "\"sudo usermod -a -G fuse %s\" and reboot your system or " "execute xmount as root.\n\n", p_passwd->pw_name); return; } } else { printf("\nWARNING: Your system does not seem to have a \"fuse\" group. If " "mounting works, you can ignore this message.\n\n"); } #endif // Read FUSE's config file /etc/fuse.conf and check for set user_allow_other h_fuse_conf=(FILE*)FOPEN("/etc/fuse.conf","r"); if(h_fuse_conf!=NULL) { // Search conf file for set user_allow_others found=FALSE; while(fgets(line,sizeof(line),h_fuse_conf)!=NULL) { // TODO: This works as long as there is no other parameter beginning with // "user_allow_other" :) if(strncmp(line,"user_allow_other",16)==0) { found=TRUE; break; } } fclose(h_fuse_conf); if(found==TRUE) { glob_xmount.may_set_fuse_allow_other=TRUE; } else { printf("\nWARNING: FUSE will not allow other users nor root to access " "your virtual harddisk image. To change this behavior, please " "add \"user_allow_other\" to /etc/fuse.conf or execute xmount " "as root.\n\n"); } } else { printf("\nWARNING: Unable to open /etc/fuse.conf. If mounting works, you " "can ignore this message. If you encounter issues, please create " "the file and add a single line containing the string " "\"user_allow_other\" or execute xmount as root.\n\n"); return; } } //! Parse command line options /*! * \param argc Number of cmdline params * \param pp_argv Array containing cmdline params * \return TRUE on success, FALSE on error */ static int ParseCmdLine(const int argc, char **pp_argv) { int i=1; int FuseMinusOControl=TRUE; int FuseAllowOther=TRUE; int first; char *p_buf; pts_InputImage p_input_image; // add pp_argv[0] to FUSE's argv XMOUNT_MALLOC(glob_xmount.pp_fuse_argv,char**,sizeof(char*)); XMOUNT_STRSET(glob_xmount.pp_fuse_argv[0],pp_argv[0]); glob_xmount.fuse_argc=1; // Parse options while(i1 && *(pp_argv[i]+1)!='-') { // Options beginning with one - are mostly FUSE specific if(strcmp(pp_argv[i],"-d")==0) { // Enable FUSE's and xmount's debug mode XMOUNT_REALLOC(glob_xmount.pp_fuse_argv, char**, (glob_xmount.fuse_argc+1)*sizeof(char*)); XMOUNT_STRSET(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc], pp_argv[i]) glob_xmount.fuse_argc++; glob_xmount.debug=TRUE; } else if(strcmp(pp_argv[i],"-h")==0) { // Print help message PrintUsage(pp_argv[0]); exit(0); } else if(strcmp(pp_argv[i],"-o")==0) { // Next parameter specifies fuse / lib mount options if((argc+1)>i) { i++; // As the user specified the -o option, we assume he knows what he is // doing. We won't append allow_other automatically. And we allow him // to disable allow_other by passing a single "-o no_allow_other" // which won't be passed to FUSE as it is xmount specific. if(strcmp(pp_argv[i],"no_allow_other")!=0) { glob_xmount.fuse_argc+=2; XMOUNT_REALLOC(glob_xmount.pp_fuse_argv, char**, glob_xmount.fuse_argc*sizeof(char*)); XMOUNT_STRSET(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc-2], pp_argv[i-1]); XMOUNT_STRSET(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc-1], pp_argv[i]); FuseMinusOControl=FALSE; } else FuseAllowOther=FALSE; } else { LOG_ERROR("Couldn't parse mount options!\n") return FALSE; } } else if(strcmp(pp_argv[i],"-s")==0) { // Enable FUSE's single threaded mode XMOUNT_REALLOC(glob_xmount.pp_fuse_argv, char**, (glob_xmount.fuse_argc+1)*sizeof(char*)); XMOUNT_STRSET(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc], pp_argv[i]); glob_xmount.fuse_argc++; } else if(strcmp(pp_argv[i],"-V")==0) { // Display FUSE version info XMOUNT_REALLOC(glob_xmount.pp_fuse_argv, char**, (glob_xmount.fuse_argc+1)*sizeof(char*)); XMOUNT_STRSET(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc], pp_argv[i]); glob_xmount.fuse_argc++; } else { LOG_ERROR("Unknown command line option \"%s\"\n",pp_argv[i]); return FALSE; } } else { // Options beginning with -- are xmount specific if(strcmp(pp_argv[i],"--cache")==0 || strcmp(pp_argv[i],"--rw")==0) { // Emulate writable access to mounted image // Next parameter must be cache file to read/write changes from/to if((argc+1)>i) { i++; XMOUNT_STRSET(glob_xmount.cache.p_cache_file,pp_argv[i]) glob_xmount.output.writable=TRUE; } else { LOG_ERROR("You must specify a cache file!\n") return FALSE; } LOG_DEBUG("Enabling virtual write support using cache file \"%s\"\n", glob_xmount.cache.p_cache_file) } else if(strcmp(pp_argv[i],"--in")==0) { // Specify input image type and source files if((argc+2)>i) { i++; // Alloc and init new ts_InputImage struct XMOUNT_MALLOC(p_input_image,pts_InputImage,sizeof(ts_InputImage)); XMOUNT_STRSET(p_input_image->p_type,pp_argv[i]); p_input_image->pp_files=NULL; p_input_image->p_functions=NULL; p_input_image->p_handle=NULL; // Parse input image filename(s) and add to p_input_image->pp_files i++; p_input_image->files_count=0; while(i<(argc-1) && strncmp(pp_argv[i],"--",2)!=0) { p_input_image->files_count++; XMOUNT_REALLOC(p_input_image->pp_files, char**, p_input_image->files_count*sizeof(char*)); XMOUNT_STRSET(p_input_image->pp_files[p_input_image->files_count-1], pp_argv[i]); i++; } i--; if(p_input_image->files_count==0) { LOG_ERROR("No input files specified for \"--in %s\"!\n", p_input_image->p_type) free(p_input_image->p_type); free(p_input_image); return FALSE; } // Add input image struct to input image array glob_xmount.input.images_count++; XMOUNT_REALLOC(glob_xmount.input.pp_images, pts_InputImage*, glob_xmount.input.images_count* sizeof(pts_InputImage)); glob_xmount.input.pp_images[glob_xmount.input.images_count-1]= p_input_image; } else { LOG_ERROR("You must specify an input image type and source file!\n"); return FALSE; } } else if(strcmp(pp_argv[i],"--inopts")==0) { if((argc+1)>i) { i++; if(glob_xmount.input.pp_lib_params==NULL) { if(SplitLibraryParameters(pp_argv[i], &(glob_xmount.input.lib_params_count), &(glob_xmount.input.pp_lib_params) )==FALSE) { LOG_ERROR("Unable to parse input library options '%s'!\n", pp_argv[i]); return FALSE; } } else { LOG_ERROR("You can only specify --inopts once!") return FALSE; } } else { LOG_ERROR("You must specify special options!\n"); return FALSE; } } else if(strcmp(pp_argv[i],"--morph")==0) { if((argc+1)>i) { i++; if(glob_xmount.morphing.p_morph_type==NULL) { XMOUNT_STRSET(glob_xmount.morphing.p_morph_type,pp_argv[i]); } else { LOG_ERROR("You can only specify --morph once!") return FALSE; } } else { LOG_ERROR("You must specify morphing type!\n"); return FALSE; } } else if(strcmp(pp_argv[i],"--morphopts")==0) { if((argc+1)>i) { i++; if(glob_xmount.morphing.pp_lib_params==NULL) { if(SplitLibraryParameters(pp_argv[i], &(glob_xmount.morphing.lib_params_count), &(glob_xmount.morphing.pp_lib_params) )==FALSE) { LOG_ERROR("Unable to parse morphing library options '%s'!\n", pp_argv[i]); return FALSE; } } else { LOG_ERROR("You can only specify --morphopts once!") return FALSE; } } else { LOG_ERROR("You must specify special morphing lib params!\n"); return FALSE; } } else if(strcmp(pp_argv[i],"--out")==0) { // Specify output image type // Next parameter must be image type if((argc+1)>i) { i++; if(strcmp(pp_argv[i],"dd")==0) { glob_xmount.output.VirtImageType=VirtImageType_DD; LOG_DEBUG("Setting virtual image type to DD\n") } else if(strcmp(pp_argv[i],"dmg")==0) { glob_xmount.output.VirtImageType=VirtImageType_DMG; LOG_DEBUG("Setting virtual image type to DMG\n") } else if(strcmp(pp_argv[i],"vdi")==0) { glob_xmount.output.VirtImageType=VirtImageType_VDI; LOG_DEBUG("Setting virtual image type to VDI\n") } else if(strcmp(pp_argv[i],"vhd")==0) { glob_xmount.output.VirtImageType=VirtImageType_VHD; LOG_DEBUG("Setting virtual image type to VHD\n") } else if(strcmp(pp_argv[i],"vmdk")==0) { glob_xmount.output.VirtImageType=VirtImageType_VMDK; LOG_DEBUG("Setting virtual image type to VMDK\n") } else if(strcmp(pp_argv[i],"vmdks")==0) { glob_xmount.output.VirtImageType=VirtImageType_VMDKS; LOG_DEBUG("Setting virtual image type to VMDKS\n") } else { LOG_ERROR("Unknown output image type \"%s\"!\n",pp_argv[i]) return FALSE; } } else { LOG_ERROR("You must specify an output image type!\n"); return FALSE; } } else if(strcmp(pp_argv[i],"--owcache")==0) { // Enable writable access to mounted image and overwrite existing cache // Next parameter must be cache file to read/write changes from/to if((argc+1)>i) { i++; XMOUNT_STRSET(glob_xmount.cache.p_cache_file,pp_argv[i]) glob_xmount.output.writable=TRUE; glob_xmount.cache.overwrite_cache=TRUE; } else { LOG_ERROR("You must specify a cache file!\n") return FALSE; } LOG_DEBUG("Enabling virtual write support overwriting cache file %s\n", glob_xmount.cache.p_cache_file) } else if(strcmp(pp_argv[i],"--version")==0 || strcmp(pp_argv[i],"--info")==0) { printf(XMOUNT_COPYRIGHT_NOTICE "\n\n",XMOUNT_VERSION); #ifdef __GNUC__ printf(" compile timestamp: %s %s\n",__DATE__,__TIME__); printf(" gcc version: %s\n",__VERSION__); #endif printf(" loaded input libraries:\n"); for(uint32_t ii=0;iip_name); p_buf=glob_xmount.input.pp_libs[ii]->p_supported_input_types; first=TRUE; while(*p_buf!='\0') { if(first) { printf("\"%s\"",p_buf); first=FALSE; } else printf(", \"%s\"",p_buf); p_buf+=(strlen(p_buf)+1); } printf("\n"); } printf(" loaded morphing libraries:\n"); for(uint32_t ii=0;iip_name); p_buf=glob_xmount.morphing.pp_libs[ii]->p_supported_morphing_types; first=TRUE; while(*p_buf!='\0') { if(first) { printf("\"%s\"",p_buf); first=FALSE; } else printf(", \"%s\"",p_buf); p_buf+=(strlen(p_buf)+1); } printf("\n"); } printf("\n"); exit(0); } else if(strcmp(pp_argv[i],"--offset")==0) { if((argc+1)>i) { i++; glob_xmount.input.image_offset=strtoull(pp_argv[i],NULL,10); } else { LOG_ERROR("You must specify an offset!\n") return FALSE; } LOG_DEBUG("Setting input image offset to \"%" PRIu64 "\"\n", glob_xmount.input.image_offset) } else { LOG_ERROR("Unknown command line option \"%s\"\n",pp_argv[i]); return FALSE; } } i++; } // Extract mountpoint if(i==(argc-1)) { XMOUNT_STRSET(glob_xmount.p_mountpoint,pp_argv[argc-1]) XMOUNT_REALLOC(glob_xmount.pp_fuse_argv, char**, (glob_xmount.fuse_argc+1)*sizeof(char*)); XMOUNT_STRSET(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc], glob_xmount.p_mountpoint); glob_xmount.fuse_argc++; } else { LOG_ERROR("No mountpoint specified!\n") return FALSE; } if(FuseMinusOControl==TRUE) { // We control the -o flag, set subtype, fsname and allow_other options glob_xmount.fuse_argc+=2; XMOUNT_REALLOC(glob_xmount.pp_fuse_argv, char**, glob_xmount.fuse_argc*sizeof(char*)); XMOUNT_STRSET(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc-2],"-o"); XMOUNT_STRSET(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc-1], "subtype=xmount"); if(glob_xmount.input.images_count!=0) { // Set name of first source file as fsname XMOUNT_STRAPP(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc-1], ",fsname="); XMOUNT_STRAPP(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc-1], glob_xmount.input.pp_images[0]->pp_files[0]); } if(FuseAllowOther==TRUE) { // Add "allow_other" option if allowed if(glob_xmount.may_set_fuse_allow_other) { XMOUNT_STRAPP(glob_xmount.pp_fuse_argv[glob_xmount.fuse_argc-1], ",allow_other"); } } } return TRUE; } //! Extract virtual file name from input image name /*! * \param p_orig_name Name of input image (may include a path) * \return TRUE on success, FALSE on error */ static int ExtractVirtFileNames(char *p_orig_name) { char *tmp; // Truncate any leading path tmp=strrchr(p_orig_name,'/'); if(tmp!=NULL) p_orig_name=tmp+1; // Extract file extension tmp=strrchr(p_orig_name,'.'); // Set leading '/' XMOUNT_STRSET(glob_xmount.output.p_virtual_image_path,"/"); XMOUNT_STRSET(glob_xmount.output.p_info_path,"/"); if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { XMOUNT_STRSET(glob_xmount.output.vmdk.p_virtual_vmdk_path,"/"); } // Copy filename if(tmp==NULL) { // Input image filename has no extension XMOUNT_STRAPP(glob_xmount.output.p_virtual_image_path,p_orig_name); XMOUNT_STRAPP(glob_xmount.output.p_info_path,p_orig_name); if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { XMOUNT_STRAPP(glob_xmount.output.vmdk.p_virtual_vmdk_path,p_orig_name); } XMOUNT_STRAPP(glob_xmount.output.p_info_path,".info"); } else { XMOUNT_STRNAPP(glob_xmount.output.p_virtual_image_path,p_orig_name, strlen(p_orig_name)-strlen(tmp)); XMOUNT_STRNAPP(glob_xmount.output.p_info_path,p_orig_name, strlen(p_orig_name)-strlen(tmp)); if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { XMOUNT_STRNAPP(glob_xmount.output.vmdk.p_virtual_vmdk_path,p_orig_name, strlen(p_orig_name)-strlen(tmp)); } XMOUNT_STRAPP(glob_xmount.output.p_info_path,".info"); } // Add virtual file extensions switch(glob_xmount.output.VirtImageType) { case VirtImageType_DD: XMOUNT_STRAPP(glob_xmount.output.p_virtual_image_path,".dd"); break; case VirtImageType_DMG: XMOUNT_STRAPP(glob_xmount.output.p_virtual_image_path,".dmg"); break; case VirtImageType_VDI: XMOUNT_STRAPP(glob_xmount.output.p_virtual_image_path,".vdi"); break; case VirtImageType_VHD: XMOUNT_STRAPP(glob_xmount.output.p_virtual_image_path,".vhd"); break; case VirtImageType_VMDK: case VirtImageType_VMDKS: XMOUNT_STRAPP(glob_xmount.output.p_virtual_image_path,".dd"); XMOUNT_STRAPP(glob_xmount.output.vmdk.p_virtual_vmdk_path,".vmdk"); break; default: LOG_ERROR("Unknown virtual image type!\n") return FALSE; } LOG_DEBUG("Set virtual image name to \"%s\"\n", glob_xmount.output.p_virtual_image_path); LOG_DEBUG("Set virtual image info name to \"%s\"\n", glob_xmount.output.p_info_path); if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { LOG_DEBUG("Set virtual vmdk name to \"%s\"\n", glob_xmount.output.vmdk.p_virtual_vmdk_path); } return TRUE; } //! Get size of morphed image /*! * \param p_size Buf to save size to * \return TRUE on success, FALSE on error */ static int GetMorphedImageSize(uint64_t *p_size) { int ret; ret=glob_xmount.morphing.p_functions->Size(glob_xmount.morphing.p_handle, p_size); if(ret!=0) { LOG_ERROR("Unable to get morphed image size: %s!\n", glob_xmount.morphing.p_functions->GetErrorMessage(ret)); return FALSE; } return TRUE; } //! Get size of virtual image /*! * \param p_size Pointer to an uint64_t to which the size will be written to * \return TRUE on success, FALSE on error */ static int GetVirtImageSize(uint64_t *p_size) { if(glob_xmount.output.image_size!=0) { *p_size=glob_xmount.output.image_size; return TRUE; } switch(glob_xmount.output.VirtImageType) { case VirtImageType_DD: case VirtImageType_DMG: case VirtImageType_VMDK: case VirtImageType_VMDKS: // Virtual image is a DD, DMG or VMDK file. Just return the size of the // original image if(!GetMorphedImageSize(p_size)) { LOG_ERROR("Couldn't get size of input image!\n") return FALSE; } break; case VirtImageType_VDI: // Virtual image is a VDI file. Get size of original image and add size // of VDI header etc. if(!GetMorphedImageSize(p_size)) { LOG_ERROR("Couldn't get size of input image!\n") return FALSE; } (*p_size)+=(sizeof(ts_VdiFileHeader)+ glob_xmount.output.vdi.vdi_block_map_size); break; case VirtImageType_VHD: // Virtual image is a VHD file. Get size of original image and add size // of VHD footer. if(!GetMorphedImageSize(p_size)) { LOG_ERROR("Couldn't get size of input image!\n") return FALSE; } (*p_size)+=sizeof(ts_VhdFileHeader); break; default: LOG_ERROR("Unsupported image type!\n") return FALSE; } glob_xmount.output.image_size=*p_size; return TRUE; } //! Read data from input image /*! * \param p_image Image from which to read data * \param p_buf Pointer to buffer to write read data to (must be preallocated!) * \param offset Offset at which data should be read * \param size Size of data which should be read (size of buffer) * \param p_read Number of read bytes on success * \return 0 on success, negated error code on error */ static int GetInputImageData(pts_InputImage p_image, char *p_buf, off_t offset, size_t size, size_t *p_read) { int ret; size_t to_read=0; LOG_DEBUG("Reading %zu bytes at offset %zu from input image '%s'\n", size, offset, p_image->pp_files[0]); // Make sure we aren't reading past EOF of image file if(offset>=p_image->size) { // Offset is beyond image size LOG_DEBUG("Offset %zu is at / beyond size of input image '%s'\n", offset, p_image->pp_files[0]); *p_read=0; return 0; } if(offset+size>p_image->size) { // Attempt to read data past EOF of image file to_read=p_image->size-offset; LOG_DEBUG("Attempt to read data past EOF of input image '%s'. " "Correcting size from %zu to %zu\n", p_image->pp_files[0], size, to_read); } else to_read=size; // Read data from image file (adding input image offset if one was specified) ret=p_image->p_functions->Read(p_image->p_handle, p_buf, offset+glob_xmount.input.image_offset, to_read, p_read); if(ret!=0) { LOG_ERROR("Couldn't read %zu bytes at offset %zu from input image " "'%s': %s!\n", to_read, offset, p_image->pp_files[0], p_image->p_functions->GetErrorMessage(ret)); return -EIO; } return 0; } //! Read data from morphed image /*! * \param p_buf Pointer to buffer to write read data to (must be preallocated!) * \param offset Offset at which data should be read * \param size Size of data which should be read (size of buffer) * \param p_read Number of read bytes on success * \return TRUE on success, negated error code on error */ static int GetMorphedImageData(char *p_buf, off_t offset, size_t size, size_t *p_read) { int ret; size_t to_read=0; size_t read; uint64_t image_size=0; // Make sure we aren't reading past EOF of image file if(GetMorphedImageSize(&image_size)!=TRUE) { LOG_ERROR("Couldn't get size of morphed image!\n"); return -EIO; } if(offset>=image_size) { // Offset is beyond image size LOG_DEBUG("Offset %zu is at / beyond size of morphed image.\n",offset); *p_read=0; return 0; } if(offset+size>image_size) { // Attempt to read data past EOF of morphed image file to_read=image_size-offset; LOG_DEBUG("Attempt to read data past EOF of morphed image. Corrected size " "from %zu to %zu.\n", size, to_read); } else to_read=size; // Read data from morphed image ret=glob_xmount.morphing.p_functions->Read(glob_xmount.morphing.p_handle, p_buf, offset, to_read, &read); if(ret!=0) { LOG_ERROR("Couldn't read %zu bytes at offset %zu from morphed image: %s!\n", to_read, offset, glob_xmount.morphing.p_functions->GetErrorMessage(ret)); return -EIO; } *p_read=to_read; return TRUE; } //! Read data from virtual image /*! * \param p_buf Pointer to buffer to write read data to * \param offset Offset at which data should be read * \param size Size of data which should be read * \return Number of read bytes on success or negated error code on error */ static int GetVirtImageData(char *p_buf, off_t offset, size_t size) { uint32_t cur_block=0; uint64_t morphed_image_size, virt_image_size; size_t read, to_read=0, cur_to_read=0; off_t file_off=offset, block_off=0; size_t to_read_later=0; int ret; // Get virtual image size if(GetVirtImageSize(&virt_image_size)!=TRUE) { LOG_ERROR("Couldn't get size of virtual image!\n") return -EIO; } if(offset>=virt_image_size) { LOG_DEBUG("Offset %zu is at / beyond size of virtual image.\n",offset); return 0; } if(offset+size>virt_image_size) { LOG_DEBUG("Attempt to read data past EOF of virtual image. Corrected size " "from %zu to %zu.\n", size, virt_image_size-offset); size=virt_image_size-offset; } to_read=size; // Get morphed image size if(GetMorphedImageSize(&morphed_image_size)!=TRUE) { LOG_ERROR("Couldn't get morphed image size!") return -EIO; } // Read virtual image type specific data preceeding morphed image data switch(glob_xmount.output.VirtImageType) { case VirtImageType_DD: case VirtImageType_DMG: case VirtImageType_VMDK: case VirtImageType_VMDKS: break; case VirtImageType_VDI: if(file_offglob_xmount.output.vdi.vdi_header_size) { cur_to_read=glob_xmount.output.vdi.vdi_header_size-file_off; } else { cur_to_read=to_read; } if(glob_xmount.output.writable==TRUE && glob_xmount.cache.p_cache_header->VdiFileHeaderCached==TRUE) { // VDI header was already cached if(fseeko(glob_xmount.cache.h_cache_file, glob_xmount.cache.p_cache_header->pVdiFileHeader+file_off, SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to cached VDI header at offset %" PRIu64 "\n", glob_xmount.cache.p_cache_header->pVdiFileHeader+file_off) return -EIO; } if(fread(p_buf,cur_to_read,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't read %zu bytes from cache file at offset %" PRIu64 "\n", cur_to_read, glob_xmount.cache.p_cache_header->pVdiFileHeader+file_off) return -EIO; } LOG_DEBUG("Read %zd bytes from cached VDI header at offset %" PRIu64 " at cache file offset %" PRIu64 "\n", cur_to_read, file_off, glob_xmount.cache.p_cache_header->pVdiFileHeader+file_off) } else { // VDI header isn't cached memcpy(p_buf, ((char*)glob_xmount.output.vdi.p_vdi_header)+file_off, cur_to_read); LOG_DEBUG("Read %zd bytes at offset %" PRIu64 " from virtual VDI header\n",cur_to_read, file_off) } if(to_read==cur_to_read) return to_read; else { // Adjust values to read from morphed image to_read-=cur_to_read; p_buf+=cur_to_read; file_off=0; } } else file_off-=glob_xmount.output.vdi.vdi_header_size; break; case VirtImageType_VHD: // When emulating VHD, make sure the while loop below only reads data // available in the morphed image. Any VHD footer data must be read // afterwards. if(file_off>=morphed_image_size) { to_read_later=to_read; to_read=0; } else if((file_off+to_read)>morphed_image_size) { to_read_later=(file_off+to_read)-morphed_image_size; to_read-=to_read_later; } break; } // Calculate block to read data from cur_block=file_off/CACHE_BLOCK_SIZE; block_off=file_off%CACHE_BLOCK_SIZE; // Read image data while(to_read!=0) { // Calculate how many bytes we have to read from this block if(block_off+to_read>CACHE_BLOCK_SIZE) { cur_to_read=CACHE_BLOCK_SIZE-block_off; } else cur_to_read=to_read; if(glob_xmount.output.writable==TRUE && glob_xmount.cache.p_cache_blkidx[cur_block].Assigned==TRUE) { // Write support enabled and need to read altered data from cachefile if(fseeko(glob_xmount.cache.h_cache_file, glob_xmount.cache.p_cache_blkidx[cur_block].off_data+block_off, SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to offset %" PRIu64 " in cache file\n") return -EIO; } if(fread(p_buf,cur_to_read,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't read data from cache file!\n") return -EIO; } LOG_DEBUG("Read %zd bytes at offset %" PRIu64 " from cache file\n",cur_to_read,file_off) } else { // No write support or data not cached ret=GetMorphedImageData(p_buf,file_off,cur_to_read,&read); if(ret!=TRUE || read!=cur_to_read) { LOG_ERROR("Couldn't read data from virtual image!\n") return -EIO; } LOG_DEBUG("Read %zu bytes at offset %zu from virtual image file\n", cur_to_read, file_off); } cur_block++; block_off=0; p_buf+=cur_to_read; to_read-=cur_to_read; file_off+=cur_to_read; } if(to_read_later!=0) { // Read virtual image type specific data following morphed image data switch(glob_xmount.output.VirtImageType) { case VirtImageType_DD: case VirtImageType_DMG: case VirtImageType_VMDK: case VirtImageType_VMDKS: case VirtImageType_VDI: break; case VirtImageType_VHD: // Micro$oft has choosen to use a footer rather then a header. if(glob_xmount.output.writable==TRUE && glob_xmount.cache.p_cache_header->VhdFileHeaderCached==TRUE) { // VHD footer was already cached if(fseeko(glob_xmount.cache.h_cache_file, glob_xmount.cache.p_cache_header->pVhdFileHeader+ (file_off-morphed_image_size), SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to cached VHD footer at offset %" PRIu64 "\n", glob_xmount.cache.p_cache_header->pVhdFileHeader+ (file_off-morphed_image_size)) return -EIO; } if(fread(p_buf,to_read_later,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't read %zu bytes from cache file at offset %" PRIu64 "\n", to_read_later, glob_xmount.cache.p_cache_header->pVhdFileHeader+ (file_off-morphed_image_size)) return -EIO; } LOG_DEBUG("Read %zd bytes from cached VHD footer at offset %" PRIu64 " at cache file offset %" PRIu64 "\n", to_read_later, (file_off-morphed_image_size), glob_xmount.cache.p_cache_header->pVhdFileHeader+ (file_off-morphed_image_size)) } else { // VHD header isn't cached memcpy(p_buf, ((char*)glob_xmount.output.vhd.p_vhd_header)+ (file_off-morphed_image_size), to_read_later); LOG_DEBUG("Read %zd bytes at offset %" PRIu64 " from virtual VHD header\n", to_read_later, (file_off-morphed_image_size)) } break; } } return size; } //! Write data to virtual VDI file header /*! * \param p_buf Buffer containing data to write * \param offset Offset of changes * \param size Amount of bytes to write * \return Number of written bytes on success or "-1" on error */ static int SetVdiFileHeaderData(char *p_buf,off_t offset,size_t size) { if(offset+size>glob_xmount.output.vdi.vdi_header_size) { size=glob_xmount.output.vdi.vdi_header_size-offset; } LOG_DEBUG("Need to cache %zu bytes at offset %" PRIu64 " from VDI header\n", size, offset); if(glob_xmount.cache.p_cache_header->VdiFileHeaderCached==1) { // Header was already cached if(fseeko(glob_xmount.cache.h_cache_file, glob_xmount.cache.p_cache_header->pVdiFileHeader+offset, SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to cached VDI header at address %" PRIu64 "\n", glob_xmount.cache.p_cache_header->pVdiFileHeader+offset) return -1; } if(fwrite(p_buf,size,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't write %zu bytes to cache file at offset %" PRIu64 "\n", size, glob_xmount.cache.p_cache_header->pVdiFileHeader+offset) return -1; } LOG_DEBUG("Wrote %zd bytes at offset %" PRIu64 " to cache file\n", size, glob_xmount.cache.p_cache_header->pVdiFileHeader+offset) } else { // Header wasn't already cached. if(fseeko(glob_xmount.cache.h_cache_file, 0, SEEK_END)!=0) { LOG_ERROR("Couldn't seek to end of cache file!") return -1; } glob_xmount.cache.p_cache_header->pVdiFileHeader= ftello(glob_xmount.cache.h_cache_file); LOG_DEBUG("Caching whole VDI header\n") if(offset>0) { // Changes do not begin at offset 0, need to prepend with data from // VDI header if(fwrite((char*)glob_xmount.output.vdi.p_vdi_header, offset, 1, glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Error while writing %" PRIu64 " bytes " "to cache file at offset %" PRIu64 "!\n", offset, glob_xmount.cache.p_cache_header->pVdiFileHeader); return -1; } LOG_DEBUG("Prepended changed data with %" PRIu64 " bytes at cache file offset %" PRIu64 "\n", offset, glob_xmount.cache.p_cache_header->pVdiFileHeader) } // Cache changed data if(fwrite(p_buf,size,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't write %zu bytes to cache file at offset %" PRIu64 "\n",size, glob_xmount.cache.p_cache_header->pVdiFileHeader+offset) return -1; } LOG_DEBUG("Wrote %zu bytes of changed data to cache file offset %" PRIu64 "\n", size, glob_xmount.cache.p_cache_header->pVdiFileHeader+offset) if(offset+size!=glob_xmount.output.vdi.vdi_header_size) { // Need to append data from VDI header to cache whole data struct if(fwrite(((char*)glob_xmount.output.vdi.p_vdi_header)+offset+size, glob_xmount.output.vdi.vdi_header_size-(offset+size), 1, glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't write %zu bytes to cache file at offset %" PRIu64 "\n", glob_xmount.output.vdi.vdi_header_size-(offset+size), (uint64_t)(glob_xmount.cache.p_cache_header->pVdiFileHeader+ offset+size)); return -1; } LOG_DEBUG("Appended %" PRIu32 " bytes to changed data at cache file offset %" PRIu64 "\n", glob_xmount.output.vdi.vdi_header_size-(offset+size), glob_xmount.cache.p_cache_header->pVdiFileHeader+offset+size) } // Mark header as cached and update header in cache file glob_xmount.cache.p_cache_header->VdiFileHeaderCached=1; if(fseeko(glob_xmount.cache.h_cache_file,0,SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to offset 0 of cache file!\n") return -1; } if(fwrite((char*)glob_xmount.cache.p_cache_header, sizeof(ts_CacheFileHeader), 1, glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't write changed cache file header!\n") return -1; } } // All important data has been written, now flush all buffers to make // sure data is written to cache file fflush(glob_xmount.cache.h_cache_file); #ifndef __APPLE__ ioctl(fileno(glob_xmount.cache.h_cache_file),BLKFLSBUF,0); #endif return size; } //! Write data to virtual VHD file footer /*! * \param p_buf Buffer containing data to write * \param offset Offset of changes * \param size Amount of bytes to write * \return Number of written bytes on success or "-1" on error */ static int SetVhdFileHeaderData(char *p_buf,off_t offset,size_t size) { LOG_DEBUG("Need to cache %zu bytes at offset %" PRIu64 " from VHD footer\n",size,offset) if(glob_xmount.cache.p_cache_header->VhdFileHeaderCached==1) { // Header has already been cached if(fseeko(glob_xmount.cache.h_cache_file, glob_xmount.cache.p_cache_header->pVhdFileHeader+offset, SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to cached VHD header at address %" PRIu64 "\n", glob_xmount.cache.p_cache_header->pVhdFileHeader+offset); return -1; } if(fwrite(p_buf,size,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't write %zu bytes to cache file at offset %" PRIu64 "\n", size, glob_xmount.cache.p_cache_header->pVhdFileHeader+offset); return -1; } LOG_DEBUG("Wrote %zd bytes at offset %" PRIu64 " to cache file\n", size, glob_xmount.cache.p_cache_header->pVhdFileHeader+offset); } else { // Header hasn't been cached yet. if(fseeko(glob_xmount.cache.h_cache_file, 0, SEEK_END)!=0) { LOG_ERROR("Couldn't seek to end of cache file!") return -1; } glob_xmount.cache.p_cache_header->pVhdFileHeader= ftello(glob_xmount.cache.h_cache_file); LOG_DEBUG("Caching whole VHD header\n") if(offset>0) { // Changes do not begin at offset 0, need to prepend with data from // VHD header if(fwrite((char*)glob_xmount.output.vhd.p_vhd_header, offset, 1, glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Error while writing %" PRIu64 " bytes " "to cache file at offset %" PRIu64 "!\n", offset, glob_xmount.cache.p_cache_header->pVhdFileHeader); return -1; } LOG_DEBUG("Prepended changed data with %" PRIu64 " bytes at cache file offset %" PRIu64 "\n", offset, glob_xmount.cache.p_cache_header->pVhdFileHeader); } // Cache changed data if(fwrite(p_buf,size,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't write %zu bytes to cache file at offset %" PRIu64 "\n", size, glob_xmount.cache.p_cache_header->pVhdFileHeader+offset); return -1; } LOG_DEBUG("Wrote %zu bytes of changed data to cache file offset %" PRIu64 "\n", size, glob_xmount.cache.p_cache_header->pVhdFileHeader+offset); if(offset+size!=sizeof(ts_VhdFileHeader)) { // Need to append data from VHD header to cache whole data struct if(fwrite(((char*)glob_xmount.output.vhd.p_vhd_header)+offset+size, sizeof(ts_VhdFileHeader)-(offset+size), 1, glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't write %zu bytes to cache file at offset %" PRIu64 "\n", sizeof(ts_VhdFileHeader)-(offset+size), (uint64_t)(glob_xmount.cache.p_cache_header->pVhdFileHeader+ offset+size)) return -1; } LOG_DEBUG("Appended %" PRIu32 " bytes to changed data at cache file offset %" PRIu64 "\n", sizeof(ts_VhdFileHeader)-(offset+size), glob_xmount.cache.p_cache_header->pVhdFileHeader+offset+size); } // Mark header as cached and update header in cache file glob_xmount.cache.p_cache_header->VhdFileHeaderCached=1; if(fseeko(glob_xmount.cache.h_cache_file,0,SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to offset 0 of cache file!\n") return -1; } if(fwrite((char*)glob_xmount.cache.p_cache_header, sizeof(ts_CacheFileHeader), 1, glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't write changed cache file header!\n") return -1; } } // All important data has been written, now flush all buffers to make // sure data is written to cache file fflush(glob_xmount.cache.h_cache_file); #ifndef __APPLE__ ioctl(fileno(glob_xmount.cache.h_cache_file),BLKFLSBUF,0); #endif return size; } //! Write data to virtual image /*! * \param p_buf Buffer containing data to write * \param offset Offset to start writing at * \param size Size of data to be written * \return Number of written bytes on success or "-1" on error */ static int SetVirtImageData(const char *p_buf, off_t offset, size_t size) { uint64_t cur_block=0; uint64_t virt_image_size; uint64_t orig_image_size; size_t to_write=0; size_t to_write_later=0; size_t to_write_now=0; off_t file_offset=offset; off_t block_offset=0; char *p_write_buf=(char*)p_buf; char *p_buf2; int ret; size_t read; // Get virtual image size if(!GetVirtImageSize(&virt_image_size)) { LOG_ERROR("Couldn't get virtual image size!\n") return -1; } if(offset>=virt_image_size) { LOG_ERROR("Attempt to write beyond EOF of virtual image file!\n") return -1; } if(offset+size>virt_image_size) { LOG_DEBUG("Attempt to write past EOF of virtual image file\n") size=virt_image_size-offset; } to_write=size; // Get original image size if(!GetMorphedImageSize(&orig_image_size)) { LOG_ERROR("Couldn't get morphed image size!\n") return -1; } // Cache virtual image type specific data preceeding original image data switch(glob_xmount.output.VirtImageType) { case VirtImageType_DD: case VirtImageType_DMG: case VirtImageType_VMDK: case VirtImageType_VMDKS: break; case VirtImageType_VDI: if(file_offset=orig_image_size) { to_write_later=to_write; to_write=0; } else if((file_offset+to_write)>orig_image_size) { to_write_later=(file_offset+to_write)-orig_image_size; to_write-=to_write_later; } break; } // Calculate block to write data to cur_block=file_offset/CACHE_BLOCK_SIZE; block_offset=file_offset%CACHE_BLOCK_SIZE; while(to_write!=0) { // Calculate how many bytes we have to write to this block if(block_offset+to_write>CACHE_BLOCK_SIZE) { to_write_now=CACHE_BLOCK_SIZE-block_offset; } else to_write_now=to_write; if(glob_xmount.cache.p_cache_blkidx[cur_block].Assigned==1) { // Block was already cached // Seek to data offset in cache file if(fseeko(glob_xmount.cache.h_cache_file, glob_xmount.cache.p_cache_blkidx[cur_block].off_data+block_offset, SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to cached block at address %" PRIu64 "\n", glob_xmount.cache.p_cache_blkidx[cur_block].off_data+ block_offset); return -1; } if(fwrite(p_write_buf,to_write_now,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Error while writing %zu bytes " "to cache file at offset %" PRIu64 "!\n", to_write_now, glob_xmount.cache.p_cache_blkidx[cur_block].off_data+ block_offset); return -1; } LOG_DEBUG("Wrote %zd bytes at offset %" PRIu64 " to cache file\n",to_write_now, glob_xmount.cache.p_cache_blkidx[cur_block].off_data+ block_offset); } else { // Uncached block. Need to cache entire new block // Seek to end of cache file to append new cache block fseeko(glob_xmount.cache.h_cache_file,0,SEEK_END); glob_xmount.cache.p_cache_blkidx[cur_block].off_data= ftello(glob_xmount.cache.h_cache_file); if(block_offset!=0) { // Changed data does not begin at block boundry. Need to prepend // with data from virtual image file XMOUNT_MALLOC(p_buf2,char*,block_offset*sizeof(char)); ret=GetMorphedImageData(p_buf2, file_offset-block_offset, block_offset, &read); if(ret!=TRUE || read!=block_offset) { LOG_ERROR("Couldn't read data from morphed image!\n") return -1; } if(fwrite(p_buf2,block_offset,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't writing %" PRIu64 " bytes " "to cache file at offset %" PRIu64 "!\n", block_offset, glob_xmount.cache.p_cache_blkidx[cur_block].off_data); return -1; } LOG_DEBUG("Prepended changed data with %" PRIu64 " bytes from virtual image file at offset %" PRIu64 "\n",block_offset,file_offset-block_offset) free(p_buf2); } if(fwrite(p_write_buf,to_write_now,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Error while writing %zd bytes " "to cache file at offset %" PRIu64 "!\n", to_write_now, glob_xmount.cache.p_cache_blkidx[cur_block].off_data+ block_offset); return -1; } if(block_offset+to_write_now!=CACHE_BLOCK_SIZE) { // Changed data does not end at block boundry. Need to append // with data from virtual image file XMOUNT_MALLOC(p_buf2,char*,(CACHE_BLOCK_SIZE- (block_offset+to_write_now))*sizeof(char)) memset(p_buf2,0,CACHE_BLOCK_SIZE-(block_offset+to_write_now)); if((file_offset-block_offset)+CACHE_BLOCK_SIZE>orig_image_size) { // Original image is smaller than full cache block ret=GetMorphedImageData(p_buf2, file_offset+to_write_now, orig_image_size-(file_offset+to_write_now), &read); if(ret!=TRUE || read!=orig_image_size-(file_offset+to_write_now)) { LOG_ERROR("Couldn't read data from virtual image file!\n") return -1; } } else { ret=GetMorphedImageData(p_buf2, file_offset+to_write_now, CACHE_BLOCK_SIZE-(block_offset+to_write_now), &read); if(ret!=TRUE || read!=CACHE_BLOCK_SIZE-(block_offset+to_write_now)) { LOG_ERROR("Couldn't read data from virtual image file!\n") return -1; } } if(fwrite(p_buf2, CACHE_BLOCK_SIZE-(block_offset+to_write_now), 1, glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Error while writing %zd bytes " "to cache file at offset %" PRIu64 "!\n", CACHE_BLOCK_SIZE-(block_offset+to_write_now), glob_xmount.cache.p_cache_blkidx[cur_block].off_data+ block_offset+to_write_now); return -1; } free(p_buf2); } // All important data for this cache block has been written, // flush all buffers and mark cache block as assigned fflush(glob_xmount.cache.h_cache_file); #ifndef __APPLE__ ioctl(fileno(glob_xmount.cache.h_cache_file),BLKFLSBUF,0); #endif glob_xmount.cache.p_cache_blkidx[cur_block].Assigned=1; // Update cache block index entry in cache file fseeko(glob_xmount.cache.h_cache_file, sizeof(ts_CacheFileHeader)+ (cur_block*sizeof(ts_CacheFileBlockIndex)), SEEK_SET); if(fwrite(&(glob_xmount.cache.p_cache_blkidx[cur_block]), sizeof(ts_CacheFileBlockIndex), 1, glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't update cache file block index!\n"); return -1; } LOG_DEBUG("Updated cache file block index: Number=%" PRIu64 ", Data offset=%" PRIu64 "\n", cur_block, glob_xmount.cache.p_cache_blkidx[cur_block].off_data); } // Flush buffers fflush(glob_xmount.cache.h_cache_file); #ifndef __APPLE__ ioctl(fileno(glob_xmount.cache.h_cache_file),BLKFLSBUF,0); #endif block_offset=0; cur_block++; p_write_buf+=to_write_now; to_write-=to_write_now; file_offset+=to_write_now; } if(to_write_later!=0) { // Cache virtual image type specific data preceeding original image data switch(glob_xmount.output.VirtImageType) { case VirtImageType_DD: case VirtImageType_DMG: case VirtImageType_VMDK: case VirtImageType_VMDKS: case VirtImageType_VDI: break; case VirtImageType_VHD: // Micro$oft has choosen to use a footer rather then a header. ret=SetVhdFileHeaderData(p_write_buf, file_offset-orig_image_size, to_write_later); if(ret==-1) { LOG_ERROR("Couldn't write data to virtual VHD file footer!\n") return -1; } break; } } return size; } //! Calculates an MD5 hash of the first HASH_AMOUNT bytes of the input image /*! * \param p_hash_low Pointer to the lower 64 bit of the hash * \param p_hash_high Pointer to the higher 64 bit of the hash * \return TRUE on success, FALSE on error */ static int CalculateInputImageHash(uint64_t *p_hash_low, uint64_t *p_hash_high) { char hash[16]; md5_state_t md5_state; char *p_buf; int ret; size_t read_data; XMOUNT_MALLOC(p_buf,char*,HASH_AMOUNT*sizeof(char)); ret=GetMorphedImageData(p_buf,0,HASH_AMOUNT,&read_data); if(ret!=TRUE || read_data==0) { LOG_ERROR("Couldn't read data from morphed image file!\n") free(p_buf); return FALSE; } // Calculate MD5 hash md5_init(&md5_state); md5_append(&md5_state,(const md5_byte_t*)p_buf,read_data); md5_finish(&md5_state,(md5_byte_t*)hash); // Convert MD5 hash into two 64bit integers *p_hash_low=*((uint64_t*)hash); *p_hash_high=*((uint64_t*)(hash+8)); free(p_buf); return TRUE; } //! Build and init virtual VDI file header /*! * \return TRUE on success, FALSE on error */ static int InitVirtVdiHeader() { // See http://forums.virtualbox.org/viewtopic.php?t=8046 for a // "description" of the various header fields uint64_t image_size; off_t offset; uint32_t i,block_entries; // Get input image size if(!GetMorphedImageSize(&image_size)) { LOG_ERROR("Couldn't get morphed image size!\n") return FALSE; } // Calculate how many VDI blocks we need block_entries=image_size/VDI_IMAGE_BLOCK_SIZE; if((image_size%VDI_IMAGE_BLOCK_SIZE)!=0) block_entries++; glob_xmount.output.vdi.vdi_block_map_size=block_entries*sizeof(uint32_t); LOG_DEBUG("BlockMap: %d (%08X) entries, %d (%08X) bytes!\n", block_entries, block_entries, glob_xmount.output.vdi.vdi_block_map_size, glob_xmount.output.vdi.vdi_block_map_size) // Allocate memory for vdi header and block map glob_xmount.output.vdi.vdi_header_size= sizeof(ts_VdiFileHeader)+glob_xmount.output.vdi.vdi_block_map_size; XMOUNT_MALLOC(glob_xmount.output.vdi.p_vdi_header, pts_VdiFileHeader, glob_xmount.output.vdi.vdi_header_size); memset(glob_xmount.output.vdi.p_vdi_header, 0, glob_xmount.output.vdi.vdi_header_size); glob_xmount.output.vdi.p_vdi_block_map= ((void*)glob_xmount.output.vdi.p_vdi_header)+sizeof(ts_VdiFileHeader); // Init header values strncpy(glob_xmount.output.vdi.p_vdi_header->szFileInfo, VDI_FILE_COMMENT, strlen(VDI_FILE_COMMENT)+1); glob_xmount.output.vdi.p_vdi_header->u32Signature=VDI_IMAGE_SIGNATURE; glob_xmount.output.vdi.p_vdi_header->u32Version=VDI_IMAGE_VERSION; // No idea what the following value is for! Testimage had same value glob_xmount.output.vdi.p_vdi_header->cbHeader=0x00000180; glob_xmount.output.vdi.p_vdi_header->u32Type=VDI_IMAGE_TYPE_FIXED; glob_xmount.output.vdi.p_vdi_header->fFlags=VDI_IMAGE_FLAGS; strncpy(glob_xmount.output.vdi.p_vdi_header->szComment, VDI_HEADER_COMMENT, strlen(VDI_HEADER_COMMENT)+1); glob_xmount.output.vdi.p_vdi_header->offData= glob_xmount.output.vdi.vdi_header_size; glob_xmount.output.vdi.p_vdi_header->offBlocks=sizeof(ts_VdiFileHeader); glob_xmount.output.vdi.p_vdi_header->cCylinders=0; // Legacy info glob_xmount.output.vdi.p_vdi_header->cHeads=0; // Legacy info glob_xmount.output.vdi.p_vdi_header->cSectors=0; // Legacy info glob_xmount.output.vdi.p_vdi_header->cbSector=512; // Legacy info glob_xmount.output.vdi.p_vdi_header->u32Dummy=0; glob_xmount.output.vdi.p_vdi_header->cbDisk=image_size; // Seems as VBox is always using a 1MB blocksize glob_xmount.output.vdi.p_vdi_header->cbBlock=VDI_IMAGE_BLOCK_SIZE; glob_xmount.output.vdi.p_vdi_header->cbBlockExtra=0; glob_xmount.output.vdi.p_vdi_header->cBlocks=block_entries; glob_xmount.output.vdi.p_vdi_header->cBlocksAllocated=block_entries; // Use partial MD5 input file hash as creation UUID and generate a random // modification UUID. VBox won't accept immages where create and modify UUIDS // aren't set. glob_xmount.output.vdi.p_vdi_header->uuidCreate_l= glob_xmount.input.image_hash_lo; glob_xmount.output.vdi.p_vdi_header->uuidCreate_h= glob_xmount.input.image_hash_hi; #define rand64(var) { \ *((uint32_t*)&(var))=rand(); \ *(((uint32_t*)&(var))+1)=rand(); \ } rand64(glob_xmount.output.vdi.p_vdi_header->uuidModify_l); rand64(glob_xmount.output.vdi.p_vdi_header->uuidModify_h); #undef rand64 // Generate block map i=0; for(offset=0;offsetcookie=VHD_IMAGE_HVAL_COOKIE; glob_xmount.output.vhd.p_vhd_header->features=VHD_IMAGE_HVAL_FEATURES; glob_xmount.output.vhd.p_vhd_header->file_format_version= VHD_IMAGE_HVAL_FILE_FORMAT_VERSION; glob_xmount.output.vhd.p_vhd_header->data_offset=VHD_IMAGE_HVAL_DATA_OFFSET; glob_xmount.output.vhd.p_vhd_header->creation_time= htobe32(time(NULL)-VHD_IMAGE_TIME_CONVERSION_OFFSET); glob_xmount.output.vhd.p_vhd_header->creator_app= VHD_IMAGE_HVAL_CREATOR_APPLICATION; glob_xmount.output.vhd.p_vhd_header->creator_ver= VHD_IMAGE_HVAL_CREATOR_VERSION; glob_xmount.output.vhd.p_vhd_header->creator_os= VHD_IMAGE_HVAL_CREATOR_HOST_OS; glob_xmount.output.vhd.p_vhd_header->size_original=htobe64(orig_image_size); glob_xmount.output.vhd.p_vhd_header->size_current= glob_xmount.output.vhd.p_vhd_header->size_original; // Convert size to sectors if(orig_image_size>136899993600) { // image is larger then CHS values can address. // Set sectors to max (C65535*H16*S255). geom_tot_s=267382800; } else { // Calculate actual sectors geom_tot_s=orig_image_size/512; if((orig_image_size%512)!=0) geom_tot_s++; } // Calculate CHS values. This is done according to the VHD specs if(geom_tot_s>=66059280) { // C65535 * H16 * S63 geom_s=255; geom_h=16; geom_c_x_h=geom_tot_s/geom_s; } else { geom_s=17; geom_c_x_h=geom_tot_s/geom_s; geom_h=(geom_c_x_h+1023)/1024; if(geom_h<4) geom_h=4; if(geom_c_x_h>=(geom_h*1024) || geom_h>16) { geom_s=31; geom_h=16; geom_c_x_h=geom_tot_s/geom_s; } if(geom_c_x_h>=(geom_h*1024)) { geom_s=63; geom_h=16; geom_c_x_h=geom_tot_s/geom_s; } } geom_c=geom_c_x_h/geom_h; glob_xmount.output.vhd.p_vhd_header->disk_geometry_c=htobe16(geom_c); glob_xmount.output.vhd.p_vhd_header->disk_geometry_h=geom_h; glob_xmount.output.vhd.p_vhd_header->disk_geometry_s=geom_s; glob_xmount.output.vhd.p_vhd_header->disk_type=VHD_IMAGE_HVAL_DISK_TYPE; glob_xmount.output.vhd.p_vhd_header->uuid_l=glob_xmount.input.image_hash_lo; glob_xmount.output.vhd.p_vhd_header->uuid_h=glob_xmount.input.image_hash_hi; glob_xmount.output.vhd.p_vhd_header->saved_state=0x00; // Calculate footer checksum for(i=0;ichecksum=htobe32(~checksum); LOG_DEBUG("VHD header size = %u\n",sizeof(ts_VhdFileHeader)); return TRUE; } //! Init the virtual VMDK file /*! * \return TRUE on success, FALSE on error */ static int InitVirtualVmdkFile() { uint64_t image_size=0; uint64_t image_blocks=0; char buf[500]; // Get original image size if(!GetMorphedImageSize(&image_size)) { LOG_ERROR("Couldn't get morphed image size!\n") return FALSE; } image_blocks=image_size/512; if(image_size%512!=0) image_blocks++; #define VMDK_DESC_FILE "# Disk DescriptorFile\n" \ "version=1\n" \ "CID=fffffffe\n" \ "parentCID=ffffffff\n" \ "createType=\"monolithicFlat\"\n\n" \ "# Extent description\n" \ "RW %" PRIu64 " FLAT \"%s\" 0\n\n" \ "# The Disk Data Base\n" \ "#DDB\n" \ "ddb.virtualHWVersion = \"3\"\n" \ "ddb.adapterType = \"%s\"\n" \ "ddb.geometry.cylinders = \"0\"\n" \ "ddb.geometry.heads = \"0\"\n" \ "ddb.geometry.sectors = \"0\"\n" if(glob_xmount.output.VirtImageType==VirtImageType_VMDK) { // VMDK with IDE bus sprintf(buf, VMDK_DESC_FILE, image_blocks, (glob_xmount.output.p_virtual_image_path)+1, "ide"); } else if(glob_xmount.output.VirtImageType==VirtImageType_VMDKS){ // VMDK with SCSI bus sprintf(buf, VMDK_DESC_FILE, image_blocks, (glob_xmount.output.p_virtual_image_path)+1, "scsi"); } else { LOG_ERROR("Unknown virtual VMDK file format!\n") return FALSE; } #undef VMDK_DESC_FILE // Do not use XMOUNT_STRSET here to avoid adding '\0' to the buffer! XMOUNT_MALLOC(glob_xmount.output.vmdk.p_vmdk_file,char*,strlen(buf)) strncpy(glob_xmount.output.vmdk.p_vmdk_file,buf,strlen(buf)); glob_xmount.output.vmdk.vmdk_file_size=strlen(buf); return TRUE; } //! Create virtual image info file /*! * \return TRUE on success, FALSE on error */ static int InitVirtImageInfoFile() { int ret; char *p_buf; // Start with static input header XMOUNT_MALLOC(glob_xmount.output.p_info_file, char*, strlen(IMAGE_INFO_INPUT_HEADER)+1); strncpy(glob_xmount.output.p_info_file, IMAGE_INFO_INPUT_HEADER, strlen(IMAGE_INFO_INPUT_HEADER)+1); // Get and add infos from input lib(s) for(uint64_t i=0;ip_functions-> GetInfofileContent(glob_xmount.input.pp_images[i]->p_handle,(const char**)&p_buf); if(ret!=0) { LOG_ERROR("Unable to get info file content for image '%s': %s!\n", glob_xmount.input.pp_images[i]->pp_files[0], glob_xmount.input.pp_images[i]->p_functions-> GetErrorMessage(ret)); return FALSE; } // Add infos to main buffer and free p_buf XMOUNT_STRAPP(glob_xmount.output.p_info_file,"\n--> "); XMOUNT_STRAPP(glob_xmount.output.p_info_file, glob_xmount.input.pp_images[i]->pp_files[0]); XMOUNT_STRAPP(glob_xmount.output.p_info_file," <--\n"); if(p_buf!=NULL) { XMOUNT_STRAPP(glob_xmount.output.p_info_file,p_buf); glob_xmount.input.pp_images[i]->p_functions->FreeBuffer(p_buf); } else { XMOUNT_STRAPP(glob_xmount.output.p_info_file,"None\n"); } } // Add static morphing header XMOUNT_STRAPP(glob_xmount.output.p_info_file,IMAGE_INFO_MORPHING_HEADER); // Get and add infos from morphing lib ret=glob_xmount.morphing.p_functions-> - GetInfofileContent(glob_xmount.morphing.p_handle,&p_buf); + GetInfofileContent(glob_xmount.morphing.p_handle,(const char**)&p_buf); if(ret!=0) { LOG_ERROR("Unable to get info file content from morphing lib: %s!\n", glob_xmount.morphing.p_functions->GetErrorMessage(ret)); return FALSE; } if(p_buf!=NULL) { XMOUNT_STRAPP(glob_xmount.output.p_info_file,p_buf); glob_xmount.morphing.p_functions->FreeBuffer(p_buf); } else { XMOUNT_STRAPP(glob_xmount.output.p_info_file,"None\n"); } return TRUE; } //! Create / load cache file to enable virtual write support /*! * \return TRUE on success, FALSE on error */ static int InitCacheFile() { uint64_t image_size=0; uint64_t blockindex_size=0; uint64_t cachefile_header_size=0; uint64_t cachefile_size=0; uint32_t needed_blocks=0; uint64_t buf; if(!glob_xmount.cache.overwrite_cache) { // Try to open an existing cache file or create a new one glob_xmount.cache.h_cache_file=(FILE*)FOPEN(glob_xmount.cache.p_cache_file, "rb+"); if(glob_xmount.cache.h_cache_file==NULL) { // As the c lib seems to have no possibility to open a file rw wether it // exists or not (w+ does not work because it truncates an existing file), // when r+ returns NULL the file could simply not exist LOG_DEBUG("Cache file does not exist. Creating new one\n") glob_xmount.cache.h_cache_file= (FILE*)FOPEN(glob_xmount.cache.p_cache_file,"wb+"); if(glob_xmount.cache.h_cache_file==NULL) { // There is really a problem opening the file LOG_ERROR("Couldn't open cache file \"%s\"!\n", glob_xmount.cache.p_cache_file) return FALSE; } } } else { // Overwrite existing cache file or create a new one glob_xmount.cache.h_cache_file=(FILE*)FOPEN(glob_xmount.cache.p_cache_file, "wb+"); if(glob_xmount.cache.h_cache_file==NULL) { LOG_ERROR("Couldn't open cache file \"%s\"!\n", glob_xmount.cache.p_cache_file) return FALSE; } } // Get input image size if(!GetMorphedImageSize(&image_size)) { LOG_ERROR("Couldn't get morphed image size!\n") return FALSE; } // Calculate how many blocks are needed and how big the buffers must be // for the actual cache file version needed_blocks=image_size/CACHE_BLOCK_SIZE; if((image_size%CACHE_BLOCK_SIZE)!=0) needed_blocks++; blockindex_size=needed_blocks*sizeof(ts_CacheFileBlockIndex); cachefile_header_size=sizeof(ts_CacheFileHeader)+blockindex_size; LOG_DEBUG("Cache blocks: %u (%04X) entries, %zd (%08zX) bytes\n", needed_blocks, needed_blocks, blockindex_size, blockindex_size) // Get cache file size // fseeko64 had massive problems! if(fseeko(glob_xmount.cache.h_cache_file,0,SEEK_END)!=0) { LOG_ERROR("Couldn't seek to end of cache file!\n") return FALSE; } // Same here, ftello64 didn't work at all and returned 0 all the times cachefile_size=ftello(glob_xmount.cache.h_cache_file); LOG_DEBUG("Cache file has %zd bytes\n",cachefile_size) if(cachefile_size>0) { // Cache file isn't empty, parse block header LOG_DEBUG("Cache file not empty. Parsing block header\n") if(fseeko(glob_xmount.cache.h_cache_file,0,SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to beginning of cache file!\n") return FALSE; } // Read and check file signature if(fread(&buf,8,1,glob_xmount.cache.h_cache_file)!=1 || buf!=CACHE_FILE_SIGNATURE) { LOG_ERROR("Not an xmount cache file or cache file corrupt!\n") return FALSE; } // Now get cache file version (Has only 32bit!) if(fread(&buf,4,1,glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Not an xmount cache file or cache file corrupt!\n") return FALSE; } switch((uint32_t)buf) { case 0x00000001: // Old v1 cache file. LOG_ERROR("Unsupported cache file version!\n") LOG_ERROR("Please use xmount-tool to upgrade your cache file.\n") return FALSE; case CUR_CACHE_FILE_VERSION: // Current version if(fseeko(glob_xmount.cache.h_cache_file,0,SEEK_SET)!=0) { LOG_ERROR("Couldn't seek to beginning of cache file!\n") return FALSE; } // Alloc memory for header and block index XMOUNT_MALLOC(glob_xmount.cache.p_cache_header, pts_CacheFileHeader, cachefile_header_size); memset(glob_xmount.cache.p_cache_header,0,cachefile_header_size); // Read header and block index from file if(fread(glob_xmount.cache.p_cache_header, cachefile_header_size, 1, glob_xmount.cache.h_cache_file)!=1) { // Cache file isn't big enough LOG_ERROR("Cache file corrupt!\n") return FALSE; } break; default: LOG_ERROR("Unknown cache file version!\n") return FALSE; } // Check if cache file has same block size as we do if(glob_xmount.cache.p_cache_header->BlockSize!=CACHE_BLOCK_SIZE) { LOG_ERROR("Cache file does not use default cache block size!\n") return FALSE; } // Set pointer to block index glob_xmount.cache.p_cache_blkidx= (pts_CacheFileBlockIndex)((void*)glob_xmount.cache.p_cache_header+ glob_xmount.cache.p_cache_header->pBlockIndex); } else { // New cache file, generate a new block header LOG_DEBUG("Cache file is empty. Generating new block header\n"); // Alloc memory for header and block index XMOUNT_MALLOC(glob_xmount.cache.p_cache_header, pts_CacheFileHeader, cachefile_header_size) memset(glob_xmount.cache.p_cache_header,0,cachefile_header_size); glob_xmount.cache.p_cache_header->FileSignature=CACHE_FILE_SIGNATURE; glob_xmount.cache.p_cache_header->CacheFileVersion=CUR_CACHE_FILE_VERSION; glob_xmount.cache.p_cache_header->BlockSize=CACHE_BLOCK_SIZE; glob_xmount.cache.p_cache_header->BlockCount=needed_blocks; //glob_xmount.cache.p_cache_header->UsedBlocks=0; // The following pointer is only usuable when reading data from cache file glob_xmount.cache.p_cache_header->pBlockIndex=sizeof(ts_CacheFileHeader); glob_xmount.cache.p_cache_blkidx= (pts_CacheFileBlockIndex)((void*)glob_xmount.cache.p_cache_header+ sizeof(ts_CacheFileHeader)); glob_xmount.cache.p_cache_header->VdiFileHeaderCached=FALSE; glob_xmount.cache.p_cache_header->pVdiFileHeader=0; glob_xmount.cache.p_cache_header->VmdkFileCached=FALSE; glob_xmount.cache.p_cache_header->VmdkFileSize=0; glob_xmount.cache.p_cache_header->pVmdkFile=0; glob_xmount.cache.p_cache_header->VhdFileHeaderCached=FALSE; glob_xmount.cache.p_cache_header->pVhdFileHeader=0; // Write header to file if(fwrite(glob_xmount.cache.p_cache_header, cachefile_header_size, 1, glob_xmount.cache.h_cache_file)!=1) { LOG_ERROR("Couldn't write cache file header to file!\n"); return FALSE; } } return TRUE; } //! Load input / morphing libs /*! * \return TRUE on success, FALSE on error */ static int LoadLibs() { DIR *p_dir=NULL; struct dirent *p_dirent=NULL; int base_library_path_len=0; char *p_library_path=NULL; void *p_libxmount=NULL; t_LibXmount_Input_GetApiVersion pfun_input_GetApiVersion; t_LibXmount_Input_GetSupportedFormats pfun_input_GetSupportedFormats; t_LibXmount_Input_GetFunctions pfun_input_GetFunctions; t_LibXmount_Morphing_GetApiVersion pfun_morphing_GetApiVersion; t_LibXmount_Morphing_GetSupportedTypes pfun_morphing_GetSupportedTypes; t_LibXmount_Morphing_GetFunctions pfun_morphing_GetFunctions; const char *p_supported_formats=NULL; const char *p_buf; uint32_t supported_formats_len=0; pts_InputLib p_input_lib=NULL; pts_MorphingLib p_morphing_lib=NULL; LOG_DEBUG("Searching for xmount libraries in '%s'.\n", XMOUNT_LIBRARY_PATH); // Open lib dir p_dir=opendir(XMOUNT_LIBRARY_PATH); if(p_dir==NULL) { LOG_ERROR("Unable to access xmount library directory '%s'!\n", XMOUNT_LIBRARY_PATH); return FALSE; } // Construct base library path base_library_path_len=strlen(XMOUNT_LIBRARY_PATH); XMOUNT_STRSET(p_library_path,XMOUNT_LIBRARY_PATH); if(XMOUNT_LIBRARY_PATH[base_library_path_len]!='/') { base_library_path_len++; XMOUNT_STRAPP(p_library_path,"/"); } #define LIBXMOUNT_LOAD(path) { \ p_libxmount=dlopen(path,RTLD_NOW); \ if(p_libxmount==NULL) { \ LOG_ERROR("Unable to load input library '%s': %s!\n", \ path, \ dlerror()); \ continue; \ } \ } #define LIBXMOUNT_LOAD_SYMBOL(name,pfun) { \ if((pfun=dlsym(p_libxmount,name))==NULL) { \ LOG_ERROR("Unable to load symbol '%s' from library '%s'!\n", \ name, \ p_library_path); \ dlclose(p_libxmount); \ p_libxmount=NULL; \ continue; \ } \ } // Loop over lib dir while((p_dirent=readdir(p_dir))!=NULL) { LOG_DEBUG("Trying to load '%s'\n",p_dirent->d_name); // Construct full path to found object p_library_path=realloc(p_library_path, base_library_path_len+strlen(p_dirent->d_name)+1); if(p_library_path==NULL) { LOG_ERROR("Couldn't allocate memmory!\n"); exit(1); } strcpy(p_library_path+base_library_path_len,p_dirent->d_name); if(strncmp(p_dirent->d_name,"libxmount_input_",16)==0) { // Found possible input lib. Try to load it LIBXMOUNT_LOAD(p_library_path); // Load library symbols LIBXMOUNT_LOAD_SYMBOL("LibXmount_Input_GetApiVersion", pfun_input_GetApiVersion); // Check library's API version if(pfun_input_GetApiVersion()!=LIBXMOUNT_INPUT_API_VERSION) { LOG_DEBUG("Failed! Wrong API version.\n"); LOG_ERROR("Unable to load input library '%s'. Wrong API version\n", p_library_path); dlclose(p_libxmount); continue; } LIBXMOUNT_LOAD_SYMBOL("LibXmount_Input_GetSupportedFormats", pfun_input_GetSupportedFormats); LIBXMOUNT_LOAD_SYMBOL("LibXmount_Input_GetFunctions", pfun_input_GetFunctions); // Construct new entry for our library list XMOUNT_MALLOC(p_input_lib,pts_InputLib,sizeof(ts_InputLib)); // Initialize lib_functions structure to NULL memset(&(p_input_lib->lib_functions), 0, sizeof(ts_LibXmountInputFunctions)); // Set name and handle XMOUNT_STRSET(p_input_lib->p_name,p_dirent->d_name); p_input_lib->p_lib=p_libxmount; // Get and set supported formats p_supported_formats=pfun_input_GetSupportedFormats(); supported_formats_len=0; p_buf=p_supported_formats; while(*p_buf!='\0') { supported_formats_len+=(strlen(p_buf)+1); p_buf+=(strlen(p_buf)+1); } supported_formats_len++; XMOUNT_MALLOC(p_input_lib->p_supported_input_types, char*, supported_formats_len); memcpy(p_input_lib->p_supported_input_types, p_supported_formats, supported_formats_len); // Get, set and check lib_functions pfun_input_GetFunctions(&(p_input_lib->lib_functions)); if(p_input_lib->lib_functions.CreateHandle==NULL || p_input_lib->lib_functions.DestroyHandle==NULL || p_input_lib->lib_functions.Open==NULL || p_input_lib->lib_functions.Close==NULL || p_input_lib->lib_functions.Size==NULL || p_input_lib->lib_functions.Read==NULL || p_input_lib->lib_functions.OptionsHelp==NULL || p_input_lib->lib_functions.OptionsParse==NULL || p_input_lib->lib_functions.GetInfofileContent==NULL || p_input_lib->lib_functions.GetErrorMessage==NULL || p_input_lib->lib_functions.FreeBuffer==NULL) { LOG_DEBUG("Missing implemention of one or more functions in lib %s!\n", p_dirent->d_name); free(p_input_lib->p_supported_input_types); free(p_input_lib->p_name); free(p_input_lib); dlclose(p_libxmount); continue; } // Add entry to the input library list XMOUNT_REALLOC(glob_xmount.input.pp_libs, pts_InputLib*, sizeof(pts_InputLib)*(glob_xmount.input.libs_count+1)); glob_xmount.input.pp_libs[glob_xmount.input.libs_count++]=p_input_lib; LOG_DEBUG("Input library '%s' loaded successfully\n",p_dirent->d_name); } if(strncmp(p_dirent->d_name,"libxmount_morphing_",19)==0) { // Found possible morphing lib. Try to load it LIBXMOUNT_LOAD(p_library_path); // Load library symbols LIBXMOUNT_LOAD_SYMBOL("LibXmount_Morphing_GetApiVersion", pfun_morphing_GetApiVersion); // Check library's API version if(pfun_morphing_GetApiVersion()!=LIBXMOUNT_MORPHING_API_VERSION) { LOG_DEBUG("Failed! Wrong API version.\n"); LOG_ERROR("Unable to load morphing library '%s'. Wrong API version\n", p_library_path); dlclose(p_libxmount); continue; } LIBXMOUNT_LOAD_SYMBOL("LibXmount_Morphing_GetSupportedTypes", pfun_morphing_GetSupportedTypes); LIBXMOUNT_LOAD_SYMBOL("LibXmount_Morphing_GetFunctions", pfun_morphing_GetFunctions); // Construct new entry for our library list XMOUNT_MALLOC(p_morphing_lib,pts_MorphingLib,sizeof(ts_MorphingLib)); // Initialize lib_functions structure to NULL memset(&(p_morphing_lib->lib_functions), 0, sizeof(ts_LibXmountMorphingFunctions)); // Set name and handle XMOUNT_STRSET(p_morphing_lib->p_name,p_dirent->d_name); p_morphing_lib->p_lib=p_libxmount; // Get and set supported types p_supported_formats=pfun_morphing_GetSupportedTypes(); supported_formats_len=0; p_buf=p_supported_formats; while(*p_buf!='\0') { supported_formats_len+=(strlen(p_buf)+1); p_buf+=(strlen(p_buf)+1); } supported_formats_len++; XMOUNT_MALLOC(p_morphing_lib->p_supported_morphing_types, char*, supported_formats_len); memcpy(p_morphing_lib->p_supported_morphing_types, p_supported_formats, supported_formats_len); // Get, set and check lib_functions pfun_morphing_GetFunctions(&(p_morphing_lib->lib_functions)); if(p_morphing_lib->lib_functions.CreateHandle==NULL || p_morphing_lib->lib_functions.DestroyHandle==NULL || p_morphing_lib->lib_functions.Morph==NULL || p_morphing_lib->lib_functions.Size==NULL || p_morphing_lib->lib_functions.Read==NULL || p_morphing_lib->lib_functions.OptionsHelp==NULL || p_morphing_lib->lib_functions.OptionsParse==NULL || p_morphing_lib->lib_functions.GetInfofileContent==NULL || p_morphing_lib->lib_functions.GetErrorMessage==NULL || p_morphing_lib->lib_functions.FreeBuffer==NULL) { LOG_DEBUG("Missing implemention of one or more functions in lib %s!\n", p_dirent->d_name); free(p_morphing_lib->p_supported_morphing_types); free(p_morphing_lib->p_name); free(p_morphing_lib); dlclose(p_libxmount); continue; } // Add entry to the input library list XMOUNT_REALLOC(glob_xmount.morphing.pp_libs, pts_MorphingLib*, sizeof(pts_MorphingLib)* (glob_xmount.morphing.libs_count+1)); glob_xmount.morphing.pp_libs[glob_xmount.morphing.libs_count++]= p_morphing_lib; LOG_DEBUG("Morphing library '%s' loaded successfully\n",p_dirent->d_name); } else { LOG_DEBUG("Ignoring '%s'.\n",p_dirent->d_name); continue; } } #undef LIBXMOUNT_LOAD_SYMBOL #undef LIBXMOUNT_LOAD LOG_DEBUG("A total of %u input libs and %u morphing libs were loaded.\n", glob_xmount.input.libs_count, glob_xmount.morphing.libs_count); free(p_library_path); closedir(p_dir); return ((glob_xmount.input.libs_count>0 && glob_xmount.morphing.libs_count>0) ? TRUE : FALSE); } //! Search an appropriate input lib for specified input type /*! * \param p_input_image Input image to search input lib for * \return TRUE on success, FALSE on error */ static int FindInputLib(pts_InputImage p_input_image) { char *p_buf; LOG_DEBUG("Trying to find suitable library for input type '%s'.\n", p_input_image->p_type); // Loop over all loaded libs for(uint32_t i=0;ip_name); p_buf=glob_xmount.input.pp_libs[i]->p_supported_input_types; while(*p_buf!='\0') { if(strcmp(p_buf,p_input_image->p_type)==0) { // Library supports input type, set lib functions LOG_DEBUG("Input library '%s' pretends to handle that input type.\n", glob_xmount.input.pp_libs[i]->p_name); p_input_image->p_functions= &(glob_xmount.input.pp_libs[i]->lib_functions); return TRUE; } p_buf+=(strlen(p_buf)+1); } } LOG_DEBUG("Couldn't find any suitable library.\n"); // No library supporting input type found return FALSE; } //! Search an appropriate morphing lib for the specified morph type /*! * \return TRUE on success, FALSE on error */ static int FindMorphingLib() { char *p_buf; LOG_DEBUG("Trying to find suitable library for morph type '%s'.\n", glob_xmount.morphing.p_morph_type); // Loop over all loaded libs for(uint32_t i=0;ip_name); p_buf=glob_xmount.morphing.pp_libs[i]->p_supported_morphing_types; while(*p_buf!='\0') { if(strcmp(p_buf,glob_xmount.morphing.p_morph_type)==0) { // Library supports morph type, set lib functions LOG_DEBUG("Morphing library '%s' pretends to handle that morph type.\n", glob_xmount.morphing.pp_libs[i]->p_name); glob_xmount.morphing.p_functions= &(glob_xmount.morphing.pp_libs[i]->lib_functions); return TRUE; } p_buf+=(strlen(p_buf)+1); } } LOG_DEBUG("Couldn't find any suitable library.\n"); // No library supporting input type found return FALSE; } static void InitResources() { // Input glob_xmount.input.libs_count=0; glob_xmount.input.pp_libs=NULL; glob_xmount.input.lib_params_count=0; glob_xmount.input.pp_lib_params=NULL; glob_xmount.input.images_count=0; glob_xmount.input.pp_images=NULL; glob_xmount.input.image_offset=0; glob_xmount.input.image_hash_lo=0; glob_xmount.input.image_hash_hi=0; // Morphing glob_xmount.morphing.libs_count=0; glob_xmount.morphing.pp_libs=NULL; glob_xmount.morphing.p_morph_type=NULL; glob_xmount.morphing.lib_params_count=0; glob_xmount.morphing.pp_lib_params=NULL; glob_xmount.morphing.p_handle=NULL; glob_xmount.morphing.p_functions=NULL; glob_xmount.morphing.input_image_functions.ImageCount= &LibXmount_Morphing_ImageCount; glob_xmount.morphing.input_image_functions.Size=&LibXmount_Morphing_Size; glob_xmount.morphing.input_image_functions.Read=&LibXmount_Morphing_Read; // Cache glob_xmount.cache.p_cache_file=NULL; glob_xmount.cache.h_cache_file=NULL; glob_xmount.cache.p_cache_header=NULL; glob_xmount.cache.p_cache_blkidx=NULL; glob_xmount.cache.overwrite_cache=FALSE; // Output #ifndef __APPLE__ glob_xmount.output.VirtImageType=VirtImageType_DD; #else glob_xmount.output.VirtImageType=VirtImageType_DMG; #endif glob_xmount.output.image_size=0; glob_xmount.output.writable=FALSE; glob_xmount.output.p_virtual_image_path=NULL; glob_xmount.output.p_info_path=NULL; glob_xmount.output.p_info_file=NULL; glob_xmount.output.vdi.vdi_header_size=0; glob_xmount.output.vdi.p_vdi_header=NULL; glob_xmount.output.vdi.vdi_block_map_size=0; glob_xmount.output.vdi.p_vdi_block_map=NULL; glob_xmount.output.vhd.p_vhd_header=NULL; glob_xmount.output.vmdk.p_virtual_vmdk_path=NULL; glob_xmount.output.vmdk.p_vmdk_file=NULL; glob_xmount.output.vmdk.vmdk_file_size=0; glob_xmount.output.vmdk.p_vmdk_lockdir1=NULL; glob_xmount.output.vmdk.p_vmdk_lockdir2=NULL; glob_xmount.output.vmdk.p_vmdk_lockfile_data=NULL; glob_xmount.output.vmdk.vmdk_lockfile_size=0; glob_xmount.output.vmdk.p_vmdk_lockfile_name=NULL; // Misc data glob_xmount.debug=FALSE; glob_xmount.may_set_fuse_allow_other=FALSE; glob_xmount.fuse_argc=0; glob_xmount.pp_fuse_argv=NULL; glob_xmount.p_mountpoint=NULL; } /* * FreeResources */ static void FreeResources() { int ret; LOG_DEBUG("Freeing all resources\n"); // Misc if(glob_xmount.pp_fuse_argv!=NULL) { for(int i=0;i DestroyHandle(&(glob_xmount.morphing.p_handle)); if(ret!=0) { LOG_ERROR("Unable to destroy morphing handle: %s!\n", glob_xmount.morphing.p_functions->GetErrorMessage(ret)); } } } if(glob_xmount.morphing.pp_lib_params!=NULL) { for(uint32_t i=0;ip_supported_morphing_types!=NULL) free(glob_xmount.morphing.pp_libs[i]->p_supported_morphing_types); if(glob_xmount.morphing.pp_libs[i]->p_lib!=NULL) dlclose(glob_xmount.morphing.pp_libs[i]->p_lib); if(glob_xmount.morphing.pp_libs[i]->p_name!=NULL) free(glob_xmount.morphing.pp_libs[i]->p_name); free(glob_xmount.morphing.pp_libs[i]); } free(glob_xmount.morphing.pp_libs); } // Input if(glob_xmount.input.pp_images!=NULL) { // Close all input images for(uint64_t i=0;ip_functions!=NULL) { if(glob_xmount.input.pp_images[i]->p_handle!=NULL) { ret=glob_xmount.input.pp_images[i]->p_functions-> Close(glob_xmount.input.pp_images[i]->p_handle); if(ret!=0) { LOG_ERROR("Unable to close input image: %s\n", glob_xmount.input.pp_images[i]->p_functions-> GetErrorMessage(ret)); } ret=glob_xmount.input.pp_images[i]->p_functions-> DestroyHandle(&(glob_xmount.input.pp_images[i]->p_handle)); if(ret!=0) { LOG_ERROR("Unable to destroy input image handle: %s\n", glob_xmount.input.pp_images[i]->p_functions-> GetErrorMessage(ret)); } } } if(glob_xmount.input.pp_images[i]->pp_files!=NULL) { for(uint64_t ii=0;iifiles_count;ii++) { if(glob_xmount.input.pp_images[i]->pp_files[ii]!=NULL) free(glob_xmount.input.pp_images[i]->pp_files[ii]); } free(glob_xmount.input.pp_images[i]->pp_files); } if(glob_xmount.input.pp_images[i]->p_type!=NULL) free(glob_xmount.input.pp_images[i]->p_type); free(glob_xmount.input.pp_images[i]); } free(glob_xmount.input.pp_images); } if(glob_xmount.input.pp_lib_params!=NULL) { for(uint32_t i=0;ip_supported_input_types!=NULL) free(glob_xmount.input.pp_libs[i]->p_supported_input_types); if(glob_xmount.input.pp_libs[i]->p_lib!=NULL) dlclose(glob_xmount.input.pp_libs[i]->p_lib); if(glob_xmount.input.pp_libs[i]->p_name!=NULL) free(glob_xmount.input.pp_libs[i]->p_name); free(glob_xmount.input.pp_libs[i]); } free(glob_xmount.input.pp_libs); } // Before we return, initialize everything in case ReleaseResources would be // called again. InitResources(); } //! Function to split given library options static int SplitLibraryParameters(char *p_params, uint32_t *p_ret_opts_count, pts_LibXmountOptions **ppp_ret_opt) { pts_LibXmountOptions p_opts=NULL; pts_LibXmountOptions *pp_opts=NULL; uint32_t params_len; uint32_t opts_count=0; uint32_t sep_pos=0; char *p_buf=p_params; if(p_params==NULL) return FALSE; // Get params length params_len=strlen(p_params); // Return if no params specified if(params_len==0) { *ppp_ret_opt=NULL; p_ret_opts_count=0; return TRUE; } // Split params while(*p_buf!='\0') { XMOUNT_MALLOC(p_opts,pts_LibXmountOptions,sizeof(ts_LibXmountOptions)); p_opts->valid=0; #define FREE_PP_OPTS() { \ if(pp_opts!=NULL) { \ for(uint32_t i=0;ip_key,p_buf,sep_pos); p_buf+=(sep_pos+1); // Search next separator sep_pos=0; while(p_buf[sep_pos]!='\0' && p_buf[sep_pos]!=',') sep_pos++; if(sep_pos==0) { LOG_ERROR("Library parameter '%s' is not of format key=value!\n", p_opts->p_key); free(p_opts->p_key); free(p_opts); FREE_PP_OPTS(); return FALSE; } // Save option value XMOUNT_STRNSET(p_opts->p_value,p_buf,sep_pos); p_buf+=sep_pos; LOG_DEBUG("Extracted library option: '%s' = '%s'\n", p_opts->p_key, p_opts->p_value); #undef FREE_PP_OPTS // Add current option to return array XMOUNT_REALLOC(pp_opts, pts_LibXmountOptions*, sizeof(pts_LibXmountOptions)*(opts_count+1)); pp_opts[opts_count++]=p_opts; // If we're not at the end of p_params, skip over separator for next run if(*p_buf!='\0') p_buf++; } LOG_DEBUG("Extracted a total of %" PRIu32 " library options\n",opts_count); *p_ret_opts_count=opts_count; *ppp_ret_opt=pp_opts; return TRUE; } /******************************************************************************* * LibXmount_Morphing function implementation ******************************************************************************/ //! Function to get the amount of input images /*! * \param p_count Count of input images * \return 0 on success */ static int LibXmount_Morphing_ImageCount(uint64_t *p_count) { *p_count=glob_xmount.input.images_count; return 0; } //! Function to get the size of the morphed data /*! * \param image Image number * \param p_size Pointer to store input image's size to * \return 0 on success */ static int LibXmount_Morphing_Size(uint64_t image, uint64_t *p_size) { if(image>=glob_xmount.input.images_count) return -1; *p_size=glob_xmount.input.pp_images[image]->size; return 0; } //! Function to read data from input image /*! * \param image Image number * \param p_buf Buffer to store read data to * \param offset Position at which to start reading * \param count Amount of bytes to read * \param p_read Number of read bytes on success * \return 0 on success or negated error code on error */ static int LibXmount_Morphing_Read(uint64_t image, char *p_buf, off_t offset, size_t count, size_t *p_read) { if(image>=glob_xmount.input.images_count) return -EIO; return GetInputImageData(glob_xmount.input.pp_images[image], p_buf, offset, count, p_read); } /******************************************************************************* * FUSE function implementation ******************************************************************************/ //! FUSE access implementation /*! * \param p_path Path of file to get attributes from * \param perm Requested permissisons * \return 0 on success, negated error code on error */ /* static int FuseAccess(const char *path, int perm) { // TODO: Implement propper file permission handling // http://www.cs.cf.ac.uk/Dave/C/node20.html // Values for the second argument to access. // These may be OR'd together. //#define R_OK 4 // Test for read permission. //#define W_OK 2 // Test for write permission. //#define X_OK 1 // Test for execute permission. //#define F_OK 0 // Test for existence. return 0; } */ //! FUSE getattr implementation /*! * \param p_path Path of file to get attributes from * \param p_stat Pointer to stat structure to save attributes to * \return 0 on success, negated error code on error */ static int FuseGetAttr(const char *p_path, struct stat *p_stat) { memset(p_stat,0,sizeof(struct stat)); if(strcmp(p_path,"/")==0) { // Attributes of mountpoint p_stat->st_mode=S_IFDIR | 0777; p_stat->st_nlink=2; } else if(strcmp(p_path,glob_xmount.output.p_virtual_image_path)==0) { // Attributes of virtual image if(!glob_xmount.output.writable) p_stat->st_mode=S_IFREG | 0444; else p_stat->st_mode=S_IFREG | 0666; p_stat->st_nlink=1; // Get virtual image file size if(!GetVirtImageSize((uint64_t*)&(p_stat->st_size))) { LOG_ERROR("Couldn't get image size!\n"); return -ENOENT; } if(glob_xmount.output.VirtImageType==VirtImageType_VHD) { // Make sure virtual image seems to be fully allocated (not sparse file). // Without this, Windows won't attach the vhd file! p_stat->st_blocks=p_stat->st_size/512; if(p_stat->st_size%512!=0) p_stat->st_blocks++; } } else if(strcmp(p_path,glob_xmount.output.p_info_path)==0) { // Attributes of virtual image info file p_stat->st_mode=S_IFREG | 0444; p_stat->st_nlink=1; // Get virtual image info file size if(glob_xmount.output.p_info_file!=NULL) { p_stat->st_size=strlen(glob_xmount.output.p_info_file); } else p_stat->st_size=0; } else if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { // Some special files only present when emulating VMDK files if(strcmp(p_path,glob_xmount.output.vmdk.p_virtual_vmdk_path)==0) { // Attributes of virtual vmdk file if(!glob_xmount.output.writable) p_stat->st_mode=S_IFREG | 0444; else p_stat->st_mode=S_IFREG | 0666; p_stat->st_nlink=1; // Get virtual image info file size if(glob_xmount.output.vmdk.p_vmdk_file!=NULL) { p_stat->st_size=glob_xmount.output.vmdk.vmdk_file_size; } else p_stat->st_size=0; } else if(glob_xmount.output.vmdk.p_vmdk_lockdir1!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockdir1)==0) { p_stat->st_mode=S_IFDIR | 0777; p_stat->st_nlink=2; } else if(glob_xmount.output.vmdk.p_vmdk_lockdir2!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockdir2)==0) { p_stat->st_mode=S_IFDIR | 0777; p_stat->st_nlink=2; } else if(glob_xmount.output.vmdk.p_vmdk_lockfile_name!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockfile_name)==0) { p_stat->st_mode=S_IFREG | 0666; if(glob_xmount.output.vmdk.p_vmdk_lockfile_name!=NULL) { p_stat->st_size=strlen(glob_xmount.output.vmdk.p_vmdk_lockfile_name); } else p_stat->st_size=0; } else return -ENOENT; } else return -ENOENT; // Set uid and gid of all files to uid and gid of current process p_stat->st_uid=getuid(); p_stat->st_gid=getgid(); return 0; } //! FUSE mkdir implementation /*! * \param p_path Directory path * \param mode Directory permissions * \return 0 on success, negated error code on error */ static int FuseMkDir(const char *p_path, mode_t mode) { // Only allow creation of VMWare's lock directories if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { if(glob_xmount.output.vmdk.p_vmdk_lockdir1==NULL) { char aVmdkLockDir[strlen(glob_xmount.output.vmdk.p_virtual_vmdk_path)+5]; sprintf(aVmdkLockDir, "%s.lck", glob_xmount.output.vmdk.p_virtual_vmdk_path); if(strcmp(p_path,aVmdkLockDir)==0) { LOG_DEBUG("Creating virtual directory \"%s\"\n",aVmdkLockDir) XMOUNT_STRSET(glob_xmount.output.vmdk.p_vmdk_lockdir1,aVmdkLockDir) return 0; } else { LOG_ERROR("Attempt to create illegal directory \"%s\"!\n",p_path) LOG_DEBUG("Supposed: %s\n",aVmdkLockDir) return -1; } } else if(glob_xmount.output.vmdk.p_vmdk_lockdir2==NULL && strncmp(p_path, glob_xmount.output.vmdk.p_vmdk_lockdir1, strlen(glob_xmount.output.vmdk.p_vmdk_lockdir1))==0) { LOG_DEBUG("Creating virtual directory \"%s\"\n",p_path) XMOUNT_STRSET(glob_xmount.output.vmdk.p_vmdk_lockdir2,p_path) return 0; } else { LOG_ERROR("Attempt to create illegal directory \"%s\"!\n",p_path) LOG_DEBUG("Compared to first %u chars of \"%s\"\n", strlen(glob_xmount.output.vmdk.p_vmdk_lockdir1), glob_xmount.output.vmdk.p_vmdk_lockdir1) return -1; } } LOG_ERROR("Attempt to create directory \"%s\" " "on read-only filesystem!\n",p_path) return -1; } //! FUSE create implementation. /*! * Currently only allows to create VMWare's lock file * * \param p_path File to create * \param mode File mode * \param dev ??? but not used * \return 0 on success, negated error code on error */ static int FuseMkNod(const char *p_path, mode_t mode, dev_t dev) { if((glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) && glob_xmount.output.vmdk.p_vmdk_lockdir1!=NULL && glob_xmount.output.vmdk.p_vmdk_lockfile_name==NULL) { LOG_DEBUG("Creating virtual file \"%s\"\n",p_path) XMOUNT_STRSET(glob_xmount.output.vmdk.p_vmdk_lockfile_name,p_path); return 0; } else { LOG_ERROR("Attempt to create illegal file \"%s\"\n",p_path) return -1; } } //! FUSE readdir implementation /*! * \param p_path Path from where files should be listed * \param p_buf Buffer to write file entrys to * \param filler Function to write dir entrys to buffer * \param offset ??? but not used * \param p_fi File info struct * \return 0 on success, negated error code on error */ static int FuseReadDir(const char *p_path, void *p_buf, fuse_fill_dir_t filler, off_t offset, struct fuse_file_info *p_fi) { // Ignore some params (void)offset; (void)p_fi; if(strcmp(p_path,"/")==0) { // Add std . and .. entrys filler(p_buf,".",NULL,0); filler(p_buf,"..",NULL,0); // Add our virtual files (p+1 to ignore starting "/") filler(p_buf,glob_xmount.output.p_virtual_image_path+1,NULL,0); filler(p_buf,glob_xmount.output.p_info_path+1,NULL,0); if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { // For VMDK's, we use an additional descriptor file filler(p_buf,glob_xmount.output.vmdk.p_virtual_vmdk_path+1,NULL,0); // And there could also be a lock directory if(glob_xmount.output.vmdk.p_vmdk_lockdir1!=NULL) { filler(p_buf,glob_xmount.output.vmdk.p_vmdk_lockdir1+1,NULL,0); } } } else if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { // For VMDK emulation, there could be a lock directory if(glob_xmount.output.vmdk.p_vmdk_lockdir1!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockdir1)==0) { filler(p_buf,".",NULL,0); filler(p_buf,"..",NULL,0); if(glob_xmount.output.vmdk.p_vmdk_lockfile_name!=NULL) { filler(p_buf, glob_xmount.output.vmdk.p_vmdk_lockfile_name+ strlen(glob_xmount.output.vmdk.p_vmdk_lockdir1)+1, NULL, 0); } } else if(glob_xmount.output.vmdk.p_vmdk_lockdir2!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockdir2)==0) { filler(p_buf,".",NULL,0); filler(p_buf,"..",NULL,0); } else return -ENOENT; } else return -ENOENT; return 0; } //! FUSE open implementation /*! * \param p_path Path to file to open * \param p_fi File info struct * \return 0 on success, negated error code on error */ static int FuseOpen(const char *p_path, struct fuse_file_info *p_fi) { #define CHECK_OPEN_PERMS() { \ if(!glob_xmount.output.writable && (p_fi->flags & 3)!=O_RDONLY) { \ LOG_DEBUG("Attempt to open the read-only file \"%s\" for writing.\n", \ p_path) \ return -EACCES; \ } \ return 0; \ } if(strcmp(p_path,glob_xmount.output.p_virtual_image_path)==0 || strcmp(p_path,glob_xmount.output.p_info_path)==0) { CHECK_OPEN_PERMS(); } else if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { if(strcmp(p_path,glob_xmount.output.vmdk.p_virtual_vmdk_path)==0 || (glob_xmount.output.vmdk.p_vmdk_lockfile_name!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockfile_name)==0)) { CHECK_OPEN_PERMS(); } } #undef CHECK_OPEN_PERMS LOG_DEBUG("Attempt to open inexistant file \"%s\".\n",p_path); return -ENOENT; } //! FUSE read implementation /*! * \param p_path Path (relative to mount folder) of file to read data from * \param p_buf Pre-allocated buffer where read data should be written to * \param size Number of bytes to read * \param offset Offset to start reading at * \param p_fi: File info struct * \return Read bytes on success, negated error code on error */ static int FuseRead(const char *p_path, char *p_buf, size_t size, off_t offset, struct fuse_file_info *p_fi) { (void)p_fi; int ret; uint64_t len; #define READ_MEM_FILE(filebuf,filesize,filetypestr,mutex) { \ len=filesize; \ if(offsetlen) { \ LOG_DEBUG("Attempt to read past EOF of virtual " filetypestr " file\n"); \ LOG_DEBUG("Adjusting read size from %u to %u\n",size,len-offset); \ size=len-offset; \ } \ pthread_mutex_lock(&mutex); \ memcpy(p_buf,filebuf+offset,size); \ pthread_mutex_unlock(&mutex); \ LOG_DEBUG("Read %" PRIu64 " bytes at offset %" PRIu64 \ " from virtual " filetypestr " file\n",size,offset); \ ret=size; \ } else { \ LOG_DEBUG("Attempt to read behind EOF of virtual " filetypestr " file\n"); \ ret=0; \ } \ } if(strcmp(p_path,glob_xmount.output.p_virtual_image_path)==0) { // Read data from virtual output file // Wait for other threads to end reading/writing data pthread_mutex_lock(&(glob_xmount.mutex_image_rw)); // Get requested data if((ret=GetVirtImageData(p_buf,offset,size))<0) { LOG_ERROR("Couldn't read data from virtual image file!\n") } // Allow other threads to read/write data again pthread_mutex_unlock(&(glob_xmount.mutex_image_rw)); } else if(strcmp(p_path,glob_xmount.output.p_info_path)==0) { // Read data from virtual info file READ_MEM_FILE(glob_xmount.output.p_info_file, strlen(glob_xmount.output.p_info_file), "info", glob_xmount.mutex_info_read); } else if(strcmp(p_path,glob_xmount.output.vmdk.p_virtual_vmdk_path)==0) { // Read data from virtual vmdk file READ_MEM_FILE(glob_xmount.output.vmdk.p_vmdk_file, glob_xmount.output.vmdk.vmdk_file_size, "vmdk", glob_xmount.mutex_image_rw); } else if(glob_xmount.output.vmdk.p_vmdk_lockfile_name!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockfile_name)==0) { // Read data from virtual lock file READ_MEM_FILE(glob_xmount.output.vmdk.p_vmdk_lockfile_data, glob_xmount.output.vmdk.vmdk_lockfile_size, "vmdk lock", glob_xmount.mutex_image_rw); } else { // Attempt to read non existant file LOG_DEBUG("Attempt to read from non existant file \"%s\"\n",p_path) ret=-ENOENT; } #undef READ_MEM_FILE // TODO: Return size of read data!!!!! return ret; } //! FUSE rename implementation /*! * \param p_path File to rename * \param p_npath New filename * \return 0 on error, negated error code on error */ static int FuseRename(const char *p_path, const char *p_npath) { if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { if(glob_xmount.output.vmdk.p_vmdk_lockfile_name!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockfile_name)==0) { LOG_DEBUG("Renaming virtual lock file from \"%s\" to \"%s\"\n", glob_xmount.output.vmdk.p_vmdk_lockfile_name, p_npath) XMOUNT_REALLOC(glob_xmount.output.vmdk.p_vmdk_lockfile_name,char*, (strlen(p_npath)+1)*sizeof(char)); strcpy(glob_xmount.output.vmdk.p_vmdk_lockfile_name,p_npath); return 0; } } return -ENOENT; } //! FUSE rmdir implementation /*! * \param p_path Directory to delete * \return 0 on success, negated error code on error */ static int FuseRmDir(const char *p_path) { // Only VMWare's lock directories can be deleted if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { if(glob_xmount.output.vmdk.p_vmdk_lockdir1!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockdir1)==0) { LOG_DEBUG("Deleting virtual lock dir \"%s\"\n", glob_xmount.output.vmdk.p_vmdk_lockdir1) free(glob_xmount.output.vmdk.p_vmdk_lockdir1); glob_xmount.output.vmdk.p_vmdk_lockdir1=NULL; return 0; } else if(glob_xmount.output.vmdk.p_vmdk_lockdir2!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockdir2)==0) { LOG_DEBUG("Deleting virtual lock dir \"%s\"\n", glob_xmount.output.vmdk.p_vmdk_lockdir1) free(glob_xmount.output.vmdk.p_vmdk_lockdir2); glob_xmount.output.vmdk.p_vmdk_lockdir2=NULL; return 0; } } return -1; } //! FUSE unlink implementation /*! * \param p_path File to delete * \return 0 on success, negated error code on error */ static int FuseUnlink(const char *p_path) { // Only VMWare's lock file can be deleted if(glob_xmount.output.VirtImageType==VirtImageType_VMDK || glob_xmount.output.VirtImageType==VirtImageType_VMDKS) { if(glob_xmount.output.vmdk.p_vmdk_lockfile_name!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockfile_name)==0) { LOG_DEBUG("Deleting virtual file \"%s\"\n", glob_xmount.output.vmdk.p_vmdk_lockfile_name) free(glob_xmount.output.vmdk.p_vmdk_lockfile_name); free(glob_xmount.output.vmdk.p_vmdk_lockfile_data); glob_xmount.output.vmdk.p_vmdk_lockfile_name=NULL; glob_xmount.output.vmdk.p_vmdk_lockfile_data=NULL; glob_xmount.output.vmdk.vmdk_lockfile_size=0; return 0; } } return -1; } //! FUSE statfs implementation /*! * \param p_path Get stats for fs that the specified file resides in * \param stats Stats * \return 0 on success, negated error code on error */ /* static int FuseStatFs(const char *p_path, struct statvfs *stats) { struct statvfs CacheFileFsStats; int ret; if(glob_xmount.writable==TRUE) { // If write support is enabled, return stats of fs upon which cache file // resides in if((ret=statvfs(glob_xmount.p_cache_file,&CacheFileFsStats))==0) { memcpy(stats,&CacheFileFsStats,sizeof(struct statvfs)); return 0; } else { LOG_ERROR("Couldn't get stats for fs upon which resides \"%s\"\n", glob_xmount.p_cache_file) return ret; } } else { // TODO: Return read only return 0; } } */ // FUSE write implementation /*! * \param p_buf Buffer containing data to write * \param size Number of bytes to write * \param offset Offset to start writing at * \param p_fi: File info struct * * Returns: * Written bytes on success, negated error code on error */ static int FuseWrite(const char *p_path, const char *p_buf, size_t size, off_t offset, struct fuse_file_info *p_fi) { (void)p_fi; uint64_t len; if(strcmp(p_path,glob_xmount.output.p_virtual_image_path)==0) { // Wait for other threads to end reading/writing data pthread_mutex_lock(&(glob_xmount.mutex_image_rw)); // Get virtual image file size if(!GetVirtImageSize(&len)) { LOG_ERROR("Couldn't get virtual image size!\n") pthread_mutex_unlock(&(glob_xmount.mutex_image_rw)); return 0; } if(offsetlen) size=len-offset; if(SetVirtImageData(p_buf,offset,size)!=size) { LOG_ERROR("Couldn't write data to virtual image file!\n") pthread_mutex_unlock(&(glob_xmount.mutex_image_rw)); return 0; } } else { LOG_DEBUG("Attempt to write past EOF of virtual image file\n") pthread_mutex_unlock(&(glob_xmount.mutex_image_rw)); return 0; } // Allow other threads to read/write data again pthread_mutex_unlock(&(glob_xmount.mutex_image_rw)); } else if(strcmp(p_path,glob_xmount.output.vmdk.p_virtual_vmdk_path)==0) { pthread_mutex_lock(&(glob_xmount.mutex_image_rw)); len=glob_xmount.output.vmdk.vmdk_file_size; if((offset+size)>len) { // Enlarge or create buffer if needed if(len==0) { len=offset+size; XMOUNT_MALLOC(glob_xmount.output.vmdk.p_vmdk_file, char*, len*sizeof(char)); } else { len=offset+size; XMOUNT_REALLOC(glob_xmount.output.vmdk.p_vmdk_file, char*, len*sizeof(char)); } glob_xmount.output.vmdk.vmdk_file_size=offset+size; } // Copy data to buffer memcpy(glob_xmount.output.vmdk.p_vmdk_file+offset,p_buf,size); pthread_mutex_unlock(&(glob_xmount.mutex_image_rw)); } else if(glob_xmount.output.vmdk.p_vmdk_lockfile_name!=NULL && strcmp(p_path,glob_xmount.output.vmdk.p_vmdk_lockfile_name)==0) { pthread_mutex_lock(&(glob_xmount.mutex_image_rw)); if((offset+size)>glob_xmount.output.vmdk.vmdk_lockfile_size) { // Enlarge or create buffer if needed if(glob_xmount.output.vmdk.vmdk_lockfile_size==0) { glob_xmount.output.vmdk.vmdk_lockfile_size=offset+size; XMOUNT_MALLOC(glob_xmount.output.vmdk.p_vmdk_lockfile_data,char*, glob_xmount.output.vmdk.vmdk_lockfile_size*sizeof(char)) } else { glob_xmount.output.vmdk.vmdk_lockfile_size=offset+size; XMOUNT_REALLOC(glob_xmount.output.vmdk.p_vmdk_lockfile_data,char*, glob_xmount.output.vmdk.vmdk_lockfile_size*sizeof(char)) } } // Copy data to buffer memcpy(glob_xmount.output.vmdk.p_vmdk_lockfile_data+offset,p_buf,size); pthread_mutex_unlock(&(glob_xmount.mutex_image_rw)); } else if(strcmp(p_path,glob_xmount.output.p_info_path)==0) { // Attempt to write data to read only image info file LOG_DEBUG("Attempt to write data to virtual info file\n"); return -ENOENT; } else { // Attempt to write to non existant file LOG_DEBUG("Attempt to write to the non existant file \"%s\"\n",p_path) return -ENOENT; } return size; } /******************************************************************************* * Main ******************************************************************************/ int main(int argc, char *argv[]) { struct stat file_stat; int ret; int fuse_ret; char *p_err_msg; // Set implemented FUSE functions struct fuse_operations xmount_operations = { //.access=FuseAccess, .getattr=FuseGetAttr, .mkdir=FuseMkDir, .mknod=FuseMkNod, .open=FuseOpen, .readdir=FuseReadDir, .read=FuseRead, .rename=FuseRename, .rmdir=FuseRmDir, //.statfs=FuseStatFs, .unlink=FuseUnlink, .write=FuseWrite }; // Disable std output / input buffering setbuf(stdout,NULL); setbuf(stderr,NULL); // Init glob_xmount InitResources(); // Load input and morphing libs if(!LoadLibs()) { LOG_ERROR("Unable to load any libraries!\n") return 1; } // Check FUSE settings CheckFuseSettings(); // Parse command line options if(ParseCmdLine(argc,argv)!=TRUE) { PrintUsage(argv[0]); FreeResources(); return 1; } // Check command line options if(glob_xmount.input.images_count==0) { LOG_ERROR("No --in command line option specified!\n") PrintUsage(argv[0]); FreeResources(); return 1; } if(glob_xmount.fuse_argc<2) { LOG_ERROR("Couldn't parse command line options!\n") PrintUsage(argv[0]); FreeResources(); return 1; } if(glob_xmount.morphing.p_morph_type==NULL) { XMOUNT_STRSET(glob_xmount.morphing.p_morph_type,"combine"); } // Check if mountpoint is a valid dir if(stat(glob_xmount.p_mountpoint,&file_stat)!=0) { LOG_ERROR("Unable to stat mount point '%s'!\n",glob_xmount.p_mountpoint); PrintUsage(argv[0]); FreeResources(); return 1; } if(!S_ISDIR(file_stat.st_mode)) { LOG_ERROR("Mount point '%s' is not a directory!\n", glob_xmount.p_mountpoint); PrintUsage(argv[0]); FreeResources(); return 1; } if(glob_xmount.debug==TRUE) { LOG_DEBUG("Options passed to FUSE: ") for(int i=0;ifiles_count==1) { LOG_DEBUG("Loading image file \"%s\"...\n", glob_xmount.input.pp_images[i]->pp_files[0]) } else { LOG_DEBUG("Loading image files \"%s .. %s\"...\n", glob_xmount.input.pp_images[i]->pp_files[0], glob_xmount.input.pp_images[i]-> pp_files[glob_xmount.input.pp_images[i]->files_count-1]) } } // Find input lib if(!FindInputLib(glob_xmount.input.pp_images[i])) { LOG_ERROR("Unknown input image type '%s' for input image '%s'!\n", glob_xmount.input.pp_images[i]->p_type, glob_xmount.input.pp_images[i]->pp_files[0]) PrintUsage(argv[0]); FreeResources(); return 1; } // Init input image handle ret=glob_xmount.input.pp_images[i]->p_functions-> CreateHandle(&(glob_xmount.input.pp_images[i]->p_handle), - glob_xmount.input.pp_images[i]->p_type); + glob_xmount.input.pp_images[i]->p_type, + glob_xmount.debug); if(ret!=0) { LOG_ERROR("Unable to init input handle for input image '%s': %s!\n", glob_xmount.input.pp_images[i]->pp_files[0], glob_xmount.input.pp_images[i]->p_functions-> GetErrorMessage(ret)); FreeResources(); return 1; } // Parse input lib specific options if(glob_xmount.input.pp_lib_params!=NULL) { ret=glob_xmount.input.pp_images[i]->p_functions-> OptionsParse(glob_xmount.input.pp_images[i]->p_handle, glob_xmount.input.lib_params_count, glob_xmount.input.pp_lib_params, (const char**)&p_err_msg); if(ret!=0) { if(p_err_msg!=NULL) { LOG_ERROR("Unable to parse input library specific options for image " "'%s': %s: %s!\n", glob_xmount.input.pp_images[i]->pp_files[0], glob_xmount.input.pp_images[i]->p_functions-> GetErrorMessage(ret), p_err_msg); glob_xmount.input.pp_images[i]->p_functions->FreeBuffer(p_err_msg); FreeResources(); return 1; } else { LOG_ERROR("Unable to parse input library specific options for image " "'%s': %s!\n", glob_xmount.input.pp_images[i]->pp_files[0], glob_xmount.input.pp_images[i]->p_functions-> GetErrorMessage(ret)); FreeResources(); return 1; } } } // Open input image ret= glob_xmount.input.pp_images[i]-> p_functions-> Open(glob_xmount.input.pp_images[i]->p_handle, (const char**)(glob_xmount.input.pp_images[i]->pp_files), glob_xmount.input.pp_images[i]->files_count); if(ret!=0) { LOG_ERROR("Unable to open input image file '%s': %s!\n", glob_xmount.input.pp_images[i]->pp_files[0], glob_xmount.input.pp_images[i]->p_functions-> GetErrorMessage(ret)); FreeResources(); return 1; } // Determine input image size ret=glob_xmount.input.pp_images[i]-> p_functions-> Size(glob_xmount.input.pp_images[i]->p_handle, &(glob_xmount.input.pp_images[i]->size)); if(ret!=0) { LOG_ERROR("Unable to determine size of input image '%s': %s!\n", glob_xmount.input.pp_images[i]->pp_files[0], glob_xmount.input.pp_images[i]-> p_functions->GetErrorMessage(ret)); FreeResources(); return 1; } // If an offset was specified, check it against offset and change size if(glob_xmount.input.image_offset!=0) { if(glob_xmount.input.image_offset>glob_xmount.input.pp_images[i]->size) { LOG_ERROR("The specified offset is larger then the size of the input " "image '%s'! (%" PRIu64 " > %" PRIu64 ")\n", glob_xmount.input.pp_images[i]->pp_files[0], glob_xmount.input.image_offset, glob_xmount.input.pp_images[i]->size); FreeResources(); return 1; } glob_xmount.input.pp_images[i]->size-=glob_xmount.input.image_offset; } LOG_DEBUG("Input image loaded successfully\n") } // Find morphing lib if(FindMorphingLib()!=TRUE) { LOG_ERROR("Unable to find a library supporting the morphing type '%s'!\n", glob_xmount.morphing.p_morph_type); FreeResources(); return 1; } // Init morphing ret=glob_xmount.morphing.p_functions-> CreateHandle(&glob_xmount.morphing.p_handle, glob_xmount.morphing.p_morph_type, glob_xmount.debug); if(ret!=0) { LOG_ERROR("Unable to create morphing handle: %s!\n", glob_xmount.morphing.p_functions->GetErrorMessage(ret)); FreeResources(); return 1; } + + // Parse morphing lib specific options + if(glob_xmount.morphing.pp_lib_params!=NULL) { + p_err_msg=NULL; + ret=glob_xmount.morphing.p_functions-> + OptionsParse(glob_xmount.morphing.p_handle, + glob_xmount.morphing.lib_params_count, + glob_xmount.morphing.pp_lib_params, + (const char**)&p_err_msg); + if(ret!=0) { + if(p_err_msg!=NULL) { + LOG_ERROR("Unable to parse morphing library specific options: %s: %s!\n", + glob_xmount.morphing.p_functions->GetErrorMessage(ret), + p_err_msg); + glob_xmount.morphing.p_functions->FreeBuffer(p_err_msg); + FreeResources(); + return 1; + } else { + LOG_ERROR("Unable to parse morphing library specific options: %s!\n", + glob_xmount.morphing.p_functions->GetErrorMessage(ret)); + FreeResources(); + return 1; + } + } + } + + // Morph image ret=glob_xmount.morphing.p_functions-> Morph(glob_xmount.morphing.p_handle, &(glob_xmount.morphing.input_image_functions)); if(ret!=0) { LOG_ERROR("Unable to start morphing: %s!\n", glob_xmount.morphing.p_functions->GetErrorMessage(ret)); FreeResources(); return 1; } // Init random generator srand(time(NULL)); // Calculate partial MD5 hash of input image file if(CalculateInputImageHash(&(glob_xmount.input.image_hash_lo), &(glob_xmount.input.image_hash_hi))==FALSE) { LOG_ERROR("Couldn't calculate partial hash of morphed image!\n") return 1; } if(glob_xmount.debug==TRUE) { LOG_DEBUG("Partial MD5 hash of morphed image: ") for(int i=0;i<8;i++) printf("%02hhx",*(((char*)(&(glob_xmount.input.image_hash_lo)))+i)); for(int i=0;i<8;i++) printf("%02hhx",*(((char*)(&(glob_xmount.input.image_hash_hi)))+i)); printf("\n"); } if(!ExtractVirtFileNames(glob_xmount.input.pp_images[0]->pp_files[0])) { LOG_ERROR("Couldn't extract virtual file names!\n"); FreeResources(); return 1; } LOG_DEBUG("Virtual file names extracted successfully\n") // Gather infos for info file if(!InitVirtImageInfoFile()) { LOG_ERROR("Couldn't gather infos for virtual image info file!\n") FreeResources(); return 1; } LOG_DEBUG("Virtual image info file build successfully\n") // Do some virtual image type specific initialisations switch(glob_xmount.output.VirtImageType) { case VirtImageType_DD: case VirtImageType_DMG: break; case VirtImageType_VDI: // When mounting as VDI, we need to construct a vdi header if(!InitVirtVdiHeader()) { LOG_ERROR("Couldn't initialize virtual VDI file header!\n") FreeResources(); return 1; } LOG_DEBUG("Virtual VDI file header build successfully\n") break; case VirtImageType_VHD: // When mounting as VHD, we need to construct a vhd footer if(!InitVirtVhdHeader()) { LOG_ERROR("Couldn't initialize virtual VHD file footer!\n") FreeResources(); return 1; } LOG_DEBUG("Virtual VHD file footer build successfully\n") break; case VirtImageType_VMDK: case VirtImageType_VMDKS: // When mounting as VMDK, we need to construct the VMDK descriptor file if(!InitVirtualVmdkFile()) { LOG_ERROR("Couldn't initialize virtual VMDK file!\n") FreeResources(); return 1; } break; } if(glob_xmount.output.writable) { // Init cache file and cache file block index if(!InitCacheFile()) { LOG_ERROR("Couldn't initialize cache file!\n") FreeResources(); return 1; } LOG_DEBUG("Cache file initialized successfully\n") } // Call fuse_main to do the fuse magic fuse_ret=fuse_main(glob_xmount.fuse_argc, glob_xmount.pp_fuse_argv, &xmount_operations, NULL); // Destroy mutexes pthread_mutex_destroy(&(glob_xmount.mutex_image_rw)); pthread_mutex_destroy(&(glob_xmount.mutex_info_read)); // Free allocated memory FreeResources(); return fuse_ret; } /* ----- Change log ----- 20090131: v0.1.0 released * Some minor things have still to be done. * Mounting ewf as dd: Seems to work. Diff didn't complain about changes between original dd and emulated dd. * Mounting ewf as vdi: Seems to work too. VBox accepts the emulated vdi as valid vdi file and I was able to mount the containing fs under Debian. INFO: Debian freezed when not using mount -r !! 20090203: v0.1.1 released * Multiple code improvements. For ex. cleaner vdi header allocation. * Fixed severe bug in image block calculation. Didn't check for odd input in conversion from bytes to megabytes. * Added more debug output 20090210: v0.1.2 released * Fixed compilation problem (Typo in image_init_info() function). * Fixed some problems with the debian scripts to be able to build packages. * Added random generator initialisation (Makes it possible to use more than one image in VBox at a time). 20090215: * Added function init_cache_blocks which creates / loads a cache file used to implement virtual write capability. 20090217: * Implemented the fuse write function. Did already some basic tests with dd and it seems to work. But there are certainly still some bugs left as there are also still some TODO's left. 20090226: * Changed program name from mountewf to xmount. * Began with massive code cleanups to ease full implementation of virtual write support and to be able to support multiple input image formats (DD, EWF and AFF are planned for now). * Added defines for supported input formats so it should be possible to compile xmount without supporting all input formats. (DD input images are always supported as these do not require any additional libs). Input formats should later be en/disabled by the configure script in function to which libs it detects. * GetOrigImageSize function added to get the size of the original image whatever type it is in. * GetOrigImageData function added to retrieve data from original image file whatever type it is in. * GetVirtImageSize function added to get the size of the virtual image file. * Cleaned function mountewf_getattr and renamed it to GetVirtFileAttr * Cleaned function mountewf_readdir and renamed it to GetVirtFiles * Cleaned function mountewf_open and renamed it to OpenVirtFile 20090227: * Cleaned function init_info_file and renamed it to InitVirtImageInfoFile 20090228: * Cleaned function init_cache_blocks and renamed it to InitCacheFile * Added LogMessage function to ease error and debug logging (See also LOG_ERROR and LOG_DEBUG macros in xmount.h) * Cleaned function init_vdi_header and renamed it to InitVirtVdiHeader * Added PrintUsage function to print out xmount usage informations * Cleaned function parse_cmdline and renamed it to ParseCmdLine * Cleaned function main * Added ExtractVirtFileNames function to extract virtual file names from input image name * Added function GetVirtImageData to retrieve data from the virtual image file. This includes reading data from cache file if virtual write support is enabled. * Added function ReadVirtFile to replace mountewf_read 20090229: * Fixed a typo in virtual file name creation * Added function SetVirtImageData to write data to virtual image file. This includes writing data to cache file and caching entire new blocks * Added function WriteVirtFile to replace mountewf_write 20090305: * Solved a problem that made it impossible to access offsets >32bit 20090308: * Added SetVdiFileHeaderData function to handle virtual image type specific data to be cached. This makes cache files independent from virtual image type 20090316: v0.2.0 released 20090327: v0.2.1 released * Fixed a bug in virtual write support. Checking whether data is cached didn't use semaphores. This could corrupt cache files when running multi-threaded. * Added IsVdiFileHeaderCached function to check whether VDI file header was already cached * Added IsBlockCached function to check whether a block was already cached 20090331: v0.2.2 released (Internal release) * Further changes to semaphores to fix write support bug. 20090410: v0.2.3 released * Reverted most of the fixes from v0.2.1 and v0.2.2 as those did not solve the write support bug. * Removed all semaphores * Added two pthread mutexes to protect virtual image and virtual info file. 20090508: * Configure script will now exit when needed libraries aren't found * Added support for newest libewf beta version 20090506 as it seems to reduce memory usage when working with EWF files by about 1/2. * Added LIBEWF_BETA define to adept source to new libewf API. * Added function InitVirtualVmdkFile to build a VmWare virtual disk descriptor file. 20090519: * Added function CreateVirtDir implementing FUSE's mkdir to allow VMWare to create his .vmdk.lck lock folder. Function does not allow to create other folders! * Changed cache file handling as VMDK caching will need new cache file structure incompatible to the old one. 20090522: v0.3.0 released * Added function DeleteVirtFile and DeleteVirtDir so VMWare can remove his lock directories and files. * Added function RenameVirtFile because VMWare needs to rename his lock files. * VMDK support should work now but descriptor file won't get cached as I didn't implement it yet. 20090604: * Added --cache commandline parameter doing the same as --rw. * Added --owcache commandline parameter doing the same as --rw but overwrites any existing cache data. This can be handy for debugging and testing purposes. * Added "vmdks" output type. Same as "vmdk" but generates a disk connected to the SCSI bus rather than the IDE bus. 20090710: v0.3.1 released 20090721: * Added function CheckFuseAllowOther to check wether FUSE supports the "-o allow_other" option. It is supported when "user_allow_other" is set in /etc/fuse.conf or when running xmount as root. * Automatic addition of FUSE's "-o allow_other" option if it is supported. * Added special "-o no_allow_other" command line parameter to disable automatic addition of the above option. * Reorganisation of FUSE's and xmount's command line options processing. * Added LogWarnMessage function to output a warning message. 20090722: * Added function CalculateInputImageHash to calculate an MD5 hash of the first input image's HASH_AMOUNT bytes of data. This hash is used as VDI creation UUID and will later be used to match cache files to input images. 20090724: v0.3.2 released 20090725: v0.4.0 released * Added AFF input image support. * Due to various problems with libewf and libaff packages (Mainly in Debian and Ubuntu), I decided to include them into xmount's source tree and link them in statically. This has the advantage that I can use whatever version I want. 20090727: v0.4.1 released * Added again the ability to compile xmount with shared libs as the Debian folks don't like the static ones :) 20090812: * Added TXMountConfData.OrigImageSize and TXMountConfData.VirtImageSize to save the size of the input and output image in order to avoid regetting it always from disk. 20090814: * Replaced all malloc and realloc occurences with the two macros XMOUNT_MALLOC and XMOUNT_REALLOC. 20090816: * Replaced where applicable all occurences of str(n)cpy or alike with their corresponding macros XMOUNT_STRSET, XMOUNT_STRCPY and XMOUNT_STRNCPY pendants. 20090907: v0.4.2 released * Fixed a bug in VMDK lock file access. glob_vmdk_lockfile_size wasn't reset to 0 when the file was deleted. * Fixed a bug in VMDK descriptor file access. Had to add glob_vmdk_file_size to track the size of this file as strlen was a bad idea :). 20100324: v0.4.3 released * Changed all header structs to prevent different sizes on i386 and amd64. See xmount.h for more details. 20100810: v0.4.4 released * Found a bug in InitVirtVdiHeader(). The 64bit values were addressed incorrectly while filled with rand(). This leads to an error message when trying to add a VDI file to VirtualBox 3.2.8. 20110210: * Adding subtype and fsname FUSE options in order to display mounted source in mount command output. 20110211: v0.4.5 released 20111011: * Changes to deal with libewf v2 API (thx to Joachim Metz) 20111109: v0.4.6 released * Added support for DMG output type (actually a DD with .dmg file extension). This type is used as default output type when using xmount under Mac OS X. 20120130: v0.4.7 released * Made InitVirtImageInfoFile less picky about missing EWF infos. 20120507: * Added support for VHD output image as requested by various people. * Statically linked libs updated to 20120504 (libewf) and 3.7.0 (afflib). 20120510: v0.5.0 released * Added stbuf->st_blocks calculation for VHD images in function GetVirtFileAttr. This makes Windows not think the emulated file would be a sparse file. Sparse vhd files are not attachable in Windows. 20130726: v0.6.0 released * Added libaaff to replace libaff (thx to Guy Voncken). * Added libdd to replace raw dd input file handling and finally support split dd files (thx to Guy Voncken). 20140311: * Added libaewf (thx to Guy Voncken). 20140726: * Added support for dynamically loading of input libs. This should ease adding support for new input image formats in the future. * Moved input image functions to their corresponding dynamically loadable libs. * Prepended "glob_" to all global vars for better identification. 20140731: * Added --offset option as requested by HPM. * Began massive code cleanup. 20140803: * Added correct return code handling when calling input lib functions including getting error messages using GetErrorMessage. * Added input lib specific option parsing. * Re-implemented InitVirtImageInfoFile() using input lib's GetInfofileContent() function. * Further code cleanups. 20140807: * Further code cleanups. * Renamed GetVirtFileAttr() to FuseGetAttr() * Renamed CreateVirtDir() to FuseMkDir() * Renamed CreateVirtDir() to FuseMkNod() * Renamed OpenVirtFile() to FuseOpen() * Renamed GetVirtFiles() to FuseReadDir() * Renamed ReadVirtFile() to FuseRead() * Renamed RenameVirtFile() to FuseRename() * Renamed DeleteVirtDir() to FuseRmDir() * Renamed DeleteVirtFile() to FuseUnlink() * Renamed WriteVirtFile() to FuseWrite() * Fixed bug in CalculateInputImageHash() where always HASH_AMOUNT bytes were hased even if input image is smaller. * Fixed a newly introduced bug in FuseRead() and GetVirtImageData() returning -EIO when trying to read behind EOF. The correct return value is 0. 20140811: * Renamed CheckFuseAllowOther() to CheckFuseSettings() and added a check to see if user is part of the fuse group. 20140814: * Replaced cuserid() with getpwuid(geteuid()) in CheckFuseSettings() as it is deprecated on Linux and not available on OSx. * Only build fuse group checks from CheckFuseSettings() on Linux. 20140820: * Added libxmount_morphing handling. * Renamed LoadInputLibs() to LoadLibs() and added code to find and load morphing libs. * Added FindMorphingLib() function. 20140821: * Changed command line syntax to support specification of multiple input images of different types. * Added code in main() to initialize and open multiple input images. * Added GetMorphedImageSize() and GetMorphedImageData(). 20140822: * Removed GetInputImageSize() as it isn't needed anymore. * Quick test showed morphing using libxmount_morphing_combine seems to work. 20140825: * Added InitResources() and FreeResources() functions. */