~ubuntu-branches/ubuntu/raring/qtwebkit-source/raring-proposed

static PassRefPtr<WorkerThreadableLoader> create(WorkerContext* workerContext, ThreadableLoaderClient* client, const String& taskMode, const ResourceRequest& request, const ThreadableLoaderOptions& options)

{

return adoptRef(new WorkerThreadableLoader(workerContext, client, taskMode, request, options));

}

~WorkerThreadableLoader();

virtual void cancel();

bool done() const { return m_workerClientWrapper->done(); }

using RefCounted<WorkerThreadableLoader>::ref;

using RefCounted<WorkerThreadableLoader>::deref;

protected:

virtual void refThreadableLoader() { ref(); }

virtual void derefThreadableLoader() { deref(); }

private:

// Creates a loader on the main thread and bridges communication between

// the main thread and the worker context's thread where WorkerThreadableLoader runs.

// Regarding the bridge and lifetimes of items used in callbacks, there are a few cases:

// all cases. All tasks posted from the worker context's thread are ok because

// the last task posted always is "mainThreadDestroy", so MainThreadBridge is

// around for all tasks that use it on the main thread.

// case 1. worker.terminate is called.

// In this case, no more tasks are posted from the worker object's thread to the worker

// context's thread -- WorkerContextProxy implementation enforces this.

// case 2. xhr gets aborted and the worker context continues running.

// The ThreadableLoaderClientWrapper has the underlying client cleared, so no more calls

// go through it. All tasks posted from the worker object's thread to the worker context's

// thread do "ThreadableLoaderClientWrapper::ref" (automatically inside of the cross thread copy

// done in createCallbackTask), so the ThreadableLoaderClientWrapper instance is there until all

// tasks are executed.

class MainThreadBridge : public ThreadableLoaderClient {

public:

100

// All executed on the worker context's thread.

101

MainThreadBridge(PassRefPtr<ThreadableLoaderClientWrapper>, WorkerLoaderProxy&, const String& taskMode, const ResourceRequest&, const ThreadableLoaderOptions&, const String& outgoingReferrer);

102

void cancel();

103

void destroy();

104

105

private:

106

// Executed on the worker context's thread.

107

void clearClientWrapper();

108

109

// All executed on the main thread.

110

static void mainThreadDestroy(ScriptExecutionContext*, MainThreadBridge*);

111

~MainThreadBridge();

112

113

static void mainThreadCreateLoader(ScriptExecutionContext*, MainThreadBridge*, PassOwnPtr<CrossThreadResourceRequestData>, ThreadableLoaderOptions, const String& outgoingReferrer);

114

static void mainThreadCancel(ScriptExecutionContext*, MainThreadBridge*);

115

virtual void didSendData(unsigned long long bytesSent, unsigned long long totalBytesToBeSent);

116

virtual void didReceiveResponse(unsigned long identifier, const ResourceResponse&);

117

virtual void didReceiveData(const char*, int dataLength);

118

virtual void didReceiveCachedMetadata(const char*, int dataLength);

119

virtual void didFinishLoading(unsigned long identifier, double finishTime);

120

virtual void didFail(const ResourceError&);

121

virtual void didFailRedirectCheck();

122

123

// Only to be used on the main thread.

124

RefPtr<ThreadableLoader> m_mainThreadLoader;

125

126

// ThreadableLoaderClientWrapper is to be used on the worker context thread.

127

// The ref counting is done on either thread.

128

RefPtr<ThreadableLoaderClientWrapper> m_workerClientWrapper;

129

130

// May be used on either thread.

131

WorkerLoaderProxy& m_loaderProxy;

132

133

// For use on the main thread.

134

String m_taskMode;

135

};

136

137

WorkerThreadableLoader(WorkerContext*, ThreadableLoaderClient*, const String& taskMode, const ResourceRequest&, const ThreadableLoaderOptions&);

138

139

RefPtr<WorkerContext> m_workerContext;

140

RefPtr<ThreadableLoaderClientWrapper> m_workerClientWrapper;

141

MainThreadBridge& m_bridge;

142

};

143

144

} // namespace WebCore

145

146

#endif // ENABLE(WORKERS)

147

148

#endif // WorkerThreadableLoader_h

Older »