This will undo the client protection done by protectClient() */
| 2180 | |
| 2181 | /* This will undo the client protection done by protectClient() */ |
| 2182 | void unprotectClient(client *c) { |
| 2183 | AssertCorrectThread(c); |
| 2184 | if (c->flags & CLIENT_PROTECTED) { |
| 2185 | c->flags &= ~CLIENT_PROTECTED; |
| 2186 | if (c->conn) { |
| 2187 | connSetReadHandler(c->conn,readQueryFromClient, true); |
| 2188 | if (clientHasPendingReplies(c)) clientInstallWriteHandler(c); |
| 2189 | } |
| 2190 | } |
| 2191 | } |
| 2192 | |
| 2193 | /* Like processMultibulkBuffer(), but for the inline protocol instead of RESP, |
| 2194 | * this function consumes the client query buffer and creates a command ready |
no test coverage detected