1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/*
Copyright (C) 1998 Lars Knoll (knoll@mpi-hd.mpg.de)
Copyright (C) 2001 Dirk Mueller <mueller@kde.org>
Copyright (C) 2004, 2006, 2007, 2008 Apple Inc. All rights reserved.
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Library General Public
License as published by the Free Software Foundation; either
version 2 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Library General Public License for more details.
You should have received a copy of the GNU Library General Public License
along with this library; see the file COPYING.LIB. If not, write to
the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
Boston, MA 02110-1301, USA.
*/
#ifndef loader_h
#define loader_h
#include "AtomicString.h"
#include "AtomicStringImpl.h"
#include "PlatformString.h"
#include "SubresourceLoaderClient.h"
#include "Timer.h"
#include <wtf/Deque.h>
#include <wtf/HashMap.h>
#include <wtf/Noncopyable.h>
namespace WebCore {
class CachedResource;
class DocLoader;
class Request;
class Loader : Noncopyable {
public:
Loader();
~Loader();
void load(DocLoader*, CachedResource*, bool incremental = true, bool skipCanLoadCheck = false, bool sendResourceLoadCallbacks = true);
void cancelRequests(DocLoader*);
enum Priority { Low, Medium, High };
void servePendingRequests(Priority minimumPriority = Low);
bool isSuspendingPendingRequests() { return m_isSuspendingPendingRequests; }
void suspendPendingRequests();
void resumePendingRequests();
private:
Priority determinePriority(const CachedResource*) const;
void scheduleServePendingRequests();
void requestTimerFired(Timer<Loader>*);
class Host : public RefCounted<Host>, private SubresourceLoaderClient {
public:
static PassRefPtr<Host> create(const AtomicString& name, unsigned maxRequestsInFlight)
{
return adoptRef(new Host(name, maxRequestsInFlight));
}
~Host();
const AtomicString& name() const { return m_name; }
void addRequest(Request*, Priority);
void servePendingRequests(Priority minimumPriority = Low);
void cancelRequests(DocLoader*);
bool hasRequests() const;
bool processingResource() const { return m_numResourcesProcessing != 0; }
private:
Host(const AtomicString&, unsigned);
virtual void didReceiveResponse(SubresourceLoader*, const ResourceResponse&);
virtual void didReceiveData(SubresourceLoader*, const char*, int);
virtual void didFinishLoading(SubresourceLoader*);
virtual void didFail(SubresourceLoader*, const ResourceError&);
typedef Deque<Request*> RequestQueue;
void servePendingRequests(RequestQueue& requestsPending, bool& serveLowerPriority);
void didFail(SubresourceLoader*, bool cancelled = false);
void cancelPendingRequests(RequestQueue& requestsPending, DocLoader*);
RequestQueue m_requestsPending[High + 1];
typedef HashMap<RefPtr<SubresourceLoader>, Request*> RequestMap;
RequestMap m_requestsLoading;
const AtomicString m_name;
const int m_maxRequestsInFlight;
int m_numResourcesProcessing;
};
typedef HashMap<AtomicStringImpl*, RefPtr<Host> > HostMap;
HostMap m_hosts;
RefPtr<Host> m_nonHTTPProtocolHost;
Timer<Loader> m_requestTimer;
bool m_isSuspendingPendingRequests;
};
}
#endif
|
