summaryrefslogtreecommitdiff
path: root/TAO/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp')
-rw-r--r--TAO/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp299
1 files changed, 0 insertions, 299 deletions
diff --git a/TAO/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp b/TAO/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp
deleted file mode 100644
index f910374f71f..00000000000
--- a/TAO/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp
+++ /dev/null
@@ -1,299 +0,0 @@
-
-//=======================================================================
-/**
- * @file ZIP_Wrapper.cpp
- *
- * $Id$
- *
- * Purpose: implementing the ZIP_Wrapper class
- *
- * @author Stoyan Paunov
- */
-//=======================================================================
-
-
-#include "ace/Containers_T.h" //for ACE_Double_Linked_List
-#include "ace/Message_Block.h" //for ACE_Message_Block
-
-#include "ace/OS_NS_fcntl.h" //for open
-#include "ace/OS_NS_unistd.h" //for close
-#include "ace/OS_NS_string.h" //for strncpy
-#include "ace/SString.h" //for ACE_CString
-#include "ace/OS_NS_sys_stat.h" //for stat
-#include "ace/OS_NS_sys_stat.h" //for filesize and mkdir
-#include "ace/OS_Memory.h" //for ACE_NEW* macros
-
-#include <string>
-#include <memory> //for auto_ptr
-
-/////////////////////////////////////////////////////////////////////////////
-//NOTE: some #defines problems with zzip & ACE - put these 2 lines on top!!!!
-/////////////////////////////////////////////////////////////////////////////
-#include "zzip/zzip.h" //for ZZIP
-#include "ZIP_Wrapper.h"
-
-
-//ZIP_File_Info constructor
-ZIP_File_Info::ZIP_File_Info (char* name, size_t size)
- : name_ (name),
- size_ (size),
- next_ (0),
- prev_ (0)
-{
-}
-
-//ZIP_File_Info default constructor
-ZIP_File_Info::ZIP_File_Info ()
- : name_ (""),
- size_ (0),
- next_ (0),
- prev_ (0)
-{
-}
-
-
-//get a list of the files in the archive
-int ZIP_Wrapper::file_list_info (char* zip_name, ACE_Double_Linked_List<ZIP_File_Info> &list)
-{
- size_t num = 0; //number of files in archive
- ZZIP_DIR * dir = 0; //pointer to a zip archive
- ZZIP_DIRENT * dir_entry = 0; //pointer to a file within the archive
-
- //open the zip archive
- dir = zzip_opendir(zip_name);
-
- if (!dir)
- return 0;
-
- //read each dir entry and show one line of info per file
- while ((dir_entry = zzip_readdir (dir)))
- {
- //retrieve the name of the file
- char* name = dir_entry->d_name;
-
- //remove the subpath part if any NOTE: Lunux style assumed, need to check
- //while(char* next = strstr(name, "/"))
- // name = next + 1;
-
- ZIP_File_Info* next;
- ACE_NEW_RETURN (next, ZIP_File_Info (name, dir_entry->st_size), -1);
-
- list.insert_tail (next);
- num++;
- }
-
- zzip_closedir(dir);
- return num;
-}
-
-// Get file and store it into an ACE_Message_Block
-bool ZIP_Wrapper::get_file (char* accessor, ACE_Message_Block &file)
-{
- bool return_code = true;
-
- ZZIP_FILE* zip_file = zzip_open (accessor, O_RDONLY| O_BINARY);
-
- if (!zip_file)
- return false;
-
- int num_read = 0;
- file.size(BUFSIZ);
- ACE_Message_Block* head = &file;
-
- // read chunks of 16 bytes into buf and print them to stdout
- while (0 < (num_read = zzip_read(zip_file, head->wr_ptr(), head->size())))
- {
- head->wr_ptr (num_read);
- ACE_Message_Block* next;
- ACE_NEW_RETURN (next, ACE_Message_Block (BUFSIZ), false);
- head->cont (next);
- head = head->cont ();
- }
-
- if (num_read < 0)
- return_code = false;
-
- zzip_file_close (zip_file);
-
- return return_code;
-}
-
-
-bool ZIP_Wrapper::get_file (char* archive_path, char* filename, ACE_Message_Block &file)
-{
- bool return_code = true;
- ZZIP_DIR * dir; //pointer to a zip archive
-
- //open the zip archive
- dir = zzip_opendir(archive_path);
-
- if (!dir)
- return false;
-
- //get the handle to the file
- ZZIP_FILE* zip_file = zzip_file_open (dir, filename, O_RDONLY | O_BINARY);
-
- if (!zip_file)
- return false;
-
- int num_read = 0;
- ACE_Message_Block* head = &file;
-
- //read the file into the ACE_Message_Block
- do
- {
- if (head->space () == 0)
- {
- ACE_Message_Block* next;
- ACE_NEW_RETURN (next, ACE_Message_Block (BUFSIZ), false);
- head->cont ();
- head = head->cont ();
- }
-
- num_read = zzip_read(zip_file, head->wr_ptr(), head->space());
-
- if (num_read > 0)
- head->wr_ptr (num_read);
-
- } while (num_read > 0);
-
- if (num_read < 0)
- return_code = false;
-
- zzip_file_close (zip_file);
- zzip_closedir(dir);
-
- return return_code;
-}
-
-
-//uncompress
-//the uncompress format will be
-//mkdir(name of zip archive).
-//the path is assumed to be an existing directory
-//directory structure of archive is recreated
-bool ZIP_Wrapper::uncompress (char* zip_archive, char* path, bool verbose)
-{
- ZZIP_DIR * dir = 0; //pointer to a zip archive
- ZZIP_DIRENT * dir_entry = 0; //pointer to a file within the archive
- ZZIP_FILE* file = 0; //pointer to a zip file within an archive
-
- //open the zip archive
- dir = zzip_opendir(zip_archive);
-
- if (!dir)
- return false;
-
- //??????
- //check if a directory with the name if the archive exists
- //If not, create it. Else, existing files will be truncated upon open.
- //??????
-
- //get the name of the archive
- ACE_CString arch_dir (path);
- arch_dir += "/";
-
- //get only the name of the archive; remove path info
- char* n = ACE_OS::strstr (zip_archive, "/");
- char* zip_name = 0;
- while (n != NULL)
- {
- zip_name = ++n;
- n = ACE_OS::strstr (n, "/");
- }
-
- arch_dir += zip_name;
- //NOTE: Assumes .zip or cpk extension
- arch_dir = arch_dir.substring (0, arch_dir.length () - 4);
-
- //create directory
- ACE_OS::mkdir(arch_dir.c_str()); //if dir exists -1 is returned and ignored
-
- //read each dir entry and show one line of info per file
- while ((dir_entry = zzip_readdir (dir)))
- {
- //retrieve the name of the file
- char* name = dir_entry->d_name;
-
- //remove the subpath part if any NOTE: Lunux style assumed, need to check
-
- //let's try to create the directory structure for the package
- char dir_name [2048];
- char* next = ACE_OS::strstr (name, "/");
- while (next != NULL)
- {
- ACE_CString location (arch_dir);
- ACE_OS::strncpy (dir_name, name, next - name + 1);
- dir_name[next - name + 1] = '\0';
-
- location += "/";
- location += dir_name;
-
- ACE_stat stat;
- if (ACE_OS::stat (location.c_str (), &stat) == -1)
- ACE_OS::mkdir (location.c_str ());
-
- next++;
- next = ACE_OS::strstr (next, "/");
- }
-
- //open a zip handle
- file = zzip_file_open(dir, dir_entry->d_name, O_RDONLY | O_BINARY);
- if (!file)
- return false;
-
- //allocate buffer
-
- //std::auto_ptr releases the memory upon reset.
- //ACE_Auto_Ptr does not support this functionality
- std::auto_ptr<char> buffer;
- char* temp;
- ACE_NEW_RETURN (temp, char [dir_entry->st_size + 1], false);
- buffer.reset (temp);
-
- //read in the data
- zzip_read(file, &(*buffer), dir_entry->st_size);
-
- //close the zip handle
- zzip_file_close (file);
-
- //create file name + path to open
- std::string file_path (arch_dir.c_str ()); //NOTE: need the c-style char to stop at '\0'
- file_path += "/";
- file_path += name;
-
- //print out the file to be uncompressed
- if (verbose)
- {
- ACE_OS::write(ACE_STDOUT, file_path.c_str (), file_path.length () );
- ACE_OS::write(ACE_STDOUT, "\n", 1);
- }
-
- // Open a file handle to the local filesystem
- ACE_HANDLE handle = ACE_OS::open (file_path.c_str (), O_CREAT | O_TRUNC | O_WRONLY);
- if (handle == ACE_INVALID_HANDLE)
- {
- zzip_closedir(dir);
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("%p\n"),
- ACE_TEXT ("[uncompress] file creation error")),
- 0);
- }
-
- //write the uncompressed data to the file
- if (ACE_OS::write (handle, &(*buffer), dir_entry->st_size) == -1)
- {
- zzip_closedir(dir);
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("%p\n"),
- ACE_TEXT ("[uncompress] file write error")),
- 0);
- }
-
- // Close the file handle
- ACE_OS::close (handle);
- }
-
- zzip_closedir(dir);
- return true;
-}
View Lorry Controller Status