glib_tools.h

/*
 * If not stated otherwise in this file or this component's Licenses.txt file the
 * following copyright and licenses apply:
 *
 * Copyright 2017 RDK Management
 *
 * 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 GLIB_TOOLS_H
#define GLIB_TOOLS_H
 
#include <glib.h>
 
/**
 * @addtogroup MSE Player
 * @{
 */
 
constexpr int eintr_maximum_attempts =100;
#define HANDLE_EINTR_EAGAIN(x) ({            \
  unsigned char _attempts = 0;               \
                                             \
  decltype(x) _result;                       \
                                             \
  do                                         \
  {                                          \
    _result = (x);                           \
  }                                          \
  while (_result == -1                       \
         && (errno == EINTR ||               \
             errno == EAGAIN ||              \
             errno == EWOULDBLOCK)           \
         && _attempts++ < eintr_maximum_attempts); \
                                             \
  _result;                                   \
})
 
constexpr int PIPE_LISTEN = 0, PIPE_WRITE = 1;
typedef void (*PipeSourceCallback)(void* ctx);
 
/**
 *  @brief This API creates a new event source "rtRemoteSource".
 *
 *  This API also adds a file descriptor polled for this source,  sets whether a source can be called recursively.
 *
 *  @param[in] pipefd   Pipe File descriptor
 *  @param[in] cb       Callback Function
 *  @param[in] ctx      Context
 *
 *  @return Returns RT_OK on success, appropriate error code otherwise.
*/
GSource* pipe_source_new(int pipefd[2], PipeSourceCallback cb, void* ctx);
 
#endif // GLIB_TOOLS_H