URLSessionDataTask.c File Reference

#include <assert.h>
#include <stdlib.h>
#include <string.h>
#include <curl/curl.h>
#include "URLSession.h"
#include "URLCache.h"
#include "Data.h"
#include "URLSessionDataTask.h"

Go to the source code of this file.

Macros
#define	_Class   _URLSessionDataTask

Functions
Class *	_URLSessionDataTask (void)
static void	cacheResponse (URLSessionDataTask *self)
static void	cancel (URLSessionTask *self)
static void	dealloc (Object *self)
static void	execute (URLSessionTask *self)
static void	initialize (Class *clazz)
static void	materializeCachedResponse (URLSessionDataTask *self)
	Copies a cached response into this task's live response and data fields.
static void	resume (URLSessionTask *self)
static void	setup (URLSessionTask *self)
static size_t	writeFunction (char *data, size_t size, size_t count, ident self)
	The CURLOPT_WRITEFUNCTION callback.

Macro Definition Documentation

_Class

#define _Class   _URLSessionDataTask

Definition at line 35 of file URLSessionDataTask.c.

Function Documentation

_URLSessionDataTask()

Class * _URLSessionDataTask

(

void

)

Definition at line 228 of file URLSessionDataTask.c.

                                 {
  static Class *clazz;
  static Once once;
 
  do_once(&once, {
    clazz = _initialize(&(const ClassDef) {
      .name = "URLSessionDataTask",
      .superclass = _URLSessionTask(),
      .instanceSize = sizeof(URLSessionDataTask),
      .interfaceOffset = offsetof(URLSessionDataTask, interface),
      .interfaceSize = sizeof(URLSessionDataTaskInterface),
      .initialize = initialize,
    });
  });
 
  return clazz;
}

cacheResponse()

static void cacheResponse ( URLSessionDataTask *  self )

static

Definition at line 82 of file URLSessionDataTask.c.

                                                    {
 
  if (self->cachedResponse) {
    return;
  }
 
  URLCache *cache = self->urlSessionTask.session->configuration->urlCache;
  if (cache) {
    $(cache, storeCachedResponseForRequest, self->urlSessionTask.request, self->urlSessionTask.response, self->data);
  }
}

cancel()

static void cancel ( URLSessionTask *  self )

static

See also

URLSessionTask::cancel(URLSessionTask *)

Definition at line 97 of file URLSessionDataTask.c.

                                         {
 
  URLSessionDataTask *this = (URLSessionDataTask *) self;
 
  if (this->cachedResponse) {
    if (this->urlSessionTask.state != URLSESSIONTASK_COMPLETED) {
      release(this->cachedResponse);
      this->cachedResponse = NULL;
      this->urlSessionTask.state = URLSESSIONTASK_CANCELED;
    }
 
    return;
  }
 
  super(URLSessionTask, self, cancel);
}

dealloc()

static void dealloc ( Object *  self )

static

See also

Object::dealloc(Object *)

Definition at line 42 of file URLSessionDataTask.c.

                                  {
 
  URLSessionDataTask *this = (URLSessionDataTask *) self;
 
  release(this->cachedResponse);
  release(this->data);
 
  super(Object, self, dealloc);
}

execute()

static void execute ( URLSessionTask *  self )

static

See also

URLSessionTask::execute(URLSessionTask *)

Definition at line 117 of file URLSessionDataTask.c.

                                          {
 
  URLSessionDataTask *this = (URLSessionDataTask *) self;
 
  if (this->urlSessionTask.state == URLSESSIONTASK_CANCELED
      || this->urlSessionTask.state == URLSESSIONTASK_COMPLETED) {
    return;
  }
 
  if (this->cachedResponse) {
    materializeCachedResponse(this);
    this->urlSessionTask.state = URLSESSIONTASK_COMPLETED;
    return;
  }
 
  $(self, setup);
 
  CURLcode code = curl_easy_perform(self->locals.handle);
 
  curl_easy_getinfo(self->locals.handle, CURLINFO_RESPONSE_CODE, (long *) &self->response->httpStatusCode);
 
  this->urlSessionTask.state = URLSESSIONTASK_COMPLETED;
 
  if (code == CURLE_OK) {
    $(this, cacheResponse);
  }
 
  $(self, teardown);
}

initialize()

static void initialize ( Class *  clazz )

static

See also

Class::initialize(Class *)

Definition at line 212 of file URLSessionDataTask.c.

                                     {
 
  ((ObjectInterface *) clazz->interface)->dealloc = dealloc;
 
  ((URLSessionTaskInterface *) clazz->interface)->cancel = cancel;
  ((URLSessionTaskInterface *) clazz->interface)->execute = execute;
  ((URLSessionTaskInterface *) clazz->interface)->setup = setup;
  ((URLSessionTaskInterface *) clazz->interface)->resume = resume;
 
  ((URLSessionDataTaskInterface *) clazz->interface)->cacheResponse = cacheResponse;
}

materializeCachedResponse()

static void materializeCachedResponse ( URLSessionDataTask *  self )

static

Copies a cached response into this task's live response and data fields.

Definition at line 57 of file URLSessionDataTask.c.

                                                                {
 
  if (self->cachedResponse == NULL) {
    return;
  }
 
  release(self->urlSessionTask.response);
  self->urlSessionTask.response = (URLResponse *) $((Object *) self->cachedResponse->response, copy);
 
  release(self->data);
  self->data = (Data *) $((Object *) self->cachedResponse->data, copy);
 
  self->urlSessionTask.bytesExpectedToReceive = self->cachedResponse->size;
  self->urlSessionTask.bytesReceived = self->cachedResponse->size;
  self->urlSessionTask.bytesExpectedToSend = 0;
  self->urlSessionTask.bytesSent = 0;
 
  release(self->cachedResponse);
  self->cachedResponse = NULL;
}

resume()

static void resume ( URLSessionTask *  self )

static

See also

URLSessionTask::resume(URLSessionTask *)

Definition at line 150 of file URLSessionDataTask.c.

                                         {
 
  URLSessionDataTask *this = (URLSessionDataTask *) self;
 
  if (this->cachedResponse) {
    switch (this->urlSessionTask.state) {
      case URLSESSIONTASK_SUSPENDING:
      case URLSESSIONTASK_SUSPENDED:
      case URLSESSIONTASK_RESUMING:
        materializeCachedResponse(this);
        this->urlSessionTask.state = URLSESSIONTASK_COMPLETED;
 
        if (this->urlSessionTask.completion) {
          this->urlSessionTask.completion((URLSessionTask *) this, true);
        }
        break;
      default:
        break;
    }
 
    return;
  }
 
  super(URLSessionTask, self, resume);
}

setup()

static void setup ( URLSessionTask *  self )

static

See also

URLSessionTask::setup(URLSessionTask *)

Definition at line 199 of file URLSessionDataTask.c.

                                        {
 
  super(URLSessionTask, self, setup);
 
  curl_easy_setopt(self->locals.handle, CURLOPT_WRITEFUNCTION, writeFunction);
  curl_easy_setopt(self->locals.handle, CURLOPT_WRITEDATA, self);
}

writeFunction()

static size_t writeFunction ( char *  data, size_t  size, size_t  count, ident  self  )

static

The CURLOPT_WRITEFUNCTION callback.

Definition at line 179 of file URLSessionDataTask.c.

                                                                               {
 
  URLSessionDataTask *this = (URLSessionDataTask *) self;
 
  const uint8_t *bytes = (uint8_t *) data;
  const size_t bytesReceived = size * count;
 
  if (this->data == NULL) {
    this->data = (Data *) $(alloc(Data), init);
  }
 
  $((Data *) this->data, appendBytes, bytes, bytesReceived);
 
  this->urlSessionTask.bytesReceived += bytesReceived;
  return bytesReceived;
}