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
|
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
#include "nsAHttpConnection.h"
#include "mozilla/Components.h"
#include "nsSocketTransportService2.h"
#include "nsThreadUtils.h"
namespace mozilla::net {
NS_IMPL_ADDREF(nsAHttpConnection)
NS_IMETHODIMP_(MozExternalRefCountType)
nsAHttpConnection::Release() {
nsrefcnt count;
MOZ_ASSERT(0 != mRefCnt, "dup release");
count = --mRefCnt;
NS_LOG_RELEASE(this, count, "nsAHttpConnection");
if (0 == count) {
mRefCnt = 1; /* stablize */
// it is essential that the connection be destroyed on the socket thread.
DeleteSelfOnSocketThread();
return 0;
}
return count;
}
NS_IMPL_QUERY_INTERFACE0(nsAHttpConnection)
nsAHttpConnection::~nsAHttpConnection() = default;
class DeleteAHttpConnection : public Runnable {
public:
explicit DeleteAHttpConnection(nsAHttpConnection* aConn)
: Runnable("net::DeleteAHttpConnection"), mConn(aConn) {}
NS_IMETHOD Run() override {
delete mConn;
return NS_OK;
}
private:
nsAHttpConnection* mConn;
};
void nsAHttpConnection::DeleteSelfOnSocketThread() {
if (OnSocketThread()) {
delete this;
return;
}
nsCOMPtr<nsIEventTarget> sts =
mozilla::components::SocketTransport::Service();
nsCOMPtr<nsIRunnable> event = new DeleteAHttpConnection(this);
(void)NS_WARN_IF(
NS_FAILED(sts->Dispatch(event.forget(), NS_DISPATCH_NORMAL)));
}
} // namespace mozilla::net
|
