|
|
@@ -427,6 +427,7 @@ func (that *GlobalBackfeedManager) Handle(res http.ResponseWriter, req *http.Req |
|
|
|
|
|
|
|
var err error |
|
|
|
statusCode := http.StatusNoContent |
|
|
|
n := 0 |
|
|
|
for scanner.Scan() { |
|
|
|
b := scanner.Bytes() |
|
|
|
if len(b) == 0 { |
|
|
@@ -443,6 +444,7 @@ func (that *GlobalBackfeedManager) Handle(res http.ResponseWriter, req *http.Req |
|
|
|
statusCode = http.StatusServiceUnavailable |
|
|
|
break |
|
|
|
} |
|
|
|
n++ |
|
|
|
} |
|
|
|
if err == nil { |
|
|
|
err = scanner.Err() |
|
|
@@ -450,7 +452,11 @@ func (that *GlobalBackfeedManager) Handle(res http.ResponseWriter, req *http.Req |
|
|
|
statusCode = http.StatusBadRequest |
|
|
|
} |
|
|
|
} |
|
|
|
WriteResponse(res, statusCode, err) |
|
|
|
if err != nil { |
|
|
|
WriteResponse(res, statusCode, err) |
|
|
|
} else { |
|
|
|
WriteResponse(res, http.StatusOK, fmt.Sprintf("%d items queued", n)) |
|
|
|
} |
|
|
|
return |
|
|
|
} |
|
|
|
|
|
|
|