See More

// Produce deprecation warnings (needs to come before arrayobject.h inclusion). #define NPY_NO_DEPRECATED_API NPY_1_7_API_VERSION #include #include #include #include #include #include // these need to be included after boost on OS X #include // NOLINT(build/include_order) #include // NOLINT(build/include_order) #include // NOLINT #include "caffe/caffe.hpp" #include "caffe/definitions.hpp" #include "caffe/layers/memory_data_layer.hpp" #include "caffe/layers/python_layer.hpp" #include "caffe/sgd_solvers.hpp" // Temporary solution for numpy < 1.7 versions: old macro, no promises. // You're strongly advised to upgrade to >= 1.7. #ifndef NPY_ARRAY_C_CONTIGUOUS #define NPY_ARRAY_C_CONTIGUOUS NPY_C_CONTIGUOUS #define PyArray_SetBaseObject(arr, x) (PyArray_BASE(arr) = (x)) #endif /* Fix to avoid registration warnings in pycaffe (#3960) */ #define BP_REGISTER_SHARED_PTR_TO_PYTHON(PTR) do { \ const boost::python::type_info info = \ boost::python::type_id >(); \ const boost::python::converter::registration* reg = \ boost::python::converter::registry::query(info); \ if (reg == NULL) { \ bp::register_ptr_to_python >(); \ } else if ((*reg).m_to_python == NULL) { \ bp::register_ptr_to_python >(); \ } \ } while (0) #if defined(_MSC_VER) && (_MSC_FULL_VER >= 190024210) // Workaround for VS 2015 Update 3 which breaks boost python // See: http://stackoverflow.com/questions/38261530/unresolved-external-symbols-since-visual-studio-2015-update-3-boost-python-link // and https://msdn.microsoft.com/vs-knownissues/vs2015-update3 #define BP_GET_POINTER(cls) \ namespace boost { \ template <> \ const volatile caffe::cls * \ get_pointer(const volatile caffe::cls *c) { \ return c; \ } \ } #define BP_GET_POINTER_T(cls, dtype) BP_GET_POINTER(cls) // forward declare the NCCL class // in case we are not using NCCL namespace caffe { template class NCCL; } BP_GET_POINTER_T(Net, float); BP_GET_POINTER_T(Layer, float); BP_GET_POINTER_T(Solver, float); BP_GET_POINTER_T(SGDSolver, float); BP_GET_POINTER_T(NesterovSolver, float); BP_GET_POINTER_T(AdaGradSolver, float); BP_GET_POINTER_T(RMSPropSolver, float); BP_GET_POINTER_T(AdaDeltaSolver, float); BP_GET_POINTER_T(AdamSolver, float); BP_GET_POINTER_T(NCCL, float); BP_GET_POINTER(Timer); BP_GET_POINTER(LayerParameter); BP_GET_POINTER(NetParameter); BP_GET_POINTER(NetState); #endif namespace bp = boost::python; namespace caffe { // For Python, for now, we'll just always use float as the type. typedef float Dtype; const int NPY_DTYPE = NPY_FLOAT32; // Selecting mode. void set_mode_cpu() { Caffe::set_mode(Caffe::CPU); } void set_mode_gpu() { Caffe::set_mode(Caffe::GPU); } void select_device(int id, bool listId) { Caffe::SelectDevice(id, listId); } void set_devices(bp::tuple args) { vector devices(bp::len(args)); for (int i = 0; i < bp::len(args); ++i) { devices[i] = bp::extract(args[i]); } Caffe::SetDevices(devices); } void InitLog(int level) { FLAGS_logtostderr = 1; FLAGS_minloglevel = level; ::google::InitGoogleLogging(""); #ifndef _MSC_VER // this symbol is undefined on windows ::google::InstallFailureSignalHandler(); #endif // _MSC_VER } void InitLogInfo() { // Windows disables abbreviated severities InitLog(google::GLOG_INFO); } void Log(const string& s) { LOG(INFO) << s; } void set_random_seed(unsigned int seed) { Caffe::set_random_seed(seed, Caffe::GetDefaultDevice()); } // For convenience, check that input files can be opened, and raise an // exception that boost will send to Python if not (caffe could still crash // later if the input files are disturbed before they are actually used, but // this saves frustration in most cases). static void CheckFile(const string& filename) { std::ifstream f(filename.c_str()); if (!f.good()) { f.close(); throw std::runtime_error("Could not open file " + filename); } f.close(); } void CheckContiguousArray(PyArrayObject* arr, string name, vector shape) { if (!(PyArray_FLAGS(arr) & NPY_ARRAY_C_CONTIGUOUS)) { throw std::runtime_error(name + " must be C contiguous"); } // This does not have to hold anymore /* if (PyArray_NDIM(arr) != 4) { throw std::runtime_error(name + " must be 4-d"); } */ if (PyArray_TYPE(arr) != NPY_FLOAT32) { throw std::runtime_error(name + " must be float32"); } for (int_tp i = 1; i < PyArray_NDIM(arr); ++i) { if (PyArray_DIMS(arr)[i] != shape[i]) { throw std::runtime_error( "Shape dimension " + std::to_string(i) + " has wrong size (" + std::to_string(static_cast (PyArray_DIMS(arr)[i])) + " vs. " + std::to_string(shape[i]) + ")"); } } } // Net constructor shared_ptr > Net_Init(string network_file, int phase, int level, const bp::object& stages, const bp::object& weights) { CheckFile(network_file); // Convert stages from list to vector std::vector<:string> stages_vector; if (!stages.is_none()) { for (int i = 0; i < len(stages); i++) { stages_vector.push_back(bp::extract(stages[i])); } } // Initialize net shared_ptr > net(new Net(network_file, static_cast(phase), Caffe::GetDefaultDevice(), level, &stages_vector)); // Load weights if (!weights.is_none()) { std::string weights_file_str = bp::extract<:string>(weights); CheckFile(weights_file_str); net->CopyTrainedLayersFrom(weights_file_str); } return net; } // Legacy Net construct-and-load convenience constructor shared_ptr > Net_Init_Load( string param_file, string pretrained_param_file, int phase, int level, const bp::object& stages) { LOG(WARNING) << "DEPRECATION WARNING - deprecated use of Python interface"; LOG(WARNING) << "Use this instead (with the named \"weights\"" << " parameter):"; LOG(WARNING) << "Net('" << param_file << "', " << phase << ", weights='" << pretrained_param_file << "')"; CheckFile(param_file); CheckFile(pretrained_param_file); // Convert stages from list to vector std::vector<:string> stages_vector; if (!stages.is_none()) { for (int i = 0; i < len(stages); i++) { stages_vector.push_back(bp::extract(stages[i])); } } shared_ptr > net(new Net(param_file, static_cast(phase), Caffe::GetDefaultDevice(), level, &stages_vector)); net->CopyTrainedLayersFrom(pretrained_param_file); return net; } void Net_Save(const Net& net, string filename) { NetParameter net_param; net.ToProto(&net_param, false); WriteProtoToBinaryFile(net_param, filename.c_str()); } void Net_SaveHDF5(const Net& net, string filename) { net.ToHDF5(filename); } void Net_LoadHDF5(Net* net, string filename) { net->CopyTrainedLayersFromHDF5(filename.c_str()); } void Net_SetInputArrays(Net* net, int index, bp::object data_obj, bp::object labels_obj) { // check that this network has an input MemoryDataLayer shared_ptr > md_layer = boost::dynamic_pointer_cast >(net->layers()[index]); if (!md_layer) { throw std::runtime_error("set_input_arrays may only be called if the" " first layer is a MemoryDataLayer"); } // check that we were passed appropriately-sized contiguous memory PyArrayObject* data_arr = reinterpret_cast(data_obj.ptr()); PyArrayObject* labels_arr = reinterpret_cast(labels_obj.ptr()); CheckContiguousArray(data_arr, "data array", md_layer->shape()); CheckContiguousArray(labels_arr, "labels array", md_layer->label_shape()); if (PyArray_DIMS(data_arr)[0] != PyArray_DIMS(labels_arr)[0]) { throw std::runtime_error("data and labels must have the same first" " dimension"); } if (PyArray_DIMS(data_arr)[0] % md_layer->batch_size() != 0) { throw std::runtime_error("first dimensions of input arrays must be a" " multiple of batch size"); } md_layer->Reset(static_cast(PyArray_DATA(data_arr)), static_cast(PyArray_DATA(labels_arr)), PyArray_DIMS(data_arr)[0]); } void Net_SetLayerInputArrays(Net* net, Layer* layer, bp::object data_obj, bp::object labels_obj) { MemoryDataLayer* md_layer = (MemoryDataLayer*)(layer); // check that we were passed appropriately-sized contiguous memory PyArrayObject* data_arr = reinterpret_cast(data_obj.ptr()); CheckContiguousArray(data_arr, "data array", md_layer->shape()); if (PyArray_DIMS(data_arr)[0] % md_layer->batch_size() != 0) { throw std::runtime_error("first dimensions of input arrays must be a" " multiple of batch size"); } PyArrayObject* labels_arr = nullptr; if (labels_obj.ptr() != bp::object().ptr()) { labels_arr = reinterpret_cast(labels_obj.ptr()); CheckContiguousArray(labels_arr, "labels array", md_layer->label_shape()); if (PyArray_DIMS(data_arr)[0] != PyArray_DIMS(labels_arr)[0]) { throw std::runtime_error("data and labels must have the same first" " dimension"); } md_layer->Reset(static_cast(PyArray_DATA(data_arr)), static_cast(PyArray_DATA(labels_arr)), PyArray_DIMS(data_arr)[0]); } else { md_layer->Reset(static_cast(PyArray_DATA(data_arr)), nullptr, PyArray_DIMS(data_arr)[0]); } } Solver* GetSolverFromFile(const string& filename) { SolverParameter param; ReadSolverParamsFromTextFileOrDie(filename, &param); return SolverRegistry::CreateSolver(param); } Solver* GetSolver(const SolverParameter& solver_param) { return SolverRegistry::CreateSolver(solver_param); } struct NdarrayConverterGenerator { template struct apply; }; template <> struct NdarrayConverterGenerator::apply { struct type { PyObject* operator() (Dtype* data) const { // Just store the data pointer, and add the shape information in postcall. return PyArray_SimpleNewFromData(0, NULL, NPY_DTYPE, data); } const PyTypeObject* get_pytype() { return &PyArray_Type; } }; }; struct NdarrayCallPolicies : public bp::default_call_policies { typedef NdarrayConverterGenerator result_converter; PyObject* postcall(PyObject* pyargs, PyObject* result) { bp::object pyblob = bp::extract<:tuple>(pyargs)()[0]; shared_ptr > blob = bp::extract > >(pyblob); // Free the temporary pointer-holding array, and construct a new one with // the shape information from the blob. void* data = PyArray_DATA(reinterpret_cast(result)); Py_DECREF(result); const int_tp num_axes = blob->num_axes(); #ifdef USE_INDEX64 vector dims(blob->shape().begin(), blob->shape().end()); PyObject *arr_obj = PyArray_SimpleNewFromData(num_axes, dims.data(), NPY_FLOAT32, data); #else vector dims(blob->shape().begin(), blob->shape().end()); PyObject *arr_obj = PyArray_SimpleNewFromData(num_axes, dims.data(), NPY_FLOAT32, data); #endif // SetBaseObject steals a ref, so we need to INCREF. Py_INCREF(pyblob.ptr()); PyArray_SetBaseObject(reinterpret_cast(arr_obj), pyblob.ptr()); return arr_obj; } }; bp::object Blob_Reshape(bp::tuple args, bp::dict kwargs) { if (bp::len(kwargs) > 0) { throw std::runtime_error("Blob.reshape takes no kwargs"); } Blob* self = bp::extract*>(args[0]); vector shape(bp::len(args) - 1); for (int_tp i = 1; i < bp::len(args); ++i) { shape[i - 1] = bp::extract(args[i]); } self->Reshape(shape); // We need to explicitly return None to use bp::raw_function. return bp::object(); } bp::object BlobVec_add_blob(bp::tuple args, bp::dict kwargs) { if (bp::len(kwargs) > 0) { throw std::runtime_error("BlobVec.add_blob takes no kwargs"); } typedef vector > > BlobVec; BlobVec* self = bp::extract(args[0]); vector shape(bp::len(args) - 1); for (int_tp i = 1; i < bp::len(args); ++i) { shape[i - 1] = bp::extract(args[i]); } self->push_back(shared_ptr >(new Blob(shape))); // We need to explicitly return None to use bp::raw_function. return bp::object(); } void exception_translator(std::exception ex) { std::cout << ex.what() << std::endl; } // NOLINT_NEXT_LINE(runtime/references) Dtype ForwardFromTo_NoGIL(Net& net, int_tp start, int_tp end) { Dtype loss; Py_BEGIN_ALLOW_THREADS loss = net.ForwardFromTo(start, end); Py_END_ALLOW_THREADS return loss; } // NOLINT_NEXT_LINE(runtime/references) void BackwardFromTo_NoGIL(Net& net, int_tp start, int_tp end) { Py_BEGIN_ALLOW_THREADS net.BackwardFromTo(start, end); Py_END_ALLOW_THREADS } // NOLINT_NEXT_LINE(runtime/references) Dtype Step_NoGIL(Solver& solver, int_tp iters) { Dtype smoothed_loss; Py_BEGIN_ALLOW_THREADS smoothed_loss = solver.Step(iters); Py_END_ALLOW_THREADS return smoothed_loss; } // NOLINT_NEXT_LINE(runtime/references) void Solve_NoGIL(Solver& solver, const char* resume_file) { Py_BEGIN_ALLOW_THREADS solver.Solve(resume_file); Py_END_ALLOW_THREADS } template class SolverCallback: public Solver::Callback { protected: bp::object on_start_, on_gradients_ready_; public: SolverCallback(bp::object on_start, bp::object on_gradients_ready) : on_start_(on_start), on_gradients_ready_(on_gradients_ready) { } virtual void on_gradients_ready() { on_gradients_ready_(); } virtual void on_start() { on_start_(); } }; template void Solver_add_callback(Solver * solver, bp::object on_start, bp::object on_gradients_ready) { solver->add_callback(new SolverCallback(on_start, on_gradients_ready)); } // Seems boost cannot call the base method directly void Solver_add_nccl(SGDSolver* solver #ifdef USE_NCCL , NCCL* nccl #endif ) { #ifdef USE_NCCL solver->add_callback(nccl); #endif } template class NetCallback: public Net::Callback { public: explicit NetCallback(bp::object run) : run_(run) {} protected: virtual void run(int layer) { run_(layer); } bp::object run_; }; void Net_before_forward(Net* net, bp::object run) { net->add_before_forward(new NetCallback(run)); } void Net_after_forward(Net* net, bp::object run) { net->add_after_forward(new NetCallback(run)); } void Net_before_backward(Net* net, bp::object run) { net->add_before_backward(new NetCallback(run)); } void Net_after_backward(Net* net, bp::object run) { net->add_after_backward(new NetCallback(run)); } void Net_add_nccl(Net* net #ifdef USE_NCCL , NCCL* nccl #endif ) { #ifdef USE_NCCL net->add_after_backward(nccl); #endif } #ifndef USE_NCCL template class NCCL { public: NCCL(shared_ptr > solver, const string& uid) {} }; #endif BOOST_PYTHON_MEMBER_FUNCTION_OVERLOADS(SolveOverloads, Solve, 0, 1); BOOST_PYTHON_MODULE(_caffe) { bp::register_exception_translator<:exception>(&exception_translator); // below, we prepend an underscore to methods that will be replaced // in Python bp::scope().attr("__version__") = AS_STRING(CAFFE_VERSION); // Caffe utility functions bp::def("init_log", &InitLog); bp::def("init_log", &InitLogInfo); bp::def("log", &Log); bp::def("set_mode_cpu", &set_mode_cpu); bp::def("set_mode_gpu", &set_mode_gpu); bp::def("set_random_seed", &set_random_seed); bp::def("set_device", &Caffe::SetDevice); bp::def("set_devices", &set_devices); bp::def("select_device", &select_device); bp::def("enumerate_devices", &Caffe::EnumerateDevices); bp::def("solver_count", &Caffe::solver_count); bp::def("set_solver_count", &Caffe::set_solver_count); bp::def("solver_rank", &Caffe::solver_rank); bp::def("set_solver_rank", &Caffe::set_solver_rank); bp::def("set_multiprocess", &Caffe::set_multiprocess); bp::def("layer_type_list", &LayerRegistry::LayerTypeList); bp::class_, shared_ptr >, boost::noncopyable >("Net", bp::no_init) // Constructor .def("__init__", bp::make_constructor(&Net_Init, bp::default_call_policies(), (bp::arg("network_file"), "phase", bp::arg("level")=0, bp::arg("stages")=bp::object(), bp::arg("weights")=bp::object()))) // Legacy constructor .def("__init__", bp::make_constructor(&Net_Init_Load, bp::default_call_policies(), (bp::arg("network_file"), bp::arg("pretrained_param_file"), "phase", bp::arg("level")=0, bp::arg("stages")=bp::object()))) .def("_forward", &ForwardFromTo_NoGIL) .def("_backward", &BackwardFromTo_NoGIL) .def("reshape", &Net::Reshape) .def("clear_param_diffs", &Net::ClearParamDiffs) // The cast is to select a particular overload. .def("copy_from", static_cast::*)(const string)>( &Net::CopyTrainedLayersFrom)) .def("share_with", &Net::ShareTrainedLayersWith) .add_property("_blob_loss_weights", bp::make_function( &Net::blob_loss_weights, bp::return_internal_reference<>())) .def("_bottom_ids", bp::make_function(&Net::bottom_ids, bp::return_value_policy<:copy_const_reference>())) .def("_top_ids", bp::make_function(&Net::top_ids, bp::return_value_policy<:copy_const_reference>())) .add_property("_blobs", bp::make_function(&Net::blobs, bp::return_internal_reference<>())) .add_property("layers", bp::make_function(&Net::layers, bp::return_internal_reference<>())) .add_property("_blob_names", bp::make_function(&Net::blob_names, bp::return_value_policy<:copy_const_reference>())) .add_property("_layer_names", bp::make_function(&Net::layer_names, bp::return_value_policy<:copy_const_reference>())) .add_property("_inputs", bp::make_function(&Net::input_blob_indices, bp::return_value_policy<:copy_const_reference>())) .add_property("_outputs", bp::make_function(&Net::output_blob_indices, bp::return_value_policy<:copy_const_reference>())) .def("_set_input_arrays", &Net_SetInputArrays, bp::with_custodian_and_ward<1, 3, bp::with_custodian_and_ward<1, 4> > ()) .def("_set_layer_input_arrays", &Net_SetLayerInputArrays, bp::with_custodian_and_ward<1, 3, bp::with_custodian_and_ward<1, 4> > ()) .def("save", &Net_Save) .def("save_hdf5", &Net_SaveHDF5) .def("load_hdf5", &Net_LoadHDF5) .def("before_forward", &Net_before_forward) .def("after_forward", &Net_after_forward) .def("before_backward", &Net_before_backward) .def("after_backward", &Net_after_backward) .def("after_backward", &Net_add_nccl); BP_REGISTER_SHARED_PTR_TO_PYTHON(Net); bp::class_, shared_ptr >, boost::noncopyable>( "Blob", bp::no_init) .add_property("shape", bp::make_function( static_cast& (Blob::*)() const>( &Blob::shape), bp::return_value_policy<:copy_const_reference>())) .add_property("num", &Blob::num) .add_property("channels", &Blob::channels) .add_property("height", &Blob::height) .add_property("width", &Blob::width) .add_property("count", static_cast::*)() const>( &Blob::count)) .def("reshape", bp::raw_function(&Blob_Reshape)) .add_property("data", bp::make_function(&Blob::mutable_cpu_data, NdarrayCallPolicies())) .add_property("diff", bp::make_function(&Blob::mutable_cpu_diff, NdarrayCallPolicies())); BP_REGISTER_SHARED_PTR_TO_PYTHON(Blob); bp::class_, shared_ptr >, boost::noncopyable>("Layer", bp::init()) .add_property("blobs", bp::make_function(&Layer::blobs, bp::return_internal_reference<>())) .def("setup", &Layer::LayerSetUp) .def("reshape", &Layer::Reshape) .add_property("type", bp::make_function(&Layer::type)) .add_property("layer_param", bp::make_function(&Layer::layer_param, bp::return_internal_reference<>())); BP_REGISTER_SHARED_PTR_TO_PYTHON(Layer); bp::class_("LayerParameter", bp::no_init) .add_property("name", bp::make_function( static_cast(&LayerParameter::name), bp::return_value_policy<:return_by_value>())) .add_property("bottom_size", &LayerParameter::bottom_size) .def("get_bottom", bp::make_function( static_cast(&LayerParameter::bottom), // NOLINT bp::return_value_policy<:return_by_value>())) .add_property("top_size", &LayerParameter::top_size) .def("get_top", bp::make_function( static_cast(&LayerParameter::top), // NOLINT bp::return_value_policy<:return_by_value>())); bp::class_("SolverParameter", bp::no_init) .add_property("max_iter", &SolverParameter::max_iter) .add_property("display", &SolverParameter::display) .add_property("layer_wise_reduce", &SolverParameter::layer_wise_reduce); bp::class_("LayerParameter", bp::no_init); bp::class_, shared_ptr >, boost::noncopyable>( "Solver", bp::no_init) .add_property("net", &Solver::net) .add_property("max_iter", &Solver::max_iter) .add_property("test_nets", bp::make_function(&Solver::test_nets, bp::return_internal_reference<>())) .add_property("iter", &Solver::iter) .add_property("solver_params", &Solver::GetSolverParams, &Solver::UpdateSolverParams) .def("step", &Step_NoGIL) .def("solve", &Solve_NoGIL) .def("add_callback", &Solver_add_callback) .def("add_callback", &Solver_add_nccl) .def("solve", static_cast::*)(const char*)>( &Solver::Solve), SolveOverloads()) .def("step", &Solver::Step) .def("restore", &Solver::Restore) .def("snapshot", &Solver::Snapshot) .add_property("param", bp::make_function(&Solver::param, bp::return_value_policy<:copy_const_reference>())); BP_REGISTER_SHARED_PTR_TO_PYTHON(Solver); bp::class_("NetState", bp::init<>()) .add_property("phase", &NetState::phase, &NetState::set_phase) .add_property("level", &NetState::level, &NetState::set_level) .def("stage_size", &NetState::stage_size) .def("get_stage", bp::make_function( static_cast(&NetState::stage), // NOLINT bp::return_value_policy<:return_by_value>())) .def("add_stage", static_cast(&NetState::add_stage)) .def("set_stage", static_cast(&NetState::set_stage)) .def("clear_stage", &NetState::clear_stage); bp::class_("NetParameter", bp::init<>()) .add_property("force_backward", &NetParameter::force_backward, &NetParameter::set_force_backward) .add_property("state", bp::make_function(&NetParameter::state, bp::return_value_policy<:copy_const_reference>()), static_cast( &NetParameter::set_allocated_state)); bp::class_("SolverParameter", bp::init<>()) .add_property("base_lr", &SolverParameter::base_lr, &SolverParameter::set_base_lr) .add_property("max_iter", &SolverParameter::max_iter, &SolverParameter::set_max_iter) .add_property("lr_policy", bp::make_function(&SolverParameter::lr_policy, bp::return_value_policy<:copy_const_reference>()), static_cast( &SolverParameter::set_lr_policy)) .add_property("gamma", &SolverParameter::gamma, &SolverParameter::set_gamma) .add_property("power", &SolverParameter::power, &SolverParameter::set_power) .add_property("momentum", &SolverParameter::momentum, &SolverParameter::set_momentum) .add_property("momentum2", &SolverParameter::momentum2, &SolverParameter::set_momentum2) .add_property("delta", &SolverParameter::delta, &SolverParameter::set_delta) .add_property("rms_decay", &SolverParameter::rms_decay, &SolverParameter::set_rms_decay) .add_property("weight_decay", &SolverParameter::weight_decay, &SolverParameter::set_weight_decay) .add_property("display", &SolverParameter::display, &SolverParameter::set_display) .add_property("regularization_type", bp::make_function(&SolverParameter::regularization_type, bp::return_value_policy<:copy_const_reference>()), static_cast( &SolverParameter::set_regularization_type)) .add_property("stepsize", &SolverParameter::stepsize, &SolverParameter::set_stepsize) .add_property("snapshot", &SolverParameter::snapshot, &SolverParameter::set_snapshot) .add_property("snapshot_format", &SolverParameter::snapshot_format, &SolverParameter::set_snapshot_format) .add_property("snapshot_prefix", bp::make_function(&SolverParameter::snapshot_prefix, bp::return_value_policy<:copy_const_reference>()), static_cast( &SolverParameter::set_snapshot_prefix)) .add_property("type", bp::make_function(&SolverParameter::type, bp::return_value_policy<:copy_const_reference>()), static_cast( &SolverParameter::set_type)) .add_property("net", bp::make_function(&SolverParameter::net, bp::return_value_policy<:copy_const_reference>()), static_cast( &SolverParameter::set_net)) .add_property("train_net", bp::make_function(&SolverParameter::train_net, bp::return_value_policy<:copy_const_reference>()), static_cast( &SolverParameter::set_train_net)) .add_property("net_param", bp::make_function(&SolverParameter::mutable_net_param, bp::return_value_policy<:reference_existing_object>()), static_cast( &SolverParameter::set_allocated_net_param)) .add_property("train_state", bp::make_function(&SolverParameter::mutable_train_state, bp::return_value_policy<:reference_existing_object>()), static_cast( &SolverParameter::set_allocated_train_state)); bp::enum_<::caffe::SolverParameter_SnapshotFormat>("snapshot_format") .value("HDF5", SolverParameter_SnapshotFormat_HDF5) .value("BINARYPROTO", SolverParameter_SnapshotFormat_BINARYPROTO); bp::class_, bp::bases >, shared_ptr >, boost::noncopyable>( "SGDSolver", bp::init()); bp::class_, bp::bases >, shared_ptr >, boost::noncopyable>( "NesterovSolver", bp::init()); bp::class_, bp::bases >, shared_ptr >, boost::noncopyable>( "AdaGradSolver", bp::init()); bp::class_, bp::bases >, shared_ptr >, boost::noncopyable>( "RMSPropSolver", bp::init()); bp::class_, bp::bases >, shared_ptr >, boost::noncopyable>( "AdaDeltaSolver", bp::init()); bp::class_, bp::bases >, shared_ptr >, boost::noncopyable>( "AdamSolver", bp::init()); bp::def("get_solver_from_file", &GetSolverFromFile, bp::return_value_policy<:manage_new_object>()); bp::def("get_solver", &GetSolver, bp::return_value_policy<:manage_new_object>()); // vector wrappers for all the vector types we use bp::class_ > > >("BlobVec") .def(bp::vector_indexing_suite > >, true>()) .def("add_blob", bp::raw_function(&BlobVec_add_blob)); bp::class_*> >("RawBlobVec") .def(bp::vector_indexing_suite*>, true>()); bp::class_ > > >("LayerVec") .def(bp::vector_indexing_suite > >, true>()); bp::class_ >("StringVec") .def(bp::vector_indexing_suite >()); bp::class_ >("IntTpVec") .def(bp::vector_indexing_suite >()); bp::class_ >("IntVec") .def(bp::vector_indexing_suite >()); bp::class_ >("DtypeVec") .def(bp::vector_indexing_suite >()); bp::class_ > > >("NetVec") .def(bp::vector_indexing_suite > >, true>()); bp::class_ >("BoolVec") .def(bp::vector_indexing_suite >()); bp::class_, shared_ptr >, boost::noncopyable>("NCCL", bp::init >, const string&>()) #ifdef USE_NCCL .def("new_uid", &NCCL::new_uid).staticmethod("new_uid") .def("bcast", &NCCL::Broadcast) #endif /* NOLINT_NEXT_LINE(whitespace/semicolon) */ ; BP_REGISTER_SHARED_PTR_TO_PYTHON(NCCL); bp::class_, boost::noncopyable>( "Timer", bp::init<>()) .def("start", &Timer::Start) .def("stop", &Timer::Stop) .add_property("ms", &Timer::MilliSeconds); BP_REGISTER_SHARED_PTR_TO_PYTHON(Timer); // boost python expects a void (missing) return value, while import_array // returns NULL for python3. import_array1() forces a void return value. import_array1(); } } // namespace caffe