| 114 | |
| 115 | |
| 116 | void cSocketThreads::Write(const cCallback * a_Client, const AString & a_Data) |
| 117 | { |
| 118 | // Puts a_Data into outgoing data queue for a_Client |
| 119 | cCSLock Lock(m_CS); |
| 120 | for (cSocketThreadList::iterator itr = m_Threads.begin(); itr != m_Threads.end(); ++itr) |
| 121 | { |
| 122 | if ((*itr)->Write(a_Client, a_Data)) |
| 123 | { |
| 124 | return; |
| 125 | } |
| 126 | } // for itr - m_Threads[] |
| 127 | |
| 128 | // This may be perfectly legal, if the socket has been destroyed and the client is finishing up |
| 129 | // ASSERT(!"Writing to an unknown socket"); |
| 130 | } |
| 131 | |
| 132 | |
| 133 |
nothing calls this directly
no test coverage detected