This is used to have a bunch of ZeroRPC clients and workers talking to each other.
WARNING: this is not compatible with heartbeats and streaming!
Clients connect to the "in" side of the hub.
Workers connect to the "out" side of the hub.
<!DOCTYPE html> | |
<html lang="en"> | |
<head> | |
<!-- Le styles --> | |
<link href="../bootstrap/css/bootstrap.css" rel="stylesheet"> | |
<script type="text/javascript" src="http://ajax.googleapis.com/ajax/libs/jquery/1.7/jquery.js"></script> | |
</head> | |
<body> |
int ReadVectorToDatum(float* data_ptr, int data_len, Datum* datum){ | |
//reshape and clear data | |
datum->set_channels(data_len); | |
datum->set_height(1); | |
datum->set_width(1); | |
datum->set_label(0); | |
datum->clear_data(); | |
datum->clear_float_data(); | |
CHECK_EQ(mdb_cursor_get(mdb_cursor_, &mdb_key_, | |
&mdb_value_, MDB_GET_CURRENT), MDB_SUCCESS); | |
datum.ParseFromArray(mdb_value_.mv_data, | |
mdb_value_.mv_size); | |
LOG(INFO)<<"Read "<<item_id<<" "<<(char*)mdb_key_.mv_data; |
Guide for merging accelerated convolution to Caffe. | |
==== | |
*Yuanjun Xiong* | |
--- | |
[TOC] |