Skip to content

Commit b7eeef2

Browse files
author
kavyasrinet
authored
Updating the comments for send_op and recv_op. (#7747)
* Updating the cluster trainign doc * Fixed comments * Updating few comments in recv_op
1 parent 6ae46a2 commit b7eeef2

File tree

2 files changed

+11
-11
lines changed

2 files changed

+11
-11
lines changed

paddle/operators/recv_op.cc

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ static void CreateTensorFromMessageType(framework::Variable *var,
4949
var->GetMutable<framework::SelectedRows>();
5050
} else {
5151
PADDLE_THROW(
52-
"VraibleMessage type %d is not in "
52+
"VariableMessage type %d is not in "
5353
"[LoDTensor, SelectedRows]",
5454
var_type);
5555
}
@@ -121,17 +121,17 @@ class RecvOp : public framework::OperatorBase {
121121
if (it != grad_list.end()) {
122122
param_var_name = param_list[it - grad_list.begin()];
123123
} else {
124-
LOG(ERROR) << "grad have no paired param:" << grad_var_name;
124+
LOG(ERROR) << "grad has no paired param:" << grad_var_name;
125125
}
126-
VLOG(3) << "recved grad: " << grad_var_name
126+
VLOG(3) << "received grad: " << grad_var_name
127127
<< " updating param: " << param_var_name;
128128
if (fan_in > 1) {
129129
grad_var_name = this->GetGradVarNameForTrainer(grad_var_name);
130130
}
131131
auto *var = recv_scope.FindVar(grad_var_name);
132132
if (var == nullptr) {
133-
LOG(ERROR) << "can not find server side var: " << grad_var_name;
134-
PADDLE_THROW("can not find server side var");
133+
LOG(ERROR) << "Can not find server side var: " << grad_var_name;
134+
PADDLE_THROW("Can not find server side var");
135135
}
136136
detail::DeserializeFromMessage(v.second, dev_ctx, var);
137137
}
@@ -165,7 +165,7 @@ class RecvOpMaker : public framework::OpProtoAndCheckerMaker {
165165
AddComment(R"DOC(
166166
Recv operator
167167
168-
This operator will recv tensor from send_op
168+
This operator will recieve tensor from send_op
169169
)DOC");
170170
AddAttr<std::string>("endpoint",
171171
"(string, default 127.0.0.1:6164)"
@@ -176,11 +176,11 @@ This operator will recv tensor from send_op
176176
kOptimizeBlock, "Serialized ProgramDesc string for recv to run.");
177177
AddAttr<std::vector<std::string>>(
178178
"ParamList", "type list of string",
179-
"grad->param name mapping to find which param to optimize.")
179+
"grad->param name mapping to find which parameters to optimize.")
180180
.SetDefault({});
181181
AddAttr<std::vector<std::string>>(
182182
"GradList", "type list of string",
183-
"grad->param name mapping to find which param to optimize.")
183+
"grad->param name mapping to find which parameters to optimize.")
184184
.SetDefault({});
185185
AddAttr<int>("Fanin", "type int",
186186
"Number of trainers in the current cluster job")

paddle/operators/send_op.cc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -62,13 +62,13 @@ class SendOpMaker : public framework::OpProtoAndCheckerMaker {
6262
public:
6363
SendOpMaker(OpProto* proto, OpAttrChecker* op_checker)
6464
: OpProtoAndCheckerMaker(proto, op_checker) {
65-
AddInput("X", "(Tensor) Input tensor to be send").AsDuplicable();
66-
AddOutput("Out", "(Tensor) Output tensor to get from server")
65+
AddInput("X", "(Tensor) Input tensor to be sent").AsDuplicable();
66+
AddOutput("Out", "(Tensor) Output tensor to be received from server")
6767
.AsDuplicable();
6868
AddComment(R"DOC(
6969
Send operator
7070
71-
This operator will send tensor to recv_op.
71+
This operator will send tensor to recv_op at the parameter server.
7272
)DOC");
7373
AddAttr<std::vector<std::string>>("endpoints",
7474
"(string vector, default 127.0.0.1:6164)"

0 commit comments

Comments
 (0)