Layer（层）是Caffe中最庞大最繁杂的模块。由于Caffe强调模块化设计，因此只允许每个layer完成一类特定的计算，例如convolution操作、pooling、非线性变换、内积运算，以及数据加载、归一化和损失计算等。layer这个类可以说是里面最终的一个基本类了，深度网络呢就是一层一层的layer，相互之间通过blob传输数据连接起来。
我们先看一张图：
然后我们从头文件看看：
Caffe中与Layer相关的头文件有7个，
layer.hpp: 父类Layer，定义所有layer的基本接口。data_layers.hpp: 继承自父类Layer，定义与输入数据操作相关的子Layer，例如DataLayer，HDF5DataLayer和ImageDataLayer等。vision_layers.hpp: 继承自父类Layer，定义与特征表达相关的子Layer，例如ConvolutionLayer，PoolingLayer和LRNLayer等。neuron_layers.hpp: 继承自父类Layer，定义与非线性变换相关的子Layer，例如ReLULayer，TanHLayer和SigmoidLayer等。loss_layers.hpp: 继承自父类Layer，定义与输出误差计算相关的子Layer，例如EuclideanLossLayer，SoftmaxWithLossLayer和HingeLossLayer等。common_layers.hpp: 继承自父类Layer，定义与中间结果数据变形、逐元素操作相关的子Layer，例如ConcatLayer，InnerProductLayer和SoftmaxLayer等。layer_factory.hpp: Layer工厂模式类，负责维护现有可用layer和相应layer构造方法的映射表。1.About
layer.hpp
和layer相关的头文件有：
common_layers.hpp data_layers.hpp layer.hpp loss_layers.hpp neuron_layers.hpp vision_layers.hpp其中``layer.hpp是抽象出来的基类，其他都是在其基础上的继承，也即剩下的五个头文件和上图中的五个部分。在layer.hpp`头文件里，包含了这几个头文件：
#include "caffe/blob.hpp" #include "caffe/common.hpp" #include "caffe/proto/caffe.pb.h" #include "caffe/util/device_alternate.hpp"在device_alternate.hpp中，通过#ifdef CPU_ONLY定义了一些宏来取消GPU的调用：
#define STUB_GPU(classname) #define STUB_GPU_FORWARD(classname, funcname) #define STUB_GPU_BACKWARD(classname, funcname)layer中有这三个主要参数：
LayerParameter layer_param_; // 这个是protobuf文件中存储的layer参数 vector<share_ptr<Blob<Dtype>>> blobs_; // 这个存储的是layer的参数，在程序中用的 vector<bool> param_propagate_down_; // 这个bool表示是否计算各个blob参数的diff，即传播误差Layer类的构建函数explicit Layer(const LayerParameter& param) : layer_param_(param)会尝试从protobuf文件读取参数。其三个主要接口：
virtual void SetUp(const vector<Blob<Dtype>*>& bottom, vector<Blob<Dtype>*>* top) inline Dtype Forward(const vector<Blob<Dtype>*>& bottom, vector<Blob<Dtype>*>* top); inline void Backward(const vector<Blob<Dtype>*>& top, const vector<bool>& propagate_down, const <Blob<Dtype>*>* bottom);SetUp函数需要根据实际的参数设置进行实现，对各种类型的参数初始化；Forward和Backward对应前向计算和反向更新，输入统一都是bottom，输出为top，其中Backward里面有个propagate_down参数，用来表示该Layer是否反向传播参数。
在Forward和Backward的具体实现里，会根据Caffe::mode()进行对应的操作，即使用cpu或者gpu进行计算，两个都实现了对应的接口Forward_cpu、Forward_gpu和Backward_cpu、Backward_gpu，这些接口都是virtual，具体还是要根据layer的类型进行对应的计算（注意：有些layer并没有GPU计算的实现，所以封装时加入了CPU的计算作为后备）。另外，还实现了ToProto的接口，将Layer的参数写入到protocol buffer文件中。
data_layers.hpp
data_layers.hpp这个头文件包含了这几个头文件：
#include "boost/scoped_ptr.hpp" #include "hdf5.h" #include "leveldb/db.h" #include "lmdb.h" #include "caffe/blob.hpp" #include "caffe/common.hpp" #include "caffe/filler.hpp" #include "caffe/internal_thread.hpp" #include "caffe/layer.hpp" #include "caffe/proto/caffe.pb.h"看到hdf5、leveldb、lmdb，确实是与具体数据相关了。data_layer作为原始数据的输入层，处于整个网络的最底层，它可以从数据库leveldb、lmdb中读取数据，也可以直接从内存中读取，还可以从hdf5，甚至是原始的图像读入数据。
关于这几个数据库，简介如下：
LevelDB是Google公司搞的一个高性能的key/value存储库，调用简单，数据是被Snappy压缩，据说效率很多，可以减少磁盘I/O，具体例子可以看看维基百科。
而LMDB（Lightning Memory-Mapped Database），是个和levelDB类似的key/value存储库，但效果似乎更好些，其首页上写道“ultra-fast，ultra-compact”，这个有待进一步学习啊～～
HDF（Hierarchical Data Format）是一种为存储和处理大容量科学数据而设计的文件格式及相应的库文件，当前最流行的版本是HDF5,其文件包含两种基本数据对象：
群组（group）：类似文件夹，可以包含多个数据集或下级群组；数据集（dataset）：数据内容，可以是多维数组，也可以是更复杂的数据类型。以上内容来自维基百科，关于使用可以参考[HDF5 小试——高大上的多对象文件格式](HDF5 小试——高大上的多对象文件格式)，后续会再详细的研究下怎么用。
caffe/filler.hpp的作用是在网络初始化时，根据layer的定义进行初始参数的填充，下面的代码很直观，根据FillerParameter指定的类型进行对应的参数填充。
// A function to get a specific filler from the specification given in // FillerParameter. Ideally this would be replaced by a factory pattern, // but we will leave it this way for now. template <typename Dtype> Filler<Dtype>* GetFiller(const FillerParameter& param) { const std::string& type = param.type(); if (type == "constant") { return new ConstantFiller<Dtype>(param); } else if (type == "gaussian") { return new GaussianFiller<Dtype>(param); } else if (type == "positive_unitball") { return new PositiveUnitballFiller<Dtype>(param); } else if (type == "uniform") { return new UniformFiller<Dtype>(param); } else if (type == "xavier") { return new XavierFiller<Dtype>(param); } else { CHECK(false) << "Unknown filler name: " << param.type(); } return (Filler<Dtype>*)(NULL); }internal_thread.hpp里面封装了pthread函数，继承的子类可以得到一个单独的线程，主要作用是在计算当前的一批数据时，在后台获取新一批的数据。
关于data_layer，基本要注意的我都在图片上标注了。
neuron_layers.hpp
输入了data后，就要计算了，比如常见的sigmoid、tanh等等，这些都计算操作被抽象成了neuron_layers.hpp里面的类NeuronLayer，这个层只负责具体的计算，因此明确定义了输入ExactNumBottomBlobs()和ExactNumTopBlobs()都是常量1,即输入一个blob，输出一个blob。
common_layers.hpp
NeruonLayer仅仅负责简单的一对一计算，而剩下的那些复杂的计算则通通放在了common_layers.hpp中。像ArgMaxLayer、ConcatLayer、FlattenLayer、SoftmaxLayer、SplitLayer和SliceLayer等各种对blob增减修改的操作。
loss_layers.hpp
前面的data layer和common layer都是中间计算层，虽然会涉及到反向传播，但传播的源头来自于loss_layer，即网络的最终端。这一层因为要计算误差，所以输入都是2个blob，输出1个blob。
vision_layers.hpp
vision_layer主要是图像卷积的操作，像convolusion、pooling、LRN都在里面，按官方文档的说法，是可以输出图像的，这个要看具体实现代码了。里面有个im2col的实现，看caffe作者的解释，主要是为了加速卷积的。
layer_factory.hpp
layer_factory比较重要我就放在下一篇里面了。
2. Detail
在这一Section中，我们深入到上一小节所讲的集中layer的细节中去。对于一些常用的layer，如卷积层，池化层（Pooling），还给出对应的proto代码。
数据通过数据层进入Caffe，数据层在整个网络的底部。数据可以来自高效的数据库（LevelDB 或者 LMDB），直接来自内存。如果不追求高效性，可以以HDF5或者一般图像的格式从硬盘读取数据。
一些基本的操作，如：mean subtraction, scaling, random cropping, and mirroring均可以直接在数据层上进行指定。
类型：Data
必须参数：
source: 包含数据的目录名称
batch_size: 一次处理的输入的数量
可选参数：
rand_skip: 在开始的时候从输入中跳过这个数值，这在异步随机梯度下降（SGD）的时候非常有用
backend [default LEVELDB]: 选择使用 LEVELDB 或者 LMDB
类型: MemoryData
必需参数：
batch_size, channels, height, width: 指定从内存读取数据的大小MemoryData层直接从内存中读取数据，而不是拷贝过来。因此，要使用它的话，你必须调用MemoryDataLayer::Reset (from C++)或者Net.set_input_arrays (from Python)以此指定一块连续的数据（通常是一个四维张量）。
类型: HDF5Data
必要参数：
source: 需要读取的文件名
batch_size：一次处理的输入的数量
类型: HDF5Output
必要参数：
file_name: 输出的文件名HDF5的作用和这节中的其他的层不一样，它是把输入的blobs写到硬盘
类型: ImageData
必要参数：
source: text文件的名字，每一行给出一张图片的文件名和label
batch_size: 一个batch中图片的数量
可选参数：
rand_skip：在开始的时候从输入中跳过这个数值，这在异步随机梯度下降（SGD）的时候非常有用
shuffle [default false]
new_height, new_width: 把所有的图像resize到这个大小
类型：WindowData
类型：DummyData
Dummy 层用于development 和debugging。具体参数DummyDataParameter。
一般来说，激励层是element-wise的操作，输入和输出的大小相同，一般情况下就是一个非线性函数。
输入：
n×c×h×w输出：
n×c×h×w类型: ReLU
例子:
<span style="font-family:Microsoft YaHei;font-size:12px;">layer { name: "relu1" type: "ReLU" bottom: "conv1" top: "conv1" }</span>可选参数：
negative_slope [default 0]： 指定输入值小于零时的输出。ReLU是目前使用做多的激励函数，主要因为其收敛更快，并且能保持同样效果。标准的ReLU函数为max(x, 0)，而一般为当x > 0时输出x，但x <= 0时输出negative_slope。RELU层支持in-place计算，这意味着bottom的输出和输入相同以避免内存的消耗。
ReLU(x)=max{0,x}
类型：Sigmoid
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;">layer { name: "encode1neuron" bottom: "encode1" top: "encode1neuron" type: "Sigmoid" }</span>Sigmoid层通过 sigmoid(x) 计算每一个输入x的输出，函数如下图。
σ(x)=11+exp−x
类型: TanH
例子:
<span style="font-family:Microsoft YaHei;font-size:12px;">layer { name: "layer" bottom: "in" top: "out" type: "TanH" }</span>TanH层通过 tanh(x) 计算每一个输入x的输出，函数如下图。请注意sigmoid函数和TanH函数在纵轴上的区别。sigmoid函数将实数映射到(0,1)。TanH将实数映射到(-1,1)。
tanh(x)=expx−exp−xexpx+exp−x
类型: AbsVal
例子:
<span style="font-family:Microsoft YaHei;font-size:12px;">layer { name: "layer" bottom: "in" top: "out" type: "AbsVal" }</span>ABSVAL层通过 abs(x) 计算每一个输入x的输出。
类型： Power
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;">layer { name: "layer" bottom: "in" top: "out" type: "Power" power_param { power: 1 scale: 1 shift: 0 } }</span>可选参数：
power [default 1]
scale [default 1]
shift [default 0]
POWER层通过 (shift + scale * x) ^ power计算每一个输入x的输出。
类型: BNLL
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;">layer { name: "layer" bottom: "in" top: "out" type: BNLL }</span>BNLL (binomial normal log likelihood) 层通过 log(1 + exp(x)) 计算每一个输入x的输出。
类型：Convolution
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;">layers { name: "conv1" type: CONVOLUTION bottom: "data" top: "conv1" blobs_lr: 1 # learning rate multiplier for the filters blobs_lr: 2 # learning rate multiplier for the biases weight_decay: 1 # weight decay multiplier for the filters weight_decay: 0 # weight decay multiplier for the biases convolution_param { num_output: 96 # learn 96 filters kernel_size: 11 # each filter is 11x11 stride: 4 # step 4 pixels between each filter application weight_filler { type: "gaussian" # initialize the filters from a Gaussian std: 0.01 # distribution with stdev 0.01 (default mean: 0) } bias_filler { type: "constant" # initialize the biases to zero (0) value: 0 } } } }</span>blobs_lr: 学习率调整的参数，在上面的例子中设置权重学习率和运行中求解器给出的学习率一样，同时是偏置学习率为权重的两倍。 weight_decay：
卷积层的重要参数
必须参数：
num_output (c_o)：过滤器的个数
kernel_size (or kernel_h and kernel_w)：过滤器的大小（也就是所谓“核”的大小）。
建议参数：
weight_filler [default type: ‘constant’ value: 0]：参数的初始化方法可选参数：
bias_filler：偏置的初始化方法
bias_term [default true]：指定是否是否开启偏置项
pad (or pad_h and pad_w) [default 0]：指定在输入的每一边加上多少个像素
stride (or stride_h and stride_w) [default 1]：指定过滤器的步长
group (g) [default 1]: 如果g>1，那么将每个滤波器都限定只与某个输入的子集有关联。换句话说，将输入分为g组，同时将输出也分为g组。那么第i组输出只与第i组输入有关。
通过卷积后的大小变化：
输入：
n×ci×hi×wi输出：
n×co×ho×wo其中： ho=(hi+2×padh−kernelh)/strideh+1 。 wo 通过同样的方法计算。
类型：Pooling
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;">layers { name: "pool1" type: POOLING bottom: "conv1" top: "pool1" pooling_param { pool: MAX kernel_size: 3 # pool over a 3x3 region stride: 2 # step two pixels (in the bottom blob) between pooling regions } }</span>卷积层的重要参数
必需参数：
kernel_size (or kernel_h and kernel_w)：过滤器的大小可选参数：
pool [default MAX]：pooling的方法，目前有MAX, AVE, 和STOCHASTIC三种方法
pad (or pad_h and pad_w) [default 0]：指定在输入的每一遍加上多少个像素
stride (or stride_h and stride_w) [default 1]：指定过滤器的步长
通过池化后的大小变化：
输入：
n×ci×hi×wi输出：
n×co×ho×wo其中： ho=(hi+2×padh−kernelh)/strideh+1 。 wo 通过同样的方法计算。
类型：LRN
可选参数：
local_size [default 5]：对于cross channel LRN为需要求和的邻近channel的数量；对于within channel LRN为需要求和的空间区域的边长；
alpha [default 1]：scaling参数；
beta [default 5]：指数；
norm_region [default ACROSS_CHANNELS]: 选择LRN实现的方法：1. ACROSS_CHANNELS ；2. WITHIN_CHANNEL
LRN（Local Response Normalization）是对一个局部的输入区域进行的归一化。有两种不同的形式：1. ACCROSS_CHANNEL；2. WITHIN_CHANNEL。其实很好从字面上进行理解。第一种方法综合了不同的channel，而在一个channel里面只取1*1（所以size是 localsize×1×1 ）。而在第二种方法中，不在channel方向上扩展，只在单一channel上进行空间扩展（所以size是 1×localsize×localsize ）。
计算公式：对每一个输入除以 (1+(α/n)⋅∑ix2i)β
在这里，参数 α 是scaling参数，参数 β 是指数。而参数 n 对应local region的大小。
深度学习是通过最小化输出和目标的Loss来驱动学习。
类型: SoftmaxWithLoss
关于Softmax的内容，可以参考我之前的博客：【机器学习】Softmax Regression简介。Softmax Loss层应用于多标签分类。对于输入，计算了multinomial logistic loss。在概念上近似等于一个Softmax层加上一个multinomial logistic loss层。但在梯度的计算上更加稳定。
类型: EuclideanLoss
Euclidean loss层计算了两个输入差的平方和：
12N∑i=1N||x1i−x2i||2x类型: HingeLoss
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;">L1 Normlayers { name: "loss" type: HINGE_LOSS bottom: "pred" bottom: "label" } L2 Normlayers { name: "loss" type: HINGE_LOSS bottom: "pred" bottom: "label" top: "loss" hinge_loss_param { norm: L2 } }</span>可选参数：
norm [default L1]: 选择L1或者L2范数输入：
n×c×h×w Predictions n×1×1×1 Labels输出
1×1×1×1 Computed Loss类型：SigmoidCrossEntropyLoss
类型：InfoGainLoss
类型：Accuracy
用来计算输出和目标的正确率，事实上这不是一个loss，而且没有backward这一步。
类型：InnerProduct
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;">layer { name: "fc8" type: "InnerProduct" # learning rate and decay multipliers for the weights param { lr_mult: 1 decay_mult: 1 } # learning rate and decay multipliers for the biases param { lr_mult: 2 decay_mult: 0 } inner_product_param { num_output: 1000 weight_filler { type: "gaussian" std: 0.01 } bias_filler { type: "constant" value: 0 } } bottom: "fc7" top: "fc8" }</span>必要参数：
num_output (c_o)：过滤器的个数可选参数：
weight_filler [default type: ‘constant’ value: 0]：参数的初始化方法
bias_filler：偏置的初始化方法
bias_term [default true]：指定是否是否开启偏置项
通过全连接层后的大小变化：
输入： n×ci×hi×wi 输出： n×co×1×1
类型：Split
Splitting层可以把一个输入blob分离成多个输出blobs。这个用在当需要把一个blob输入到多个输出层的时候。
类型：Flatten
Flatten层是把一个输入的大小为n * c * h * w变成一个简单的向量，其大小为 n * (c*h*w) * 1 * 1。
类型：Reshape
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;"> layer { name: "reshape" type: "Reshape" bottom: "input" top: "output" reshape_param { shape { dim: 0 # copy the dimension from below dim: 2 dim: 3 dim: -1 # infer it from the other dimensions } } }</span>输入：单独的一个blob，可以是任意维；
输出：同样的blob，但是它的维度已经被我们人为地改变，维度的数据由reshap_param定义。
可选参数：
shapeReshape层被用于改变输入的维度，而不改变输入的具体数据。就像Flatten层一样。只是维度被改变而已，这个过程不涉及数据的拷贝。
输出的维度由ReshapeParam proto控制。可以直接使用数字进行指定。设定输入的某一维到输出blob中去。此外，还有两个数字值得说一下：
0 直接从底层复制。例如，如果是底层是一个2在它的第一维，那么顶层在它的第一维也有一个2。
-1 从其他的数据里面推测这一维应该是多少。
类型：Concat
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;">layer { name: "concat" bottom: "in1" bottom: "in2" top: "out" type: "Concat" concat_param { axis: 1 } }</span>可选参数：
axis [default 1]：0代表链接num，1代表链接channels通过全连接层后的大小变化：
输入：从1到K的每一个blob的大小： ni×ci×h×w
输出：
如果axis = 0: (n1+n2+...+nK)×c1×h×w ，需要保证所有输入的 ci 相同。
如果axis = 1: n1×(c1+c2+...+cK)×h×w ，需要保证所有输入的n_i 相同。
通过Concatenation层，可以把多个的blobs链接成一个blob。
类型：Slice
例子：
<span style="font-family:Microsoft YaHei;font-size:12px;">layer { name: "slicer_label" type: "Slice" bottom: "label" ## Example of label with a shape N x 3 x 1 x 1 top: "label1" top: "label2" top: "label3" slice_param { axis: 1 slice_point: 1 slice_point: 2 } }</span>Slice层可以将输入层变成多个输出层。这些输出层沿一个给定的维度存在。axis指定了目标的轴，slice_point则指定了选择维度的序号。
类型：Eltwise
类型：ArgMax
类型：Softmax
类型：MVN
==================================================================================================================================
每个layer的输入数据来自一些'bottom' blobs, 输出一些'top' blobs。Caffe中每种类型layer的参数说明定义在caffe.proto文件中，具体的layer参数值则定义在具体应用的protocals buffer网络结构说明文件中。例如，卷积层（ConvolutionLayer）的参数说明在caffe.proto中是如下定义的，
[cpp] view plain copy // in caffe.proto // Message that stores parameters used by ConvolutionLayer message ConvolutionParameter { optional uint32 num_output = 1; // The number of outputs for the layer optional bool bias_term = 2 [default = true]; // whether to have bias terms // Pad, kernel size, and stride are all given as a single value for equal // dimensions in height and width or as Y, X pairs. optional uint32 pad = 3 [default = 0]; // The padding size (equal in Y, X) optional uint32 pad_h = 9 [default = 0]; // The padding height optional uint32 pad_w = 10 [default = 0]; // The padding width optional uint32 kernel_size = 4; // The kernel size (square) optional uint32 kernel_h = 11; // The kernel height optional uint32 kernel_w = 12; // The kernel width optional uint32 group = 5 [default = 1]; // The group size for group conv optional uint32 stride = 6 [default = 1]; // The stride (equal in Y, X) optional uint32 stride_h = 13; // The stride height optional uint32 stride_w = 14; // The stride width optional FillerParameter weight_filler = 7; // The filler for the weight optional FillerParameter bias_filler = 8; // The filler for the bias enum Engine { DEFAULT = 0; CAFFE = 1; CUDNN = 2; } optional Engine engine = 15 [default = DEFAULT]; } 其中的参数说明包括卷积核的个数、大小和步长等。在 examples\mnist\lenet_train_test.prototxt 网络结构说明文件中，具体一个卷积层（ConvolutionLayer）是这样定义的，
[cpp] view plain copy # in examples\mnist\lenet_train_test.prototxt layer { name: "conv1" // 层的名字 type: "Convolution" // 层的类型，说明具体执行哪一种计算 bottom: "data" // 层的输入数据Blob的名字 top: "conv1" // 层的输出数据Blob的名字 param { // 层的权值和偏置相关参数 lr_mult: 1 } param { lr_mult: 2 } convolution_param { // 卷积层卷积运算相关的参数 num_output: 20 kernel_size: 5 stride: 1 weight_filler { type: "xavier" } bias_filler { type: "constant" } } } 层的输入输出结构，图示是这样的，
每种类型的layer需要定义三种关键操作LayerSetUp, Forward, Backward：
LayerSetUp: 网络构建时初始化层和层的连接Forward: 网络数据前向传递，给定bottom输入数据，计算输出到topBackward： 网络误差反向传递，给定top的梯度，计算bottom的梯度并存储到bottom blob Layer的设计主要就是SetUp、Forward、Backward函数（层一开始的时候的设置、然后就是前传和反传） 这其中的SetUp的实现又依赖于CheckBlobCounts、LayerSetUp、Reshape等的实现。这其中Reshape又是必须要实现的，因为它是纯虚函数 这其中的Forward中又依赖于Forward_cpu、Forward_gpu，这其中Forward_cpu又是必须要实现的。 这其中的Backward中又依赖于Backward_cpu、Backward_gpu，这其中Backward_cpu 又是必须要实现的。=================================================================================================================================
首先layer必须要实现一个forward function，前递函数当然功能可以自己定义啦，在forward中呢他会从input也就是Layer的bottom，对了caffe里面网络的前一层是叫bottom的，从bottom中获取blob，并且计算输出的Blob，当然他们也会实现一个反向传播，根据他们的input的blob以及output blob的error gradient 梯度误差计算得到该层的梯度误差。从公式中也可以看到：
δl=((wl+1)Tδl+1)σ′(zl)
想学好caffe建议看源码，layer.hpp:
[cpp] view plain copy #ifndef CAFFE_LAYER_H_ #define CAFFE_LAYER_H_ #include <algorithm> #include <string> #include <vector> #include "caffe/blob.hpp" #include "caffe/common.hpp" #include "caffe/layer_factory.hpp" #include "caffe/proto/caffe.pb.h" #include "caffe/util/device_alternate.hpp" namespace caffe { /** * @brief An interface for the units of computation which can be composed into a * Net. * * Layer%s must implement a Forward function, in which they take their input * (bottom) Blob%s (if any) and compute their output Blob%s (if any). * They may also implement a Backward function, in which they compute the error * gradients with respect to their input Blob%s, given the error gradients with * their output Blob%s. */ template <typename Dtype> class Layer { public: /* 首先获得当前网络的Phase，是train还是test，在初始化列表初始化LayerParameter,之后blobs_这里存放的是一个指向blob类的shared_ptr指针的一个vector，在这里是申请空间，然后将传入的layer_param中的blob拷贝过来。 */ // 显示的构造函数不需要重写，任何初始工作在SetUp()中完成 // 构造方法只复制层参数说明的值，如果层说明参数中提供了权值和偏置参数，也复制 explicit Layer(const LayerParameter& param) : layer_param_(param) { // Set phase and copy blobs (if there are any). // 训练还是测试？phase phase_ = param.phase(); if (layer_param_.blobs_size() > 0) { // 将blobs_的大小设置为参数中的大小 blobs_.resize(layer_param_.blobs_size()); for (int i = 0; i < layer_param_.blobs_size(); ++i) { // 新建若干个Blob blobs_[i].reset(new Blob<Dtype>()); // 从blob文件中获取数据 blobs_[i]->FromProto(layer_param_.blobs(i)); } }//用protobuf 传入的参数对blobs_ 做初始化，blobs_ 是一个vector 存放指向Blob类的智能指针。 #ifdef USE_MPI //If this is a gather layer, all it subsequent layer doesn't need gradient sync. //We will only change itself's property here, //subsequent layers will be inferred in the Net if (is_gathering()){ set_need_sync(false); }else{ set_need_sync(true); } #endif } virtual ~Layer() {} 初始化函数SetUp，每个Layer对象都必须遵循固定的调用模式, /** * @brief Implements common layer setup functionality. * @brief 实现每个layer对象的setup函数 * @param bottom the preshaped input blobs * @param bottom 层的输入数据，blob中的存储空间已申请 * @param top * the allocated but unshaped output blobs, to be shaped by Reshape * @param top 层的输出数据，blob对象以构造但是其中的存储空间未申请， * 具体空间大小需根据bottom blob大小和layer_param_共同决定，具体在Reshape函数现实 * * Checks that the number of bottom and top blobs is correct. * Calls LayerSetUp to do special layer setup for individual layer types, * followed by Reshape to set up sizes of top blobs and internal buffers. * Sets up the loss weight multiplier blobs for any non-zero loss weights. * This method may not be overridden. * 1. 检查输入输出blob个数是否满足要求，每个层能处理的输入输出数据不一样 * 2. 调用LayerSetUp函数初始化特殊的层，每个Layer子类需重写这个函数完成定制的初始化 * 3. 调用Reshape函数为top blob分配合适大小的存储空间 * 4. 为每个top blob设置损失权重乘子，非LossLayer为的top blob其值为零 * * 此方法非虚函数，不用重写，模式固定 */ void SetUp(const vector<Blob<Dtype>*>& bottom, const vector<Blob<Dtype>*>& top) { CheckBlobCounts(bottom, top); LayerSetUp(bottom, top); Reshape(bottom, top); SetLossWeights(top); } /每个子类Layer必须重写的初始化函数LayerSetUp， /** * @brief Does layer-specific setup: your layer should implement this function * as well as Reshape. * @brief 定制初始化，每个子类layer必须实现此虚函数 * * @param bottom * the preshaped input blobs, whose data fields store the input data for * this layer * @param bottom * 输入blob, 数据成员data_和diff_存储了相关数据 * @param top * the allocated but unshaped output blobs * @param top * 输出blob, blob对象已构造但数据成员的空间尚未申请 * * This method should do one-time layer specific setup. This includes reading * and processing relevent parameters from the <code>layer_param_</code>. * Setting up the shapes of top blobs and internal buffers should be done in * <code>Reshape</code>, which will be called before the forward pass to * adjust the top blob sizes. * 此方法执行一次定制化的层初始化，包括从layer_param_读入并处理相关的层权值和偏置参数， * 调用Reshape函数申请top blob的存储空间 */ virtual void LayerSetUp(const vector<Blob<Dtype>*>& bottom, const vector<Blob<Dtype>*>& top) {} /每个子类Layer必须重写的Reshape函数，完成top blob形状的设置并为其分配存储空间， /** * @brief Adjust the shapes of top blobs and internal buffers to accomodate * the shapes of the bottom blobs. * @brief 根据bottom blob的形状和layer_param_计算top blob的形状并为其分配存储空间 * * @param bottom the input blobs, with the requested input shapes * @param top the top blobs, which should be reshaped as needed * * This method should reshape top blobs as needed according to the shapes * of the bottom (input) blobs, as well as reshaping any internal buffers * and making any other necessary adjustments so that the layer can * accomodate the bottom blobs. */ virtual void Reshape(const vector<Blob<Dtype>*>& bottom, const vector<Blob<Dtype>*>& top) = 0; /** * @brief Given the bottom blobs, compute the top blobs and the loss. * * @param bottom * the input blobs, whose data fields store the input data for this layer * @param top * the preshaped output blobs, whose data fields will store this layers' * outputs * \return The total loss from the layer. * * The Forward wrapper calls the relevant device wrapper function * (Forward_cpu or Forward_gpu) to compute the top blob values given the * bottom blobs. If the layer has any non-zero loss_weights, the wrapper * then computes and returns the loss. * * Your layer should implement Forward_cpu and (optionally) Forward_gpu. */ //前向传播函数Forward和反向传播函数Backward /* 首先是Forward.这其实是一个装饰器，继承之后在调用的调用其相应的forward_cpu或者forward_gpu，根据输入的input data blob计算相应的output data blob，同时会反应这一层layer的total loss. */ inline Dtype Forward(const vector<Blob<Dtype>*>& bottom, const vector<Blob<Dtype>*>& top); /** * @brief Given the top blob error gradients, compute the bottom blob error * gradients. * * @param top * the output blobs, whose diff fields store the gradient of the error * with respect to themselves * @param propagate_down * a vector with equal length to bottom, with each index indicating * whether to propagate the error gradients down to the bottom blob at * the corresponding index * @param bottom * the input blobs, whose diff fields will store the gradient of the error * with respect to themselves after Backward is run * * The Backward wrapper calls the relevant device wrapper function * (Backward_cpu or Backward_gpu) to compute the bottom blob diffs given the * top blob diffs. * * Your layer should implement Forward_cpu and (optionally) Forward_gpu. */ /* BackWard，实现的是反向传播，也就是给定top blob额error gradient 计算得到bottom的error gradient。其输入时 output blobs ，在Ouput blobs里面的diff存储的就是其相应的error gradients。其中propagate_down这个参数跟Bottom的长度是一样的，每一个Index用来指定是否需要反向传播error gradients 到对应的bottom blob。而bottom 这里面的diff 区域存放的就是BackWard计算出来相应的gradient error. */ inline void Backward(const vector<Blob<Dtype>*>& top, const vector<bool>& propagate_down, const vector<Blob<Dtype>*>& bottom); /** * @brief Returns the vector of learnable parameter blobs. */ vector<shared_ptr<Blob<Dtype> > >& blobs() { return blobs_;//返回vector blobs_ } /** * @brief Returns the layer parameter. */ //返回layer parameter const LayerParameter& layer_param() const { return layer_param_; } /** * @brief Writes the layer parameter to a protocol buffer */ //将layer plarameter 写入protobuf virtual void ToProto(LayerParameter* param, bool write_diff = false); //返回 ,设置一个blob top 在给定 index 的 loss /** * @brief Returns the scalar loss associated with a top blob at a given index. */ inline Dtype loss(const int top_index) const { return (loss_.size() > top_index) ? loss_[top_index] : Dtype(0); } /** * @brief Sets the loss associated with a top blob at a given index. */ inline void set_loss(const int top_index, const Dtype value) { if (loss_.size() <= top_index) { loss_.resize(top_index + 1, Dtype(0)); } loss_[top_index] = value; } //一些返回特定参数的函数： /** * 获得bottom或者top blob的数量状态，比较简单，看名字即可 */ // 虚函数，而且还是内联的，返回层类型 virtual inline const char* type() const { return ""; } // 虚函数，获得bottom blob的精确个数 virtual inline int ExactNumBottomBlobs() const { return -1; } // 虚函数，获得bottom blob的最小个数 virtual inline int MinBottomBlobs() const { return -1; } // 虚函数，获得bottom blob的最大个数 virtual inline int MaxBottomBlobs() const { return -1; } // 虚函数，获得top blob的精确个数 virtual inline int ExactNumTopBlobs() const { return -1; } // 虚函数，获得top blob的最小个数 virtual inline int MinTopBlobs() const { return -1; } // 虚函数，获得top blob的最大个数 virtual inline int MaxTopBlobs() const { return -1; } // 虚函数，bottom blob和top blob的个数是否一致 virtual inline bool EqualNumBottomTopBlobs() const { return false; } // 返回当前层是否自动创建匿名top blobs // 如果返回true，表明网络初始化的时候创建了了足够多的匿名top blobs // 来满足ExactNumTopBlobs或者MinTopBlobs所要求的top blobs的个数 virtual inline bool AutoTopBlobs() const { return false; } /* AllowforceBackward用来设置是否强制梯度返回，因为有些层其实不需要梯度信息 ，后面两个函数分别查看以及设置是是否需要计算梯度。 */ // 对于一个给定的bottom blob，返回是否允许强制反传 virtual inline bool AllowForceBackward(const int bottom_index) const { return true; } //set_param_propagate_down，param_propagate_down 函数：设置对于那些bottom 需要反向传播。 /** * @brief Specifies whether the layer should compute gradients w.r.t. a * parameter at a particular index given by param_id. * * You can safely ignore false values and always compute gradients * for all parameters, but possibly with wasteful computation. */ inline bool param_propagate_down(const int param_id) { return (param_propagate_down_.size() > param_id) ? param_propagate_down_[param_id] : false; } /** * @brief Sets whether the layer should compute gradients w.r.t. a * parameter at a particular index given by param_id. */ inline void set_param_propagate_down(const int param_id, const bool value) { if (param_propagate_down_.size() <= param_id) { param_propagate_down_.resize(param_id + 1, true); } param_propagate_down_[param_id] = value; } #ifdef USE_MPI /** * @brief Checks whether the layer accepts specifed parallel type * * If not supported, will halt the program with hints */ inline virtual bool is_gathering() {return false;} inline virtual bool is_scattering() {return false;} inline bool need_sync(){return need_sync_;} inline void set_need_sync(bool val){need_sync_ = val;} #endif protected: /** The protobuf that stores the layer parameters */ // 层说明参数，从protocal buffers格式的网络结构说明文件中读取 LayerParameter layer_param_; /** The phase: TRAIN or TEST */ // 层状态，参与网络的训练还是测试 Phase phase_; /** The vector that stores the learnable parameters as a set of blobs. */ // 层权值和偏置参数，使用向量是因为权值参数和偏置是分开保存在两个blob中的 vector<shared_ptr<Blob<Dtype> > > blobs_; /** Vector indicating whether to compute the diff of each param blob. */ // 标志每个top blob是否需要计算反向传递的梯度值 vector<bool> param_propagate_down_; /** The vector that indicates whether each top blob has a non-zero weight in * the objective function. */ // 非LossLayer为零，LossLayer中表示每个top blob计算的loss的权重 vector<Dtype> loss_; #ifdef USE_MPI /** * For parallel use */ bool need_sync_; #endif /这两个函数非虚函数，它们内部会调用如下虚函数完成数据前向传递和 /误差反向传播，根据执行环境的不同每个子类Layer必须重写CPU和GPU版本， /** @brief Using the CPU device, compute the layer output. */ virtual void Forward_cpu(const vector<Blob<Dtype>*>& bottom, const vector<Blob<Dtype>*>& top) = 0; /** * @brief Using the GPU device, compute the layer output. * Fall back to Forward_cpu() if unavailable. */ virtual void Forward_gpu(const vector<Blob<Dtype>*>& bottom, const vector<Blob<Dtype>*>& top) { // LOG(WARNING) << "Using CPU code as backup."; return Forward_cpu(bottom, top); } /** * @brief Using the CPU device, compute the gradients for any parameters and * for the bottom blobs if propagate_down is true. */ virtual void Backward_cpu(const vector<Blob<Dtype>*>& top, const vector<bool>& propagate_down, const vector<Blob<Dtype>*>& bottom) = 0; /** * @brief Using the GPU device, compute the gradients for any parameters and * for the bottom blobs if propagate_down is true. * Fall back to Backward_cpu() if unavailable. */ virtual void Backward_gpu(const vector<Blob<Dtype>*>& top, const vector<bool>& propagate_down, const vector<Blob<Dtype>*>& bottom) { // LOG(WARNING) << "Using CPU code as backup."; Backward_cpu(top, propagate_down, bottom); } /** * Called by the parent Layer's SetUp to check that the number of bottom * and top Blobs provided as input match the expected numbers specified by * the {ExactNum,Min,Max}{Bottom,Top}Blobs() functions. */ virtual void CheckBlobCounts(const vector<Blob<Dtype>*>& bottom, const vector<Blob<Dtype>*>& top) { if (ExactNumBottomBlobs() >= 0) { CHECK_EQ(ExactNumBottomBlobs(), bottom.size()) << type() << " Layer takes " << ExactNumBottomBlobs() << " bottom blob(s) as input."; }// 保证输入bottom 数量和要求的相同 if (MinBottomBlobs() >= 0) { CHECK_LE(MinBottomBlobs(), bottom.size()) << type() << " Layer takes at least " << MinBottomBlobs() << " bottom blob(s) as input."; }//保证输入的bottom数量大于或等于要求的最小数量 if (MaxBottomBlobs() >= 0) { CHECK_GE(MaxBottomBlobs(), bottom.size()) << type() << " Layer takes at most " << MaxBottomBlobs() << " bottom blob(s) as input."; }//保证输入的bottom数量小于或等于要求的最大数量 if (ExactNumTopBlobs() >= 0) { CHECK_EQ(ExactNumTopBlobs(), top.size()) << type() << " Layer produces " << ExactNumTopBlobs() << " top blob(s) as output."; }// 保证输入top数量和要求的相同 if (MinTopBlobs() >= 0) { CHECK_LE(MinTopBlobs(), top.size()) << type() << " Layer produces at least " << MinTopBlobs() << " top blob(s) as output."; }//保证输入的top数量大于或等于要求的最小数量 if (MaxTopBlobs() >= 0) { CHECK_GE(MaxTopBlobs(), top.size()) << type() << " Layer produces at most " << MaxTopBlobs() << " top blob(s) as output."; }//保证输入的top数量小于或等于要求的最大数量 if (EqualNumBottomTopBlobs()) { CHECK_EQ(bottom.size(), top.size()) << type() << " Layer produces one top blob as output for each " << "bottom blob input."; }//保证输入的bottom数量和输出的top数量相同 } /** * Called by SetUp to initialize the weights associated with any top blobs in * the loss function. Store non-zero loss weights in the diff blob. */ /* SetLoss是非常重要的一个步骤，是被SetUp调用来初始化top bottom的weights，并且存储非零的loss weights 在diff blob里面 */ inline void SetLossWeights(const vector<Blob<Dtype>*>& top) { const int num_loss_weights = layer_param_.loss_weight_size(); if (num_loss_weights) { CHECK_EQ(top.size(), num_loss_weights) << "loss_weight must be " "unspecified or specified once per top blob."; for (int top_id = 0; top_id < top.size(); ++top_id) { const Dtype loss_weight = layer_param_.loss_weight(top_id); if (loss_weight == Dtype(0)) { continue; }//如果为0不对loss进行操作 this->set_loss(top_id, loss_weight); const int count = top[top_id]->count(); Dtype* loss_multiplier = top[top_id]->mutable_cpu_diff(); caffe_set(count, loss_weight, loss_multiplier);//将loss_multiplier设为loss_weight } } } DISABLE_COPY_AND_ASSIGN(Layer); }; // class Layer /* 前传调用对应的Forward_cpu或者Forward_gpu而我们知道Forward_cpu是纯虚函数，必须要实而Forward_gpu是虚函数，如果不实现就调用 Forward_cpu函数了。前传（你必须实现自己的Forward_cpu，实现Forward_gpu是可选的） */ // Forward and backward wrappers. You should implement the cpu and // gpu specific implementations instead, and should not change these // functions. template <typename Dtype> inline Dtype Layer<Dtype>::Forward(const vector<Blob<Dtype>*>& bottom, const vector<Blob<Dtype>*>& top) { Dtype loss = 0; // 根据bottom设置top的形状 Reshape(bottom, top); // 设置运行模式CPU or GPU switch (Caffe::mode()) { case Caffe::CPU: // 调用CPU的前传 Forward_cpu(bottom, top); // 前传计算完之后计算损失（只有最后一层才进行计算，其余层都不用） for (int top_id = 0; top_id < top.size(); ++top_id) { if (!this->loss(top_id)) { continue; } const int count = top[top_id]->count(); // 获取前传的数据 const Dtype* data = top[top_id]->cpu_data(); // 获取梯度（\frac{\partial Loss}{\partial net}） const Dtype* loss_weights = top[top_id]->cpu_diff(); // data与loss_weight的点积，即得损失函数关于当前层权重的偏导了 // \frac{\partial Loss}{\partial net} * \frac{\partial net}{\frac{W}} // = \frac{\partial Loss}{\partial W} loss += caffe_cpu_dot(count, data, loss_weights); } break; case Caffe::GPU: // GPU前传 Forward_gpu(bottom, top); #ifndef CPU_ONLY // 同上，只不过这里用GPU来计算点积了 for (int top_id = 0; top_id < top.size(); ++top_id) { if (!this->loss(top_id)) { continue; } const int count = top[top_id]->count(); // 获取GPU上的数据 const Dtype* data = top[top_id]->gpu_data(); const Dtype* loss_weights = top[top_id]->gpu_diff(); Dtype blob_loss = 0; caffe_gpu_dot(count, data, loss_weights, &blob_loss); loss += blob_loss; } #endif break; default: LOG(FATAL) << "Unknown caffe mode."; } return loss; } template <typename Dtype> inline void Layer<Dtype>::Backward(const vector<Blob<Dtype>*>& top, const vector<bool>& propagate_down, const vector<Blob<Dtype>*>& bottom) { switch (Caffe::mode()) { case Caffe::CPU: Backward_cpu(top, propagate_down, bottom); //根据blob top 的error 梯度（diff）计算bottom 的 error 梯度。 propagate_down 是长度 //和bottom 相同的vector ，用于控制是否需要对对应的bottom 元素传播梯度。具体layer具体定义。 break; case Caffe::GPU: Backward_gpu(top, propagate_down, bottom); break; default: LOG(FATAL) << "Unknown caffe mode."; } } Layer的序列化函数,将layer的层说明参数layer_param_，层权值和偏置 参数blobs_复制到LayerParameter对象，便于写到磁盘， // Serialize LayerParameter to protocol buffer template <typename Dtype> void Layer<Dtype>::ToProto(LayerParameter* param, bool write_diff) { param->Clear(); param->CopyFrom(layer_param_); // 复制层说明参数layer_param_ param->clear_blobs(); // 复制层权值和偏置参数blobs_ for (int i = 0; i < blobs_.size(); ++i) { blobs_[i]->ToProto(param->add_blobs(), write_diff); } } } // namespace caffe #endif // CAFFE_LAYER_H_
里面还有一个比较重要的文件但是比较枯燥，我也对GPU不是很懂。一起看看device_alternate.hpp：
[cpp] view plain copy #ifndef CAFFE_UTIL_DEVICE_ALTERNATE_H_ #define CAFFE_UTIL_DEVICE_ALTERNATE_H_ #ifdef CPU_ONLY // CPU-only Caffe. #include <vector> // Stub out GPU calls as unavailable. //打印出GPU不可以使用 #define NO_GPU LOG(FATAL) << "Cannot use GPU in CPU-only Caffe: check mode." // 定义给定类的前向和反向（GPU和CPU）传播的函数定义 #define STUB_GPU(classname) \ template <typename Dtype> \ void classname<Dtype>::Forward_gpu(const vector<Blob<Dtype>*>& bottom, \ const vector<Blob<Dtype>*>& top) { NO_GPU; } \ template <typename Dtype> \ void classname<Dtype>::Backward_gpu(const vector<Blob<Dtype>*>& top, \ const vector<bool>& propagate_down, \ const vector<Blob<Dtype>*>& bottom) { NO_GPU; } \ #define STUB_GPU_FORWARD(classname, funcname) \ template <typename Dtype> \ void classname<Dtype>::funcname##_##gpu(const vector<Blob<Dtype>*>& bottom, \ const vector<Blob<Dtype>*>& top) { NO_GPU; } \ #define STUB_GPU_BACKWARD(classname, funcname) \ template <typename Dtype> \ void classname<Dtype>::funcname##_##gpu(const vector<Blob<Dtype>*>& top, \ const vector<bool>& propagate_down, \ const vector<Blob<Dtype>*>& bottom) { NO_GPU; } \ #else // Normal GPU + CPU Caffe. #include <cublas_v2.h> #include <cuda.h> #include <cuda_runtime.h> #include <curand.h> #include <driver_types.h> // cuda driver types #ifdef USE_CUDNN // cuDNN acceleration library. #include "caffe/util/cudnn.hpp" #endif // // CUDA macros // // CUDA: various checks for different function calls. #define CUDA_CHECK(condition) \ /* Code block avoids redefinition of cudaError_t error */ \ do { \ cudaError_t error = condition; \ CHECK_EQ(error, cudaSuccess) << " " << cudaGetErrorString(error); \ } while (0) #define CUBLAS_CHECK(condition) \ do { \ cublasStatus_t status = condition; \ CHECK_EQ(status, CUBLAS_STATUS_SUCCESS) << " " \ << caffe::cublasGetErrorString(status); \ } while (0) #define CURAND_CHECK(condition) \ do { \ curandStatus_t status = condition; \ CHECK_EQ(status, CURAND_STATUS_SUCCESS) << " " \ << caffe::curandGetErrorString(status); \ } while (0) //caffe采取的线程格和线程块的维数设计 // blockDim.x* gridDim.x表示的是该线程格所有线程的数量 //n表示核函数总共要处理的元素个数 #define CUDA_KERNEL_LOOP(i, n) \ for (int i = blockIdx.x * blockDim.x + threadIdx.x; \ i < (n); \ i += blockDim.x * gridDim.x) // CUDA: check for error after kernel execution and exit loudly if there is one. #define CUDA_POST_KERNEL_CHECK CUDA_CHECK(cudaPeekAtLastError()) namespace caffe { //CUDA的lib错误报告 const char* cublasGetErrorString(cublasStatus_t error); const char* curandGetErrorString(curandStatus_t error); // CUDA: thread number configuration. // Use 1024 threads per block, which requires cuda sm_2x or above, // or fall back to attempt compatibility (best of luck to you). #if __CUDA_ARCH__ >= 200 const int CAFFE_CUDA_NUM_THREADS = 1024; #else const int CAFFE_CUDA_NUM_THREADS = 512; #endif //CUDA线程的块的数量 inline int CAFFE_GET_BLOCKS(const int N) { return (N + CAFFE_CUDA_NUM_THREADS - 1) / CAFFE_CUDA_NUM_THREADS; } } // namespace caffe #endif // CPU_ONLY #endif // CAFFE_UTIL_DEVICE_ALTERNATE_H_
