Function FunctionDelete

src/storage/scripting.cc:588–630

}

Status FunctionDelete(engine::Context &ctx, redis::Connection *conn, const std::string &name) {
  auto lua = conn->Owner()->Lua();

  // load the library into this lua state
  if (!FunctionIsLibExist(conn, &ctx, name, true)) {
    return {Status::NotOK, "the library does not exist in lua environment"};
  }

  lua_getglobal(lua, REDIS_FUNCTION_LIBRARIES);
  if (lua_isnil(lua, -1)) {
    lua_pop(lua, 1);
    return {Status::NotOK, "the library does not exist in lua environment"};
  }

  lua_getfield(lua, -1, name.c_str());
  if (lua_isnil(lua, -1)) {
    lua_pop(lua, 2);
    return {Status::NotOK, "the library does not exist in lua environment"};
  }

  auto storage = conn->GetServer()->storage;
  auto cf = storage->GetCFHandle(ColumnFamilyID::Propagate);

  for (size_t i = 1; i <= lua_objlen(lua, -1); ++i) {
    lua_rawgeti(lua, -1, static_cast<int>(i));
    std::string func = lua_tostring(lua, -1);
    auto _ = storage->Delete(ctx, rocksdb::WriteOptions(), cf, engine::kLuaFuncLibPrefix + func);
    lua_pop(lua, 1);
  }

  lua_pop(lua, 2);

  auto s = storage->Delete(ctx, rocksdb::WriteOptions(), cf, engine::kLuaLibCodePrefix + name);
  if (!s.ok()) return {Status::NotOK, s.ToString()};

  // reset all lua context from all workers
  // to ensure the library is removed from all lua states
  // TODO: optimize it to only delete this library
  // instead of resetting all libraries
  conn->GetServer()->ScriptReset();

  return Status::OK();
}

Status FunctionFlush(redis::Connection *conn, engine::Context *ctx) {
  auto storage = conn->GetServer()->storage;