net/proxy/mojo_proxy_resolver_impl.h

// Copyright 2015 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#ifndef NET_PROXY_MOJO_PROXY_RESOLVER_IMPL_H_
#define NET_PROXY_MOJO_PROXY_RESOLVER_IMPL_H_

#include <queue>
#include <set>

#include "base/memory/ref_counted.h"
#include "base/memory/scoped_ptr.h"
#include "net/interfaces/proxy_resolver_service.mojom.h"

namespace net {

class ProxyResolver;
class ProxyResolverScriptData;

class MojoProxyResolverImpl : public interfaces::ProxyResolver {
 public:
  explicit MojoProxyResolverImpl(scoped_ptr<net::ProxyResolver> resolver);

  ~MojoProxyResolverImpl() override;

 private:
  class Job;

  struct SetPacScriptRequest {
    SetPacScriptRequest(
        const scoped_refptr<ProxyResolverScriptData>& script_data,
        const mojo::Callback<void(int32_t)>& callback);
    ~SetPacScriptRequest();

    // The script data for this request.
    scoped_refptr<ProxyResolverScriptData> script_data;

    // The callback to run to report the result of this request.
    const mojo::Callback<void(int32_t)> callback;
  };

  // interfaces::ProxyResolver overrides.
  void SetPacScript(const mojo::String& data,
                    const mojo::Callback<void(int32_t)>& callback) override;
  void GetProxyForUrl(
      const mojo::String& url,
      interfaces::ProxyResolverRequestClientPtr client) override;

  void DeleteJob(Job* job);

  void StartSetPacScript();
  void SetPacScriptDone(int result);

  scoped_ptr<net::ProxyResolver> resolver_;
  std::set<Job*> resolve_jobs_;

  std::queue<SetPacScriptRequest> set_pac_script_requests_;

  DISALLOW_COPY_AND_ASSIGN(MojoProxyResolverImpl);
};

}  // namespace net

#endif  // NET_PROXY_MOJO_PROXY_RESOLVER_IMPL_H_