Skip to content

Commit d58287a

Browse files
committed
fix TestDrivesTaskManager
1 parent 502b51b commit d58287a

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

net.lecousin.core/src/main/java/net/lecousin/framework/io/out2in/OutputToInputBuffers.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -134,6 +134,7 @@ public int writeSync(ByteBuffer buffer) {
134134
do {
135135
SynchronizationPoint<NoException> sp = null;
136136
synchronized (this) {
137+
if (isClosing() || isClosed()) return 0;
137138
if (buffers.size() >= maxPendingBuffers) {
138139
sp = new SynchronizationPoint<>();
139140
lockMaxBuffers.addLast(sp);

net.lecousin.core/src/test/java/net/lecousin/framework/core/tests/concurrent/TestDrivesTaskManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ public class TestDrivesTaskManager extends LCCoreAbstractTest {
1313
@Test(timeout=60000)
1414
public void simpleTests() {
1515
Object res1 = Threading.getDrivesTaskManager().getResource(new File("."));
16-
Object res2 = Threading.getDrivesTaskManager().getResource(".");
16+
Object res2 = Threading.getDrivesTaskManager().getResource(new File(".").getAbsolutePath());
1717
Assert.assertEquals(res1, res2);
1818

1919
Threading.getDrivesTaskManager().getResources();

0 commit comments

Comments
 (0)