谷歌浏览器的源码分析(30)

上次说到函数WinHttpReadData[/b]接收数据到缓冲区里，那么这些数据又是怎么样传送给下一步处理的呢？带着这个问题，我们来分析下面这段代码，如下：
#001 void HttpTransactionWinHttp::HandleStatusCallback(DWORD status,
#002 DWORD_PTR result,
#003 DWORD error,
#004 DWORD secure_failure) {
#005 int rv = ERR_FAILED;
#006
#007 switch (status) {
#008 case WINHTTP_CALLBACK_STATUS_REQUEST_ERROR:
#009 rv = DidReceiveError(error, secure_failure);
#010 break;
......
#027
#028 if (rv == ERR_IO_PENDING) {
#029 session_callback_->AddRef(); // balanced when callback runs.
#030 } else if (callback_) {
#031 DoCallback(rv);[/b]
#032 }
#033 }

通过上面的函数可以看到，当数据接收完成后，就会调用DoCallback[/b]函数处理接收到的数据。DoCallback[/b]函数的代码如下：

#001 void HttpTransactionWinHttp::DoCallback(int rv) {
#002 DCHECK(rv != ERR_IO_PENDING);
#003 DCHECK(callback_);
#004
#005 // since Run may result in Read being called, clear callback_ up front.
#006 CompletionCallback* c = callback_;[/b]
#007 callback_ = NULL;[/b]
#008 c->Run(rv);[/b]
#009 }

看到这里又是一个回调函数c->Run[/b]的通知，它是调用开始创建这个连接时设置的回调对象。如果是HTTP请求，那么这个请求回调函数是对象URLRequestHttpJob里的函数，也就是调用URLRequestHttpJob::OnReadCompleted函数，这个函数是当数据接收完成，或接收失败，或者接收还没有完成时都会调用。这个函数代码如下：
#001 void URLRequestHttpJob::OnReadCompleted(int result) {
#002 read_in_progress_ = false;
#003

这里是接收数据完成。
#004 if (result == 0) {
#005 NotifyDone(URLRequestStatus());
#006 } else if (result < 0) {

这里是接收数据出错划。
#007 NotifyDone(URLRequestStatus(URLRequestStatus::FAILED, result));
#008 } else {

这里是接收数据还没有完成。
#009 // Clear the IO_PENDING status
#010 SetStatus(URLRequestStatus());
#011 }
#012
#013 NotifyReadComplete(result);
#014 }

当上面读取数据完成时，就开始把接收到数据通过类ResourceDispatcherHost来发送出去，而类ResourceDispatcherHost发送数据的方式比较特别，它不是通过消息把整块数据用命名管道发送的，而是通过共享内存的方式让另一个进程来读取数据，这样达到速度快的特点，可见可多米处理处理考虑的都是速度，它的代码如下：
#001 bool OnReadCompleted(int request_id, int* bytes_read) {
#002 if (!*bytes_read)
#003 return true;
#004 DCHECK(read_buffer_.get());
#005
#006 if (!rdh_->WillSendData(render_process_host_id_, request_id)) {
#007 // We should not send this data now, we have too many pending requests.
#008 return true;
#009 }
#010

这里创建共享内存。
#011 SharedMemoryHandle handle;
#012 if (!read_buffer_->GiveToProcess(render_process_, &handle)) {
#013 // We wrongfully incremented the pending data count. Fake an ACK message
#014 // to fix this. We can't move this call above the WillSendData because
#015 // it's killing our read_buffer_, and we don't want that when we pause
#016 // the request.
#017 rdh_->OnDataReceivedACK(render_process_host_id_, request_id);
#018 return false;
#019 }
#020

把共享内存通过管道消息发送给渲染进程。
#021 receiver_->Send(new ViewMsg_Resource_DataReceived(
#022 routing_id_, request_id, handle, *bytes_read));
#023
#024 return true;
#025 }
#026

共享内存是使用Windows API函数CreateFileMapping来创建内存共享文件实现的，具体实现方法请参考类SharedMemory的实现。这里既然把消息通过管道发送出去了，那么在另一个线程里肯定就处理的这个消息，下一次再来分析那部份代码。