Method _ListObjects

serving/processor/framework/filesystem/oss_file_system.cc:626–684

For GetChildren , we should not return prefix

// For GetChildren , we should not return prefix
Status OSSFileSystem::_ListObjects(
    aos_pool_t* pool, const oss_request_options_t* options,
    const std::string& bucket, const std::string& key,
    std::vector<std::string>* result, bool return_all, bool return_full_path,
    bool should_remove_suffix, int max_ret_per_iterator) {
  aos_string_t bucket_;
  aos_status_t* s = NULL;
  oss_list_object_params_t* params = NULL;
  oss_list_object_content_t* content = NULL;
  const char* next_marker = "";

  aos_str_set(&bucket_, bucket.c_str());
  params = oss_create_list_object_params(pool);
  params->max_ret = max_ret_per_iterator;
  aos_str_set(&params->prefix, key.c_str());
  aos_str_set(&params->marker, next_marker);

  do {
    s = oss_list_object(options, &bucket_, params, NULL);
    if (!aos_status_is_ok(s)) {
      string msg;
      oss_error_message(s, &msg);
      VLOG(0) << "can not list object " << key << " errMsg: " << msg;
      return errors::NotFound("can not list object:", key, " errMsg: ", msg);
    }

    aos_list_for_each_entry(oss_list_object_content_t, content,
                            &params->object_list, node) {
      int path_length = content->key.len;
      if (should_remove_suffix && path_length > 0 &&
          content->key.data[content->key.len - 1] == '/') {
        path_length = content->key.len - 1;
      }
      if (return_full_path) {
        string child(content->key.data, 0, path_length);
        result->push_back(child);
      } else {
        int prefix_len = (key.length() > 0 && key.at(key.length() - 1) != '/')
                             ? key.length() + 1
                             : key.length();
        // remove prefix for GetChildren
        if (content->key.len > prefix_len) {
          string child(content->key.data + prefix_len, 0,
                       path_length - prefix_len);
          result->push_back(child);
        }
      }
    }

    next_marker = apr_psprintf(pool, "%.*s", params->next_marker.len,
                               params->next_marker.data);

    aos_str_set(&params->marker, next_marker);
    aos_list_init(&params->object_list);
    aos_list_init(&params->common_prefix_list);
  } while (params->truncated == AOS_TRUE && return_all);

  return Status::OK();