src/mm_player_utils.c

   1 /*
   2  * libmm-player
   3  *
   4  * Copyright (c) 2000 - 2011 Samsung Electronics Co., Ltd. All rights reserved.
   5  *
   6  * Contact: JongHyuk Choi <jhchoi.choi@samsung.com>, YeJin Cho <cho.yejin@samsung.com>,
   7  * Seungbae Shin <seungbae.shin@samsung.com>, YoungHwan An <younghwan_.an@samsung.com>
   8  *
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  * http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  *
  21  */
  22
  23 #include <stdio.h>
  24 #include <string.h>
  25 #include <unistd.h>
  26 #include <sys/stat.h>
  27 #include <fcntl.h>
  28 #include <sys/time.h>
  29 #include <netinet/in.h>
  30 #include <arpa/inet.h>
  31 #include <unicode/ucsdet.h>
  32 #include <dlog.h>
  33 #include <storage.h>
  34 #include <tzplatform_config.h>
  35 #include "mm_player_utils.h"
  36 #include "media_format.h"
  37
  38 #define MEDIA_PATH_EXTERNAL tzplatform_getenv(TZ_SYS_STORAGE) /* external storage, sd card, usb */
  39
  40 const gchar *
  41 _mmplayer_get_stream_type_name(int type)
  42 {
  43         switch (type) {
  44         case MM_PLAYER_STREAM_TYPE_AUDIO:
  45                 return "AUDIO";
  46         case MM_PLAYER_STREAM_TYPE_VIDEO:
  47                 return "VIDEO";
  48         case MM_PLAYER_STREAM_TYPE_TEXT:
  49                 return "TEXT";
  50         case MM_PLAYER_STREAM_TYPE_DEFAULT: /* fall through */
  51         case MM_PLAYER_STREAM_TYPE_MAX:     /* fall through */
  52         default:
  53                 return "INVAID";
  54         }
  55 }
  56
  57 const gchar *
  58 _mmplayer_get_state_name(int state)
  59 {
  60         switch (state) {
  61         case MM_PLAYER_STATE_NULL:
  62                 return "NULL";
  63         case MM_PLAYER_STATE_READY:
  64                 return "READY";
  65         case MM_PLAYER_STATE_PAUSED:
  66                 return "PAUSED";
  67         case MM_PLAYER_STATE_PLAYING:
  68                 return "PLAYING";
  69         case MM_PLAYER_STATE_NONE:
  70                 return "NONE";
  71         default:
  72                 return "INVAID";
  73         }
  74 }
  75
  76 gboolean
  77 _mmplayer_is_rtsp_streaming(mmplayer_t *player)
  78 {
  79         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
  80
  81         return (player->profile.uri_type == MM_PLAYER_URI_TYPE_URL_RTSP) ? TRUE : FALSE;
  82 }
  83
  84 gboolean
  85 _mmplayer_is_http_streaming(mmplayer_t *player)
  86 {
  87         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
  88
  89         return (player->profile.uri_type == MM_PLAYER_URI_TYPE_URL_HTTP) ? TRUE : FALSE;
  90 }
  91
  92 gboolean
  93 _mmplayer_is_streaming(mmplayer_t *player)
  94 {
  95         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
  96
  97         return (_mmplayer_is_rtsp_streaming(player) || _mmplayer_is_http_streaming(player)
  98                 || _mmplayer_is_http_live_streaming(player) || _mmplayer_is_dash_streaming(player)
  99                 || _mmplayer_is_smooth_streaming(player)) ? TRUE : FALSE;
 100 }
 101
 102 gboolean
 103 _mmplayer_is_live_streaming(mmplayer_t *player)
 104 {
 105         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
 106
 107         return (_mmplayer_is_rtsp_streaming(player) && player->streaming_type == STREAMING_SERVICE_LIVE) ? TRUE : FALSE;
 108 }
 109
 110 gboolean
 111 _mmplayer_is_http_live_streaming(mmplayer_t *player)
 112 {
 113         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
 114
 115         return (player->profile.uri_type == MM_PLAYER_URI_TYPE_HLS) ? TRUE : FALSE;
 116 }
 117
 118 gboolean
 119 _mmplayer_is_dash_streaming(mmplayer_t *player)
 120 {
 121         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
 122
 123         return (player->profile.uri_type == MM_PLAYER_URI_TYPE_DASH) ? TRUE : FALSE;
 124 }
 125
 126 gboolean
 127 _mmplayer_is_smooth_streaming(mmplayer_t *player)
 128 {
 129         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
 130
 131         return (player->profile.uri_type == MM_PLAYER_URI_TYPE_SS) ? TRUE : FALSE;
 132 }
 133
 134 gboolean
 135 _mmplayer_is_ms_buff_src(mmplayer_t *player)
 136 {
 137         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
 138
 139         return (player->profile.uri_type == MM_PLAYER_URI_TYPE_MS_BUFF) ? TRUE : FALSE;
 140 }
 141
 142 gboolean
 143 _mmplayer_has_suffix(mmplayer_t *player, const gchar *suffix)
 144 {
 145         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
 146         MMPLAYER_RETURN_VAL_IF_FAIL(suffix, FALSE);
 147
 148         gboolean ret = FALSE;
 149         gchar *t_url = g_ascii_strdown(player->profile.uri, -1);
 150         gchar *t_suffix = g_ascii_strdown(suffix, -1);
 151         gchar *opt = strchr(t_url, '?');
 152
 153         if (opt)
 154                 *opt = '\0';
 155
 156         ret = g_str_has_suffix(t_url, t_suffix);
 157
 158         MMPLAYER_FREEIF(t_url);
 159         MMPLAYER_FREEIF(t_suffix);
 160
 161         return ret;
 162 }
 163
 164 gboolean
 165 _mmplayer_post_message(mmplayer_t *player, enum MMMessageType msgtype, MMMessageParamType *param)
 166 {
 167         MMPLAYER_RETURN_VAL_IF_FAIL(player, FALSE);
 168
 169         if (!player->msg_cb)
 170                 return FALSE;
 171
 172         //LOGD("Message (type : %d)  will be posted using msg-cb(%p).", msgtype, player->msg_cb);
 173
 174         player->msg_cb(msgtype, param, player->msg_cb_param);
 175
 176         return TRUE;
 177 }
 178
 179 gboolean
 180 _mmplayer_dump_pipeline_state(mmplayer_t *player)
 181 {
 182         GstIterator *iter = NULL;
 183         gboolean done = FALSE;
 184
 185         GValue item = {0, };
 186         GstElement *element = NULL;
 187         GstElementFactory *factory = NULL;
 188
 189         GstState state = GST_STATE_VOID_PENDING;
 190         GstState pending = GST_STATE_VOID_PENDING;
 191         GstClockTime time = 200 * GST_MSECOND;
 192
 193         MMPLAYER_FENTER();
 194
 195         MMPLAYER_RETURN_VAL_IF_FAIL(player &&
 196                 player->pipeline &&
 197                 player->pipeline->mainbin,
 198                 FALSE);
 199
 200         MMPLAYER_GENERATE_DOT_IF_ENABLED(player, "pipeline-status-error-dump");
 201
 202         iter = gst_bin_iterate_recurse(GST_BIN(player->pipeline->mainbin[MMPLAYER_M_PIPE].gst));
 203
 204         if (iter != NULL) {
 205                 while (!done) {
 206                         switch (gst_iterator_next(iter, &item)) {
 207                         case GST_ITERATOR_OK:
 208                                 element = g_value_get_object(&item);
 209                                 gst_element_get_state(element, &state, &pending, time);
 210
 211                                 factory = gst_element_get_factory(element) ;
 212                                 if (factory)
 213                                         LOGE("%s:%s : From:%s To:%s   refcount : %d", GST_OBJECT_NAME(factory) , GST_ELEMENT_NAME(element) ,
 214                                                 gst_element_state_get_name(state), gst_element_state_get_name(pending) , GST_OBJECT_REFCOUNT_VALUE(element));
 215                                 g_value_reset(&item);
 216                                 break;
 217                         case GST_ITERATOR_RESYNC:
 218                                 gst_iterator_resync(iter);
 219                                 break;
 220                         case GST_ITERATOR_ERROR:
 221                                 done = TRUE;
 222                                 break;
 223                         case GST_ITERATOR_DONE:
 224                                 done = TRUE;
 225                                 break;
 226                         }
 227                 }
 228         }
 229
 230         element = GST_ELEMENT(player->pipeline->mainbin[MMPLAYER_M_PIPE].gst);
 231
 232         gst_element_get_state(element, &state, &pending, time);
 233
 234         factory = gst_element_get_factory(element) ;
 235
 236         if (factory) {
 237                 LOGE("%s:%s : From:%s To:%s  refcount : %d",
 238                         GST_OBJECT_NAME(factory),
 239                         GST_ELEMENT_NAME(element),
 240                         gst_element_state_get_name(state),
 241                         gst_element_state_get_name(pending),
 242                         GST_OBJECT_REFCOUNT_VALUE(element));
 243         }
 244
 245         g_value_unset(&item);
 246
 247         if (iter)
 248                 gst_iterator_free(iter);
 249
 250         MMPLAYER_FLEAVE();
 251
 252         return FALSE;
 253 }
 254
 255 int
 256 _mmplayer_exist_file_path(const char *file_path)
 257 {
 258         int fd = 0;
 259         struct stat stat_results = {0, };
 260
 261         if (!file_path || !strlen(file_path))
 262                 return MM_ERROR_PLAYER_FILE_NOT_FOUND;
 263
 264         fd = open(file_path, O_RDONLY);
 265
 266         if (fd < 0) {
 267                 char str_error[256];
 268                 strerror_r(errno, str_error, sizeof(str_error));
 269                 LOGE("failed to open file by %s (%d)", str_error, errno);
 270
 271                 if (EACCES == errno)
 272                         return MM_ERROR_PLAYER_PERMISSION_DENIED;
 273
 274                 return MM_ERROR_PLAYER_FILE_NOT_FOUND;
 275         }
 276
 277         if (fstat(fd, &stat_results) < 0) {
 278                 LOGE("failed to get file status");
 279         } else if (stat_results.st_size == 0) {
 280                 LOGE("file size is zero");
 281                 close(fd);
 282                 return MM_ERROR_PLAYER_FILE_NOT_FOUND;
 283         } else
 284                 LOGW("file size : %lld bytes", (long long)stat_results.st_size);
 285
 286         close(fd);
 287
 288         return MM_ERROR_NONE;
 289 }
 290
 291 char **
 292 _mmplayer_get_cookie_list(const char *cookies)
 293 {
 294         char **cookie_list = NULL;
 295         char *temp = NULL;
 296         gint i = 0;
 297
 298         if (!cookies || !strlen(cookies))
 299                 return NULL;
 300
 301         SECURE_LOGD("cookies : %zu[bytes] - %s", strlen(cookies), cookies);
 302
 303         temp = g_strdup(cookies);
 304
 305         /* trimming. it works inplace */
 306         g_strstrip(temp);
 307
 308         /* split */
 309         cookie_list = g_strsplit(temp, ";", 100);
 310
 311         if (!cookie_list) {
 312                 LOGE("failed to get cookie list");
 313                 goto EXIT;
 314         }
 315
 316         for (i = 0; i < g_strv_length(cookie_list); i++) {
 317                 if (cookie_list[i]) {
 318                         if (strlen(cookie_list[i])) {
 319                                 g_strstrip(cookie_list[i]);
 320                                 SECURE_LOGD("cookie_list[%d] : %zu[bytes] - %s", i, strlen(cookie_list[i]), cookie_list[i]);
 321                         } else {
 322                                 cookie_list[i][0] = '\0';
 323                         }
 324                 }
 325         }
 326
 327 EXIT:
 328         MMPLAYER_FREEIF(temp);
 329
 330         return cookie_list;
 331 }
 332
 333 /* check the given path is indicating sdp file */
 334 bool
 335 _mmplayer_is_sdp_file(const char *path)
 336 {
 337         gboolean ret = FALSE;
 338         gchar *uri = NULL;
 339
 340         MMPLAYER_FENTER();
 341
 342         MMPLAYER_RETURN_VAL_IF_FAIL(path, FALSE);
 343
 344         uri = g_ascii_strdown(path, -1);
 345
 346         if (uri == NULL)
 347                 return FALSE;
 348
 349         /* trimming */
 350         g_strstrip(uri);
 351
 352         /* strlen(".sdp") == 4 */
 353         if (strlen(uri) <= 4) {
 354                 LOGW("path is too short.");
 355                 MMPLAYER_FREEIF(uri);
 356                 return ret;
 357         }
 358
 359         /* first, check extension name */
 360         ret = g_str_has_suffix(uri, "sdp");
 361
 362         /* second, if no suffix is there, check it's contents */
 363         if (!ret)
 364                 /* FIXIT : do it soon */
 365                 LOGD("no suffix");
 366
 367         MMPLAYER_FREEIF(uri);
 368
 369         return ret;
 370 }
 371
 372 const char *
 373 _mmplayer_get_charset(const char *file_path)
 374 {
 375         UCharsetDetector *ucsd;
 376         const UCharsetMatch *ucm;
 377         UErrorCode status = U_ZERO_ERROR;
 378
 379         const char *charset = NULL;
 380         char *buf = NULL;
 381         FILE *fin = 0;
 382         size_t n_size = 0;
 383
 384         fin = fopen(file_path, "r");
 385         if (!fin) {
 386                 SECURE_LOGE("fail to open file %s", file_path);
 387                 return NULL;
 388         }
 389
 390         ucsd = ucsdet_open(&status);
 391         if (U_FAILURE(status)) {
 392                 LOGE("fail to ucsdet_open");
 393                 goto done;
 394         }
 395
 396         ucsdet_enableInputFilter(ucsd, TRUE);
 397
 398         buf = g_try_malloc(1024 * 1024);
 399         if (!buf) {
 400                 LOGE("fail to alloc");
 401                 goto done;
 402         }
 403
 404         n_size = fread(buf, 1, 1024*1024, fin);
 405         buf[1024 * 1024 - 1] = '\0';
 406         if (!n_size)
 407                 goto done;
 408
 409         ucsdet_setText(ucsd, buf, strlen(buf), &status);
 410         if (U_FAILURE(status)) {
 411                 LOGE("fail to ucsdet_setText");
 412                 goto done;
 413         }
 414
 415         ucm = ucsdet_detect(ucsd, &status);
 416         if (U_FAILURE(status)) {
 417                 LOGE("fail to ucsdet_detect");
 418                 goto done;
 419         }
 420
 421         charset = ucsdet_getName(ucm, &status);
 422         if (U_FAILURE(status)) {
 423                 LOGE("fail to ucsdet_getName");
 424                 goto done;
 425         }
 426
 427         /* CP949 encoding is an extension of the EUC-KR and it is backwards compatible.*/
 428         if (charset && !strcmp(charset, "EUC-KR"))
 429                 charset = "CP949";
 430
 431 done:
 432         if (fin)
 433                 fclose(fin);
 434
 435         if (ucsd)
 436                 ucsdet_close(ucsd);
 437
 438         MMPLAYER_FREEIF(buf);
 439
 440         return charset;
 441 }
 442
 443 int
 444 _mmplayer_get_pixtype(unsigned int fourcc)
 445 {
 446         int pixtype = MM_PIXEL_FORMAT_INVALID;
 447
 448     /*
 449         char *pfourcc = (char *)&fourcc;
 450
 451         LOGD("fourcc(%c%c%c%c)",
 452                 pfourcc[0], pfourcc[1], pfourcc[2], pfourcc[3]);
 453     */
 454
 455         switch (fourcc) {
 456         case GST_MAKE_FOURCC('S', 'N', '1', '2'):
 457         case GST_MAKE_FOURCC('N', 'V', '1', '2'):
 458                 pixtype = MM_PIXEL_FORMAT_NV12;
 459                 break;
 460         case GST_MAKE_FOURCC('S', 'T', '1', '2'):
 461                 pixtype = MM_PIXEL_FORMAT_NV12T;
 462                 break;
 463         case GST_MAKE_FOURCC('S', 'N', '2', '1'):
 464         case GST_MAKE_FOURCC('N', 'V', '2', '1'):
 465                 pixtype = MM_PIXEL_FORMAT_NV21;
 466                 break;
 467         case GST_MAKE_FOURCC('S', 'U', 'Y', 'V'):
 468         case GST_MAKE_FOURCC('Y', 'U', 'Y', 'V'):
 469         case GST_MAKE_FOURCC('Y', 'U', 'Y', '2'):
 470                 pixtype = MM_PIXEL_FORMAT_YUYV;
 471                 break;
 472         case GST_MAKE_FOURCC('S', 'Y', 'V', 'Y'):
 473         case GST_MAKE_FOURCC('U', 'Y', 'V', 'Y'):
 474                 pixtype = MM_PIXEL_FORMAT_UYVY;
 475                 break;
 476         case GST_MAKE_FOURCC('S', '4', '2', '0'):
 477         case GST_MAKE_FOURCC('I', '4', '2', '0'):
 478                 pixtype = MM_PIXEL_FORMAT_I420;
 479                 break;
 480         case GST_MAKE_FOURCC('Y', 'V', '1', '2'):
 481                 pixtype = MM_PIXEL_FORMAT_YV12;
 482                 break;
 483         case GST_MAKE_FOURCC('4', '2', '2', 'P'):
 484                 pixtype = MM_PIXEL_FORMAT_422P;
 485                 break;
 486         case GST_MAKE_FOURCC('R', 'G', 'B', 'P'):
 487                 pixtype = MM_PIXEL_FORMAT_RGB565;
 488                 break;
 489         case GST_MAKE_FOURCC('R', 'G', 'B', '3'):
 490                 pixtype = MM_PIXEL_FORMAT_RGB888;
 491                 break;
 492         case GST_MAKE_FOURCC('A', 'R', 'G', 'B'):
 493         case GST_MAKE_FOURCC('x', 'R', 'G', 'B'):
 494                 pixtype = MM_PIXEL_FORMAT_ARGB;
 495                 break;
 496         case GST_MAKE_FOURCC('B', 'G', 'R', 'A'):
 497         case GST_MAKE_FOURCC('B', 'G', 'R', 'x'):
 498         case GST_MAKE_FOURCC('S', 'R', '3', '2'):
 499                 pixtype = MM_PIXEL_FORMAT_RGBA;
 500                 break;
 501         case GST_MAKE_FOURCC('J', 'P', 'E', 'G'):
 502         case GST_MAKE_FOURCC('P', 'N', 'G', ' '):
 503                 pixtype = MM_PIXEL_FORMAT_ENCODED;
 504                 break;
 505         case GST_MAKE_FOURCC('I', 'T', 'L', 'V'):
 506                 pixtype = MM_PIXEL_FORMAT_ITLV_JPEG_UYVY;
 507                 break;
 508         default:
 509                 LOGE("Not supported fourcc type(%c%c%c%c)",
 510                         fourcc, fourcc>>8, fourcc>>16, fourcc>>24);
 511                 pixtype = MM_PIXEL_FORMAT_INVALID;
 512                 break;
 513         }
 514
 515         return pixtype;
 516 }
 517
 518 static int
 519 __mmplayer_storage_supported_cb(int storage_id, storage_type_e type,
 520         storage_state_e state, const char *path, void *user_data)
 521 {
 522         mmplayer_storage_info_t *storage_info = (mmplayer_storage_info_t *)user_data;
 523
 524         MMPLAYER_RETURN_VAL_IF_FAIL(storage_info, FALSE);
 525
 526         if (type == storage_info->type && strstr(storage_info->path, path)) {
 527                 storage_info->id = storage_id;
 528                 storage_info->state = state;
 529                 return FALSE;
 530         }
 531
 532         return TRUE;
 533 }
 534
 535 bool
 536 _mmplayer_get_storage_info(const char *path, mmplayer_storage_info_t *storage_info)
 537 {
 538         int ret = 0;
 539         const char *file_path = path;
 540
 541         MMPLAYER_RETURN_VAL_IF_FAIL(file_path && storage_info, false);
 542
 543         if (strncmp(file_path, "file://", strlen("file://")) == 0)
 544                 file_path = path + 7; /* remove file prefix */
 545
 546         if (strncmp(file_path, MEDIA_PATH_EXTERNAL, strlen(MEDIA_PATH_EXTERNAL)) == 0) {
 547                 storage_info->type = STORAGE_TYPE_EXTERNAL;
 548
 549                 memset(storage_info->path, 0x00, MM_MAX_URL_LEN);
 550                 g_snprintf(storage_info->path, MM_MAX_URL_LEN, "%s", file_path);
 551
 552                 ret = storage_foreach_device_supported((storage_device_supported_cb)__mmplayer_storage_supported_cb, storage_info);
 553                 if (ret != STORAGE_ERROR_NONE) {
 554                         LOGE("failed to check supported storage 0x%x", ret);
 555                         return false;
 556                 }
 557
 558                 if (storage_info->state <= STORAGE_STATE_REMOVED) {
 559                         LOGE("need to check the external storage state %d:%d", storage_info->id, storage_info->state);
 560                         return false;
 561                 }
 562         } else {
 563                 storage_info->type = STORAGE_TYPE_INTERNAL;
 564                 storage_info->state = STORAGE_STATE_MOUNTED;
 565         }
 566
 567         LOGD("storage info %d:%d:%d", storage_info->type, storage_info->id, storage_info->state);
 568         return true;
 569 }
 570
 571 media_format_mimetype_e _mmplayer_convert_audio_pcm_str_to_media_format_mime(const gchar *audio_pcm_str)
 572 {
 573         if (!audio_pcm_str) {
 574                 LOGW("audio pcm str is NULL");
 575                 return MEDIA_FORMAT_MAX;
 576         }
 577
 578         if (strstr(audio_pcm_str, "S16LE"))
 579                 return MEDIA_FORMAT_PCM_S16LE;
 580         else if (strstr(audio_pcm_str, "S24LE"))
 581                 return MEDIA_FORMAT_PCM_S24LE;
 582         else if (strstr(audio_pcm_str, "S32LE"))
 583                 return MEDIA_FORMAT_PCM_S32LE;
 584         else if (strstr(audio_pcm_str, "S16BE"))
 585                 return MEDIA_FORMAT_PCM_S16BE;
 586         else if (strstr(audio_pcm_str, "S24BE"))
 587                 return MEDIA_FORMAT_PCM_S24BE;
 588         else if (strstr(audio_pcm_str, "S32BE"))
 589                 return MEDIA_FORMAT_PCM_S32BE;
 590         else if (strstr(audio_pcm_str, "F32LE"))
 591                 return MEDIA_FORMAT_PCM_F32LE;
 592         else if (strstr(audio_pcm_str, "F32BE"))
 593                 return MEDIA_FORMAT_PCM_F32BE;
 594         else if (strstr(audio_pcm_str, "U16LE"))
 595                 return MEDIA_FORMAT_PCM_U16LE;
 596         else if (strstr(audio_pcm_str, "U24LE"))
 597                 return MEDIA_FORMAT_PCM_U24LE;
 598         else if (strstr(audio_pcm_str, "U32LE"))
 599                 return MEDIA_FORMAT_PCM_U32LE;
 600         else if (strstr(audio_pcm_str, "U16BE"))
 601                 return MEDIA_FORMAT_PCM_U16BE;
 602         else if (strstr(audio_pcm_str, "U24BE"))
 603                 return MEDIA_FORMAT_PCM_U24BE;
 604         else if (strstr(audio_pcm_str, "U32BE"))
 605                 return MEDIA_FORMAT_PCM_U32BE;
 606         else {
 607                 LOGW("Not supported audio pcm format str : %s", audio_pcm_str);
 608                 return MEDIA_FORMAT_MAX;
 609         }
 610 }