debian-packages/vibe-core
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fix compilation of ConnectionPool!struct. Fixes vibe-d/vibe.d#2109.

Browse source 
ConnectionPool!TCPConnection used to work with the old vibe-d:core implementation, but now failed, because TCPConnection is a struct. All assumptions about `Connection` being a class have been remove in this commit.
This commit is contained in:
Sönke Ludwig 2018-03-11 00:07:42 +01:00
parent 47cfbff1dc
commit 8ee5f4460c
1 changed files with 14 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
source/vibe/core/connectionpool.d
View file

@ -90,7 +90,8 @@ final class ConnectionPool(Connection)
} else { } else {
logDebug("creating new %s connection, all %d are in use", Connection.stringof, m_connections.length); logDebug("creating new %s connection, all %d are in use", Connection.stringof, m_connections.length);
conn = m_connectionFactory(); // NOTE: may block conn = m_connectionFactory(); // NOTE: may block
logDebug(" ... %s", () @trusted { return cast(void*)conn; } ()); static if (is(typeof(cast(void*)conn)))
logDebug(" ... %s", () @trusted { return cast(void*)conn; } ());
} }
m_lockCount[conn] = 1; m_lockCount[conn] = 1;
if( cidx == size_t.max ){ if( cidx == size_t.max ){
@ -131,6 +132,12 @@ unittest {
c3.write(); c3.write();
} }
unittest { // issue vibe-d#2109
import vibe.core.net : TCPConnection, connectTCP;
new ConnectionPool!TCPConnection({ return connectTCP("127.0.0.1", 8080); });
}
struct LockedConnection(Connection) { struct LockedConnection(Connection) {
import vibe.core.task : Task; import vibe.core.task : Task;
@ -145,7 +152,7 @@ struct LockedConnection(Connection) {
private this(ConnectionPool!Connection pool, Connection conn) private this(ConnectionPool!Connection pool, Connection conn)
{ {
assert(conn !is null); assert(!!conn);
m_pool = pool; m_pool = pool;
m_conn = conn; m_conn = conn;
m_task = Task.getThis(); m_task = Task.getThis();
@ -154,18 +161,19 @@ struct LockedConnection(Connection) {
this(this) this(this)
{ {
debug assert(m_magic == 0xB1345AC2, "LockedConnection value corrupted."); debug assert(m_magic == 0xB1345AC2, "LockedConnection value corrupted.");
if( m_conn ){ if (!!m_conn) {
auto fthis = Task.getThis(); auto fthis = Task.getThis();
assert(fthis is m_task); assert(fthis is m_task);
m_pool.m_lockCount[m_conn]++; m_pool.m_lockCount[m_conn]++;
logTrace("conn %s copy %d", () @trusted { return cast(void*)m_conn; } (), m_pool.m_lockCount[m_conn]); static if (is(typeof(cast(void*)conn)))
logTrace("conn %s copy %d", () @trusted { return cast(void*)m_conn; } (), m_pool.m_lockCount[m_conn]);
} }
} }
~this() ~this()
{ {
debug assert(m_magic == 0xB1345AC2, "LockedConnection value corrupted."); debug assert(m_magic == 0xB1345AC2, "LockedConnection value corrupted.");
if( m_conn ){ if (!!m_conn) {
auto fthis = Task.getThis(); auto fthis = Task.getThis();
assert(fthis is m_task, "Locked connection destroyed in foreign task."); assert(fthis is m_task, "Locked connection destroyed in foreign task.");
auto plc = m_conn in m_pool.m_lockCount; auto plc = m_conn in m_pool.m_lockCount;
@ -176,7 +184,7 @@ struct LockedConnection(Connection) {
() @trusted { m_pool.m_sem.unlock(); } (); () @trusted { m_pool.m_sem.unlock(); } ();
//logTrace("conn %s release", cast(void*)m_conn); //logTrace("conn %s release", cast(void*)m_conn);
} }
m_conn = null; m_conn = Connection.init;
} }
} }