src/kits/network/libnetapi/UrlSynchronousRequest.cpp

   1 /*
   2  * Copyright 2010 Haiku Inc. All rights reserved.
   3  * Distributed under the terms of the MIT License.
   4  *
   5  * Authors:
   6  *              Christophe Huriaux, c.huriaux@gmail.com
   7  */
   8
   9 #include <cstdio>
  10
  11 #include <UrlSynchronousRequest.h>
  12
  13 #define PRINT(x) printf x;
  14
  15
  16 BUrlSynchronousRequest::BUrlSynchronousRequest(BUrlRequest& request)
  17         :
  18         BUrlRequest(request.Url(), NULL, request.Context(),
  19                 "BUrlSynchronousRequest", request.Protocol()),
  20         fRequestComplete(false),
  21         fWrappedRequest(request)
  22 {
  23 }
  24
  25
  26 status_t
  27 BUrlSynchronousRequest::Perform()
  28 {
  29         fWrappedRequest.SetListener(this);
  30         fRequestComplete = false;
  31
  32         thread_id worker = fWrappedRequest.Run();
  33                 // TODO something to do with the thread_id maybe ?
  34
  35         if (worker < B_OK)
  36                 return worker;
  37         else
  38                 return B_OK;
  39 }
  40
  41
  42 status_t
  43 BUrlSynchronousRequest::WaitUntilCompletion()
  44 {
  45         while (!fRequestComplete)
  46                 snooze(10000);
  47
  48         return B_OK;
  49 }
  50
  51
  52 void
  53 BUrlSynchronousRequest::ConnectionOpened(BUrlRequest*)
  54 {
  55         PRINT(("SynchronousRequest::ConnectionOpened()\n"));
  56 }
  57
  58
  59 void
  60 BUrlSynchronousRequest::HostnameResolved(BUrlRequest*, const char* ip)
  61 {
  62         PRINT(("SynchronousRequest::HostnameResolved(%s)\n", ip));
  63 }
  64
  65
  66 void
  67 BUrlSynchronousRequest::ResponseStarted(BUrlRequest*)
  68 {
  69         PRINT(("SynchronousRequest::ResponseStarted()\n"));
  70 }
  71
  72
  73 void
  74 BUrlSynchronousRequest::HeadersReceived(BUrlRequest*)
  75 {
  76         PRINT(("SynchronousRequest::HeadersReceived()\n"));
  77 }
  78
  79
  80 void
  81 BUrlSynchronousRequest::DataReceived(BUrlRequest*, const char*,
  82         off_t, ssize_t size)
  83 {
  84         PRINT(("SynchronousRequest::DataReceived(%zd)\n", size));
  85 }
  86
  87
  88 void
  89 BUrlSynchronousRequest::DownloadProgress(BUrlRequest*,
  90         ssize_t bytesReceived, ssize_t bytesTotal)
  91 {
  92         PRINT(("SynchronousRequest::DownloadProgress(%zd, %zd)\n", bytesReceived,
  93                 bytesTotal));
  94 }
  95
  96
  97 void
  98 BUrlSynchronousRequest::UploadProgress(BUrlRequest*, ssize_t bytesSent,
  99         ssize_t bytesTotal)
 100 {
 101         PRINT(("SynchronousRequest::UploadProgress(%zd, %zd)\n", bytesSent,
 102                 bytesTotal));
 103 }
 104
 105
 106 void
 107 BUrlSynchronousRequest::RequestCompleted(BUrlRequest* caller, bool success)
 108 {
 109         PRINT(("SynchronousRequest::RequestCompleted(%s) : %s\n", (success?"true":"false"),
 110                 strerror(caller->Status())));
 111         fRequestComplete = true;
 112 }