corysanin/tubestation
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Bug 1083092: Introduce |mozilla::ipc::SocketBase|, r=shawnjohnjr

Browse Source 
The new class |SocketBase| contains the notification mechanism of
|SocketConsumerBase|. The latter still contains I/O methods.
This commit is contained in:
Thomas Zimmermann
2014-10-21 10:52:11 +02:00
parent ae8fc31910
commit 0fe75620eb
5 changed files with 75 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
ipc/unixsocket/SocketBase.cpp
View File

@@ -94,16 +94,16 @@ UnixSocketRawData::Send(int aFd)
}
//
// SocketConsumerBase
// SocketBase
//
SocketConsumerBase::~SocketConsumerBase()
SocketBase::~SocketBase()
{
MOZ_ASSERT(mConnectionStatus == SOCKET_DISCONNECTED);
}
SocketConnectionStatus
SocketConsumerBase::GetConnectionStatus() const
SocketBase::GetConnectionStatus() const
{
MOZ_ASSERT(NS_IsMainThread());
@@ -111,7 +111,7 @@ SocketConsumerBase::GetConnectionStatus() const
}
int
SocketConsumerBase::GetSuggestedConnectDelayMs() const
SocketBase::GetSuggestedConnectDelayMs() const
{
MOZ_ASSERT(NS_IsMainThread());
@@ -119,7 +119,7 @@ SocketConsumerBase::GetSuggestedConnectDelayMs() const
}
void
SocketConsumerBase::NotifySuccess()
SocketBase::NotifySuccess()
{
MOZ_ASSERT(NS_IsMainThread());
@@ -129,7 +129,7 @@ SocketConsumerBase::NotifySuccess()
}
void
SocketConsumerBase::NotifyError()
SocketBase::NotifyError()
{
MOZ_ASSERT(NS_IsMainThread());
@@ -140,7 +140,7 @@ SocketConsumerBase::NotifyError()
}
void
SocketConsumerBase::NotifyDisconnect()
SocketBase::NotifyDisconnect()
{
MOZ_ASSERT(NS_IsMainThread());
@@ -151,7 +151,7 @@ SocketConsumerBase::NotifyDisconnect()
}
uint32_t
SocketConsumerBase::CalculateConnectDelayMs() const
SocketBase::CalculateConnectDelayMs() const
{
MOZ_ASSERT(NS_IsMainThread());
@@ -170,19 +170,25 @@ SocketConsumerBase::CalculateConnectDelayMs() const
return connectDelayMs;
}
SocketConsumerBase::SocketConsumerBase()
SocketBase::SocketBase()
: mConnectionStatus(SOCKET_DISCONNECTED)
, mConnectTimestamp(0)
, mConnectDelayMs(0)
{ }
void
SocketConsumerBase::SetConnectionStatus(
SocketConnectionStatus aConnectionStatus)
SocketBase::SetConnectionStatus(SocketConnectionStatus aConnectionStatus)
{
mConnectionStatus = aConnectionStatus;
}
//
// SocketConsumerBase
//
SocketConsumerBase::~SocketConsumerBase()
{ }
//
// SocketIOBase
//