| 155 | } |
| 156 | |
| 157 | void MemcacheServer::onConnection(const TcpConnectionPtr& conn) |
| 158 | { |
| 159 | if (conn->connected()) |
| 160 | { |
| 161 | SessionPtr session(new Session(this, conn)); |
| 162 | MutexLockGuard lock(mutex_); |
| 163 | assert(sessions_.find(conn->name()) == sessions_.end()); |
| 164 | sessions_[conn->name()] = session; |
| 165 | // assert(sessions_.size() == stats_.current_conns); |
| 166 | } |
| 167 | else |
| 168 | { |
| 169 | MutexLockGuard lock(mutex_); |
| 170 | assert(sessions_.find(conn->name()) != sessions_.end()); |
| 171 | sessions_.erase(conn->name()); |
| 172 | // assert(sessions_.size() == stats_.current_conns); |
| 173 | } |
| 174 | } |