List of all members | Public Types | Public Member Functions | Static Public Member Functions | Protected Member Functions | Protected Attributes
casadi::ZipMemResource Class Reference

RAII class for reading from a zip held in memory. More...

#include <resource_internal.hpp>

Detailed Description

Extra doc: https://github.com/casadi/casadi/wiki/L_2cy

Definition at line 141 of file resource_internal.hpp.

Inheritance diagram for casadi::ZipMemResource:
Inheritance graph
[legend]
Collaboration diagram for casadi::ZipMemResource:
Collaboration graph
[legend]

Public Types

using weak_ref_type = WeakRefInternal
 

Public Member Functions

 ZipMemResource (const std::istream &src)
 
 ~ZipMemResource () override
 
const std::string & path () const override
 Get path for a consumer. More...
 
void unpack ()
 
std::string class_name () const override
 Get type name. More...
 
void disp (std::ostream &stream, bool more) const override
 Print description. More...
 
void serialize_body (SerializingStream &s) const override
 
void serialize (SerializingStream &s) const
 
virtual void serialize_type (SerializingStream &s) const
 
void change_option (const std::string &option_name, const GenericType &option_value)
 
casadi_int getCount () const
 Get the reference count. More...
 
std::string debug_repr (const SharedObjectInternal *) const
 
GenericWeakRef< SharedObject, SharedObjectInternal > * weak ()
 Get a weak reference to the object. More...
 

Static Public Member Functions

static ResourceInternaldeserialize (DeserializingStream &s)
 

Protected Member Functions

 ZipMemResource (DeserializingStream &s)
 
void initSingleton ()
 
void destroySingleton ()
 
shared_from_this ()
 Get a shared object from the current internal object. More...
 
const B shared_from_this () const
 Get a shared object from the current internal object. More...
 

Protected Attributes

std::string serialize_mode_
 

Member Typedef Documentation

◆ weak_ref_type

Definition at line 152 of file shared_object.hpp.

Constructor & Destructor Documentation

◆ ZipMemResource() [1/2]

casadi::ZipMemResource::ZipMemResource ( const std::istream &  src)

Definition at line 105 of file resource_internal.cpp.

106  : ResourceInternal() {
107  blob_ << src.rdbuf();
108  unpack();
109 }
ResourceInternal()
Initialize with a path.

References unpack().

Referenced by deserialize().

◆ ~ZipMemResource()

casadi::ZipMemResource::~ZipMemResource ( )
override

Definition at line 132 of file resource_internal.cpp.

132  {
133  try {
135  } catch (...) {
136  casadi_warning("Error: Cannot remove temporary directory: " + dir_);
137  }
138  try {
139  Filesystem::remove(lock_file_);
140  } catch (...) {
141  casadi_warning("Error: Cannot remove lock file: " + lock_file_);
142  }
143 }
static casadi_int remove_all(const std::string &path)
Definition: filesystem.cpp:48
static bool remove(const std::string &path)
Definition: filesystem.cpp:43

References casadi::Filesystem::remove(), and casadi::Filesystem::remove_all().

◆ ZipMemResource() [2/2]

casadi::ZipMemResource::ZipMemResource ( DeserializingStream s)
explicitprotected

Definition at line 200 of file resource_internal.cpp.

200  : ResourceInternal(s) {
201 #ifdef CASADI_WITH_THREADSAFE_SYMBOLICS
202  std::lock_guard<std::mutex> lock(mutex_blob_);
203 #endif // CASADI_WITH_THREADSAFE_SYMBOLICS
204  s.version("ZipMemResource", 1);
205  s.unpack("ZipMemResource::blob", blob_);
206  unpack();
207 }

References unpack(), casadi::DeserializingStream::unpack(), and casadi::DeserializingStream::version().

Member Function Documentation

◆ change_option()

void casadi::ResourceInternal::change_option ( const std::string &  option_name,
const GenericType option_value 
)
inherited

Definition at line 53 of file resource_internal.cpp.

54  {
55  if (option_name=="serialize_mode") {
56  serialize_mode_ = option_value.to_string();
57  casadi_assert(serialize_mode_=="embed" || serialize_mode_=="link",
58  "Invalid serialization mode: " + serialize_mode_ + ". Pick 'link' or 'embed'.");
59  } else {
60  casadi_error("Option '" + option_name + "' does not exist");
61  }
62 }

References casadi::ResourceInternal::serialize_mode_, and casadi::GenericType::to_string().

◆ class_name()

std::string casadi::ZipMemResource::class_name ( ) const
inlineoverridevirtual

Extra doc: https://github.com/casadi/casadi/wiki/L_2d5

Implements casadi::SharedObjectInternal.

Definition at line 152 of file resource_internal.hpp.

152 {return "ZipMemResource";}

◆ debug_repr()

std::string casadi::GenericSharedInternal< SharedObject , SharedObjectInternal >::debug_repr ( const Internal *  i) const
inherited

Definition at line 62 of file generic_shared_internal.hpp.

162  {
163  // Note: i != this because of something something multiple inheritance
164  return str( (casadi_int)(i)) + "/" + static_cast<const Internal*>(this)->class_name();
165  }
std::string str(const T &v)
String representation, any type.

◆ deserialize()

ResourceInternal * casadi::ZipMemResource::deserialize ( DeserializingStream s)
static

Definition at line 184 of file resource_internal.cpp.

184  {
185 ZipMemResource* ret = new ZipMemResource(s);
186  return ret;
187 }
ZipMemResource(const std::istream &src)

References ZipMemResource().

Referenced by casadi::ResourceInternal::deserialize().

◆ destroySingleton()

void casadi::GenericSharedInternal< SharedObject , SharedObjectInternal >::destroySingleton ( )
inlineprotectedinherited

Called in the destructor of singletons

Definition at line 77 of file generic_shared_internal.hpp.

77  {
78  static_cast<Internal*>(this)->count--;
79  }

◆ disp()

void casadi::ZipMemResource::disp ( std::ostream &  stream,
bool  more 
) const
overridevirtual

Implements casadi::SharedObjectInternal.

Definition at line 115 of file resource_internal.cpp.

115  {
116  stream << "ZipMemResource(blob) -> \"" << dir_ << "\"";
117 }

◆ getCount()

Definition at line 60 of file generic_shared_internal.hpp.

186  {
187  return static_cast<const Internal*>(this)->count;
188  }

◆ initSingleton()

void casadi::GenericSharedInternal< SharedObject , SharedObjectInternal >::initSingleton ( )
inlineprotectedinherited

Called in the constructor of singletons to avoid that the counter reaches zero

Definition at line 71 of file generic_shared_internal.hpp.

71  {
72  casadi_assert_dev(static_cast<Internal*>(this)->count==0);
73  static_cast<Internal*>(this)->count++;
74  }

◆ path()

const std::string& casadi::ZipMemResource::path ( ) const
inlineoverridevirtual

Implements casadi::ResourceInternal.

Definition at line 146 of file resource_internal.hpp.

146 {return dir_;}

◆ serialize()

void casadi::ResourceInternal::serialize ( SerializingStream s) const
inherited

Definition at line 145 of file resource_internal.cpp.

145  {
146  s.version("ResourceInternal", 1);
147  serialize_type(s);
148  serialize_body(s);
149 }
virtual void serialize_body(SerializingStream &s) const
virtual void serialize_type(SerializingStream &s) const

References casadi::ResourceInternal::serialize_body(), casadi::ResourceInternal::serialize_type(), and casadi::SerializingStream::version().

◆ serialize_body()

void casadi::ZipMemResource::serialize_body ( SerializingStream s) const
overridevirtual

Reimplemented from casadi::ResourceInternal.

Definition at line 272 of file resource_internal.cpp.

272  {
273 #ifdef CASADI_WITH_THREADSAFE_SYMBOLICS
274  std::lock_guard<std::mutex> lock(mutex_blob_);
275 #endif // CASADI_WITH_THREADSAFE_SYMBOLICS
277  s.version("ZipMemResource", 1);
278  s.pack("ZipMemResource::blob", blob_);
279 
280  // rewind
281  blob_.clear();
282  blob_.seekg(0, std::ios::beg);
283 }

References casadi::SerializingStream::pack(), casadi::ResourceInternal::serialize_body(), and casadi::SerializingStream::version().

◆ serialize_type()

void casadi::ResourceInternal::serialize_type ( SerializingStream s) const
virtualinherited

Reimplemented in casadi::ZipResource, and casadi::DirResource.

Definition at line 151 of file resource_internal.cpp.

151  {
152  s.pack("ResourceInternal::type", class_name());
153 }
virtual std::string class_name() const =0
Readable name of the internal class.

References casadi::SharedObjectInternal::class_name(), and casadi::SerializingStream::pack().

Referenced by casadi::ResourceInternal::serialize().

◆ shared_from_this() [1/2]

B casadi::GenericSharedInternal< SharedObject , SharedObjectInternal >::shared_from_this ( )
inlineprotectedinherited

Definition at line 83 of file generic_shared_internal.hpp.

83  {
84  casadi_assert_dev(B::test_cast(static_cast<Internal*>(this)));
85  B ret;
86  ret.own(static_cast<Internal*>(this));
87  return ret;
88  }

◆ shared_from_this() [2/2]

const B casadi::GenericSharedInternal< SharedObject , SharedObjectInternal >::shared_from_this ( ) const
inlineprotectedinherited

Definition at line 92 of file generic_shared_internal.hpp.

92  {
93  casadi_assert_dev(B::test_cast(static_cast<const Internal*>(this)));
94  B ret;
95  ret.own(const_cast<Internal*>(static_cast<const Internal*>(this)));
96  return ret;
97  }

◆ unpack()

void casadi::ZipMemResource::unpack ( )

Definition at line 85 of file resource_internal.cpp.

85  {
86  std::string zip_file = "zip";
87  lock_file_ = temporary_file(zip_file + ".", ".lock");
88  dir_ = lock_file_.substr(0, lock_file_.size()-5) + ".unzipped";
89  casadi_assert(Archiver::has_plugin("libzip"),
90  "Unzipping stream requires libzip. Compile CasADi with WITH_LIBZIP=ON.\n"
91  "Alternatively, save with serialize option set to link. ");
92 
93  Archiver::getPlugin("libzip").exposed.unpack_from_stringstream(blob_, dir_);
94  // rewind
95  blob_.clear();
96  blob_.seekg(0, std::ios::beg);
97 }
static bool has_plugin(const std::string &pname, bool verbose=false)
Check if a plugin is available or can be loaded.
static Plugin & getPlugin(const std::string &pname)
Load and get the creator function.
std::string temporary_file(const std::string &prefix, const std::string &suffix)

References casadi::PluginInterface< Archiver >::getPlugin(), casadi::PluginInterface< Archiver >::has_plugin(), and casadi::temporary_file().

Referenced by ZipMemResource().

◆ weak()

Extra doc: https://github.com/casadi/casadi/wiki/L_1ai

Definition at line 67 of file generic_shared_internal.hpp.

191  {
192  if (weak_ref_==nullptr) {
193  weak_ref_ = new GenericWeakRef<Shared, Internal>(static_cast<Internal*>(this));
194  }
195  return weak_ref_;
196  }

Member Data Documentation

◆ serialize_mode_

std::string casadi::ResourceInternal::serialize_mode_
protectedinherited

The documentation for this class was generated from the following files: