http_streamer: Style fixes and cleanup

This commit is contained in:
Dario Casalinuovo
2016-06-23 00:38:50 +02:00
parent f1c771f8d1
commit 40dca224fc
@@ -15,27 +15,25 @@
class FileListener : public BUrlProtocolAsynchronousListener class FileListener : public BUrlProtocolAsynchronousListener
{ {
public: public:
FileListener(BAdapterIO* owner) FileListener(BAdapterIO* owner)
: :
BUrlProtocolAsynchronousListener(true), BUrlProtocolAsynchronousListener(true),
fRequest(NULL), fRequest(NULL),
fAdapterIO(owner), fAdapterIO(owner),
fTotalSize(0) fTotalSize(0)
{ {
fInputAdapter = fAdapterIO->BuildInputAdapter(); fInputAdapter = fAdapterIO->BuildInputAdapter();
} }
virtual ~FileListener() {}; virtual ~FileListener() {};
bool ConnectionSuccessful() const bool ConnectionSuccessful() const
{ {
printf("ConnectionSuccessful\n");
return fRequest != NULL; return fRequest != NULL;
} }
void ConnectionOpened(BUrlRequest* request) void ConnectionOpened(BUrlRequest* request)
{ {
printf("Connection opened\n");
if (fRequest != NULL) if (fRequest != NULL)
fRequest->Stop(); fRequest->Stop();
@@ -43,20 +41,17 @@ public:
fTotalSize = request->Result().Length(); fTotalSize = request->Result().Length();
} }
void DataReceived(BUrlRequest* request, const char* data, void DataReceived(BUrlRequest* request, const char* data,
off_t position, ssize_t size) off_t position, ssize_t size)
{ {
printf("Data received\n");
if (request != fRequest) if (request != fRequest)
delete request; delete request;
fInputAdapter->Write(data, size); fInputAdapter->Write(data, size);
} }
void RequestCompleted(BUrlRequest* request, bool success) void RequestCompleted(BUrlRequest* request, bool success)
{ {
printf("Request completed\n");
printf("Success: %s\n", success ? "true" : "false");
if (request != fRequest) if (request != fRequest)
return; return;