summaryrefslogtreecommitdiffhomepage
path: root/src/go/unit/response.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/go/unit/response.go')
-rw-r--r--src/go/unit/response.go87
1 files changed, 0 insertions, 87 deletions
diff --git a/src/go/unit/response.go b/src/go/unit/response.go
deleted file mode 100644
index 767d66b7..00000000
--- a/src/go/unit/response.go
+++ /dev/null
@@ -1,87 +0,0 @@
-/*
- * Copyright (C) Max Romanov
- * Copyright (C) NGINX, Inc.
- */
-
-package unit
-
-/*
-#include "nxt_cgo_lib.h"
-*/
-import "C"
-
-import (
- "net/http"
-)
-
-type response struct {
- header http.Header
- headerSent bool
- req *http.Request
- c_req C.uintptr_t
-}
-
-func new_response(c_req C.uintptr_t, req *http.Request) *response {
- resp := &response{
- header: http.Header{},
- req: req,
- c_req: c_req,
- }
-
- return resp
-}
-
-func (r *response) Header() http.Header {
- return r.header
-}
-
-func (r *response) Write(p []byte) (n int, err error) {
- if !r.headerSent {
- r.WriteHeader(http.StatusOK)
- }
-
- res := C.nxt_cgo_response_write(r.c_req, buf_ref(p), C.uint32_t(len(p)))
- return int(res), nil
-}
-
-func (r *response) WriteHeader(code int) {
- if r.headerSent {
- // Note: explicitly using Stderr, as Stdout is our HTTP output.
- nxt_go_warn("multiple response.WriteHeader calls")
- return
- }
- r.headerSent = true
-
- // Set a default Content-Type
- if _, hasType := r.header["Content-Type"]; !hasType {
- r.header.Add("Content-Type", "text/html; charset=utf-8")
- }
-
- fields := 0
- fields_size := 0
-
- for k, vv := range r.header {
- for _, v := range vv {
- fields++
- fields_size += len(k) + len(v)
- }
- }
-
- C.nxt_cgo_response_create(r.c_req, C.int(code), C.int(fields),
- C.uint32_t(fields_size))
-
- for k, vv := range r.header {
- for _, v := range vv {
- C.nxt_cgo_response_add_field(r.c_req, str_ref(k), C.uint8_t(len(k)),
- str_ref(v), C.uint32_t(len(v)))
- }
- }
-
- C.nxt_cgo_response_send(r.c_req)
-}
-
-func (r *response) Flush() {
- if !r.headerSent {
- r.WriteHeader(http.StatusOK)
- }
-}