Function go_ub_write

frankenphp.go:427–468

export go_ub_write

(threadIndex C.uintptr_t, cBuf *C.char, length C.size_t)

//export go_ub_write
func go_ub_write(threadIndex C.uintptr_t, cBuf *C.char, length C.size_t) (C.size_t, C.bool) {
	thread := phpThreads[threadIndex]
	fc := thread.frankenPHPContext()

	if fc.isDone {
		return 0, C.bool(true)
	}

	var writer io.Writer
	if fc.responseWriter == nil {
		var b bytes.Buffer
		// log the output of the worker
		writer = &b
	} else {
		writer = fc.responseWriter
	}

	var ctx context.Context

	i, e := writer.Write(unsafe.Slice((*byte)(unsafe.Pointer(cBuf)), length))
	if e != nil {
		ctx = thread.context()

		if fc.logger.Enabled(ctx, slog.LevelWarn) {
			fc.logger.LogAttrs(ctx, slog.LevelWarn, "write error", slog.Any("error", e))
		}
	}

	if fc.responseWriter == nil {
		// probably starting a worker script, log the output

		if ctx == nil {
			ctx = thread.context()
		}

		if fc.logger.Enabled(ctx, slog.LevelInfo) {
			fc.logger.LogAttrs(ctx, slog.LevelInfo, writer.(*bytes.Buffer).String())
		}
	}

	return C.size_t(i), C.bool(fc.clientHasClosed())
}

//export go_apache_request_headers
func go_apache_request_headers(threadIndex C.uintptr_t) (*C.go_string, C.size_t) {