| Index: content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc
|
| diff --git a/content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc b/content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc
|
| index 97276160385a1483cb3e5b49d67e0bd84eef5e08..a76ca4eedd152a65ae23ee8ec0fcaba59fb0a99a 100644
|
| --- a/content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc
|
| +++ b/content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc
|
| @@ -171,7 +171,7 @@ int32_t PepperTCPSocketMessageFilter::OnResourceMessageReceived(
|
| int32_t PepperTCPSocketMessageFilter::OnMsgBind(
|
| const ppapi::host::HostMessageContext* context,
|
| const PP_NetAddress_Private& net_addr) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
|
|
| // This is only supported by PPB_TCPSocket v1.1 or above.
|
| if (version_ != ppapi::TCP_SOCKET_VERSION_1_1_OR_ABOVE) {
|
| @@ -198,7 +198,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgConnect(
|
| const ppapi::host::HostMessageContext* context,
|
| const std::string& host,
|
| uint16_t port) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
|
|
| // This is only supported by PPB_TCPSocket_Private.
|
| if (!IsPrivateAPI()) {
|
| @@ -234,7 +234,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgConnect(
|
| int32_t PepperTCPSocketMessageFilter::OnMsgConnectWithNetAddress(
|
| const ppapi::host::HostMessageContext* context,
|
| const PP_NetAddress_Private& net_addr) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
|
|
| content::SocketPermissionRequest request =
|
| pepper_socket_utils::CreateSocketPermissionRequest(
|
| @@ -258,7 +258,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgSSLHandshake(
|
| uint16_t server_port,
|
| const std::vector<std::vector<char> >& trusted_certs,
|
| const std::vector<std::vector<char> >& untrusted_certs) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| // Allow to do SSL handshake only if currently the socket has been connected
|
| // and there isn't pending read or write.
|
| @@ -306,7 +306,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgSSLHandshake(
|
| int32_t PepperTCPSocketMessageFilter::OnMsgRead(
|
| const ppapi::host::HostMessageContext* context,
|
| int32_t bytes_to_read) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!state_.IsConnected() || end_of_file_reached_)
|
| return PP_ERROR_FAILED;
|
| if (read_buffer_.get())
|
| @@ -344,7 +344,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgRead(
|
| int32_t PepperTCPSocketMessageFilter::OnMsgWrite(
|
| const ppapi::host::HostMessageContext* context,
|
| const std::string& data) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (!state_.IsConnected())
|
| return PP_ERROR_FAILED;
|
| @@ -368,7 +368,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgWrite(
|
| int32_t PepperTCPSocketMessageFilter::OnMsgListen(
|
| const ppapi::host::HostMessageContext* context,
|
| int32_t backlog) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
|
|
| // This is only supported by PPB_TCPSocket v1.1 or above.
|
| if (version_ != ppapi::TCP_SOCKET_VERSION_1_1_OR_ABOVE) {
|
| @@ -394,7 +394,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgListen(
|
|
|
| int32_t PepperTCPSocketMessageFilter::OnMsgAccept(
|
| const ppapi::host::HostMessageContext* context) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (pending_accept_)
|
| return PP_ERROR_INPROGRESS;
|
| @@ -416,7 +416,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgAccept(
|
|
|
| int32_t PepperTCPSocketMessageFilter::OnMsgClose(
|
| const ppapi::host::HostMessageContext* context) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (state_.state() == TCPSocketState::CLOSED)
|
| return PP_OK;
|
|
|
| @@ -434,7 +434,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgSetOption(
|
| const ppapi::host::HostMessageContext* context,
|
| PP_TCPSocket_Option name,
|
| const ppapi::SocketOptionData& value) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| switch (name) {
|
| case PP_TCPSOCKET_OPTION_NO_DELAY: {
|
| @@ -477,7 +477,7 @@ int32_t PepperTCPSocketMessageFilter::OnMsgSetOption(
|
| void PepperTCPSocketMessageFilter::DoBind(
|
| const ppapi::host::ReplyMessageContext& context,
|
| const PP_NetAddress_Private& net_addr) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (state_.IsPending(TCPSocketState::BIND)) {
|
| SendBindError(context, PP_ERROR_INPROGRESS);
|
| @@ -543,7 +543,7 @@ void PepperTCPSocketMessageFilter::DoConnect(
|
| const std::string& host,
|
| uint16_t port,
|
| ResourceContext* resource_context) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (!state_.IsValidTransition(TCPSocketState::CONNECT)) {
|
| SendConnectError(context, PP_ERROR_FAILED);
|
| @@ -570,7 +570,7 @@ void PepperTCPSocketMessageFilter::DoConnect(
|
| void PepperTCPSocketMessageFilter::DoConnectWithNetAddress(
|
| const ppapi::host::ReplyMessageContext& context,
|
| const PP_NetAddress_Private& net_addr) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (!state_.IsValidTransition(TCPSocketState::CONNECT)) {
|
| SendConnectError(context, PP_ERROR_FAILED);
|
| @@ -597,7 +597,7 @@ void PepperTCPSocketMessageFilter::DoConnectWithNetAddress(
|
|
|
| void PepperTCPSocketMessageFilter::DoWrite(
|
| const ppapi::host::ReplyMessageContext& context) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| DCHECK(write_buffer_base_.get());
|
| DCHECK(write_buffer_.get());
|
| DCHECK_GT(write_buffer_->BytesRemaining(), 0);
|
| @@ -626,7 +626,7 @@ void PepperTCPSocketMessageFilter::DoWrite(
|
| void PepperTCPSocketMessageFilter::DoListen(
|
| const ppapi::host::ReplyMessageContext& context,
|
| int32_t backlog) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (state_.IsPending(TCPSocketState::LISTEN)) {
|
| SendListenReply(context, PP_ERROR_INPROGRESS);
|
| @@ -645,7 +645,7 @@ void PepperTCPSocketMessageFilter::DoListen(
|
| void PepperTCPSocketMessageFilter::OnResolveCompleted(
|
| const ppapi::host::ReplyMessageContext& context,
|
| int net_result) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (!state_.IsPending(TCPSocketState::CONNECT)) {
|
| DCHECK(state_.state() == TCPSocketState::CLOSED);
|
| @@ -664,7 +664,7 @@ void PepperTCPSocketMessageFilter::OnResolveCompleted(
|
|
|
| void PepperTCPSocketMessageFilter::StartConnect(
|
| const ppapi::host::ReplyMessageContext& context) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| DCHECK(state_.IsPending(TCPSocketState::CONNECT));
|
| DCHECK_LT(address_index_, address_list_.size());
|
|
|
| @@ -685,7 +685,7 @@ void PepperTCPSocketMessageFilter::StartConnect(
|
| void PepperTCPSocketMessageFilter::OnConnectCompleted(
|
| const ppapi::host::ReplyMessageContext& context,
|
| int net_result) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (!state_.IsPending(TCPSocketState::CONNECT)) {
|
| DCHECK(state_.state() == TCPSocketState::CLOSED);
|
| @@ -758,7 +758,7 @@ void PepperTCPSocketMessageFilter::OnConnectCompleted(
|
| void PepperTCPSocketMessageFilter::OnSSLHandshakeCompleted(
|
| const ppapi::host::ReplyMessageContext& context,
|
| int net_result) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (!state_.IsPending(TCPSocketState::SSL_CONNECT)) {
|
| DCHECK(state_.state() == TCPSocketState::CLOSED);
|
| @@ -773,7 +773,7 @@ void PepperTCPSocketMessageFilter::OnSSLHandshakeCompleted(
|
| void PepperTCPSocketMessageFilter::OnReadCompleted(
|
| const ppapi::host::ReplyMessageContext& context,
|
| int net_result) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| DCHECK(read_buffer_.get());
|
|
|
| if (net_result > 0) {
|
| @@ -792,7 +792,7 @@ void PepperTCPSocketMessageFilter::OnReadCompleted(
|
| void PepperTCPSocketMessageFilter::OnWriteCompleted(
|
| const ppapi::host::ReplyMessageContext& context,
|
| int net_result) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| DCHECK(write_buffer_base_.get());
|
| DCHECK(write_buffer_.get());
|
|
|
| @@ -818,7 +818,7 @@ void PepperTCPSocketMessageFilter::OnWriteCompleted(
|
| void PepperTCPSocketMessageFilter::OnAcceptCompleted(
|
| const ppapi::host::ReplyMessageContext& context,
|
| int net_result) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| DCHECK(pending_accept_);
|
|
|
| pending_accept_ = false;
|
|
|