diff --git a/bundle.json b/bundle.json
index e5afdc47c37a6bf7cc0a12db541a273ebb817db4..e177e404515420721c6a171466439aa791e41a4c 100644
--- a/bundle.json
+++ b/bundle.json
@@ -56,7 +56,8 @@
                 "//foundation/distributedhardware/distributedscreen/services/screenservice/sinkservice:distributed_screen_sink",
                 "//foundation/distributedhardware/distributedscreen/services/screenservice/sourceservice:distributed_screen_source",
                 "//foundation/distributedhardware/distributedscreen/sa_profile:dscreen_sa_profile",
-                "//foundation/distributedhardware/distributedscreen/sa_profile:dscreen.cfg"
+                "//foundation/distributedhardware/distributedscreen/sa_profile:dscreen.cfg",
+                "//foundation/distributedhardware/distributedscreen/services/demo:distributedScreenTest"
             ],
             "inner_kits":[
                 {
diff --git a/services/demo/BUILD.gn b/services/demo/BUILD.gn
new file mode 100644
index 0000000000000000000000000000000000000000..f1c69ac6953ff24dcd97408325392bf1eec32c52
--- /dev/null
+++ b/services/demo/BUILD.gn
@@ -0,0 +1,69 @@
+# Copyright (c) 2022 Huawei Device Co., Ltd.
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import("//build/ohos.gni")
+import("//foundation/distributedhardware/distributedscreen/distributedscreen.gni")
+
+ohos_executable("distributedScreenTest") {
+    install_enable = false
+    include_dirs = [
+        "${services_path}/common/utils/include",
+        "${interfaces_path}/innerkits/native_cpp/screen_sink/include",
+        "${interfaces_path}/innerkits/native_cpp/screen_source/include",
+        "${interfaces_path}/innerkits/native_cpp/screen_source/include/callback",
+        "${fwk_common_path}/utils/include",
+        "${windowmanager_path}/interfaces/innerkits/dm",
+        "${services_path}/screenclient/include",
+        "${windowmanager_path}/interfaces/innerkits/wm",
+        "${common_path}/include",
+    ]
+
+    include_dirs += [
+        "./"
+    ]
+
+    sources = [
+        "./test.cpp",
+        "./decoder_demo.cpp",
+    ]
+
+    deps = [
+        "${services_path}/screenclient:distributed_screen_client",
+        "${common_path}:distributed_screen_utils",
+        "${interfaces_path}/innerkits/native_cpp/screen_sink:distributed_screen_sink_sdk",
+        "${interfaces_path}/innerkits/native_cpp/screen_source:distributed_screen_source_sdk",
+        "${windowmanager_path}/dm:libdm",
+        "${windowmanager_path}/wm:libwm",
+        "//foundation/communication/dsoftbus/adapter:softbus_adapter",
+        "//foundation/communication/dsoftbus/sdk:softbus_client",
+        "//foundation/distributedschedule/samgr/interfaces/innerkits/samgr_proxy:samgr_proxy",
+        "//foundation/graphic/graphic_2d/rosen/modules/render_service_client:librender_service_client",
+    ]
+
+    defines = [
+        "HI_LOG_ENABLE",
+        "DH_LOG_TAG=\"distributedscreentest\"",
+        "LOG_DOMAIN=0xD004100",
+    ]
+
+    external_deps = [
+        "hiviewdfx_hilog_native:libhilog",
+        "multimedia_media_standard:media_client",
+    ]
+
+    cflags = ["-Wall"]
+    cflags_cc = cflags
+
+    part_name = "distributed_screen"
+    subsystem_name = "distributedhardware"
+}
diff --git a/services/demo/common.h b/services/demo/common.h
new file mode 100644
index 0000000000000000000000000000000000000000..6133bf19d187e501733947d2b08ddca4873e60a4
--- /dev/null
+++ b/services/demo/common.h
@@ -0,0 +1,57 @@
+/*
+ * Copyright (c) 2022 Huawei Device Co., Ltd.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef DISTRIBUTED_SCREEN_TEST_SA_H
+#define DISTRIBUTED_SCREEN_TEST_SA_H
+
+#include <stdlib.h>
+#include <limits.h>
+#include <iostream>
+#include <climits>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <sys/ioctl.h>
+#include <sys/wait.h>
+#include <thread>
+#include <stdio.h>
+#include <sys/time.h>
+
+#include "idistributed_hardware_source.h"
+
+namespace OHOS {
+namespace DistributedHardware {
+class DScreenMockRegisterCallback : public RegisterCallback {
+public:
+    virtual ~DScreenMockRegisterCallback() = default;
+    int32_t OnRegisterResult(const std::string &devId, const std::string &dhId, int32_t status, const std::string &data)
+    {
+        std::cout << "Register devId: " << devId << " dhId: " << dhId << ", status: " << status << std::endl;
+        return 0;
+    }
+};
+
+class DScreenMockUnRegisterCallback : public UnregisterCallback {
+public:
+    virtual ~DScreenMockUnRegisterCallback() = default;
+    int32_t OnUnregisterResult(const std::string &devId, const std::string &dhId, int32_t status, const std::string &data)
+    {
+        std::cout << "Unregister devId: " << devId << " dhId: " << dhId << ", status: " << status << std::endl;
+        return 0;
+    }
+};
+}
+}
+#endif
\ No newline at end of file
diff --git a/services/demo/decoder_demo.cpp b/services/demo/decoder_demo.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..60fe19faea62eb911e32309754805d7f1b5bd107
--- /dev/null
+++ b/services/demo/decoder_demo.cpp
@@ -0,0 +1,328 @@
+/*
+ * Copyright (C) 2022 Huawei Device Co., Ltd.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include "decoder_demo.h"
+
+#include <iostream>
+#include <unistd.h>
+
+#include "securec.h"
+#include "wm_common.h"
+#include "ui/rs_surface_node.h"
+#include "foundation/windowmanager/interfaces/innerkits/wm/window.h"
+#include "foundation/windowmanager/interfaces/innerkits/wm/window_option.h"
+#include "foundation/multimedia/media_standard/interfaces/inner_api/native/avcodec_list.h"
+
+static const int32_t ES_RK[325] =
+{ 11895, 8109, 1578, 1616, 1313, 572, 805, 837, 755, 706, 952, 879, 13193, 422, 389, 509, 725, 465, 479, 959,
+      677, 364, 541, 696, 9306, 322, 318, 767, 590, 422, 530, 403, 505, 566, 445, 508, 7783, 460, 405, 343, 451,
+      608, 431, 411, 543, 487, 527, 400, 6287, 385, 418, 391, 592, 434, 412, 398, 504, 492, 479, 561, 5413, 317,
+      355, 422, 467, 452, 476, 460, 490, 492, 485, 451, 5036, 312, 408, 460, 432, 502, 388, 475, 407, 544, 401,
+      487, 4404, 362, 378, 427, 416, 426, 456, 414, 438, 424, 442, 444, 4310, 362, 388, 393, 390, 441, 398, 423,
+      369, 443, 406, 392, 4231, 343, 363, 355, 390, 459, 371, 378, 381, 405, 392, 426, 3975, 387, 337, 393, 439,
+      378, 355, 374, 484, 381, 373, 423, 3869, 312, 350, 400, 345, 356, 320, 473, 431, 386, 338, 431, 3426, 268,
+      315, 416, 383, 373, 381, 354, 383, 328, 348, 418, 3715, 324, 361, 331, 350, 302, 409, 377, 359, 384, 334,
+      326, 3439, 266, 324, 329, 353, 405, 303, 357, 332, 292, 361, 333, 3542, 294, 284, 247, 331, 306, 322, 287,
+      367, 341, 276, 258, 3980, 246, 245, 259, 309, 333, 250, 275, 334, 281, 253, 371, 3640, 213, 231, 301, 302,
+      228, 289, 290, 281, 201, 284, 277, 4242, 205, 328, 237, 283, 295, 266, 230, 321, 348, 212, 308, 4103, 259,
+      238, 245, 298, 330, 265, 271, 287, 267, 286, 290, 3856, 269, 242, 209, 314, 267, 278, 280, 314, 250, 433,
+      238, 3654, 195, 246, 301, 298, 250, 270, 320, 269, 305, 258, 368, 3810, 231, 212, 279, 289, 252, 303, 287,
+      295, 206, 264, 349, 4071, 242, 296, 271, 231, 307, 265, 254, 267, 317, 232, 348, 4077, 259, 222, 268, 235,
+      324, 266, 256, 312, 246, 248, 325, 4000, 266, 201, 230, 293, 264, 265, 273, 301, 304, 253, 266, 3978, 228,
+      232, 250, 248, 281, 219, 243, 293, 287, 253, 328, 3719};
+	  
+static const int32_t ES_WGR[183] =
+    { 2111, 109091, 9316, 969, 13656, 1349, 959, 10484, 1219, 14839, 1092, 23378, 1653, 1725, 1526, 8500, 15407,
+      2058, 1346, 21066, 3758, 1734, 1950, 19955, 3997, 1732, 1784, 22687, 4392, 2448, 2180, 17456, 3930, 1851,
+      1802, 24227, 4393, 2639, 2778, 18314, 4023, 2392, 2283, 20566, 4118, 2664, 2013, 18964, 2624, 45258, 5860,
+      4124, 3473, 27772, 4687, 3140, 2939, 26288, 3808, 2967, 2823, 27219, 3943, 3242, 2667, 26608, 3584, 2853,
+      2285, 19581, 2894, 2436, 24898, 4002, 2876, 2807, 25730, 3903, 2874, 2975, 26309, 3771, 2763, 2666, 23404,
+      3826, 2410, 2644, 24629, 4145, 3121, 2878, 50773, 7040, 3945, 3292, 30828, 5210, 2883, 3277, 31501, 4809,
+      3068, 3220, 30746, 4715, 3461, 3583, 32278, 4798, 3398, 3389, 31404, 4921, 3382, 3766, 31821, 5848, 3860,
+      4047, 37642, 5793, 4271, 4094, 29853, 6163, 4399, 4063, 32151, 6038, 4332, 4041, 30390, 5679, 4098, 3921,
+      29401, 5307, 3996, 3945, 4997, 7060, 3716, 4183, 26357, 6190, 3714, 4250, 29086, 5929, 3491, 4489, 27772,
+      6656, 4219, 4348, 25851, 6088, 3617, 4477, 25722, 6303, 3856, 4208, 25348, 5896, 3816, 4521, 22462, 5914,
+      3673, 4594, 18091, 6474, 3878, 4492, 10890, 4823, 4148 };
+
+using namespace OHOS;
+using namespace OHOS::Media;
+using namespace std;
+namespace {
+    constexpr uint32_t DEFAULT_WIDTH = 480;
+    constexpr uint32_t DEFAULT_HEIGHT = 360;
+    constexpr uint32_t DEFAULT_FRAME_RATE = 30;
+    constexpr uint32_t MAX_INPUT_BUFFER_SIZE = 30000;
+    constexpr uint32_t FRAME_DURATION_US = 33000;
+    constexpr uint32_t DEFAULT_FRAME_COUNT = 1;
+    const std::string CODEC_NAME_H264 = "OMX_hisi_video_encoder_avc";
+    const std::string CODEC_NAME_MPEG4 = "avenc_mpeg4";
+}
+
+void VDecDemo::RunCase()
+{
+    CheckCodecType();
+    CreateVdec();
+    Format format;
+    format.PutIntValue("width", DEFAULT_WIDTH);
+    format.PutIntValue("height", DEFAULT_HEIGHT);
+    if (isWgr) {
+        format.PutIntValue("pixel_format", 3);
+    } else {
+        format.PutIntValue("pixel_format", 2);
+    }
+    format.PutIntValue("frame_rate", DEFAULT_FRAME_RATE);
+    format.PutIntValue("max_input_size", MAX_INPUT_BUFFER_SIZE);
+    Configure(format);
+    
+    SetSurface();
+    Prepare();
+    Start();
+    sleep(3);
+    Stop();
+    Release();
+}
+
+int32_t VDecDemo::CreateVdec()
+{
+    if (isWgr) {
+        vdec_ = VideoDecoderFactory::CreateByMime("video/avc");
+    } else {
+        vdec_ = VideoDecoderFactory::CreateByMime("video/mp4v-es");
+    }
+
+    signal_ = make_shared<VDecSignal>();
+    cb_ = make_unique<VDecDemoCallback>(signal_);
+    vdec_->SetCallback(cb_);
+    return 0;
+}
+
+int32_t VDecDemo::Configure(const Format &format)
+{
+    return vdec_->Configure(format);
+}
+
+int32_t VDecDemo::Prepare()
+{
+    return vdec_->Prepare();
+}
+
+int32_t VDecDemo::Start()
+{
+    isRunning_.store(true);
+
+    testFile_ = std::make_unique<std::ifstream>();
+    testFile_->open("/data/media/video.es", std::ios::in | std::ios::binary);
+
+    inputLoop_ = make_unique<thread>(&VDecDemo::InputFunc, this);
+    outputLoop_ = make_unique<thread>(&VDecDemo::OutputFunc, this);
+    return vdec_->Start();
+}
+
+int32_t VDecDemo::Stop()
+{
+    isRunning_.store(false);
+
+    if (inputLoop_ != nullptr && inputLoop_->joinable()) {
+        unique_lock<mutex> lock(signal_->inMutex_);
+        signal_->inQueue_.push(10000); // wake up read loop thread
+        signal_->inCond_.notify_all();
+        lock.unlock();
+        inputLoop_->join();
+        inputLoop_.reset();
+    }
+
+    if (outputLoop_ != nullptr && outputLoop_->joinable()) {
+        unique_lock<mutex> lock(signal_->outMutex_);
+        signal_->outQueue_.push(10000); // wake up read loop thread
+        signal_->outCond_.notify_all();
+        lock.unlock();
+        outputLoop_->join();
+        outputLoop_.reset();
+    }
+
+    return vdec_->Stop();
+}
+
+int32_t VDecDemo::Flush()
+{
+    return vdec_->Flush();
+}
+
+int32_t VDecDemo::Reset()
+{
+    return vdec_->Reset();
+}
+
+int32_t VDecDemo::Release()
+{
+    return vdec_->Release();
+}
+
+void VDecDemo::SetOutputSurface(sptr<Surface> surface)
+{
+    surface_ = surface;
+}
+
+void VDecDemo::SetWindowSize(uint32_t width, uint32_t height)
+{
+    width_ = width;
+    height_ = height;
+}
+
+int32_t VDecDemo::SetSurface()
+{
+    return vdec_->SetOutputSurface(surface_);
+}
+
+void VDecDemo::CheckCodecType()
+{
+    std::vector<std::string> localCodecArray;
+    // query local support encoder type
+    std::shared_ptr<Media::AVCodecList> codecList = Media::AVCodecListFactory::CreateAVCodecList();
+    std::vector<std::shared_ptr<Media::VideoCaps>> caps = codecList->GetVideoEncoderCaps();
+    for (const auto &cap : caps) {
+        std::shared_ptr<Media::AVCodecInfo> codecInfo = cap->GetCodecInfo();
+        localCodecArray.push_back(codecInfo->GetName());
+    }
+
+    if (std::find(localCodecArray.begin(), localCodecArray.end(),
+        CODEC_NAME_H264) != localCodecArray.end()) {
+        isWgr = true;
+    } else if (std::find(localCodecArray.begin(), localCodecArray.end(),
+        CODEC_NAME_MPEG4) != localCodecArray.end()) {
+        isWgr = false;
+    }
+}
+
+void VDecDemo::InputFunc()
+{
+    const int32_t *frameLen = nullptr;
+    if (isWgr) {
+        frameLen = ES_WGR;
+		cout <<"frameLen is WGR"<< endl;
+    } else {
+        frameLen = ES_RK;
+		cout <<"frameLen is RK"<< endl;
+	}
+    
+    while (true) {
+        if (!isRunning_.load()) {
+            break;
+        }
+
+        unique_lock<mutex> lock(signal_->inMutex_);
+        signal_->inCond_.wait(lock, [this](){ return signal_->inQueue_.size() > 0; });
+
+        if (!isRunning_.load()) {
+            break;
+        }
+
+        uint32_t index = signal_->inQueue_.front();
+        auto buffer = vdec_->GetInputBuffer(index);
+
+        char *fileBuffer = (char *)malloc(sizeof(char) * (*frameLen) + 1);
+
+        (void)testFile_->read(fileBuffer, *frameLen);
+        if (memcpy_s(buffer->GetBase(), buffer->GetSize(), fileBuffer, *frameLen) != EOK) {
+            free(fileBuffer);
+            cout << "Fatal: memcpy fail" << endl;
+            break;
+        }
+
+        AVCodecBufferInfo info;
+        info.size = *frameLen;
+        info.offset = 0;
+        info.presentationTimeUs = timeStamp_;
+
+        int32_t ret = 0;
+        if (isFirstFrame_) {
+            ret = vdec_->QueueInputBuffer(index, info, AVCODEC_BUFFER_FLAG_CODEC_DATA);
+            isFirstFrame_ = false;
+        } else {
+            ret = vdec_->QueueInputBuffer(index, info, AVCODEC_BUFFER_FLAG_NONE);
+        }
+
+        free(fileBuffer);
+        frameLen++;
+        timeStamp_ += FRAME_DURATION_US;
+        signal_->inQueue_.pop();
+
+        frameCount_++;
+        if (frameCount_ == DEFAULT_FRAME_COUNT) {
+            cout << "Finish decode, exit" << endl;
+            break;
+        }
+
+        if (ret != 0) {
+            cout << "Fatal error, exit" << endl;
+            break;
+        }
+    }
+}
+
+void VDecDemo::OutputFunc()
+{
+    while (true) {
+        if (!isRunning_.load()) {
+            break;
+        }
+
+        unique_lock<mutex> lock(signal_->outMutex_);
+        signal_->outCond_.wait(lock, [this](){ return signal_->outQueue_.size() > 0; });
+
+        if (!isRunning_.load()) {
+            break;
+        }
+
+        uint32_t index = signal_->outQueue_.front();
+        if (vdec_->ReleaseOutputBuffer(index, true) != 0) {
+            cout << "Fatal: ReleaseOutputBuffer fail" << endl;
+            break;
+        }
+
+        signal_->outQueue_.pop();
+    }
+}
+
+VDecDemoCallback::VDecDemoCallback(shared_ptr<VDecSignal> signal)
+    : signal_(signal)
+{
+}
+
+void VDecDemoCallback::OnError(AVCodecErrorType errorType, int32_t errorCode)
+{
+    cout << "Error received, errorType:" << errorType << " errorCode:" << errorCode << endl;
+}
+
+void VDecDemoCallback::OnOutputFormatChanged(const Format &format)
+{
+    cout << "OnOutputFormatChanged received" << endl;
+}
+
+void VDecDemoCallback::OnInputBufferAvailable(uint32_t index)
+{
+    cout << "OnInputBufferAvailable received, index:" << index << endl;
+    unique_lock<mutex> lock(signal_->inMutex_);
+    signal_->inQueue_.push(index);
+    signal_->inCond_.notify_all();
+}
+
+void VDecDemoCallback::OnOutputBufferAvailable(uint32_t index, AVCodecBufferInfo info, AVCodecBufferFlag flag)
+{
+    cout << "OnOutputBufferAvailable received, index:" << index << endl;
+    unique_lock<mutex> lock(signal_->outMutex_);
+    signal_->outQueue_.push(index);
+    signal_->outCond_.notify_all();
+}
diff --git a/services/demo/decoder_demo.h b/services/demo/decoder_demo.h
new file mode 100644
index 0000000000000000000000000000000000000000..91bac0acefa713ecd3b892e0ce92fc446a97b689
--- /dev/null
+++ b/services/demo/decoder_demo.h
@@ -0,0 +1,93 @@
+/*
+ * Copyright (C) 2022 Huawei Device Co., Ltd.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef AVCODEC_VDEC_DEMO_H
+#define AVCODEC_VDEC_DEMO_H
+
+#include <atomic>
+#include <fstream>
+#include <queue>
+#include <string>
+#include <thread>
+
+#include "avcodec_video_decoder.h"
+#include "nocopyable.h"
+
+namespace OHOS {
+namespace Media {
+class VDecSignal {
+public:
+    std::mutex inMutex_;
+    std::mutex outMutex_;
+    std::condition_variable inCond_;
+    std::condition_variable outCond_;
+    std::queue<uint32_t> inQueue_;
+    std::queue<uint32_t> outQueue_;
+};
+
+class VDecDemoCallback : public AVCodecCallback, public NoCopyable {
+public:
+    explicit VDecDemoCallback(std::shared_ptr<VDecSignal> signal);
+    virtual ~VDecDemoCallback() = default;
+
+    void OnError(AVCodecErrorType errorType, int32_t errorCode) override;
+    void OnOutputFormatChanged(const Format &format) override;
+    void OnInputBufferAvailable(uint32_t index) override;
+    void OnOutputBufferAvailable(uint32_t index, AVCodecBufferInfo info, AVCodecBufferFlag flag) override;
+
+private:
+    std::shared_ptr<VDecSignal> signal_;
+};
+
+class VDecDemo : public NoCopyable {
+public:
+    VDecDemo() = default;
+    virtual ~VDecDemo() = default;
+    void RunCase();
+    void SetOutputSurface(sptr<Surface> surface);
+    void SetWindowSize(uint32_t width, uint32_t height);
+
+private:
+    int32_t CreateVdec();
+    int32_t Configure(const Format &format);
+    int32_t Prepare();
+    int32_t Start();
+    int32_t Stop();
+    int32_t Flush();
+    int32_t Reset();
+    int32_t Release();
+    int32_t SetSurface();
+    void InputFunc();
+    void OutputFunc();
+    void CheckCodecType();
+
+    std::atomic<bool> isRunning_ = false;
+    sptr<Surface> surface_ = nullptr;
+    uint32_t width_ = 0;
+    uint32_t height_ = 0;
+    std::unique_ptr<std::ifstream> testFile_;
+    std::unique_ptr<std::thread> inputLoop_;
+    std::unique_ptr<std::thread> outputLoop_;
+    std::shared_ptr<Media::AVCodecVideoDecoder> vdec_;
+    std::shared_ptr<VDecSignal> signal_;
+    std::shared_ptr<VDecDemoCallback> cb_;
+    bool isFirstFrame_ = true;
+    bool isWgr = true;
+    int64_t timeStamp_ = 0;
+    uint32_t frameCount_ = 0;
+};
+} // namespace Media
+} // namespace OHOS
+#endif // AVCODEC_VDEC_DEMO_H
\ No newline at end of file
diff --git a/services/demo/test.cpp b/services/demo/test.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..37f44146d72e4b4d89c50a45da3d0d8c68170fd9
--- /dev/null
+++ b/services/demo/test.cpp
@@ -0,0 +1,319 @@
+/*
+ * Copyright (c) 2022 Huawei Device Co., Ltd.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <string>
+#include <iostream>
+
+#include "display.h"
+#include "display_manager.h"
+#include "dscreen_source_handler.h"
+#include "dscreen_sink_handler.h"
+#include "idistributed_hardware_sink.h"
+#include "idistributed_hardware_source.h"
+#include "screen.h"
+#include "screen_client.h"
+#include "screen_client_common.h"
+#include "screen_manager.h"
+#include "wm_common.h"
+#include "window.h"
+#include "window_option.h"
+
+#include "common.h"
+#include "decoder_demo.h"
+#include "softbus_adapter_mem.h"
+#include "softbus_bus_center.h"
+#include "softbus_common.h"
+
+using namespace std;
+using namespace OHOS;
+using namespace OHOS::DistributedHardware;
+using namespace OHOS::Rosen;
+using namespace OHOS::Media;
+
+static char const *g_pkgName = "ohos.dsoftbus.tool";
+
+std::vector<sptr<Screen>> queryRemoteScreenInfo()
+{
+    std::vector<sptr<Screen>> allScreens = ScreenManager::GetInstance().GetAllScreens();
+    sptr<Display> defaultDisplay = DisplayManager::GetInstance().GetDefaultDisplay();
+    std::vector<sptr<Screen>> remoteScreens;
+    for (const auto &screen : allScreens) {
+        if (!screen->IsReal() && screen->GetWidth() > 0) {
+            remoteScreens.push_back(screen);
+        }
+    }
+    cout << "-------------remote screen info---------------" << endl;
+    cout << "remote screen Num: " << remoteScreens.size() << endl;
+    for (const auto &screen : remoteScreens) {
+        cout << endl;
+        cout << "--------screen id " << screen->GetId() << "---------" << endl;
+        cout << "screen name: " << screen->GetName() << endl;
+        cout << "width: " << screen->GetWidth() << endl;
+        cout << "height: " << screen->GetHeight() << endl;
+        cout << "-------------------------------------------" << endl;
+    }
+    return remoteScreens;
+}
+
+static void startMirror()
+{
+    vector<sptr<Screen>> remoteScreens = queryRemoteScreenInfo();
+    if (remoteScreens.size() == 0) {
+        cout << "Error: no remote screens enabled" << endl;
+        return;
+    }
+
+    cout << "select remote screen id to mirror: " << endl;
+    uint64_t mirrorId;
+    cin >> mirrorId;
+
+    // check mirrorId invalid
+    bool isMirrorIdValid = false;
+    for (const auto &screen : remoteScreens) {
+        if (screen->GetId() == mirrorId) {
+            isMirrorIdValid = true;
+            break;
+        }
+    }
+
+    if (!isMirrorIdValid) {
+        cout << "input mirrorId is not valid!" << endl;
+        return;
+    }
+
+    sptr<Display> defaultDisplay = DisplayManager::GetInstance().GetDefaultDisplay();
+    cout << endl << "------------start mirror----------" <<endl;
+    cout << "mirror screen Id is " << mirrorId << endl;
+    vector<uint64_t> mirrorIds;
+    mirrorIds.push_back(mirrorId);
+    ScreenManager::GetInstance().MakeMirror(defaultDisplay->GetScreenId(), mirrorIds);
+}
+
+static void stopMirror()
+{
+    vector<sptr<Screen>> remoteScreens = queryRemoteScreenInfo();
+    if (remoteScreens.size() == 0) {
+        cout << "no remote screens enabled, no need stop mirror" << endl;
+        return;
+    }
+
+    // check stopMirrorId invalid
+    bool isStopMirrorIdValid = false;
+    cout << "select remote screen id to stop mirror: " << endl;
+    uint64_t stopMirrorId;
+    cin >> stopMirrorId;
+
+    for (const auto &screen : remoteScreens) {
+        if (screen->GetId() == stopMirrorId) {
+            isStopMirrorIdValid = true;
+            break;
+        }
+    }
+    if (!isStopMirrorIdValid) {
+        cout << "input screenId is not valid!" << endl;
+        return;
+    }
+
+    cout << "-------------- stop mirror ------------" << endl;
+    cout << "stop mirror screen id is " << stopMirrorId << endl;
+    vector<uint64_t> stopMirrorIds;
+    stopMirrorIds.push_back(stopMirrorId);
+    ScreenManager::GetInstance().RemoveVirtualScreenFromGroup(stopMirrorIds);
+}
+
+static void startExpand()
+{
+   vector<sptr<Screen>> remoteScreens = queryRemoteScreenInfo();
+    if (remoteScreens.size() == 0) {
+        cout << "Error: no remote screens enabled" << endl;
+        return;
+    }
+
+    cout << "select remote screen id to expand: " << endl;
+    uint64_t expandId;
+    cin >> expandId;
+
+    // check expandId invalid
+    bool isExpandIdValid = false;
+    for (const auto &screen : remoteScreens) {
+        if (screen->GetId() == expandId) {
+            isExpandIdValid = true;
+            break;
+        }
+    }
+
+    if (!isExpandIdValid) {
+        cout << "input expandId is not valid!" << endl;
+        return;
+    }
+
+    sptr<Display> defaultDisplay = DisplayManager::GetInstance().GetDefaultDisplay();
+    cout << endl << "------------start expand----------" << endl;
+    cout << "expand screen Id is " << expandId << endl;
+    vector<ExpandOption> options = {{defaultDisplay->GetScreenId(), 0, 0}, {expandId, defaultDisplay->GetWidth(), 0}};
+    ScreenManager::GetInstance().MakeExpand(options);
+}
+
+static void stopExpand()
+{
+    vector<sptr<Screen>> remoteScreens = queryRemoteScreenInfo();
+    if (remoteScreens.size() == 0) {
+        cout << "no remote screens enabled, no need stop expand" << endl;
+        return;
+    }
+
+    // check stopExpandId invalid
+    bool isStopExpandIdValid = false;
+    cout << "select remote screen id to stop expand: " << endl;
+    uint64_t stopExpandId;
+    cin >> stopExpandId;
+
+    for (const auto &screen : remoteScreens) {
+        if (screen->GetId() == stopExpandId) {
+            isStopExpandIdValid = true;
+            break;
+        }
+    }
+    if (!isStopExpandIdValid) {
+        cout << "input screenId is not valid!" << endl;
+        return;
+    }
+
+    cout << "-------------- stop expand ------------" << endl;
+    cout << "stop expand screen id is " << stopExpandId << endl;
+    vector<uint64_t> stopExpandIds;
+    stopExpandIds.push_back(stopExpandId);
+    ScreenManager::GetInstance().RemoveVirtualScreenFromGroup(stopExpandIds);
+}
+
+static void PrintNodeProperty(NodeBasicInfo *nodeInfo)
+{
+    printf("DeviceName = %s\n", nodeInfo->deviceName);
+    printf("NetworkId = %s\n", nodeInfo->networkId);
+    NodeDeviceInfoKey key;
+    key = NODE_KEY_UDID;
+    unsigned char udid[UDID_BUF_LEN] = {0};
+    if (GetNodeKeyInfo(g_pkgName, nodeInfo->networkId, key, udid, UDID_BUF_LEN) != 0) {
+        printf("GetNodeKeyInfo Fail!\n");
+    } else {
+        printf("Udid = %s\n", udid);
+    }
+    key = NODE_KEY_UUID;
+    unsigned char uuid[UUID_BUF_LEN] = {0};
+    if (GetNodeKeyInfo(g_pkgName, nodeInfo->networkId, key, uuid, UUID_BUF_LEN) != 0) {
+        printf("GetNodeKeyInfo Fail!\n");
+    } else {
+        printf("Uuid = %s\n", uuid);
+    }
+}
+
+static void queryRemoteDeviceInfo()
+{
+    NodeBasicInfo localNodeinfo;
+    NodeBasicInfo *remoteNodeInfo = NULL;
+    int32_t infoNum = 0;
+    printf("-----------Local Device Info------\n");
+    if (GetLocalNodeDeviceInfo(g_pkgName, &localNodeinfo) != 0) {
+        printf("LnnGetLocalNodeInfo Fail!\n");
+        return;
+    }
+    PrintNodeProperty(&localNodeinfo);
+    printf("-------Remote Device info---------\n");
+    if (GetAllNodeDeviceInfo(g_pkgName, &remoteNodeInfo, &infoNum) != 0) {
+        printf("GetAllNodeDeviceInfo Fail!\n");
+        return;
+    }
+    printf("Device Num = %d\n", infoNum);
+    for (int i = 0; i < infoNum; ++i) {
+        printf("\n[No.%d]", i + 1);
+        PrintNodeProperty(remoteNodeInfo + i);
+    }
+    FreeNodeInfo(remoteNodeInfo);
+    printf("SoftBusDumpDeviceInfo complete!\n");
+}
+
+static void createWindow()
+{
+    cout << "create window, please input window size" << endl;
+    cout << "width: ";
+    uint32_t windowWidth;
+    cin >> windowWidth;
+    cout << "height: ";
+    uint32_t windowHeight;
+    cin >> windowHeight;
+
+    if (windowWidth <= 0 || windowHeight <= 0) {
+        cout << "Invalid window size." << endl;
+        return;
+    }
+
+    sptr<Display> defaultDisplay = DisplayManager::GetInstance().GetDefaultDisplay();
+    std::shared_ptr<WindowProperty> windowProperty = std::make_shared<WindowProperty>();
+    windowProperty->displayId = defaultDisplay->GetId();
+    windowProperty->startX = 0;
+    windowProperty->startY = 0;
+    windowProperty->width = windowWidth;
+    windowProperty->height = windowHeight;
+    int32_t windowId = ScreenClient::GetInstance().AddWindow(windowProperty);
+    ScreenClient::GetInstance().ShowWindow(windowId);
+    sptr<Surface> surface = ScreenClient::GetInstance().GetSurface(windowId);
+    cout << "create window success." << endl;
+
+    auto vdec = std::make_shared<VDecDemo>();
+    if (vdec == nullptr) {
+        cout << "videoDecoder is null" << endl;
+        return;
+    }
+    vdec->SetWindowSize(windowWidth, windowHeight);
+    vdec->SetOutputSurface(surface);
+    cout << "start run decoder" << endl;
+    vdec->RunCase();
+    cout << "create window success, window id: " << windowId
+         << ", width: " << windowWidth
+         << ", height: " << windowHeight << endl;
+    ScreenClient::GetInstance().RemoveWindow(windowId);
+}
+
+int main()
+{
+    cout << "Please select a test scenario number(default startMirror): " << endl;
+    cout << "0:startMirror" << endl;
+    cout << "1:stopMirror" << endl;
+    cout << "2:startExpand" << endl;
+    cout << "3:stopExpand" << endl;
+    cout << "4:createWindow" << endl;
+    cout << "5:queryRemoteDeviceInfo" << endl;
+    cout << "6:queryRemoteScreenInfo" << endl;
+    string mode;
+    (void)getline(cin, mode);
+    if (mode == "" || mode == "0") {
+        (void)startMirror();
+    } else if (mode == "1") {
+        (void)stopMirror();
+    } else if (mode == "2") {
+        (void)startExpand();
+    } else if (mode == "3") {
+        (void)stopExpand();
+    } else if (mode == "4") {
+        (void)createWindow();
+    } else if (mode == "5") {
+        (void)queryRemoteDeviceInfo();
+    } else if (mode == "6") {
+        (void)queryRemoteScreenInfo();
+    } else {
+        cout << "no that selection" << endl;
+    }
+    return 0;
+}