diff --git a/context.go b/context.go index 1c76c0f6..483b40ca 100644 --- a/context.go +++ b/context.go @@ -21,6 +21,7 @@ import ( "time" "github.com/gin-contrib/sse" + "github.com/gin-gonic/gin/binding" "github.com/gin-gonic/gin/render" ) @@ -71,6 +72,9 @@ type Context struct { // This mutex protects Keys map. mu sync.RWMutex + // This mutex protects headers map + hmu sync.RWMutex + // Keys is a key/value pair exclusively for the context of each request. Keys map[string]any @@ -954,6 +958,8 @@ func (c *Context) IsWebsocket() bool { } func (c *Context) requestHeader(key string) string { + c.hmu.Lock() + defer c.hmu.Unlock() return c.Request.Header.Get(key) } @@ -983,6 +989,8 @@ func (c *Context) Status(code int) { // It writes a header in the response. // If value == "", this method removes the header `c.Writer.Header().Del(key)` func (c *Context) Header(key, value string) { + c.hmu.Lock() + defer c.hmu.Unlock() if value == "" { c.Writer.Header().Del(key) return diff --git a/context_test.go b/context_test.go index ef0cfccd..3d7818fb 100644 --- a/context_test.go +++ b/context_test.go @@ -3123,3 +3123,23 @@ func TestContextNext(t *testing.T) { assert.True(t, exists) assert.Equal(t, "value3", value) } + +func TestParallelHeaderWrite(t *testing.T) { + c, _ := CreateTestContext(httptest.NewRecorder()) + wg := sync.WaitGroup{} + wg.Add(1) + go func() { + defer wg.Done() + for i := 0; i < 1000; i++ { + c.Header("key", "value") + } + }() + wg.Add(1) + go func() { + defer wg.Done() + for i := 0; i < 1000; i++ { + c.Header("key", "value") + } + }() + wg.Wait() +}