libopkg/opkg.c

   1 /* opkg.c - the opkg  package management system
   2
   3    Thomas Wood <thomas@openedhand.com>
   4
   5    Copyright (C) 2008 OpenMoko Inc
   6
   7    This program is free software; you can redistribute it and/or
   8    modify it under the terms of the GNU General Public License as
   9    published by the Free Software Foundation; either version 2, or (at
  10    your option) any later version.
  11
  12    This program is distributed in the hope that it will be useful, but
  13    WITHOUT ANY WARRANTY; without even the implied warranty of
  14    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15    General Public License for more details.
  16  */
  17
  18 #include <config.h>
  19 #include <fnmatch.h>
  20
  21 #include "opkg.h"
  22 #include "opkg_conf.h"
  23 #include "args.h"
  24
  25 #include "opkg_install.h"
  26 #include "opkg_configure.h"
  27 #include "opkg_download.h"
  28 #include "opkg_remove.h"
  29 #include "opkg_upgrade.h"
  30
  31 #include "sprintf_alloc.h"
  32 #include "file_util.h"
  33
  34 #include <libbb/libbb.h>
  35
  36 args_t *args;
  37
  38 #define opkg_assert(expr) if (!(expr)) { \
  39     printf ("opkg: file %s: line %d (%s): Assertation '%s' failed",\
  40             __FILE__, __LINE__, __PRETTY_FUNCTION__, # expr); abort (); }
  41
  42 #define progress(d, p) d.percentage = p; if (progress_callback) progress_callback (&d, user_data);
  43
  44 /** Private Functions ***/
  45
  46 static int
  47 opkg_configure_packages(char *pkg_name)
  48 {
  49         pkg_vec_t *all;
  50         int i;
  51         pkg_t *pkg;
  52         int r, err = 0;
  53
  54         all = pkg_vec_alloc();
  55         pkg_hash_fetch_available(all);
  56
  57         for (i = 0; i < all->len; i++) {
  58                 pkg = all->pkgs[i];
  59
  60                 if (pkg_name && fnmatch(pkg_name, pkg->name, 0))
  61                         continue;
  62
  63                 if (pkg->state_status == SS_UNPACKED) {
  64                         r = opkg_configure(pkg);
  65                         if (r == 0) {
  66                                 pkg->state_status = SS_INSTALLED;
  67                                 pkg->parent->state_status = SS_INSTALLED;
  68                                 pkg->state_flag &= ~SF_PREFER;
  69                         } else {
  70                                 if (!err)
  71                                         err = r;
  72                         }
  73                 }
  74         }
  75
  76         pkg_vec_free(all);
  77         return err;
  78 }
  79
  80 struct _curl_cb_data {
  81         opkg_progress_callback_t cb;
  82         opkg_progress_data_t *progress_data;
  83         void *user_data;
  84         int start_range;
  85         int finish_range;
  86 };
  87
  88 int
  89 curl_progress_cb(struct _curl_cb_data *cb_data, double t,       /* dltotal */
  90                 double d,       /* dlnow */
  91                 double ultotal, double ulnow)
  92 {
  93         int p = (t) ? d * 100 / t : 0;
  94         static int prev = -1;
  95         int progress = 0;
  96
  97         /* prevent the same value being sent twice (can occur due to rounding) */
  98         if (p == prev)
  99                 return 0;
 100         prev = p;
 101
 102         if (t < 1)
 103                 return 0;
 104
 105         progress = cb_data->start_range +
 106             (d / t * ((cb_data->finish_range - cb_data->start_range)));
 107         cb_data->progress_data->percentage = progress;
 108
 109         (cb_data->cb) (cb_data->progress_data, cb_data->user_data);
 110
 111         return 0;
 112 }
 113
 114
 115 /*** Public API ***/
 116
 117 int
 118 opkg_new()
 119 {
 120         int err;
 121
 122         args = xcalloc(1, sizeof(args_t));
 123         args_init(args);
 124
 125         err = opkg_conf_init(args);
 126         if (err) {
 127                 free(args);
 128                 return -1;
 129         }
 130
 131         return 0;
 132 }
 133
 134 void
 135 opkg_free(void)
 136 {
 137 #ifdef HAVE_CURL
 138         opkg_curl_cleanup();
 139 #endif
 140         opkg_conf_deinit();
 141         args_deinit(args);
 142         free(args);
 143 }
 144
 145 int
 146 opkg_re_read_config_files(void)
 147 {
 148         /* Unfortunately, the easiest way to re-read the config files right now is to
 149          * throw away conf and start again */
 150         opkg_free();
 151         memset(conf, '\0', sizeof(opkg_conf_t));
 152         return opkg_new();
 153         return 0;
 154 }
 155
 156 void
 157 opkg_get_option(char *option, void **value)
 158 {
 159         int i = 0;
 160         extern opkg_option_t options[];
 161
 162         /* look up the option
 163          * TODO: this would be much better as a hash table
 164          */
 165         while (options[i].name) {
 166                 if (strcmp(options[i].name, option) != 0) {
 167                         i++;
 168                         continue;
 169                 }
 170         }
 171
 172         /* get the option */
 173         switch (options[i].type) {
 174         case OPKG_OPT_TYPE_BOOL:
 175                 *((int *) value) = *((int *) options[i].value);
 176                 return;
 177
 178         case OPKG_OPT_TYPE_INT:
 179                 *((int *) value) = *((int *) options[i].value);
 180                 return;
 181
 182         case OPKG_OPT_TYPE_STRING:
 183                 *((char **) value) = xstrdup(options[i].value);
 184                 return;
 185         }
 186
 187 }
 188
 189 void
 190 opkg_set_option(char *option, void *value)
 191 {
 192         int i = 0, found = 0;
 193         extern opkg_option_t options[];
 194
 195         opkg_assert(option != NULL);
 196         opkg_assert(value != NULL);
 197
 198         /* look up the option
 199          * TODO: this would be much better as a hash table
 200          */
 201         while (options[i].name) {
 202                 if (strcmp(options[i].name, option) == 0) {
 203                         found = 1;
 204                         break;
 205                 }
 206                 i++;
 207         }
 208
 209         if (!found) {
 210                 /* XXX: Warning: Option not found */
 211                 return;
 212         }
 213
 214         /* set the option */
 215         switch (options[i].type) {
 216         case OPKG_OPT_TYPE_BOOL:
 217                 if (*((int *) value) == 0)
 218                         *((int *) options[i].value) = 0;
 219                 else
 220                         *((int *) options[i].value) = 1;
 221                 return;
 222
 223         case OPKG_OPT_TYPE_INT:
 224                 *((int *) options[i].value) = *((int *) value);
 225                 return;
 226
 227         case OPKG_OPT_TYPE_STRING:
 228                 *((char **) options[i].value) = xstrdup(value);
 229                 return;
 230         }
 231
 232 }
 233
 234 /**
 235  * @brief libopkg API: Install package
 236  * @param package_name The name of package in which is going to install
 237  * @param progress_callback The callback function that report the status to caller.
 238  */
 239 int
 240 opkg_install_package(const char *package_name,
 241                 opkg_progress_callback_t progress_callback,
 242                 void *user_data)
 243 {
 244         int err;
 245         char *stripped_filename;
 246         opkg_progress_data_t pdata;
 247         pkg_t *old, *new;
 248         pkg_vec_t *deps, *all;
 249         int i, ndepends;
 250         char **unresolved = NULL;
 251
 252         opkg_assert(package_name != NULL);
 253
 254         /* ... */
 255         pkg_info_preinstall_check();
 256
 257
 258         /* check to ensure package is not already installed */
 259         old = pkg_hash_fetch_installed_by_name(package_name);
 260         if (old) {
 261                 /* XXX: Error: Package is already installed. */
 262                 return OPKG_PACKAGE_ALREADY_INSTALLED;
 263         }
 264
 265         new = pkg_hash_fetch_best_installation_candidate_by_name(package_name);
 266         if (!new) {
 267                 /* XXX: Error: Could not find package to install */
 268                 return OPKG_PACKAGE_NOT_FOUND;
 269         }
 270
 271         new->state_flag |= SF_USER;
 272
 273         pdata.action = OPKG_INSTALL;
 274         pdata.pkg = new;
 275
 276         progress(pdata, 0);
 277
 278         /* find dependancies and download them */
 279         deps = pkg_vec_alloc();
 280         /* this function does not return the original package, so we insert it later */
 281         ndepends =
 282             pkg_hash_fetch_unsatisfied_dependencies(new, deps, &unresolved);
 283         if (unresolved) {
 284                 /* XXX: Error: Could not satisfy dependencies */
 285                 pkg_vec_free(deps);
 286                 return OPKG_DEPENDENCIES_FAILED;
 287         }
 288
 289         /* insert the package we are installing so that we download it */
 290         pkg_vec_insert(deps, new);
 291
 292         /* download package and dependancies */
 293         for (i = 0; i < deps->len; i++) {
 294                 pkg_t *pkg;
 295                 struct _curl_cb_data cb_data;
 296                 char *url;
 297
 298                 pkg = deps->pkgs[i];
 299                 if (pkg->local_filename)
 300                         continue;
 301
 302                 pdata.pkg = pkg;
 303                 pdata.action = OPKG_DOWNLOAD;
 304
 305                 if (pkg->src == NULL) {
 306                         /* XXX: Error: Package not available from any configured src */
 307                         return OPKG_PACKAGE_NOT_AVAILABLE;
 308                 }
 309
 310                 sprintf_alloc(&url, "%s/%s", pkg->src->value, pkg->filename);
 311
 312                 /* Get the filename part, without any directory */
 313                 stripped_filename = strrchr(pkg->filename, '/');
 314                 if (!stripped_filename)
 315                         stripped_filename = pkg->filename;
 316
 317                 sprintf_alloc(&pkg->local_filename, "%s/%s", conf->tmp_dir,
 318                               stripped_filename);
 319
 320                 cb_data.cb = progress_callback;
 321                 cb_data.progress_data = &pdata;
 322                 cb_data.user_data = user_data;
 323                 /* 75% of "install" progress is for downloading */
 324                 cb_data.start_range = 75 * i / deps->len;
 325                 cb_data.finish_range = 75 * (i + 1) / deps->len;
 326
 327                 err = opkg_download(url, pkg->local_filename,
 328                                     (curl_progress_func) curl_progress_cb,
 329                                     &cb_data);
 330                 free(url);
 331
 332                 if (err) {
 333                         pkg_vec_free(deps);
 334                         return OPKG_DOWNLOAD_FAILED;
 335                 }
 336
 337         }
 338         pkg_vec_free(deps);
 339
 340         /* clear depenacy checked marks, left by pkg_hash_fetch_unsatisfied_dependencies */
 341         all = pkg_vec_alloc();
 342         pkg_hash_fetch_available(all);
 343         for (i = 0; i < all->len; i++) {
 344                 all->pkgs[i]->parent->dependencies_checked = 0;
 345         }
 346         pkg_vec_free(all);
 347
 348
 349         /* 75% of "install" progress is for downloading */
 350         pdata.pkg = new;
 351         pdata.action = OPKG_INSTALL;
 352         progress(pdata, 75);
 353
 354         /* unpack the package */
 355         err = opkg_install_pkg(new, 0);
 356
 357         if (err) {
 358                 return OPKG_UNKNOWN_ERROR;
 359         }
 360
 361         progress(pdata, 75);
 362
 363         /* run configure scripts, etc. */
 364         err = opkg_configure_packages(NULL);
 365         if (err) {
 366                 return OPKG_UNKNOWN_ERROR;
 367         }
 368
 369         /* write out status files and file lists */
 370         opkg_conf_write_status_files();
 371         pkg_write_changed_filelists();
 372
 373         progress(pdata, 100);
 374         return 0;
 375 }
 376
 377 int
 378 opkg_remove_package(const char *package_name,
 379                 opkg_progress_callback_t progress_callback, void *user_data)
 380 {
 381         int err;
 382         pkg_t *pkg = NULL;
 383         pkg_t *pkg_to_remove;
 384         opkg_progress_data_t pdata;
 385
 386         opkg_assert(package_name != NULL);
 387
 388         pkg_info_preinstall_check();
 389
 390         pkg = pkg_hash_fetch_installed_by_name(package_name);
 391
 392         if (pkg == NULL) {
 393                 /* XXX: Error: Package not installed. */
 394                 return OPKG_PACKAGE_NOT_INSTALLED;
 395         }
 396
 397         pdata.action = OPKG_REMOVE;
 398         pdata.pkg = pkg;
 399         progress(pdata, 0);
 400
 401
 402         if (pkg->state_status == SS_NOT_INSTALLED) {
 403                 /* XXX:  Error: Package seems to be not installed (STATUS = NOT_INSTALLED). */
 404                 return OPKG_PACKAGE_NOT_INSTALLED;
 405         }
 406         progress(pdata, 25);
 407
 408         if (conf->restrict_to_default_dest) {
 409                 pkg_to_remove = pkg_hash_fetch_installed_by_name_dest(pkg->name,
 410                                                       conf->default_dest);
 411         } else {
 412                 pkg_to_remove = pkg_hash_fetch_installed_by_name(pkg->name);
 413         }
 414
 415
 416         progress(pdata, 75);
 417
 418         err = opkg_remove_pkg(pkg_to_remove, 0);
 419
 420         /* write out status files and file lists */
 421         opkg_conf_write_status_files();
 422         pkg_write_changed_filelists();
 423
 424
 425         progress(pdata, 100);
 426         return (err) ? OPKG_UNKNOWN_ERROR : OPKG_NO_ERROR;
 427 }
 428
 429 int
 430 opkg_upgrade_package(const char *package_name,
 431                 opkg_progress_callback_t progress_callback,
 432                 void *user_data)
 433 {
 434         int err;
 435         pkg_t *pkg;
 436         opkg_progress_data_t pdata;
 437
 438         opkg_assert(package_name != NULL);
 439
 440         pkg_info_preinstall_check();
 441
 442         if (conf->restrict_to_default_dest) {
 443                 pkg = pkg_hash_fetch_installed_by_name_dest(package_name,
 444                                                             conf->default_dest);
 445                 if (pkg == NULL) {
 446                         /* XXX: Error: Package not installed in default_dest */
 447                         return OPKG_PACKAGE_NOT_INSTALLED;
 448                 }
 449         } else {
 450                 pkg = pkg_hash_fetch_installed_by_name(package_name);
 451         }
 452
 453         if (!pkg) {
 454                 /* XXX: Error: Package not installed */
 455                 return OPKG_PACKAGE_NOT_INSTALLED;
 456         }
 457
 458         pdata.action = OPKG_INSTALL;
 459         pdata.pkg = pkg;
 460         progress(pdata, 0);
 461
 462         err = opkg_upgrade_pkg(pkg);
 463         /* opkg_upgrade_pkg returns the error codes of opkg_install_pkg */
 464         if (err) {
 465                 return OPKG_UNKNOWN_ERROR;
 466         }
 467         progress(pdata, 75);
 468
 469         err = opkg_configure_packages(NULL);
 470         if (err) {
 471                 return OPKG_UNKNOWN_ERROR;
 472         }
 473
 474         /* write out status files and file lists */
 475         opkg_conf_write_status_files();
 476         pkg_write_changed_filelists();
 477
 478         progress(pdata, 100);
 479         return 0;
 480 }
 481
 482 int
 483 opkg_upgrade_all(opkg_progress_callback_t progress_callback, void *user_data)
 484 {
 485         pkg_vec_t *installed;
 486         int err = 0;
 487         int i;
 488         pkg_t *pkg;
 489         opkg_progress_data_t pdata;
 490
 491         pdata.action = OPKG_INSTALL;
 492         pdata.pkg = NULL;
 493
 494         progress(pdata, 0);
 495
 496         installed = pkg_vec_alloc();
 497         pkg_info_preinstall_check();
 498
 499         pkg_hash_fetch_all_installed(installed);
 500         for (i = 0; i < installed->len; i++) {
 501                 pkg = installed->pkgs[i];
 502
 503                 pdata.pkg = pkg;
 504                 progress(pdata, 99 * i / installed->len);
 505
 506                 err += opkg_upgrade_pkg(pkg);
 507         }
 508         pkg_vec_free(installed);
 509
 510         if (err)
 511                 return 1;
 512
 513         err = opkg_configure_packages(NULL);
 514         if (err)
 515                 return 1;
 516
 517         pdata.pkg = NULL;
 518         progress(pdata, 100);
 519         return 0;
 520 }
 521
 522 int
 523 opkg_update_package_lists(opkg_progress_callback_t progress_callback,
 524                         void *user_data)
 525 {
 526         char *tmp;
 527         int err, result = 0;
 528         char *lists_dir;
 529         pkg_src_list_elt_t *iter;
 530         pkg_src_t *src;
 531         int sources_list_count, sources_done;
 532         opkg_progress_data_t pdata;
 533
 534         pdata.action = OPKG_DOWNLOAD;
 535         pdata.pkg = NULL;
 536         progress(pdata, 0);
 537
 538         sprintf_alloc(&lists_dir, "%s", (conf->restrict_to_default_dest)
 539                 ? conf->default_dest->lists_dir : conf->lists_dir);
 540
 541         if (!file_is_dir(lists_dir)) {
 542                 if (file_exists(lists_dir)) {
 543                         /* XXX: Error: file exists but is not a directory */
 544                         free(lists_dir);
 545                         return 1;
 546                 }
 547
 548                 err = file_mkdir_hier(lists_dir, 0755);
 549                 if (err) {
 550                         /* XXX: Error: failed to create directory */
 551                         free(lists_dir);
 552                         return 1;
 553                 }
 554         }
 555
 556         sprintf_alloc(&tmp, "%s/update-XXXXXX", conf->tmp_dir);
 557         if (mkdtemp(tmp) == NULL) {
 558                 /* XXX: Error: could not create temporary file name */
 559                 free(lists_dir);
 560                 free(tmp);
 561                 return 1;
 562         }
 563
 564         /* count the number of sources so we can give some progress updates */
 565         sources_list_count = 0;
 566         sources_done = 0;
 567         list_for_each_entry(iter, &conf->pkg_src_list.head, node) {
 568                 sources_list_count++;
 569         }
 570
 571         list_for_each_entry(iter, &conf->pkg_src_list.head, node) {
 572                 char *url, *list_file_name = NULL;
 573
 574                 src = (pkg_src_t *) iter->data;
 575
 576                 if (src->extra_data)    /* debian style? */
 577                         sprintf_alloc(&url, "%s/%s/%s", src->value,
 578                                       src->extra_data,
 579                                       src->gzip ? "Packages.gz" : "Packages");
 580                 else
 581                         sprintf_alloc(&url, "%s/%s", src->value,
 582                                       src->gzip ? "Packages.gz" : "Packages");
 583
 584                 sprintf_alloc(&list_file_name, "%s/%s", lists_dir, src->name);
 585                 if (src->gzip) {
 586                         FILE *in, *out;
 587                         struct _curl_cb_data cb_data;
 588                         char *tmp_file_name = NULL;
 589
 590                         sprintf_alloc(&tmp_file_name, "%s/%s.gz", tmp,
 591                                       src->name);
 592
 593                         /* XXX: Note: downloading url */
 594
 595                         cb_data.cb = progress_callback;
 596                         cb_data.progress_data = &pdata;
 597                         cb_data.user_data = user_data;
 598                         cb_data.start_range =
 599                             100 * sources_done / sources_list_count;
 600                         cb_data.finish_range =
 601                             100 * (sources_done + 1) / sources_list_count;
 602
 603                         err = opkg_download(url, tmp_file_name,
 604                                           (curl_progress_func) curl_progress_cb,
 605                                           &cb_data);
 606
 607                         if (err == 0) {
 608                                 /* XXX: Note: Inflating downloaded file */
 609                                 in = fopen(tmp_file_name, "r");
 610                                 out = fopen(list_file_name, "w");
 611                                 if (in && out)
 612                                         unzip(in, out);
 613                                 else
 614                                         err = 1;
 615                                 if (in)
 616                                         fclose(in);
 617                                 if (out)
 618                                         fclose(out);
 619                                 unlink(tmp_file_name);
 620                         }
 621                         free(tmp_file_name);
 622                 } else
 623                         err = opkg_download(url, list_file_name, NULL, NULL);
 624
 625                 if (err) {
 626                         /* XXX: Error: download error */
 627                         result = OPKG_DOWNLOAD_FAILED;
 628                 }
 629                 free(url);
 630
 631 #if defined(HAVE_GPGME) || defined(HAVE_OPENSSL)
 632                 if (conf->check_signature) {
 633                         char *sig_file_name;
 634                         /* download detached signitures to verify the package lists */
 635                         /* get the url for the sig file */
 636                         if (src->extra_data)    /* debian style? */
 637                                 sprintf_alloc(&url, "%s/%s/%s", src->value,
 638                                               src->extra_data, "Packages.sig");
 639                         else
 640                                 sprintf_alloc(&url, "%s/%s", src->value,
 641                                               "Packages.sig");
 642
 643                         /* create filename for signature */
 644                         sprintf_alloc(&sig_file_name, "%s/%s.sig", lists_dir,
 645                                       src->name);
 646
 647                         /* make sure there is no existing signature file */
 648                         unlink(sig_file_name);
 649
 650                         err = opkg_download(url, sig_file_name, NULL, NULL);
 651                         if (err) {
 652                                 /* XXX: Warning: Download failed */
 653                         } else {
 654                                 int err;
 655                                 err = opkg_verify_file(list_file_name,
 656                                                      sig_file_name);
 657                                 if (err == 0) {
 658                                         /* XXX: Notice: Signature check passed */
 659                                 } else {
 660                                         /* XXX: Warning: Signature check failed */
 661                                 }
 662                         }
 663                         free(sig_file_name);
 664                         free(list_file_name);
 665                         free(url);
 666                 }
 667 #else
 668                 /* XXX: Note: Signature check for %s skipped because GPG support was not
 669                  * enabled in this build
 670                  */
 671 #endif
 672
 673                 sources_done++;
 674                 progress(pdata, 100 * sources_done / sources_list_count);
 675         }
 676
 677         rmdir(tmp);
 678         free(tmp);
 679         free(lists_dir);
 680
 681         /* Now re-read the package lists to update package hash tables. */
 682         opkg_re_read_config_files();
 683
 684         return result;
 685 }
 686
 687
 688 int
 689 opkg_list_packages(opkg_package_callback_t callback, void *user_data)
 690 {
 691         pkg_vec_t *all;
 692         int i;
 693
 694         opkg_assert(callback);
 695
 696         all = pkg_vec_alloc();
 697         pkg_hash_fetch_available(all);
 698         for (i = 0; i < all->len; i++) {
 699                 pkg_t *pkg;
 700
 701                 pkg = all->pkgs[i];
 702
 703                 callback(pkg, user_data);
 704         }
 705
 706         pkg_vec_free(all);
 707
 708         return 0;
 709 }
 710
 711 int
 712 opkg_list_upgradable_packages(opkg_package_callback_t callback, void *user_data)
 713 {
 714         struct active_list *head;
 715         struct active_list *node;
 716         pkg_t *old = NULL, *new = NULL;
 717
 718         opkg_assert(callback);
 719
 720         /* ensure all data is valid */
 721         pkg_info_preinstall_check();
 722
 723         head = prepare_upgrade_list();
 724         for (node = active_list_next(head, head); node;
 725              active_list_next(head, node)) {
 726                 old = list_entry(node, pkg_t, list);
 727                 new = pkg_hash_fetch_best_installation_candidate_by_name(old->name);
 728                 if (new == NULL)
 729                         continue;
 730                 callback(new, user_data);
 731         }
 732         active_list_head_delete(head);
 733         return 0;
 734 }
 735
 736 pkg_t *
 737 opkg_find_package(const char *name, const char *ver, const char *arch,
 738                 const char *repo)
 739 {
 740         pkg_t *pkg = NULL;
 741         pkg_vec_t *all;
 742         int i;
 743 #define sstrcmp(x,y) (x && y) ? strcmp (x, y) : 0
 744
 745         all = pkg_vec_alloc();
 746         pkg_hash_fetch_available(all);
 747         for (i = 0; i < all->len; i++) {
 748                 char *pkgv;
 749
 750                 pkg = all->pkgs[i];
 751
 752                 /* check name */
 753                 if (sstrcmp(pkg->name, name))
 754                         continue;
 755
 756                 /* check version */
 757                 pkgv = pkg_version_str_alloc(pkg);
 758                 if (sstrcmp(pkgv, ver)) {
 759                         free(pkgv);
 760                         continue;
 761                 }
 762                 free(pkgv);
 763
 764                 /* check architecture */
 765                 if (arch) {
 766                         if (sstrcmp(pkg->architecture, arch))
 767                                 continue;
 768                 }
 769
 770                 /* check repository */
 771                 if (repo) {
 772                         if (sstrcmp(pkg->src->name, repo))
 773                                 continue;
 774                 }
 775
 776                 /* match found */
 777                 break;
 778         }
 779
 780         pkg_vec_free(all);
 781
 782         return pkg;
 783 }
 784
 785 #ifdef HAVE_CURL
 786 #include <curl/curl.h>
 787 #endif
 788 /**
 789  * @brief Check the accessibility of repositories. It will try to access the repository to check if the respository is accessible throught current network status.
 790  * @return return how many repositories cannot access. 0 means all okay.
 791  */
 792 int
 793 opkg_repository_accessibility_check(void)
 794 {
 795         pkg_src_list_elt_t *iter;
 796         str_list_elt_t *iter1;
 797         str_list_t *src;
 798         int repositories = 0;
 799         int ret = 0;
 800         int err;
 801         int ide
 802         char *repo_ptr;
 803         char *stmp;
 804
 805         src = str_list_alloc();
 806
 807         list_for_each_entry(iter, &conf->pkg_src_list.head, node) {
 808                 idx = index (strstr (((pkg_src_t *) iter->data)->value, "://") + 3, '/');
 809                 if (strstr(((pkg_src_t *) iter->data)->value, "://") && idx)
 810                         stmp = xstrndup(((pkg_src_t *) iter->data)->value,
 811                                      idx -
 812                                       ((pkg_src_t *) iter->data)->value) * sizeof(char);
 813                 else
 814                         stmp = xstrdup(((pkg_src_t *) iter->data)->value);
 815
 816                 for (iter1 = str_list_first(src); iter1;
 817                      iter1 = str_list_next(src, iter1)) {
 818                         if (strstr(iter1->data, stmp))
 819                                 break;
 820                 }
 821                 if (iter1)
 822                         continue;
 823
 824                 sprintf_alloc(&repo_ptr, "%s/index.html", stmp);
 825                 free(stmp);
 826
 827                 str_list_append(src, repo_ptr);
 828                 free(repo_ptr);
 829                 repositories++;
 830         }
 831         while (repositories > 0) {
 832                 iter1 = str_list_pop(src);
 833                 repositories--;
 834
 835                 err = opkg_download(iter1->data, "/dev/null", NULL, NULL);
 836 #ifdef HAVE_CURL
 837                 if (!(err == CURLE_OK ||
 838                       err == CURLE_HTTP_RETURNED_ERROR ||
 839                       err == CURLE_FILE_COULDNT_READ_FILE ||
 840                       err == CURLE_REMOTE_FILE_NOT_FOUND ||
 841                       err == CURLE_TFTP_NOTFOUND)) {
 842 #else
 843                 if (!(err == 0)) {
 844 #endif
 845                         ret++;
 846                 }
 847                 str_list_elt_deinit(iter1);
 848         }
 849         free(src);
 850         return ret;
 851 }