diff --git a/mpp/codec/dec/h264/h264d_api.c b/mpp/codec/dec/h264/h264d_api.c
index 623b7b7c..26968fc5 100644
--- a/mpp/codec/dec/h264/h264d_api.c
+++ b/mpp/codec/dec/h264/h264d_api.c
@@ -14,42 +14,32 @@
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
+#define MODULE_TAG "h264d_api"
 
 
 #include "h264d_api.h"
 
 
-#define H264D_TAG "h264d_api"
-
-
-
-
-
-MPP_RET  h264d_init   (void **decoder, MppParserInitCfg *init)
+MPP_RET  h264d_init(void **decoder, MppParserInitCfg *init)
 {
-
-
-
-
-
     return MPP_OK;
 }
 
-MPP_RET  h264d_deinit (void *decoder)
+MPP_RET  h264d_deinit(void *decoder)
 {
 
 
     return MPP_OK;
 }
 
-MPP_RET  h264d_reset  (void *decoder)
+MPP_RET  h264d_reset(void *decoder)
 {
 
     return MPP_OK;
 }
 
 
-MPP_RET  h264d_flush  (void *decoder)
+MPP_RET  h264d_flush(void *decoder)
 {
 
 
@@ -65,7 +55,7 @@ MPP_RET  h264d_control(void *decoder, RK_S32 cmd_type, void *param)
 }
 
 
-MPP_RET  h264d_parser (void *decoder, MppPacket pkt, MppSyntax *syn)
+MPP_RET  h264d_parser(void *decoder, MppPacket pkt, MppSyntax *syn)
 {
     return MPP_OK;
 }
diff --git a/mpp/codec/inc/mpp_dec.h b/mpp/codec/inc/mpp_dec.h
index e65545a5..f3c7ace2 100644
--- a/mpp/codec/inc/mpp_dec.h
+++ b/mpp/codec/inc/mpp_dec.h
@@ -20,19 +20,7 @@
 #include "rk_mpi.h"
 #include "mpp_packet.h"
 #include "mpp_buf_slot.h"
-
-#define MPP_SYNTAX_MAX_NUMBER       8
-
-/*
- * modified by parser
- *
- * number   : the number of the data pointer array element
- * data     : the address of the pointer array, parser will add its data here
- */
-typedef struct {
-    RK_U32          number;
-    void            *data;
-} MppSyntax;
+#include "mpp_hal.h"
 
 /*
  * slots    - all decoder need a slots interface to sync its internal dpb management
@@ -44,7 +32,7 @@ typedef struct {
     MppBufSlots     slots;
 } MppParserInitCfg;
 
-typedef struct MppDecCtx_t MppDecCtx;
+typedef struct MppDec_t MppDec;
 
 /*
  * MppDecParser is the data structure provided from different decoders
@@ -78,12 +66,15 @@ typedef struct {
     MPP_RET (*control)(void *ctx, RK_S32 cmd, void *param);
 } MppDecParser;
 
-struct MppDecCtx_t {
+struct MppDec_t {
     MppCodingType       coding;
-    void                *ctx;
-    MppSyntax           syntax[2];
+
+    const MppDecParser  *parser_api;
+    void                *parser_ctx;
+
+    MppHal              *hal_ctx;
+
     MppBufSlots         slots;
-    const MppDecParser  *parser;
 };
 
 
@@ -94,18 +85,19 @@ extern "C" {
 /*
  * main thread for all decoder. This thread will connect parser / hal / mpp
  */
-void *mpp_dec_thread(void *data);
+void *mpp_dec_parser_thread(void *data);
+void *mpp_dec_hal_thread(void *data);
 
 /*
  *
  */
-MPP_RET mpp_dec_init(MppDecCtx **ctx, MppCodingType coding);
-MPP_RET mpp_dec_deinit(MppDecCtx *ctx);
+MPP_RET mpp_dec_init(MppDec **dec, MppCodingType coding);
+MPP_RET mpp_dec_deinit(MppDec *dec);
 
-MPP_RET mpp_dec_parse(MppDecCtx *ctx, MppPacket pkt, MppSyntax *syntax);
-MPP_RET mpp_dec_reset(MppDecCtx *ctx);
-MPP_RET mpp_dec_flush(MppDecCtx *ctx);
-MPP_RET mpp_dec_control(MppDecCtx *ctx, RK_S32 cmd, void *para);
+MPP_RET mpp_dec_parse(MppDec *dec, MppPacket pkt, MppSyntax *syntax);
+MPP_RET mpp_dec_reset(MppDec *dec);
+MPP_RET mpp_dec_flush(MppDec *dec);
+MPP_RET mpp_dec_control(MppDec *dec, RK_S32 cmd, void *para);
 
 #ifdef __cplusplus
 }
diff --git a/mpp/codec/inc/mpp_enc.h b/mpp/codec/inc/mpp_enc.h
index 09369d3f..1b7eb144 100644
--- a/mpp/codec/inc/mpp_enc.h
+++ b/mpp/codec/inc/mpp_enc.h
@@ -26,7 +26,8 @@ extern "C" {
 /*
  * main thread for all encoder. This thread will connect encoder / hal / mpp
  */
-void *mpp_enc_thread(void *data);
+void *mpp_enc_control_thread(void *data);
+void *mpp_enc_hal_thread(void *data);
 
 #ifdef __cplusplus
 }
diff --git a/mpp/codec/mpp_dec.cpp b/mpp/codec/mpp_dec.cpp
index 964dd28f..793b93ac 100644
--- a/mpp/codec/mpp_dec.cpp
+++ b/mpp/codec/mpp_dec.cpp
@@ -24,6 +24,7 @@
 #include "mpp_dec.h"
 #include "mpp_packet.h"
 #include "mpp_packet_impl.h"
+#include "mpp_buf_slot.h"
 
 #include "h264d_api.h"
 #include "h265d_api.h"
@@ -37,150 +38,238 @@ static const MppDecParser *parsers[] = {
 
 #define MPP_TEST_FRAME_SIZE     SZ_1M
 
-void *mpp_dec_thread(void *data)
+void *mpp_dec_parser_thread(void *data)
 {
     Mpp *mpp = (Mpp*)data;
-    MppThread *dec  = mpp->mTheadCodec;
-    MppThread *hal  = mpp->mThreadHal;
+    MppThread *parser   = mpp->mTheadCodec;
+    MppThread *hal      = mpp->mThreadHal;
+    MppDec *dec_ctx  = mpp->mDec;
     mpp_list *packets   = mpp->mPackets;
+    MppHal    *hal_ctx  = dec_ctx->hal_ctx;
     MppPacketImpl packet;
+    RK_U32 packet_ready = 0;
+    RK_U32 syntax_ready = 0;
+    RK_U32 slot_ready   = 0;
 
-    while (MPP_THREAD_RUNNING == dec->get_status()) {
-        RK_U32 packet_ready = 0;
+    while (MPP_THREAD_RUNNING == parser->get_status()) {
         /*
          * wait for stream input
          */
-        dec->lock();
-        if (0 == packets->list_size())
-            dec->wait();
-        dec->unlock();
+        parser->lock();
+        if (!packet_ready && (0 == packets->list_size()))
+            parser->wait();
+        parser->unlock();
 
-        if (packets->list_size()) {
-            mpp->mPacketLock.lock();
-            /*
-             * packet will be destroyed outside, here just copy the content
-             */
-            packets->del_at_head(&packet, sizeof(packet));
-            mpp->mPacketGetCount++;
-            packet_ready = 1;
-            mpp->mPacketLock.unlock();
+        if (!packet_ready) {
+            if (packets->list_size()) {
+                mpp->mPacketLock.lock();
+                /*
+                 * packet will be destroyed outside, here just copy the content
+                 */
+                packets->del_at_head(&packet, sizeof(packet));
+                mpp->mPacketGetCount++;
+                mpp->mPacketLock.unlock();
+                packet_ready = 1;
+            }
         }
 
-        if (packet_ready) {
-            /*
-             * 1. send packet data to parser
-             *
-             *    parser functioin input / output
-             *    input:    packet data
-             *              dxva output slot
-             *    output:   dxva output slot
-             *              buffer usage informatioin
-             */
+        if (!packet_ready)
+            continue;
 
-            // decoder->parser->parse;
+        /*
+         * 1. send packet data to parser
+         *
+         *    parser functioin input / output
+         *    input:    packet data
+         *              dxva output slot
+         *    output:   dxva output slot
+         *              buffer usage informatioin
+         */
+
+        mpp_dec_parse(dec_ctx, (MppPacket)&packet, &hal_ctx->mSyn[0]);
+
+        /*
+         * 2. do buffer operation according to usage information
+         *
+         *    possible case:
+         *    a. normal case
+         *       - wait and alloc a normal frame buffer
+         *    b. field mode case
+         *       - two field may reuse a same buffer, no need to alloc
+         *    c. info change case
+         *       - need buffer in different side, need to send a info change
+         *         frame to hal loop.
+         */
+
+        //MppBuffer buffer;
+        //mpp_buffer_get(mpp->mFrameGroup, &buffer, MPP_TEST_FRAME_SIZE);
+
+
+        /*
+         * 3. send dxva output information and buffer information to hal thread
+         *    combinate video codec dxva output and buffer information
+         */
+
+        // hal->wait_prev_done;
+        // hal->send_config;
+        mpp->mTasks->add_at_tail(&mpp->mTask[0], sizeof(mpp->mTask[0]));
+        mpp->mTaskPutCount++;
+        hal->signal();
+        packet_ready = 0;
+    }
+
+    return NULL;
+}
+
+#define MPP_TEST_FRAME_SIZE     SZ_1M
+
+void *mpp_dec_hal_thread(void *data)
+{
+    Mpp *mpp = (Mpp*)data;
+    MppThread *hal      = mpp->mThreadHal;
+    mpp_list *frames    = mpp->mFrames;
+    mpp_list *tasks     = mpp->mTasks;
+
+    while (MPP_THREAD_RUNNING == hal->get_status()) {
+        /*
+         * hal thread wait for dxva interface intput firt
+         */
+        hal->lock();
+        if (0 == tasks->list_size())
+            hal->wait();
+        hal->unlock();
+
+        // get_config
+        // register genertation
+        if (tasks->list_size()) {
+            MppHalDecTask *task;
+            mpp->mTasks->del_at_head(&task, sizeof(task));
+            mpp->mTaskGetCount++;
+
+            // hal->mpp_hal_reg_gen(current);
 
             /*
-             * 2. do buffer operation according to usage information
-             *
-             *    possible case:
-             *    a. normal case
-             *       - wait and alloc a normal frame buffer
-             *    b. field mode case
-             *       - two field may reuse a same buffer, no need to alloc
-             *    c. info change case
-             *       - need buffer in different side, need to send a info change
-             *         frame to hal loop.
+             * wait previous register set done
              */
-
-            //MppBuffer buffer;
-            //mpp_buffer_get(mpp->mFrameGroup, &buffer, MPP_TEST_FRAME_SIZE);
-
+            // hal->mpp_hal_hw_wait(previous);
 
             /*
-             * 3. send dxva output information and buffer information to hal thread
-             *    combinate video codec dxva output and buffer information
+             * send current register set to hardware
              */
+            // hal->mpp_hal_hw_start(current);
 
-            // hal->wait_prev_done;
-            // hal->send_config;
-            mpp->mTasks->add_at_tail(&mpp->mTask[0], sizeof(mpp->mTask[0]));
-            mpp->mTaskPutCount++;
-            hal->signal();
+            /*
+             * mark previous buffer is complete
+             */
+            // change dpb slot status
+            // signal()
+            // mark frame in output queue
+            // wait up output thread to get a output frame
+
+            // for test
+            MppBuffer buffer;
+            mpp_buffer_get(mpp->mFrameGroup, &buffer, MPP_TEST_FRAME_SIZE);
+
+            MppFrame frame;
+            mpp_frame_init(&frame);
+            mpp_frame_set_buffer(frame, buffer);
+            frames->add_at_tail(&frame, sizeof(frame));
+            mpp->mFramePutCount++;
         }
     }
 
     return NULL;
 }
 
-MPP_RET mpp_dec_init(MppDecCtx **ctx, MppCodingType coding)
+MPP_RET mpp_dec_init(MppDec **dec, MppCodingType coding)
 {
-    MppDecCtx *p = mpp_malloc(MppDecCtx, 1);
+    MppDec *p = mpp_malloc(MppDec, 1);
     if (NULL == p) {
         mpp_err_f("failed to malloc context\n");
         return MPP_ERR_NULL_PTR;
     }
+
+    mpp_buf_slot_init(&p->slots);
+    if (NULL == p->slots) {
+        mpp_err_f("could not init buffer slot\n");
+        *dec = NULL;
+        mpp_free(p);
+        return MPP_ERR_UNKNOW;
+    }
+
     RK_U32 i;
     for (i = 0; i < MPP_ARRAY_ELEMS(parsers); i++) {
         if (coding == parsers[i]->coding) {
-            p->coding   = coding;
-            p->parser   = parsers[i];
-            *ctx = p;
+            p->coding       = coding;
+            p->parser_api   = parsers[i];
+            p->parser_ctx   = mpp_malloc_size(void, parsers[i]->ctx_size);
+            if (NULL == p->parser_ctx) {
+                mpp_err_f("failed to alloc decoder context\n");
+                break;
+            }
+            *dec = p;
             return MPP_OK;
         }
     }
     mpp_err_f("could not found coding type %d\n", coding);
-    *ctx = NULL;
+    *dec = NULL;
     mpp_free(p);
     return MPP_NOK;
 }
 
-MPP_RET mpp_dec_deinit(MppDecCtx *ctx)
+MPP_RET mpp_dec_deinit(MppDec *dec)
 {
-    if (NULL == ctx) {
+    if (NULL == dec) {
         mpp_err_f("found NULL input\n");
         return MPP_ERR_NULL_PTR;
     }
-    mpp_free(ctx);
+
+    if (dec->parser_ctx)
+        mpp_free(dec->parser_ctx);
+
+    mpp_buf_slot_deinit(dec->slots);
+
+    mpp_free(dec);
     return MPP_OK;
 }
 
-MPP_RET mpp_dec_parse(MppDecCtx *ctx, MppPacket pkt, MppSyntax **syn)
+MPP_RET mpp_dec_parse(MppDec *dec, MppPacket pkt, MppSyntax *syn)
 {
-    if (NULL == ctx || NULL == pkt || NULL == syn) {
-        mpp_err_f("found NULL input ctx %p pkt %p syn %p\n", ctx, pkt, syn);
+    if (NULL == dec || NULL == pkt || NULL == syn) {
+        mpp_err_f("found NULL input dec %p pkt %p syn %p\n", dec, pkt, syn);
         return MPP_ERR_NULL_PTR;
     }
 
-    return ctx->parser->parse(ctx, pkt, &ctx->syntax[0]);
+    return dec->parser_api->parse(dec->parser_ctx, pkt, syn);
 }
 
-MPP_RET mpp_dec_reset(MppDecCtx *ctx)
+MPP_RET mpp_dec_reset(MppDec *dec)
 {
-    if (NULL == ctx) {
-        mpp_err_f("found NULL input ctx %p\n", ctx);
+    if (NULL == dec) {
+        mpp_err_f("found NULL input dec %p\n", dec);
         return MPP_ERR_NULL_PTR;
     }
 
-    return ctx->parser->reset(ctx);
+    return dec->parser_api->reset(dec->parser_ctx);
 }
 
-MPP_RET mpp_dec_flush(MppDecCtx *ctx)
+MPP_RET mpp_dec_flush(MppDec *dec)
 {
-    if (NULL == ctx) {
-        mpp_err_f("found NULL input ctx %p\n", ctx);
+    if (NULL == dec) {
+        mpp_err_f("found NULL input dec %p\n", dec);
         return MPP_ERR_NULL_PTR;
     }
 
-    return ctx->parser->flush(ctx);
+    return dec->parser_api->flush(dec->parser_ctx);
 }
 
-MPP_RET mpp_dec_control(MppDecCtx *ctx, RK_S32 cmd, void *param)
+MPP_RET mpp_dec_control(MppDec *dec, RK_S32 cmd, void *param)
 {
-    if (NULL == ctx) {
-        mpp_err_f("found NULL input ctx %p\n", ctx);
+    if (NULL == dec) {
+        mpp_err_f("found NULL input dec %p\n", dec);
         return MPP_ERR_NULL_PTR;
     }
 
-    return ctx->parser->control(ctx, cmd, param);
+    return dec->parser_api->control(dec->parser_ctx, cmd, param);
 }
 
diff --git a/mpp/codec/mpp_enc.cpp b/mpp/codec/mpp_enc.cpp
index 688d35c6..2db2d070 100644
--- a/mpp/codec/mpp_enc.cpp
+++ b/mpp/codec/mpp_enc.cpp
@@ -25,7 +25,9 @@
 #include "mpp_packet.h"
 #include "mpp_packet_impl.h"
 
-void *mpp_enc_thread(void *data)
+#define MPP_TEST_FRAME_SIZE     SZ_1M
+
+void *mpp_enc_control_thread(void *data)
 {
     Mpp *mpp = (Mpp*)data;
     MppThread *thd_enc  = mpp->mTheadCodec;
@@ -48,3 +50,61 @@ void *mpp_enc_thread(void *data)
     return NULL;
 }
 
+void *mpp_enc_hal_thread(void *data)
+{
+    Mpp *mpp = (Mpp*)data;
+    MppThread *hal      = mpp->mThreadHal;
+    mpp_list *frames    = mpp->mFrames;
+    mpp_list *tasks     = mpp->mTasks;
+
+    while (MPP_THREAD_RUNNING == hal->get_status()) {
+        /*
+         * hal thread wait for dxva interface intput firt
+         */
+        hal->lock();
+        if (0 == tasks->list_size())
+            hal->wait();
+        hal->unlock();
+
+        // get_config
+        // register genertation
+        if (tasks->list_size()) {
+            MppHalDecTask *task;
+            mpp->mTasks->del_at_head(&task, sizeof(task));
+            mpp->mTaskGetCount++;
+
+            // hal->mpp_hal_reg_gen(current);
+
+            /*
+             * wait previous register set done
+             */
+            // hal->mpp_hal_hw_wait(previous);
+
+            /*
+             * send current register set to hardware
+             */
+            // hal->mpp_hal_hw_start(current);
+
+            /*
+             * mark previous buffer is complete
+             */
+            // change dpb slot status
+            // signal()
+            // mark frame in output queue
+            // wait up output thread to get a output frame
+
+            // for test
+            MppBuffer buffer;
+            mpp_buffer_get(mpp->mFrameGroup, &buffer, MPP_TEST_FRAME_SIZE);
+
+            MppFrame frame;
+            mpp_frame_init(&frame);
+            mpp_frame_set_buffer(frame, buffer);
+            frames->add_at_tail(&frame, sizeof(frame));
+            mpp->mFramePutCount++;
+        }
+    }
+
+    return NULL;
+}
+
diff --git a/mpp/hal/CMakeLists.txt b/mpp/hal/CMakeLists.txt
index ed3daac2..51435bd5 100644
--- a/mpp/hal/CMakeLists.txt
+++ b/mpp/hal/CMakeLists.txt
@@ -3,11 +3,15 @@
 # add mpp_hal implement
 # ----------------------------------------------------------------------------
 add_library(mpp_hal STATIC
+    mpp_syntax.cpp
     mpp_hal.cpp
     )
 set_target_properties(mpp_hal PROPERTIES FOLDER "mpp/hal")
+
 add_subdirectory(rkdec/h264d)
 
 add_subdirectory(rkdec/h265d)
 
 add_subdirectory(rkdec/vp9d)
+
+target_link_libraries(mpp_hal hal_h264d)
\ No newline at end of file
diff --git a/mpp/hal/inc/hal_h264d_api.h b/mpp/hal/inc/hal_h264d_api.h
index 3c0fac7f..eaa6aaa6 100644
--- a/mpp/hal/inc/hal_h264d_api.h
+++ b/mpp/hal/inc/hal_h264d_api.h
@@ -16,8 +16,8 @@
 */
 
 
-#ifndef _HAL_H264D_API_H_
-#define _HAL_H264D_API_H_
+#ifndef __HAL_H264D_API_H__
+#define __HAL_H264D_API_H__
 
 #include "mpp_hal.h"
 
@@ -326,12 +326,12 @@ typedef struct h264_regs_t {
 //
 //}HAL_H264dOutCtx_t;
 
-extern const MppHalApi api_h264d_hal;
-
 #ifdef __cplusplus
 extern "C" {
 #endif
 
+extern const MppHalApi api_h264d_hal;
+
 MPP_RET hal_h264d_init    (void **hal, MppHalCfg *cfg);
 MPP_RET hal_h264d_deinit  (void *hal);
 MPP_RET hal_h264d_gen_regs(void *hal, MppSyntax *syn);
@@ -341,14 +341,8 @@ MPP_RET hal_h264d_reset   (void *hal);
 MPP_RET hal_h264d_flush   (void *hal);
 MPP_RET hal_h264d_control (void *hal, RK_S32 cmd_type, void *param);
 
-
-
 #ifdef __cplusplus
 }
 #endif
 
-
-
-
-
-#endif /* _HAL_H264D_API_H_ */
\ No newline at end of file
+#endif /*__HAL_H264D_API_H__*/
diff --git a/mpp/hal/inc/mpp_hal.h b/mpp/hal/inc/mpp_hal.h
index 2792bec7..e7a5afb8 100644
--- a/mpp/hal/inc/mpp_hal.h
+++ b/mpp/hal/inc/mpp_hal.h
@@ -14,12 +14,11 @@
  * limitations under the License.
  */
 
-#ifndef __HAL_TASK__
-#define __HAL_TASK__
+#ifndef __MPP_HAL__
+#define __MPP_HAL__
 
-#include "rk_type.h"
-#include "h264d_syntax.h"
-#include "mpp_dec.h"
+#include "rk_mpi.h"
+#include "mpp_syntax.h"
 
 #define MAX_REF_SIZE    17
 
@@ -64,9 +63,6 @@ typedef struct {
     RK_S32          index_dst;
     // current task reference buffers
     MppBuffer       refer[MAX_REF_SIZE];
-
-    MppBufSlots     slots;
-    H264D_Syntax_t  mSyn;
 } MppHalDecTask;
 
 typedef void*   MppHalCtx;
@@ -83,10 +79,10 @@ typedef struct {
     MPP_RET (*init)(void **ctx, MppHalCfg *cfg);
     MPP_RET (*deinit)(void *ctx);
 
-    // to parser / mpp
+    // parser syntax process function
     MPP_RET (*reg_gen)(void *ctx, MppSyntax *syn);
 
-    // hw
+    // hw operation function
     MPP_RET (*start)(void *ctx, MppHalDecTask task);
     MPP_RET (*wait)(void *ctx, MppHalDecTask task);
 
@@ -100,7 +96,7 @@ typedef struct {
 
     void            *mHalCtx;
 
-    MppSyntax       *mSyn[2];
+    MppSyntax       mSyn[2];
     MppHalApi       *api;
 } MppHal;
 
@@ -108,8 +104,6 @@ typedef struct {
 extern "C" {
 #endif
 
-void *mpp_hal_thread(void *data);
-
 MPP_RET mpp_hal_init(MppHal **ctx, MppHalCfg *cfg);
 MPP_RET mpp_hal_deinit(MppHal *ctx);
 
@@ -121,5 +115,5 @@ MPP_RET mpp_hal_hw_wait(MppHal *ctx, MppHalDecTask *task);
 }
 #endif
 
-#endif /*__HAL_TASK__*/
+#endif /*__MPP_HAL__*/
 
diff --git a/mpp/hal/inc/mpp_syntax.h b/mpp/hal/inc/mpp_syntax.h
new file mode 100644
index 00000000..b69fef53
--- /dev/null
+++ b/mpp/hal/inc/mpp_syntax.h
@@ -0,0 +1,59 @@
+/*
+*
+* Copyright 2015 Rockchip Electronics 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 __MPP_SYNTAX_H__
+#define __MPP_SYNTAX_H__
+
+#include "mpp_err.h"
+#include "mpp_list.h"
+
+#define MPP_SYNTAX_MAX_NUMBER       8
+
+/*
+ * modified by parser
+ *
+ * number   : the number of the data pointer array element
+ * data     : the address of the pointer array, parser will add its data here
+ */
+typedef struct {
+    RK_U32              number;
+    void                *data;
+} MppSyntax;
+
+typedef struct {
+    struct list_head    list;
+    MppSyntax           syntax;
+} MppSyntaxNode;
+
+typedef void* MppSyntaxGroup;
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+MPP_RET mpp_syntax_group_init(MppSyntaxGroup *group, RK_U32 count);
+MPP_RET mpp_syntax_group_deinit(MppSyntaxGroup group);
+
+MPP_RET mpp_syntax_get_node(MppSyntaxGroup group, MppSyntaxNode **node);
+MPP_RET mpp_syntax_put_node(MppSyntaxGroup group, MppSyntaxNode *node);
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /*__MPP_SYNTAX_H__*/
+
diff --git a/mpp/hal/mpp_hal.cpp b/mpp/hal/mpp_hal.cpp
index 9bd06fc1..2d72efa0 100644
--- a/mpp/hal/mpp_hal.cpp
+++ b/mpp/hal/mpp_hal.cpp
@@ -23,65 +23,6 @@
 #include "mpp_hal.h"
 #include "mpp_frame_impl.h"
 
-#define MPP_TEST_FRAME_SIZE     SZ_1M
-
-void *mpp_hal_thread(void *data)
-{
-    Mpp *mpp = (Mpp*)data;
-    MppThread *hal      = mpp->mThreadHal;
-    mpp_list *frames    = mpp->mFrames;
-    mpp_list *tasks     = mpp->mTasks;
-
-    while (MPP_THREAD_RUNNING == hal->get_status()) {
-        /*
-         * hal thread wait for dxva interface intput firt
-         */
-        hal->lock();
-        if (0 == tasks->list_size())
-            hal->wait();
-        hal->unlock();
-
-        // get_config
-        // register genertation
-        if (tasks->list_size()) {
-            MppHalDecTask *task;
-            mpp->mTasks->del_at_head(&task, sizeof(task));
-            mpp->mTaskGetCount++;
-
-            // hal->mpp_hal_reg_gen(current);
-
-            /*
-             * wait previous register set done
-             */
-            // hal->mpp_hal_hw_wait(previous);
-
-            /*
-             * send current register set to hardware
-             */
-            // hal->mpp_hal_hw_start(current);
-
-            /*
-             * mark previous buffer is complete
-             */
-            // change dpb slot status
-            // signal()
-            // mark frame in output queue
-            // wait up output thread to get a output frame
-
-            // for test
-            MppBuffer buffer;
-            mpp_buffer_get(mpp->mFrameGroup, &buffer, MPP_TEST_FRAME_SIZE);
-
-            MppFrame frame;
-            mpp_frame_init(&frame);
-            mpp_frame_set_buffer(frame, buffer);
-            frames->add_at_tail(&frame, sizeof(frame));
-            mpp->mFramePutCount++;
-        }
-    }
-
-    return NULL;
-}
 
 MPP_RET mpp_hal_init(MppHal **ctx, MppHalCfg *cfg)
 {
diff --git a/mpp/hal/mpp_syntax.cpp b/mpp/hal/mpp_syntax.cpp
new file mode 100644
index 00000000..4e5e7dde
--- /dev/null
+++ b/mpp/hal/mpp_syntax.cpp
@@ -0,0 +1,86 @@
+/*
+ * Copyright 2010 Rockchip Electronics S.LSI 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.
+ */
+#define MODULE_TAG "mpp_syntax"
+
+#include <string.h>
+
+#include "mpp_mem.h"
+#include "mpp_log.h"
+#include "mpp_thread.h"
+
+#include "mpp_syntax.h"
+
+typedef struct {
+    struct list_head    list;
+    Mutex               *lock;
+    MppSyntaxNode       *node;
+} MppSyntaxGroupImpl;
+
+MPP_RET mpp_syntax_group_init(MppSyntaxGroup *group, RK_U32 count)
+{
+    MppSyntaxGroupImpl *p = mpp_malloc_size(MppSyntaxGroupImpl,
+                            sizeof(MppSyntaxGroupImpl) + count * sizeof(MppSyntaxNode));
+    if (NULL == p) {
+        *group = NULL;
+        mpp_err_f("malloc group failed\n");
+        return MPP_NOK;
+    }
+    memset(p, 0, sizeof(*p));
+    INIT_LIST_HEAD(&p->list);
+    p->lock = new Mutex();
+    p->node = (MppSyntaxNode*)(p+1);
+    Mutex::Autolock auto_lock(p->lock);
+    RK_U32 i;
+    for (i = 0; i < count; i++) {
+        list_add_tail(&p->node[i].list, &p->list);
+    }
+    return MPP_OK;
+}
+
+MPP_RET mpp_syntax_group_deinit(MppSyntaxGroup group)
+{
+    MppSyntaxGroupImpl *p = (MppSyntaxGroupImpl *)group;
+    if (p->lock) {
+        delete p->lock;
+        p->lock = NULL;
+    }
+    mpp_free(p);
+    return MPP_OK;
+}
+
+MPP_RET mpp_syntax_get_node(MppSyntaxGroup group, MppSyntaxNode **node)
+{
+    MppSyntaxGroupImpl *p = (MppSyntaxGroupImpl *)group;
+    Mutex::Autolock auto_lock(p->lock);
+    if (list_empty(&p->list)) {
+        *node = NULL;
+        return MPP_NOK;
+    }
+
+    struct list_head *list = p->list.next;
+    list_del_init(list);
+    *node = list_entry(list, MppSyntaxNode, list);
+    return MPP_OK;
+}
+
+MPP_RET mpp_syntax_put_node(MppSyntaxGroup group, MppSyntaxNode *node)
+{
+    MppSyntaxGroupImpl *p = (MppSyntaxGroupImpl *)group;
+    Mutex::Autolock auto_lock(p->lock);
+    list_add_tail(&node->list, &p->list);
+    return MPP_OK;
+}
+
diff --git a/mpp/hal/rkdec/h264d/hal_h264d_api.c b/mpp/hal/rkdec/h264d/hal_h264d_api.c
index 1a74f6c2..f1cfa7bf 100644
--- a/mpp/hal/rkdec/h264d/hal_h264d_api.c
+++ b/mpp/hal/rkdec/h264d/hal_h264d_api.c
@@ -14,17 +14,17 @@
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
-
+#define MODULE_TAG "hal_h264d"
 
 #include "hal_h264d_api.h"
 
 
-MPP_RET hal_h264d_init    (void **hal, MppHalCfg *cfg)
+MPP_RET hal_h264d_init(void **hal, MppHalCfg *cfg)
 {
     return MPP_OK;
 }
 
-MPP_RET hal_h264d_deinit  (void *hal)
+MPP_RET hal_h264d_deinit(void *hal)
 {
     return MPP_OK;
 }
@@ -33,27 +33,27 @@ MPP_RET hal_h264d_gen_regs(void *hal, MppSyntax *syn)
 {
     return MPP_OK;
 }
-MPP_RET hal_h264d_start   (void *hal, MppHalDecTask task)
+MPP_RET hal_h264d_start(void *hal, MppHalDecTask task)
 {
     return MPP_OK;
 }
 
-MPP_RET hal_h264d_wait    (void *hal, MppHalDecTask task)
+MPP_RET hal_h264d_wait(void *hal, MppHalDecTask task)
 {
     return MPP_OK;
 }
 
-MPP_RET hal_h264d_reset   (void *hal)
+MPP_RET hal_h264d_reset(void *hal)
 {
     return MPP_OK;
 }
 
-MPP_RET hal_h264d_flush   (void *hal)
+MPP_RET hal_h264d_flush(void *hal)
 {
     return MPP_OK;
 }
 
-MPP_RET hal_h264d_control (void *hal, RK_S32 cmd_type, void *param)
+MPP_RET hal_h264d_control(void *hal, RK_S32 cmd_type, void *param)
 {
     return MPP_OK;
 }
@@ -61,7 +61,6 @@ MPP_RET hal_h264d_control (void *hal, RK_S32 cmd_type, void *param)
 
 
 const MppHalApi api_h264d_hal = {
-
     0,
     hal_h264d_init,
     hal_h264d_deinit,
diff --git a/mpp/mpp.cpp b/mpp/mpp.cpp
index 20160bcb..6bd1312d 100644
--- a/mpp/mpp.cpp
+++ b/mpp/mpp.cpp
@@ -47,13 +47,11 @@ Mpp::Mpp(MppCtxType type, MppCodingType coding)
       mPacketGroup(NULL),
       mFrameGroup(NULL),
       mDec(NULL),
-      mHal(NULL),
       mTheadCodec(NULL),
       mThreadHal(NULL),
       mType(type),
       mCoding(coding),
       mStatus(0),
-      mBufSlots(NULL),
       mTask(NULL),
       mTaskNum(2)
 {
@@ -64,13 +62,8 @@ Mpp::Mpp(MppCtxType type, MppCodingType coding)
         mTasks      = new mpp_list((node_destructor)NULL);
 
         mpp_dec_init(&mDec, coding);
-        MppHalCfg cfg = {
-            type,
-            coding,
-        };
-        mpp_hal_init(&mHal, &cfg);
-        mTheadCodec = new MppThread(mpp_dec_thread, this);
-        mThreadHal  = new MppThread(mpp_hal_thread, this);
+        mTheadCodec = new MppThread(mpp_dec_parser_thread, this);
+        mThreadHal  = new MppThread(mpp_dec_hal_thread, this);
 
         mTask       = mpp_malloc(MppHalDecTask*, mTaskNum);
         mpp_buffer_group_normal_get(&mInternalGroup, MPP_BUFFER_TYPE_ION);
@@ -84,13 +77,8 @@ Mpp::Mpp(MppCtxType type, MppCodingType coding)
         mTasks      = new mpp_list((node_destructor)NULL);
 
         mpp_dec_init(&mDec, coding);
-        MppHalCfg cfg = {
-            type,
-            coding,
-        };
-        mpp_hal_init(&mHal, &cfg);
-        mTheadCodec = new MppThread(mpp_enc_thread, this);
-        mThreadHal  = new MppThread(mpp_hal_thread, this);
+        mTheadCodec = new MppThread(mpp_enc_control_thread, this);
+        mThreadHal  = new MppThread(mpp_dec_hal_thread, this);
 
         mTask       = mpp_malloc(MppHalDecTask*, mTaskNum);
         mpp_buffer_group_normal_get(&mInternalGroup, MPP_BUFFER_TYPE_ION);
@@ -103,7 +91,7 @@ Mpp::Mpp(MppCtxType type, MppCodingType coding)
     }
 
     if (mFrames && mPackets && mTask &&
-        mDec && mHal &&
+        (mDec || mEnc) &&
         mTheadCodec && mThreadHal &&
         mPacketGroup && mFrameGroup) {
         mTheadCodec->start();
@@ -141,10 +129,6 @@ void Mpp::clear()
             mpp_dec_deinit(mDec);
         mDec = NULL;
     }
-    if (mHal) {
-        mpp_hal_deinit(mHal);
-        mHal = NULL;
-    }
     if (mPackets) {
         delete mPackets;
         mPackets = NULL;
diff --git a/mpp/mpp.h b/mpp/mpp.h
index 3cd0e4fa..ba0d05d0 100644
--- a/mpp/mpp.h
+++ b/mpp/mpp.h
@@ -18,10 +18,7 @@
 #define __MPP_H__
 
 #include "rk_mpi.h"
-#include "mpp_list.h"
-#include "mpp_thread.h"
-#include "mpp_hal.h"
-#include "mpp_buf_slot.h"
+#include "mpp_dec.h"
 
 #define MPP_DBG_FUNCTION                (0x00000001)
 #define MPP_DBG_PACKET                  (0x00000002)
@@ -77,13 +74,8 @@ public:
 
     RK_U32          mStatus;
 
-    union {
-        MppDecCtx   *mDec;
-    };
-    MppHal          *mHal;
-
-    // decoder context
-    MppBufSlots     mBufSlots;
+    MppDec       *mDec;
+    MppDec       *mEnc;
 
     MppHalDecTask   **mTask;
     RK_U32          mTaskNum;