Skip to content
This repository was archived by the owner on Jan 26, 2026. It is now read-only.

Commit c427db6

Browse files
committed
adding setget tests, removing debug prints
1 parent f68fab8 commit c427db6

File tree

5 files changed

+34
-30
lines changed

5 files changed

+34
-30
lines changed

src/Deferred.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@ void process_promises()
4242
while(true) {
4343
Deferred::ptr_type d;
4444
_deferred.pop(d);
45-
std::cerr << "Executing something" << std::endl;
4645
if(d) d->run();
4746
else break;
4847
d.reset();

src/MPIMediator.cpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,6 @@ void MPIMediator::listen()
145145
Deserializer ser{buff.begin(), cnt};
146146
int tag;
147147
ser.value<sizeof(tag)>(tag);
148-
std::cerr << "Recvd " << cnt << " bytes from " << requester << " tag " << tag << std::endl;
149148

150149
switch(tag) {
151150
case DEFER_TAG: {
@@ -170,7 +169,6 @@ void MPIMediator::listen()
170169
MPI_Wait(&request_out, MPI_STATUS_IGNORE);
171170
ptr->bufferize(slice, rbuff);
172171
if(slice.size() * ptr->item_size() != rbuff.size()) throw(std::runtime_error("Got unexpected buffer size."));
173-
std::cerr << "Sending " << rbuff.size() << " bytes to " << requester << " tag PUSH_TAG" << std::endl;
174172
MPI_Isend(rbuff.data(), rbuff.size(), MPI_CHAR, requester, PUSH_TAG, comm, &request_out);
175173
break;
176174
}

test/conftest.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,12 @@
11
import os
22
import ddptensor as dt
33

4-
ddpt_cw = bool(int(os.environ.get('DDPT_CW')))
4+
ddpt_cw = os.environ.get('DDPT_CW')
5+
ddpt_cw = False if ddpt_cw is None else bool(int(ddpt_cw))
56

67
def pytest_configure(config):
7-
print(f"DDPT_CW={bool(ddpt_cw)}")
88
dt.init(ddpt_cw)
99

1010
def pytest_unconfigure(config):
1111
dt.fini()
12+
#pytest.exit("", returncode=0)

test/test_set.py

Lines changed: 0 additions & 25 deletions
This file was deleted.

test/test_setget.py

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
import ddptensor as dt
2+
3+
class TestSetGet:
4+
def test_setitem1(self):
5+
a = dt.ones([16, 16], dt.float64)
6+
a[0:16:2, 0:16:2] = dt.zeros([8,8], dt.float64)
7+
for i in range(16):
8+
for j in range(16):
9+
assert float(a[i:i+1, j:j+1]) == (1 if i % 2 or j % 2 else 0)
10+
11+
def test_setitem2(self):
12+
a = dt.ones([16, 16], dt.float64)
13+
b = dt.zeros([16, 16], dt.float64)
14+
a[1:8,0:6] = b[0:7, 0:6]
15+
for i in range(16):
16+
for j in range(16):
17+
if i >= 1 and i < 8 and j < 6:
18+
assert float(a[i:i+1, j:j+1]) == 0
19+
else:
20+
assert float(a[i:i+1, j:j+1]) == 1
21+
22+
def test_setitem3(self):
23+
a = dt.ones([16, 16], dt.float64)
24+
b = dt.zeros([16, 16], dt.float64)
25+
a[7:16:3, 4:10:2] = b[4:7, 10:16:2]
26+
for i in range(16):
27+
for j in range(16):
28+
if i >= 7 and i < 16 and ((i-7) % 3 == 0) and j >= 4 and j < 10 and ((j-4) % 2 == 0):
29+
assert float(a[i:i+1, j:j+1]) == 0
30+
else:
31+
assert float(a[i:i+1, j:j+1]) == 1

0 commit comments

Comments
 (0)