bda03db289
Found using the new unsubmitted newline_checker slave script: piraeus.cnc.corp.google.com:10125/builders/Skia_House_Keeping/builds/5/steps/shell_1/logs/stdio Review URL: https://codereview.appspot.com/6443124 git-svn-id: http://skia.googlecode.com/svn/trunk@5097 2bbb7eff-a529-9590-31e7-b0007b416f81
52 lines
1.3 KiB
C++
52 lines
1.3 KiB
C++
/*
|
|
* Copyright 2011 Google Inc.
|
|
*
|
|
* Use of this source code is governed by a BSD-style license that can be
|
|
* found in the LICENSE file.
|
|
*/
|
|
#include "SkNetPipeController.h"
|
|
|
|
SkNetPipeController::SkNetPipeController(SkCanvas* target) : fReader(target) {
|
|
fBlock = NULL;
|
|
fBlockSize = fBytesWritten = 0;
|
|
fPlayback = true;
|
|
fStatus = SkGPipeReader::kDone_Status;
|
|
fTotalWritten = 0;
|
|
fAtomsWritten = 0;
|
|
}
|
|
SkNetPipeController::~SkNetPipeController() {
|
|
sk_free(fBlock);
|
|
}
|
|
|
|
int SkNetPipeController::writeToSocket(SkSocket* sockfd, SkSocket::DataType type) {
|
|
if (NULL != sockfd && fTotalWritten > 4)
|
|
return sockfd->writePacket(fBlock, fBytesWritten, type);
|
|
else
|
|
return -1;
|
|
}
|
|
|
|
void* SkNetPipeController::requestBlock(size_t minRequest, size_t* actual) {
|
|
sk_free(fBlock);
|
|
|
|
fBlockSize = minRequest * 4;
|
|
fBlock = sk_malloc_throw(fBlockSize);
|
|
fBytesWritten = 0;
|
|
*actual = fBlockSize;
|
|
return fBlock;
|
|
}
|
|
|
|
void SkNetPipeController::notifyWritten(size_t bytes) {
|
|
SkASSERT(fBytesWritten + bytes <= fBlockSize);
|
|
|
|
if (fPlayback) {
|
|
fStatus = fReader.playback((const char*)fBlock + fBytesWritten, bytes);
|
|
}
|
|
|
|
SkASSERT(SkGPipeReader::kError_Status != fStatus);
|
|
fBytesWritten += bytes;
|
|
fTotalWritten += bytes;
|
|
|
|
fAtomsWritten += 1;
|
|
}
|
|
|