| 92 | | @@active_connections.each do |name, conn| |
|---|
| 93 | | if conn.requires_reloading? |
|---|
| 94 | | conn.disconnect! |
|---|
| 95 | | @@active_connections.delete(name) |
|---|
| | 92 | if @@allow_concurrency |
|---|
| | 93 | # With concurrent connections @@active_connections is |
|---|
| | 94 | # a hash keyed by thread id. |
|---|
| | 95 | @@active_connections.each do |thread_id, conns| |
|---|
| | 96 | conns.each do |name, conn| |
|---|
| | 97 | if conn.requires_reloading? |
|---|
| | 98 | conn.disconnect! |
|---|
| | 99 | @@active_connections[thread_id].delete(name) |
|---|
| | 100 | end |
|---|
| | 101 | end |
|---|
| | 102 | end |
|---|
| | 103 | else |
|---|
| | 104 | @@active_connections.each do |name, conn| |
|---|
| | 105 | if conn.requires_reloading? |
|---|
| | 106 | conn.disconnect! |
|---|
| | 107 | @@active_connections.delete(name) |
|---|
| | 108 | end |
|---|
