| 756 | } |
| 757 | |
| 758 | void signalFlushedDb(int dbid, int async) { |
| 759 | int startdb, enddb; |
| 760 | if (dbid == -1) { |
| 761 | startdb = 0; |
| 762 | enddb = cserver.dbnum-1; |
| 763 | } else { |
| 764 | startdb = enddb = dbid; |
| 765 | } |
| 766 | |
| 767 | for (int j = startdb; j <= enddb; j++) { |
| 768 | touchAllWatchedKeysInDb(g_pserver->db[j], NULL); |
| 769 | } |
| 770 | |
| 771 | trackingInvalidateKeysOnFlush(async); |
| 772 | } |
| 773 | |
| 774 | /*----------------------------------------------------------------------------- |
| 775 | * Type agnostic commands operating on the key space |
no test coverage detected