lzo_ex.cpp

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include "nixsys.h"
#include "minilzo.203/minilzo.h"

#if defined(__LZO_STRICT_16BIT)
  #define IN_LEN      (8*1024u)
#elif defined(LZO_ARCH_I086) && !defined(LZO_HAVE_MM_HUGE_ARRAY)
  #define IN_LEN      (60*1024u)
#else
//   #define IN_LEN      (128*1024ul)
  #define IN_LEN      (4*1024ul)
#endif
#define OUT_LEN     (IN_LEN + IN_LEN / 16 + 64 + 3)

#define HEAP_ALLOC(var,size) \
    lzo_align_t __LZO_MMODEL var [ ((size) + (sizeof(lzo_align_t) - 1)) / sizeof(lzo_align_t) ]


unsigned char __LZO_MMODEL in  [ IN_LEN ];
unsigned char __LZO_MMODEL out [ OUT_LEN ];
HEAP_ALLOC(wrkmem,LZO1X_1_MEM_COMPRESS);

// using namespace n2nc;

int main(int argc, char *argv[]){
  void *buf = malloc(16000);
  void *buf2 = malloc(16000);
  char *str= "text data text data text data text data text data text data" ;
int  r;  
  lzo_uint in_len;
  lzo_uint out_len;
  lzo_uint new_len;
    
  std::cerr << "INLEN " << IN_LEN <<  std::endl ;

  int outw,n ;
  if (lzo_init() != LZO_E_OK){
    fprintf(stderr,"internal error - lzo_init() failed !!!\n");
    fprintf(stderr,"(this usually indicates a compiler bug - try recompiling\nwithout optimizations, and enable `-DLZO_DEBUG' for diagnostics)\n");
    return 3;
  }

  if (argc < 2){
    std::cerr << "compressing" << std::endl ;
    outw = 0 ;
    while(n = ::read(0,buf,129)){
//       outw = rs.encrypt(buf, buf2,n);
//       ::write(1,buf2,outw);
      
      in_len = n;
      lzo_memcpy(in,buf,n);
//       in_len = strlen(str);
//       in_len = IN_LEN;
//       lzo_memcpy(in,str,strlen(str));
      
      r = lzo1x_1_compress(in,in_len,out,&out_len,wrkmem);
      if (r == LZO_E_OK)
          fprintf(stderr,"compressed %lu bytes into %lu bytes\n",
              (unsigned long) in_len, (unsigned long) out_len);
      else
      {
          /* this should NEVER happen */
          fprintf(stderr,"internal error - compression failed: %d\n", r);
          return 2;
      }
     
      ::write(1,out,out_len);
      std::cerr << "written " << out_len << "bytes" << std::endl ;
    }
  }else{
    outw = 0 ;
      std::cerr << "decompressing" << std::endl ;
    while(n = ::read(0,out,100)){
//     while(n = ::read(0,out,OUT_LEN)){
      
      out_len = n ;
//       lzo_memcpy(out
      r = lzo1x_decompress(out,out_len,in,&new_len,NULL);
      if (r == LZO_E_OK)
          fprintf(stderr,"decompressed %lu bytes back into %lu bytes\n",
              (unsigned long) out_len, (unsigned long) new_len);
      else
      {
          /* this should NEVER happen */
          fprintf(stderr,"internal error - decompression failed: %d\n", r);
          return 1;
      }

      ::write(1,in,new_len);

//       outw = rs2.decrypt(buf, buf2,n);
//       ::write(1,buf2,outw);
      std::cerr << "written" << outw << "bytes" << std::endl ;
      
    }
  }
  
  
  
/*  
  written = bf.encrypt((void*)str,buf,strlen(str));
  written += bf.encrypt((void*)str,(void*)((uint)buf+written),strlen(str));
  
  bf2.decrypt(buf,buf2,written);
  std::cerr << (char*)buf2 << "wlen:" << written<< std::endl ;*/
  
  
  return EXIT_SUCCESS;
}

---