Turn WorkerLoaderProxy into a threadsafe, ref-counted object.

Source/modules/websockets/WorkerWebSocketChannel.h

 /*
  * Copyright (C) 2011 Google Inc.  All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 65 matching lines @@
     virtual void disconnect() override; // Will suppress didClose().
 
     virtual void trace(Visitor*) override;
 
     class Bridge;
     // Allocated in the worker thread, but used in the main thread.
     class Peer final : public GarbageCollectedFinalized<Peer>, public WebSocketChannelClient {
         USING_GARBAGE_COLLECTED_MIXIN(Peer);
         WTF_MAKE_NONCOPYABLE(Peer);
     public:
-        Peer(Bridge*, WorkerLoaderProxy&, WebSocketChannelSyncHelper*);
+        Peer(Bridge*, PassRefPtr<WorkerLoaderProxy>, WebSocketChannelSyncHelper*);
         virtual ~Peer();
 
         // sourceURLAtConnection and lineNumberAtConnection parameters may
         // be shown when the connection fails.
         static void initialize(ExecutionContext* executionContext, Peer* peer, const String& sourceURLAtConnection, unsigned lineNumberAtConnection)
         {
             peer->initializeInternal(executionContext, sourceURLAtConnection, lineNumberAtConnection);
         }
 
         void connect(const KURL&, const String& protocol);
@@ skipping 12 matching lines @@
         virtual void didReceiveBinaryMessage(PassOwnPtr<Vector<char>>) override;
         virtual void didConsumeBufferedAmount(uint64_t) override;
         virtual void didStartClosingHandshake() override;
         virtual void didClose(ClosingHandshakeCompletionStatus, unsigned short code, const String& reason) override;
         virtual void didError() override;
 
     private:
         void initializeInternal(ExecutionContext*, const String& sourceURLAtConnection, unsigned lineNumberAtConnection);
 
         Member<Bridge> m_bridge;
-        WorkerLoaderProxy& m_loaderProxy;
+        RefPtr<WorkerLoaderProxy> m_loaderProxy;
         Member<WebSocketChannel> m_mainWebSocketChannel;
         Member<WebSocketChannelSyncHelper> m_syncHelper;
     };
 
     // Bridge for Peer. Running on the worker thread.
     class Bridge final : public GarbageCollectedFinalized<Bridge> {
         WTF_MAKE_NONCOPYABLE(Bridge);
     public:
         Bridge(WebSocketChannelClient*, WorkerGlobalScope&);
         ~Bridge();
@@ skipping 12 matching lines @@
         WebSocketChannelClient* client() { return m_client; }
 
         void trace(Visitor*);
 
     private:
         // Returns false if shutdown event is received before method completion.
         bool waitForMethodCompletion(PassOwnPtr<ExecutionContextTask>);
 
         Member<WebSocketChannelClient> m_client;
         RefPtrWillBeMember<WorkerGlobalScope> m_workerGlobalScope;
-        WorkerLoaderProxy& m_loaderProxy;
+        RefPtr<WorkerLoaderProxy> m_loaderProxy;
         Member<WebSocketChannelSyncHelper> m_syncHelper;
         Member<Peer> m_peer;
     };
 
 private:
     WorkerWebSocketChannel(WorkerGlobalScope&, WebSocketChannelClient*, const String& sourceURL, unsigned lineNumber);
 
     Member<Bridge> m_bridge;
     String m_sourceURLAtConnection;
     unsigned m_lineNumberAtConnection;
 };
 
 } // namespace blink
 
 #endif // WorkerWebSocketChannel_h