cnt_fetch(struct sess *sp)
{
+
if (Fetch(sp)) {
- AZ(Fake(sp, 503, "Backend did not respond.", 30));
- } else {
- RFC2616_cache_policy(sp, &sp->obj->http); /* XXX -> VCL */
+ sp->obj->cacheable = 0;
+ HSH_Unbusy(sp->obj);
+ HSH_Deref(sp->obj);
+ sp->obj = NULL;
+ sp->step = STP_DONE;
+ RES_Error(sp, 503, NULL);
+ return (0);
+ }
- VCL_fetch_method(sp);
+ RFC2616_cache_policy(sp, &sp->obj->http); /* XXX -> VCL */
- if (sp->handling == VCL_RET_ERROR)
- INCOMPL();
+ VCL_fetch_method(sp);
- if (sp->handling == VCL_RET_PASS)
- sp->obj->pass = 1;
- }
+ if (sp->handling == VCL_RET_ERROR)
+ INCOMPL();
+
+ if (sp->handling == VCL_RET_PASS)
+ sp->obj->pass = 1;
sp->obj->cacheable = 1;
if (sp->obj->objhead != NULL) {
* $Id$
*/
+#include <stdio.h> /* XXX: for NULL ?? */
+#include <string.h> /* XXX: for NULL ?? */
#include <sys/types.h>
#include <sys/time.h>
-#include <stdlib.h>
-
#ifndef HAVE_CLOCK_GETTIME
#include "compat/clock_gettime.h"
#endif
vsb_cat(sb,
"Server: Varnish\r\n"
"Connection: close\r\n"
- "Content-Type: text/html; charset=utf-8\r\n"
+ "Content-Type: text/html; charset=iso-8859-1\r\n"
"\r\n"
"<!DOCTYPE HTML PUBLIC \"-//IETF//DTD HTML 2.0//EN\">\r\n"
"<HTML>\r\n"
vsb_delete(sb);
}
-/*--------------------------------------------------------------------*/
-
-int
-Fake(struct sess *sp, int status, const char *reason, int ttl)
-{
- struct storage *st;
- struct object *o;
- struct vsb vsb;
- struct http_msg *mp;
- const char *msg;
- char buf[40];
- time_t now;
- size_t len;
-
- CHECK_OBJ_NOTNULL(sp, SESS_MAGIC);
- CHECK_OBJ_NOTNULL(sp->obj, OBJECT_MAGIC);
- CHECK_OBJ_NOTNULL(&sp->obj->http, HTTP_MAGIC);
- assert(sp->obj->busy != 0);
- o = sp->obj;
- time(&now);
-
- assert(status >= 100 && status <= 999);
- msg = "Unknown error";
- for (mp = http_msg; mp->nbr != 0 && mp->nbr <= status; mp++) {
- if (mp->nbr < status)
- continue;
- if (mp->nbr > status)
- break;
- msg = mp->txt;
- if (reason == NULL)
- reason = mp->reason;
- break;
- }
- if (reason == NULL)
- reason = msg;
- AN(reason);
- AN(msg);
-
- o->response = status;
- o->valid = 1;
- o->entered = now;
- o->ttl = now + ttl;
- o->last_modified = now;
-
- /* generate body */
- st = stevedore->alloc(stevedore, 1024);
- XXXAN(st->stevedore);
- TAILQ_INSERT_TAIL(&sp->obj->store, st, list);
-
- vsb_new(&vsb, (char *)st->ptr, st->space, VSB_FIXEDLEN);
- vsb_cat(&vsb,
- "<!DOCTYPE HTML PUBLIC \"-//IETF//DTD HTML 2.0//EN\">\r\n"
- "<HTML>\r\n"
- " <HEAD>\r\n");
- vsb_printf(&vsb,
- " <TITLE>%03d %s</TITLE>\r\n", status, msg);
- vsb_printf(&vsb,
- " </HEAD>\r\n"
- " <BODY>\r\n");
- vsb_printf(&vsb,
- " <H1>Error %03d %s</H1>\r\n", status, msg);
- vsb_printf(&vsb,
- " <P>%s</P>\r\n", reason);
- vsb_printf(&vsb,
- " <H3>Guru Meditation:</H3>\r\n");
- vsb_printf(&vsb,
- " <P>XID: %u</P>\r\n", sp->xid);
- vsb_printf(&vsb,
- " <I><A href=\"http://www.varnish-cache.org/\">Varnish</A></I>\r\n"
- " </BODY>\r\n"
- "</HTML>\r\n");
- vsb_finish(&vsb);
- vsb_finish(&vsb);
- o->len = st->len = vsb_len(&vsb);
- vsb_delete(&vsb);
-
- /* generate header */
- o->http.s = calloc(len = 1024, 1);
- XXXAN(o->http.s);
- o->http.e = o->http.s + len;
-
- /* XXX we could use a little less magic here */
- vsb_new(&vsb, o->http.s, len, VSB_FIXEDLEN);
- vsb_printf(&vsb, "\n");
- vsb_printf(&vsb, "\n");
- vsb_printf(&vsb, "HTTP/1.1\r\n");
- vsb_printf(&vsb, "%d\n", status);
- vsb_printf(&vsb, "%s\n", reason);
- TIM_format(now, buf);
- vsb_printf(&vsb, "Date: %s\n", buf);
- vsb_printf(&vsb, "Server: Varnish\n");
- vsb_printf(&vsb, "Retry-After: %ju\n", (uintmax_t)ttl);
- vsb_printf(&vsb, "Content-Type: text/html; charset=utf-8\n");
- vsb_printf(&vsb, "Content-Length: %ud\n", o->len);
- vsb_finish(&vsb);
- vsb_delete(&vsb);
-
- /* XXX and here */
- o->http.f = o->http.s;
- o->http.nhd = 0;
- do {
- o->http.hd[o->http.nhd].b = o->http.f;
- while (*o->http.f != '\n')
- ++o->http.f;
- o->http.hd[o->http.nhd].e = o->http.f;
- ++o->http.nhd;
- ++o->http.f;
- } while (*o->http.f);
-
- return (0);
-}
/*--------------------------------------------------------------------*/
projects / varnish / commitdiff