global.h

//
//  global.h
//  Red5Pro
//
//  Created by Andy Zupko on 9/15/14.
//  Copyright (c) 2014 Infrared5. All rights reserved.
//
 
#ifndef Red5Pro_global_h
#define Red5Pro_global_h
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include <stdlib.h>
#ifdef IS_IOS
#include <pthread.h>
#endif
 
#define STRINGIFY_(s) #s
#define STRINGIFY(s) STRINGIFY_(s)
 
#define R5PRO_MAJOR_VERSION         10
#define R5PRO_MINOR_VERSION         0
#define R5PRO_REVISION              0
#define R5PRO_BUILD                 b826
 
 
#define R5PRO_VERSION               STRINGIFY(R5PRO_MAJOR_VERSION.R5PRO_MINOR_VERSION.R5PRO_REVISION.R5PRO_BUILD)
#define R5PRO_VERSION_ISRELEASE     0
#define R5PRO_VERSION_CHECK(maj, min) ((maj==MYLIB_MAJOR_VERSION) && (min<=MYLIB_MINOR_VERSION))
 
#define SEC_TO_NANO 1e9
#define SEC_TO_MS 1e3
 
#define SW_DECODE_YUV               1
 
#if defined(__APPLE__) && defined(__MACH__)
/* Apple OSX and iOS (Darwin). ------------------------------ */
#include <TargetConditionals.h>
#if TARGET_IPHONE_SIMULATOR == 1
/* iOS in Xcode simulator */
 
#elif TARGET_OS_IPHONE == 1
/* iOS on iPhone, iPad, etc. */
 
#elif TARGET_OS_MAC == 1
/* OSX */
 
#endif
#endif
 
#if TARGET_OS_IPHONE == 1
#define LOG(...) fprintf(stdout, __VA_ARGS__);
#define LOGD(M, ...) if(r5_get_log_level() <= (int)r5_log_level_debug) fprintf(stderr, "[R5 DEBUG]" M "\n", ##__VA_ARGS__)
#define LOGI(M, ...) if(r5_get_log_level() <= (int)r5_log_level_info) fprintf(stderr,  "[R5 INFO] " M "\n", ##__VA_ARGS__)
#define LOGW(M, ...) if(r5_get_log_level() <= (int)r5_log_level_warn) fprintf(stderr,  "[R5 WARNING] " M "\n", ##__VA_ARGS__);
#define LOGE(M, ...) if(r5_get_log_level() <= (int)r5_log_level_error) fprintf(stderr, "[R5 ERROR] " M "\n", ##__VA_ARGS__);
 
#else
#include <android/log.h>
#define LOG(...) __android_log_print(ANDROID_LOG_INFO, "r5pro", __VA_ARGS__);
#define LOGD(M, ...) if(r5_get_log_level() <= (int)r5_log_level_debug) LOG(M, ##__VA_ARGS__)
#define LOGI(M, ...) if(r5_get_log_level() <= (int)r5_log_level_info) LOG( M, ##__VA_ARGS__)
#define LOGW(M, ...) if(r5_get_log_level() <= (int)r5_log_level_warn) LOG( M, ##__VA_ARGS__);
#define LOGE(M, ...) if(r5_get_log_level() <= (int)r5_log_level_error) LOG(M, ##__VA_ARGS__);
#endif
 
#define check_mem(A) check((A), "Out of memory.")
 
    enum r5_log_level{
        r5_log_level_debug,
        r5_log_level_info,
        r5_log_level_warn,
        r5_log_level_error
    };
 
    enum r5_status {
        r5_status_connected,            
        r5_status_disconnected,         
        r5_status_connection_error,     
        r5_status_connection_timeout,   
        r5_status_connection_close,     
        r5_status_start_streaming,      
        r5_status_stop_streaming,       
        r5_status_netstatus,            
        r5_status_audio_mute,           
        r5_status_audio_unmute,         
        r5_status_video_mute,           
        r5_status_video_unmute,         
        r5_status_license_error,        
        r5_status_license_valid,        
        r5_status_buffer_flush_start,   
        r5_status_buffer_flush_empty,   
        r5_status_video_render_start,   
        r5_status_abr_level_change,     
        r5_status_srtp_key_gen_error,   
        r5_status_srtp_key_handle_error, 
        r5_status_hardware_decode_error 
    };
 
    typedef enum r5_stream_mode{
        r5_stream_mode_stop,
        r5_stream_mode_subscribe,
        r5_stream_mode_publish
    }r5_stream_mode_t;
 
    enum r5_buffer_state{
        r5_buffer_state_buffered,
        r5_buffer_state_needs_rebuffer,
        r5_buffer_state_flush_buffer,
        r5_buffer_state_rebuffering
    };
 
    typedef enum r5_scale_mode{
        r5_scale_to_fill,   //scale to fill and maintain aspect ratio (cropping will occur)
        r5_scale_to_fit,    //scale to fit inside view (letterboxing will occur)
        r5_scale_fill       //scale to fill view (will not respect aspect ratio of video)
    }r5_scale_mode;
 
    typedef enum r5_media_type{
        r5_media_type_video,            
        r5_media_type_audio,            
        r5_media_type_video_custom,     
        r5_media_type_audio_custom      
    } r5_media_type;
 
    typedef enum r5_stream_format {
        r5_stream_format_unknown,
        r5_stream_format_rgb,           
        r5_stream_format_yuv_planar,    
        r5_stream_format_yuv_biplanar,  
    } r5_stream_format;
 
    enum r5_protocol {
        r5_rtsp = 1,        //Basic flow
        r5_srtp = 2,        //rtsp with encrypted payloads and hash authentication
        r5_null_srtp = 3    //srtp without encryption
    };
 
 
    typedef struct client_ctx client_ctx;
 
 
    const char * r5_string_for_status(int status);
 
 
    void r5_set_log_level(int level);
 
    int requires_sdk_license(void);
 
    int r5_get_log_level(void);
 
    double now_ms(void);
 
 
    typedef struct r5_stats{
 
        float                   buffered_time;              
        int                     subscribe_queue_size;       
        int                     nb_audio_frames;            
        int                     nb_video_frames;            
        long                    pkts_received;              
        long                    pkts_sent;                  
        long                    pkts_video_dropped;         
        long                    pkts_audio_dropped;         
        long                    publish_pkts_dropped;       
 
        long                    total_bytes_received;       
        long                    total_bytes_sent;           
        float                   subscribe_bitrate;          
        float                   publish_bitrate;            
        long                    socket_queue_size;          
        float                   bitrate_sent_smoothed;      
        float                   bitrate_received_smoothed;  
        float                   subscribe_latency;          
        float                   video_decode_smoothed;      
 
    }r5_stats;
 
    r5_stats *r5_client_stats(client_ctx* client);
 
void freeEndPause(void);
 
 
#ifdef __cplusplus
}
#endif
 
#endif