| 1965 | } |
| 1966 | |
| 1967 | Status Server::ExecPropagatedCommand(const std::vector<std::string> &tokens) { |
| 1968 | CommandParser parser(tokens); |
| 1969 | if (parser.EatEqICase("script")) { |
| 1970 | if (parser.EatEqICase("flush")) { |
| 1971 | // here we must acquire the global lock to guarantee that |
| 1972 | // no EVAL or FCALL is executing while resetting lua state. |
| 1973 | auto guard = WorkExclusivityGuard(); |
| 1974 | ScriptReset(); |
| 1975 | } |
| 1976 | } else if (parser.EatEqICase("function")) { |
| 1977 | if (parser.EatEqICase("delete") || parser.EatEqICase("flush")) { |
| 1978 | // same as above to acquire the global lock |
| 1979 | auto guard = WorkExclusivityGuard(); |
| 1980 | ScriptReset(); |
| 1981 | } |
| 1982 | } |
| 1983 | |
| 1984 | return Status::OK(); |
| 1985 | } |
| 1986 | |
| 1987 | // AdjustOpenFilesLimit only try best to raise the max open files according to |
| 1988 | // the max clients and RocksDB open file configuration. It also reserves a number |
no test coverage detected