@@ -66,8 +66,8 @@ TEST(MPITest, TestMPIBroadcast) {
66
66
// Let's test the value.
67
67
auto & X = ws.GetBlob (" X" )->Get <Tensor>();
68
68
Tensor X_cpu (X, CPU);
69
- EXPECT_EQ (X.size (), 10 );
70
- for (int i = 0 ; i < X.size (); ++i) {
69
+ EXPECT_EQ (X.numel (), 10 );
70
+ for (int i = 0 ; i < X.numel (); ++i) {
71
71
EXPECT_EQ (X_cpu.data <float >()[i], root);
72
72
}
73
73
}
@@ -132,10 +132,10 @@ TEST(MPITest, TestMPIReduce) {
132
132
if (rank == root) {
133
133
// Let's test the value.
134
134
auto & X = ws.GetBlob (" X_reduced" )->Get <TensorCUDA>();
135
- EXPECT_EQ (X.size (), 10 );
135
+ EXPECT_EQ (X.numel (), 10 );
136
136
int expected_result = size * (size - 1 ) / 2 ;
137
137
Tensor X_cpu (X, CPU);
138
- for (int i = 0 ; i < X.size (); ++i) {
138
+ for (int i = 0 ; i < X.numel (); ++i) {
139
139
EXPECT_EQ (X_cpu.data <float >()[i], expected_result);
140
140
}
141
141
}
@@ -192,16 +192,16 @@ TEST(MPITest, TestMPIAllgather) {
192
192
// Let's test the value.
193
193
auto & X = ws.GetBlob (" X" )->Get <TensorCUDA>();
194
194
Tensor X_cpu (X, CPU);
195
- EXPECT_EQ (X.size (), 20 );
196
- for (int i = 0 ; i < X.size (); ++i) {
195
+ EXPECT_EQ (X.numel (), 20 );
196
+ for (int i = 0 ; i < X.numel (); ++i) {
197
197
EXPECT_EQ (X_cpu.data <float >()[i], rank);
198
198
}
199
199
auto & X_gathered = ws.GetBlob (" X_gathered" )->Get <TensorCUDA>();
200
- EXPECT_EQ (X_gathered.size (), 20 * size);
200
+ EXPECT_EQ (X_gathered.numel (), 20 * size);
201
201
EXPECT_EQ (X_gathered.dim (0 ), 2 * size);
202
202
EXPECT_EQ (X_gathered.dim (1 ), 10 );
203
203
Tensor X_gathered_cpu (X_gathered, CPU);
204
- for (int i = 0 ; i < X_gathered.size (); ++i) {
204
+ for (int i = 0 ; i < X_gathered.numel (); ++i) {
205
205
EXPECT_EQ (X_gathered_cpu.data <float >()[i], i / 20 );
206
206
}
207
207
}
@@ -254,16 +254,16 @@ TEST(MPITest, TestMPIAllreduce) {
254
254
EXPECT_TRUE (net->Run ());
255
255
// Let's test the value.
256
256
auto & X = ws.GetBlob (" X" )->Get <TensorCUDA>();
257
- EXPECT_EQ (X.size (), 10 );
257
+ EXPECT_EQ (X.numel (), 10 );
258
258
Tensor X_cpu (X, CPU);
259
- for (int i = 0 ; i < X.size (); ++i) {
259
+ for (int i = 0 ; i < X.numel (); ++i) {
260
260
EXPECT_EQ (X_cpu.data <float >()[i], rank);
261
261
}
262
262
auto & X_reduced = ws.GetBlob (" X_reduced" )->Get <TensorCUDA>();
263
- EXPECT_EQ (X_reduced.size (), 10 );
263
+ EXPECT_EQ (X_reduced.numel (), 10 );
264
264
int expected_result = size * (size - 1 ) / 2 ;
265
265
Tensor X_reduced_cpu (X_reduced, CPU);
266
- for (int i = 0 ; i < X_reduced.size (); ++i) {
266
+ for (int i = 0 ; i < X_reduced.numel (); ++i) {
267
267
EXPECT_EQ (X_reduced_cpu.data <float >()[i], expected_result);
268
268
}
269
269
}
@@ -315,10 +315,10 @@ TEST(MPITest, TestInPlaceMPIAllreduce) {
315
315
EXPECT_NE (nullptr , net.get ());
316
316
EXPECT_TRUE (net->Run ());
317
317
auto & X_reduced = ws.GetBlob (" X" )->Get <TensorCUDA>();
318
- EXPECT_EQ (X_reduced.size (), 10 );
318
+ EXPECT_EQ (X_reduced.numel (), 10 );
319
319
int expected_result = size * (size - 1 ) / 2 ;
320
320
Tensor X_reduced_cpu (X_reduced, CPU);
321
- for (int i = 0 ; i < X_reduced.size (); ++i) {
321
+ for (int i = 0 ; i < X_reduced.numel (); ++i) {
322
322
EXPECT_EQ (X_reduced_cpu.data <float >()[i], expected_result);
323
323
}
324
324
}
0 commit comments