resource/csdk/connectivity/inc/caqueueingthread.h

   1 /******************************************************************
   2  *
   3  * Copyright 2014 Samsung Electronics All Rights Reserved.
   4  *
   5  *
   6  *
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  *
  19  ******************************************************************/
  20
  21 /**
  22  * @file caqueueingthread.h
  23  */
  24 #ifndef __CA_THREAD_H_
  25 #define __CA_THREAD_H_
  26
  27 #include <stdint.h>
  28
  29 #include "uthreadpool.h"
  30 #include "umutex.h"
  31 #include "uqueue.h"
  32 #include "cacommon.h"
  33 #ifdef __cplusplus
  34 extern "C"
  35 {
  36 #endif
  37
  38 typedef void (*CAThreadTask)(void* threadData);
  39
  40 typedef struct
  41 {
  42     u_thread_pool_t threadPool;
  43     u_mutex threadMutex;
  44     u_cond threadCond;
  45     CAThreadTask threadTask;
  46     CABool_t isStop;
  47     u_queue_t* dataQueue;
  48 } CAQueueingThread_t;
  49
  50 CAResult_t CAQueueingThreadInitialize(CAQueueingThread_t* thread, u_thread_pool_t handle,
  51         CAThreadTask task);
  52
  53 CAResult_t CAQueueingThreadStart(CAQueueingThread_t* thread);
  54
  55 // shallow copy
  56 CAResult_t CAQueueingThreadAddData(CAQueueingThread_t* thread, void* data, uint32_t size);
  57
  58 CAResult_t CAQueueingThreadStop(CAQueueingThread_t* thread);
  59
  60 CAResult_t CAQueueingThreadDestroy(CAQueueingThread_t* thread);
  61
  62 #ifdef __cplusplus
  63 } /* extern "C" */
  64 #endif
  65
  66 #endif  // __CA_THREAD_H_