operator.cc 3.4 KB
Newer Older
Q
Qiao Longfei 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
/* Copyright (c) 2016 PaddlePaddle Authors. All Rights Reserve.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License. */

#include "paddle/framework/operator.h"
16 17
#include <algorithm>
#include "paddle/framework/op_registry.h"
Q
Qiao Longfei 已提交
18 19 20 21

namespace paddle {
namespace framework {

Q
qijun 已提交
22
template <>
23
Eigen::DefaultDevice& ExecutionContext::GetEigenDevice<
Q
qijun 已提交
24
    platform::CPUPlace, Eigen::DefaultDevice>() const {
D
dongzhihong 已提交
25
  return *device_context_->get_eigen_device<Eigen::DefaultDevice>();
Q
qijun 已提交
26 27 28 29
}

#ifndef PADDLE_ONLY_CPU
template <>
30
Eigen::GpuDevice&
31
ExecutionContext::GetEigenDevice<platform::GPUPlace, Eigen::GpuDevice>() const {
D
dongzhihong 已提交
32
  return *device_context_->get_eigen_device<Eigen::GpuDevice>();
Q
qijun 已提交
33 34 35
}
#endif

36 37 38 39 40 41 42 43
static std::unordered_map<std::string, OpProto>* g_op_protos = nullptr;
std::unordered_map<std::string, OpProto>& OpProtos() {
  if (g_op_protos == nullptr) {
    g_op_protos = new std::unordered_map<std::string, OpProto>();
  }
  return *g_op_protos;
}

Y
Yan Chunwei 已提交
44
const std::string& OperatorBase::Input(const std::string& name) const {
Y
Yu Yang 已提交
45 46
  auto it = inputs_.find(name);
  PADDLE_ENFORCE(it != inputs_.end(), "Op %s does not have output %s", type_,
Y
Yu Yang 已提交
47
                 name);
Y
Yu Yang 已提交
48 49 50 51
  PADDLE_ENFORCE_EQ(it->second.size(), 1UL,
                    "Op %s input %s should contain only one variable", type_,
                    name);
  return it->second[0];
Y
Yan Chunwei 已提交
52 53
}

Y
Yu Yang 已提交
54 55 56
const std::vector<std::string>& OperatorBase::Inputs(
    const std::string& name) const {
  return inputs_.at(name);
Y
Yan Chunwei 已提交
57 58 59
}

const std::string& OperatorBase::Output(const std::string& name) const {
Y
Yu Yang 已提交
60 61
  auto it = outputs_.find(name);
  PADDLE_ENFORCE(it != outputs_.end(), "Op %s does not have output %s", type_,
Y
Yu Yang 已提交
62
                 name);
Y
Yu Yang 已提交
63 64 65 66
  PADDLE_ENFORCE_EQ(it->second.size(), 1UL,
                    "Op %s input %s should contain only one variable", type_,
                    name);
  return it->second[0];
Y
Yan Chunwei 已提交
67 68
}

Y
Yu Yang 已提交
69 70 71
const std::vector<std::string>& OperatorBase::Outputs(
    const std::string& name) const {
  return outputs_.at(name);
Y
Yan Chunwei 已提交
72 73
}

Q
Qiao Longfei 已提交
74 75
std::string OperatorBase::DebugString() const {
  std::stringstream ss;
Y
Yu Yang 已提交
76 77 78 79 80 81 82 83
  ss << "Op(" << type_ << "), inputs:{";
  for (auto& input : inputs_) {
    ss << input.first << "[";
    for (size_t i = 0; i < input.second.size(); ++i) {
      ss << input.second[i];
      if (i != input.second.size() - 1) {
        ss << ", ";
      }
84
    }
Y
Yu Yang 已提交
85
    ss << "]";
Q
Qiao Longfei 已提交
86
  }
Y
Yu Yang 已提交
87 88 89 90 91 92 93 94
  ss << "}, outputs:{";
  for (auto& output : outputs_) {
    ss << output.first << "[";
    for (size_t i = 0; i < output.second.size(); ++i) {
      ss << output.second[i];
      if (i != output.second.size() - 1) {
        ss << ", ";
      }
95
    }
Y
Yu Yang 已提交
96
    ss << "]";
Q
Qiao Longfei 已提交
97
  }
Y
Yu Yang 已提交
98
  ss << "}.";
Q
Qiao Longfei 已提交
99 100 101
  return ss.str();
}

D
dongzhihong 已提交
102 103
void OperatorBase::Rename(const std::string& old_name,
                          const std::string& new_name) {
Y
Yu Yang 已提交
104 105 106 107 108 109 110
  for (auto& input : inputs_) {
    std::replace(input.second.begin(), input.second.end(), old_name, new_name);
  }
  for (auto& output : outputs_) {
    std::replace(output.second.begin(), output.second.end(), old_name,
                 new_name);
  }
D
dongzhihong 已提交
111 112
}

Q
Qiao Longfei 已提交
113
}  // namespace framework
L
liaogang 已提交
114
}  // namespace paddle