d6176b0dca
This CL is part II of IV (I broke down the 1280 files into 4 CLs). Review URL: https://codereview.appspot.com/6474054 git-svn-id: http://skia.googlecode.com/svn/trunk@5263 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;
|
|
}
|
|
|