Nulo/kawipiko
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

[server] Update logging messages to have module prefixes of the same length.

Browse source
This commit is contained in:
Ciprian Dorin Craciun 2021-12-17 23:27:55 +02:00
parent faaaffe657
commit 0da155a72c
2 changed files with 101 additions and 101 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

196
sources/cmd/server/server.go
View file

@ -102,14 +102,14 @@ func (_server *server) Serve (_context *fasthttp.RequestCtx) () {
if ! bytes.Equal (StringToBytes (http.MethodGet), _requestMethod) { if ! bytes.Equal (StringToBytes (http.MethodGet), _requestMethod) {
if !_server.quiet { if !_server.quiet {
log.Printf ("[ww] [bce7a75b] [http] invalid method `%s` for `%s`!\n", BytesToString (_requestHeaders.Method ()), *_requestUriString) log.Printf ("[ww] [bce7a75b] [http-x..] invalid method `%s` for `%s`!\n", BytesToString (_requestHeaders.Method ()), *_requestUriString)
} }
_server.ServeError (_context, http.StatusMethodNotAllowed, nil, true) _server.ServeError (_context, http.StatusMethodNotAllowed, nil, true)
return return
} }
if (_pathLen == 0) || (_path[0] != '/') { if (_pathLen == 0) || (_path[0] != '/') {
if !_server.quiet { if !_server.quiet {
log.Printf ("[ww] [fa6b1923] [http] invalid path `%s`!\n", *_requestUriString) log.Printf ("[ww] [fa6b1923] [http-x..] invalid path `%s`!\n", *_requestUriString)
} }
_server.ServeError (_context, http.StatusBadRequest, nil, true) _server.ServeError (_context, http.StatusBadRequest, nil, true)
return return
@ -238,7 +238,7 @@ func (_server *server) Serve (_context *fasthttp.RequestCtx) () {
if _fingerprints == nil { if _fingerprints == nil {
if !_server.quiet { if !_server.quiet {
log.Printf ("[ww] [7416f61d] [http] not found `%s`!\n", *_requestUriString) log.Printf ("[ww] [7416f61d] [http-x..] not found `%s`!\n", *_requestUriString)
} }
_server.ServeError (_context, http.StatusNotFound, nil, true) _server.ServeError (_context, http.StatusNotFound, nil, true)
return return
@ -247,7 +247,7 @@ func (_server *server) Serve (_context *fasthttp.RequestCtx) () {
_fingerprintsSplit := bytes.IndexByte (_fingerprints, ':') _fingerprintsSplit := bytes.IndexByte (_fingerprints, ':')
if _fingerprintsSplit < 0 { if _fingerprintsSplit < 0 {
if !_server.quiet { if !_server.quiet {
log.Printf ("[ee] [7ee6c981] [cdb] invalid data fingerprints for `%s`!\n", *_requestUriString) log.Printf ("[ee] [7ee6c981] [cdb.....] invalid data fingerprints for `%s`!\n", *_requestUriString)
} }
_server.ServeError (_context, http.StatusInternalServerError, nil, false) _server.ServeError (_context, http.StatusInternalServerError, nil, false)
return return
@ -272,7 +272,7 @@ func (_server *server) Serve (_context *fasthttp.RequestCtx) () {
} }
if _data == nil { if _data == nil {
if !_server.quiet { if !_server.quiet {
log.Printf ("[ee] [0165c193] [cdb] missing data content for `%s`!\n", *_requestUriString) log.Printf ("[ee] [0165c193] [cdb.....] missing data content for `%s`!\n", *_requestUriString)
} }
_server.ServeError (_context, http.StatusInternalServerError, nil, false) _server.ServeError (_context, http.StatusInternalServerError, nil, false)
return return
@ -295,7 +295,7 @@ func (_server *server) Serve (_context *fasthttp.RequestCtx) () {
} }
if _dataMetaRaw == nil { if _dataMetaRaw == nil {
if !_server.quiet { if !_server.quiet {
log.Printf ("[ee] [e8702411] [cdb] missing data metadata for `%s`!\n", *_requestUriString) log.Printf ("[ee] [e8702411] [cdb.....] missing data metadata for `%s`!\n", *_requestUriString)
} }
_server.ServeError (_context, http.StatusInternalServerError, nil, false) _server.ServeError (_context, http.StatusInternalServerError, nil, false)
return return
@ -314,19 +314,19 @@ func (_server *server) Serve (_context *fasthttp.RequestCtx) () {
_responseStatus = _value _responseStatus = _value
} else { } else {
if !_server.quiet { if !_server.quiet {
log.Printf ("[ee] [c2f7ec36] [cdb] invalid data metadata for `%s`!\n", *_requestUriString) log.Printf ("[ee] [c2f7ec36] [cdb.....] invalid data metadata for `%s`!\n", *_requestUriString)
} }
_responseStatus = http.StatusInternalServerError _responseStatus = http.StatusInternalServerError
} }
} else { } else {
if !_server.quiet { if !_server.quiet {
log.Printf ("[ee] [beedae55] [cdb] invalid data metadata for `%s`!\n", *_requestUriString) log.Printf ("[ee] [beedae55] [cdb.....] invalid data metadata for `%s`!\n", *_requestUriString)
} }
_responseStatus = http.StatusInternalServerError _responseStatus = http.StatusInternalServerError
} }
default : default :
if !_server.quiet { if !_server.quiet {
log.Printf ("[ee] [7acc7d90] [cdb] invalid data metadata for `%s`!\n", *_requestUriString) log.Printf ("[ee] [7acc7d90] [cdb.....] invalid data metadata for `%s`!\n", *_requestUriString)
} }
} }
} }
@ -352,7 +352,7 @@ func (_server *server) Serve (_context *fasthttp.RequestCtx) () {
} }
if _server.debug { if _server.debug {
log.Printf ("[dd] [b15f3cad] [http] serving for `%s`...\n", *_requestUriString) log.Printf ("[dd] [b15f3cad] [http-x..] serving for `%s`...\n", *_requestUriString)
} }
if _server.delay != 0 { if _server.delay != 0 {
@ -431,7 +431,7 @@ func (_server *server) ServeError (_context *fasthttp.RequestCtx, _status uint,
_response.SetStatusCode (int (_status)) _response.SetStatusCode (int (_status))
if (_error != nil) && !_server.quiet { if (_error != nil) && !_server.quiet {
LogError (_error, "[23d6cb35] [http] failed handling request!") LogError (_error, "[23d6cb35] [http-x..] failed handling request!")
} }
} }
@ -450,17 +450,17 @@ func (_server *server) ServeHTTP (_response http.ResponseWriter, _request *http.
case 1 : case 1 :
_requestProtoUnsupported = _server.http1Disabled || (_request.ProtoMinor < 0) || (_request.ProtoMinor > 1) _requestProtoUnsupported = _server.http1Disabled || (_request.ProtoMinor < 0) || (_request.ProtoMinor > 1)
if _server.debug && !_requestProtoUnsupported { if _server.debug && !_requestProtoUnsupported {
log.Printf ("[dd] [670e36d4] [gohttp] using Go HTTP/1 for `%s`...", _request.URL.Path) log.Printf ("[dd] [670e36d4] [go-http.] using Go HTTP/1 for `%s`...", _request.URL.Path)
} }
case 2 : case 2 :
_requestProtoUnsupported = _server.http2Disabled || (_request.ProtoMinor != 0) _requestProtoUnsupported = _server.http2Disabled || (_request.ProtoMinor != 0)
if _server.debug && !_requestProtoUnsupported { if _server.debug && !_requestProtoUnsupported {
log.Printf ("[dd] [524cd64b] [gohttp] using Go HTTP/2 for `%s`...", _request.URL.Path) log.Printf ("[dd] [524cd64b] [go-http.] using Go HTTP/2 for `%s`...", _request.URL.Path)
} }
case 3 : case 3 :
_requestProtoUnsupported = (_server.quicServer == nil) || (_request.ProtoMinor != 0) _requestProtoUnsupported = (_server.quicServer == nil) || (_request.ProtoMinor != 0)
if _server.debug && !_requestProtoUnsupported { if _server.debug && !_requestProtoUnsupported {
log.Printf ("[dd] [be95da51] [gohttp] using QUIC HTTP/3 for `%s`...", _request.URL.Path) log.Printf ("[dd] [be95da51] [go-http.] using QUIC HTTP/3 for `%s`...", _request.URL.Path)
} }
default : default :
_requestProtoUnsupported = true _requestProtoUnsupported = true
@ -469,7 +469,7 @@ func (_server *server) ServeHTTP (_response http.ResponseWriter, _request *http.
_request.Close = true _request.Close = true
_response.WriteHeader (http.StatusHTTPVersionNotSupported) _response.WriteHeader (http.StatusHTTPVersionNotSupported)
if !_server.quiet { if !_server.quiet {
log.Printf ("[ww] [4c44e3c0] [gohttp] protocol HTTP/%d not supported for `%s`!", _request.ProtoMajor, _request.URL.Path) log.Printf ("[ww] [4c44e3c0] [go-http.] protocol HTTP/%d not supported for `%s`!", _request.ProtoMajor, _request.URL.Path)
} }
return return
} }
@ -836,7 +836,7 @@ func main_0 () (error) {
if _processes > 1 { if _processes > 1 {
log.Printf ("[ii] [06f8c944] [master] sub-processes starting (`%d` processes with `%d` threads each)...\n", _processes, _threads) log.Printf ("[ii] [06f8c944] [master..] sub-processes starting (`%d` processes with `%d` threads each)...\n", _processes, _threads)
_processesJoin := & sync.WaitGroup {} _processesJoin := & sync.WaitGroup {}
@ -928,25 +928,25 @@ func main_0 () (error) {
_processesJoin.Add (1) _processesJoin.Add (1)
_processesPid[_processIndex] = _processPid _processesPid[_processIndex] = _processPid
if !_quiet { if !_quiet {
log.Printf ("[ii] [63cb22f8] [master] sub-process `%d` started (with `%d` threads);\n", _processPid.Pid, _threads) log.Printf ("[ii] [63cb22f8] [master..] sub-process `%d` started (with `%d` threads);\n", _processPid.Pid, _threads)
} }
go func (_index int, _processPid *os.Process) () { go func (_index int, _processPid *os.Process) () {
if _processStatus, _error := _processPid.Wait (); _error == nil { if _processStatus, _error := _processPid.Wait (); _error == nil {
if _processStatus.Success () { if _processStatus.Success () {
if _debug { if _debug {
log.Printf ("[ii] [66b60b81] [master] sub-process `%d` succeeded;\n", _processPid.Pid) log.Printf ("[ii] [66b60b81] [master..] sub-process `%d` succeeded;\n", _processPid.Pid)
} }
} else { } else {
log.Printf ("[ww] [5d25046b] [master] sub-process `%d` failed: `%s`; ignoring!\n", _processPid.Pid, _processStatus) log.Printf ("[ww] [5d25046b] [master..] sub-process `%d` failed: `%s`; ignoring!\n", _processPid.Pid, _processStatus)
} }
} else { } else {
LogError (_error, fmt.Sprintf ("[f1bfc927] [master] failed waiting for sub-process `%d`; ignoring!", _processPid.Pid)) LogError (_error, fmt.Sprintf ("[f1bfc927] [master..] failed waiting for sub-process `%d`; ignoring!", _processPid.Pid))
} }
_processesPid[_processIndex] = nil _processesPid[_processIndex] = nil
_processesJoin.Done () _processesJoin.Done ()
} (_processIndex, _processPid) } (_processIndex, _processPid)
} else { } else {
LogError (_error, "[8892b34d] [master] failed starting sub-process; ignoring!") LogError (_error, "[8892b34d] [master..] failed starting sub-process; ignoring!")
} }
} }
@ -957,12 +957,12 @@ func main_0 () (error) {
for { for {
_signal := <- _signals _signal := <- _signals
if _debug { if _debug {
log.Printf ("[ii] [a9243ecb] [master] signaling sub-processes...\n") log.Printf ("[ii] [a9243ecb] [master..] signaling sub-processes...\n")
} }
for _, _processPid := range _processesPid { for _, _processPid := range _processesPid {
if _processPid != nil { if _processPid != nil {
if _error := _processPid.Signal (_signal); _error != nil { if _error := _processPid.Signal (_signal); _error != nil {
LogError (_error, fmt.Sprintf ("[ab681164] [master] failed signaling sub-process `%d`; ignoring!", _processPid.Pid)) LogError (_error, fmt.Sprintf ("[ab681164] [master..] failed signaling sub-process `%d`; ignoring!", _processPid.Pid))
} }
} }
} }
@ -973,7 +973,7 @@ func main_0 () (error) {
_processesJoin.Wait () _processesJoin.Wait ()
if !_quiet { if !_quiet {
log.Printf ("[ii] [b949bafc] [master] sub-processes terminated;\n") log.Printf ("[ii] [b949bafc] [master..] sub-processes terminated;\n")
} }
return nil return nil
@ -981,7 +981,7 @@ func main_0 () (error) {
if _isMaster { if _isMaster {
log.Printf ("[ii] [6602a54a] [master] starting (with `%d` threads)...\n", _threads) log.Printf ("[ii] [6602a54a] [master..] starting (with `%d` threads)...\n", _threads)
} }
@ -997,14 +997,14 @@ func main_0 () (error) {
if _archivePath != "" { if _archivePath != "" {
if !_quiet && (_debug || _isFirst) { if !_quiet && (_debug || _isFirst) {
log.Printf ("[ii] [3b788396] [cdb] opening archive file `%s`...\n", _archivePath) log.Printf ("[ii] [3b788396] [cdb.....] opening archive file `%s`...\n", _archivePath)
} }
var _cdbFile *os.File var _cdbFile *os.File
if _cdbFile_0, _error := os.Open (_archivePath); _error == nil { if _cdbFile_0, _error := os.Open (_archivePath); _error == nil {
_cdbFile = _cdbFile_0 _cdbFile = _cdbFile_0
} else { } else {
AbortError (_error, "[9e0b5ed3] [cdb] failed opening archive file!") AbortError (_error, "[9e0b5ed3] [cdb.....] failed opening archive file!")
} }
var _cdbFileSize int var _cdbFileSize int
@ -1013,20 +1013,20 @@ func main_0 () (error) {
if _cdbFileStat, _error := _cdbFile.Stat (); _error == nil { if _cdbFileStat, _error := _cdbFile.Stat (); _error == nil {
_cdbFileSize_0 = _cdbFileStat.Size () _cdbFileSize_0 = _cdbFileStat.Size ()
} else { } else {
AbortError (_error, "[0ccf0a3b] [cdb] failed opening archive file!") AbortError (_error, "[0ccf0a3b] [cdb.....] failed opening archive file!")
} }
if _cdbFileSize_0 < 1024 { if _cdbFileSize_0 < 1024 {
AbortError (nil, "[6635a2a8] [cdb] failed opening archive: file is too small (or empty)!") AbortError (nil, "[6635a2a8] [cdb.....] failed opening archive: file is too small (or empty)!")
} }
if _cdbFileSize_0 >= (4 * 1024 * 1024 * 1024) { if _cdbFileSize_0 >= (4 * 1024 * 1024 * 1024) {
AbortError (nil, "[545bf6ce] [cdb] failed opening archive: file is too large!") AbortError (nil, "[545bf6ce] [cdb.....] failed opening archive: file is too large!")
} }
_cdbFileSize = int (_cdbFileSize_0) _cdbFileSize = int (_cdbFileSize_0)
} }
if _archivePreload { if _archivePreload {
if !_quiet { if !_quiet {
log.Printf ("[ii] [13f4ebf7] [cdb] preloading archive file...\n") log.Printf ("[ii] [13f4ebf7] [cdb.....] preloading archive file...\n")
} }
_buffer := [16 * 1024]byte {} _buffer := [16 * 1024]byte {}
_loop : for { _loop : for {
@ -1036,7 +1036,7 @@ func main_0 () (error) {
case nil : case nil :
continue _loop continue _loop
default : default :
AbortError (_error, "[a1c3b922] [cdb] failed preloading archive file...") AbortError (_error, "[a1c3b922] [cdb.....] failed preloading archive file...")
} }
} }
} }
@ -1048,29 +1048,29 @@ func main_0 () (error) {
if _archiveInmem { if _archiveInmem {
if _debug { if _debug {
log.Printf ("[ii] [216e584b] [cdb] opening memory-loaded archive...\n") log.Printf ("[ii] [216e584b] [cdb.....] opening memory-loaded archive...\n")
} }
_cdbData = make ([]byte, _cdbFileSize) _cdbData = make ([]byte, _cdbFileSize)
if _, _error := io.ReadFull (_cdbFile, _cdbData); _error != nil { if _, _error := io.ReadFull (_cdbFile, _cdbData); _error != nil {
AbortError (_error, "[73039784] [cdb] failed loading archive file!") AbortError (_error, "[73039784] [cdb.....] failed loading archive file!")
} }
} else if _archiveMmap { } else if _archiveMmap {
if _debug { if _debug {
log.Printf ("[ii] [f47fae8a] [cdb] opening memory-mapped archive...\n") log.Printf ("[ii] [f47fae8a] [cdb.....] opening memory-mapped archive...\n")
} }
if _cdbData_0, _error := syscall.Mmap (int (_cdbFile.Fd ()), 0, int (_cdbFileSize), syscall.PROT_READ, syscall.MAP_SHARED); _error == nil { if _cdbData_0, _error := syscall.Mmap (int (_cdbFile.Fd ()), 0, int (_cdbFileSize), syscall.PROT_READ, syscall.MAP_SHARED); _error == nil {
_cdbData = _cdbData_0 _cdbData = _cdbData_0
} else { } else {
AbortError (_error, "[c0e2632c] [cdb] failed mapping archive file!") AbortError (_error, "[c0e2632c] [cdb.....] failed mapping archive file!")
} }
if _archivePreload { if _archivePreload {
if _debug { if _debug {
log.Printf ("[ii] [d96b06c9] [cdb] preloading memory-loaded archive...\n") log.Printf ("[ii] [d96b06c9] [cdb.....] preloading memory-loaded archive...\n")
} }
_buffer := [16 * 1024]byte {} _buffer := [16 * 1024]byte {}
_bufferOffset := 0 _bufferOffset := 0
@ -1087,37 +1087,37 @@ func main_0 () (error) {
} }
if _error := _cdbFile.Close (); _error != nil { if _error := _cdbFile.Close (); _error != nil {
AbortError (_error, "[5e0449c2] [cdb] failed closing archive file!") AbortError (_error, "[5e0449c2] [cdb.....] failed closing archive file!")
} }
if _cdbReader_0, _error := cdb.NewFromBufferWithHasher (_cdbData, nil); _error == nil { if _cdbReader_0, _error := cdb.NewFromBufferWithHasher (_cdbData, nil); _error == nil {
_cdbReader = _cdbReader_0 _cdbReader = _cdbReader_0
} else { } else {
AbortError (_error, "[27e4813e] [cdb] failed opening archive!") AbortError (_error, "[27e4813e] [cdb.....] failed opening archive!")
} }
} else { } else {
if !_quiet && (_debug || _isFirst) { if !_quiet && (_debug || _isFirst) {
log.Printf ("[ww] [dd697a66] [cdb] using `read`-based archive (with significant performance impact)!\n") log.Printf ("[ww] [dd697a66] [cdb.....] using `read`-based archive (with significant performance impact)!\n")
} }
if _cdbReader_0, _error := cdb.NewFromReaderWithHasher (_cdbFile, nil); _error == nil { if _cdbReader_0, _error := cdb.NewFromReaderWithHasher (_cdbFile, nil); _error == nil {
_cdbReader = _cdbReader_0 _cdbReader = _cdbReader_0
} else { } else {
AbortError (_error, "[35832022] [cdb] failed opening archive!") AbortError (_error, "[35832022] [cdb.....] failed opening archive!")
} }
} }
if _schemaVersion, _error := _cdbReader.GetWithCdbHash ([]byte (NamespaceSchemaVersion)); _error == nil { if _schemaVersion, _error := _cdbReader.GetWithCdbHash ([]byte (NamespaceSchemaVersion)); _error == nil {
if _schemaVersion == nil { if _schemaVersion == nil {
AbortError (nil, "[09316866] [cdb] missing archive schema version!") AbortError (nil, "[09316866] [cdb.....] missing archive schema version!")
} else if string (_schemaVersion) != CurrentSchemaVersion { } else if string (_schemaVersion) != CurrentSchemaVersion {
AbortError (nil, "[e6482cf7] [cdb] invalid archive schema version!") AbortError (nil, "[e6482cf7] [cdb.....] invalid archive schema version!")
} }
} else { } else {
AbortError (_error, "[87cae197] [cdb] failed opening archive!") AbortError (_error, "[87cae197] [cdb.....] failed opening archive!")
} }
} }
@ -1145,7 +1145,7 @@ func main_0 () (error) {
if _indexPaths || _indexDataMeta || _indexDataContent { if _indexPaths || _indexDataMeta || _indexDataContent {
if !_quiet { if !_quiet {
log.Printf ("[ii] [fa5338fd] [cdb] indexing archive...\n") log.Printf ("[ii] [fa5338fd] [cdb.....] indexing archive...\n")
} }
if _filesIndex, _error := _cdbReader.GetWithCdbHash ([]byte (NamespaceFilesIndex)); _error == nil { if _filesIndex, _error := _cdbReader.GetWithCdbHash ([]byte (NamespaceFilesIndex)); _error == nil {
if _filesIndex != nil { if _filesIndex != nil {
@ -1173,15 +1173,15 @@ func main_0 () (error) {
_fingerprints = _fingerprints_0 _fingerprints = _fingerprints_0
_fingerprintsSplit := bytes.IndexByte (_fingerprints, ':') _fingerprintsSplit := bytes.IndexByte (_fingerprints, ':')
if _fingerprintsSplit < 0 { if _fingerprintsSplit < 0 {
AbortError (nil, "[aa6e678f] [cdb] failed indexing archive!") AbortError (nil, "[aa6e678f] [cdb.....] failed indexing archive!")
} }
_fingerprintMeta = _fingerprints[:_fingerprintsSplit] _fingerprintMeta = _fingerprints[:_fingerprintsSplit]
_fingerprintContent = _fingerprints[_fingerprintsSplit + 1:] _fingerprintContent = _fingerprints[_fingerprintsSplit + 1:]
} else { } else {
AbortError (_error, "[460b3cf1] [cdb] failed indexing archive!") AbortError (_error, "[460b3cf1] [cdb.....] failed indexing archive!")
} }
} else { } else {
AbortError (_error, "[216f2075] [cdb] failed indexing archive!") AbortError (_error, "[216f2075] [cdb.....] failed indexing archive!")
} }
} }
if _indexPaths { if _indexPaths {
@ -1197,10 +1197,10 @@ func main_0 () (error) {
if _dataMeta != nil { if _dataMeta != nil {
_cachedDataMeta[BytesToString (_fingerprintMeta)] = _dataMeta _cachedDataMeta[BytesToString (_fingerprintMeta)] = _dataMeta
} else { } else {
AbortError (_error, "[6df556bf] [cdb] failed indexing archive!") AbortError (_error, "[6df556bf] [cdb.....] failed indexing archive!")
} }
} else { } else {
AbortError (_error, "[0d730134] [cdb] failed indexing archive!") AbortError (_error, "[0d730134] [cdb.....] failed indexing archive!")
} }
} }
} }
@ -1214,19 +1214,19 @@ func main_0 () (error) {
if _dataContent != nil { if _dataContent != nil {
_cachedDataContent[BytesToString (_fingerprintContent)] = _dataContent _cachedDataContent[BytesToString (_fingerprintContent)] = _dataContent
} else { } else {
AbortError (_error, "[4e27fe46] [cdb] failed indexing archive!") AbortError (_error, "[4e27fe46] [cdb.....] failed indexing archive!")
} }
} else { } else {
AbortError (_error, "[532845ad] [cdb] failed indexing archive!") AbortError (_error, "[532845ad] [cdb.....] failed indexing archive!")
} }
} }
} }
} }
} else { } else {
log.Printf ("[ww] [30314f31] [cdb] missing archive files index; ignoring!\n") log.Printf ("[ww] [30314f31] [cdb.....] missing archive files index; ignoring!\n")
} }
} else { } else {
AbortError (_error, "[82299b3d] [cdb] failed indexing arcdive!") AbortError (_error, "[82299b3d] [cdb.....] failed indexing arcdive!")
} }
} }
@ -1234,7 +1234,7 @@ func main_0 () (error) {
if _error := _cdbReader.Close (); _error == nil { if _error := _cdbReader.Close (); _error == nil {
_cdbReader = nil _cdbReader = nil
} else { } else {
AbortError (_error, "[d7aa79e1] [cdb] failed closing archive!") AbortError (_error, "[d7aa79e1] [cdb.....] failed closing archive!")
} }
} }
@ -1248,32 +1248,32 @@ func main_0 () (error) {
if _profileCpu != "" { if _profileCpu != "" {
log.Printf ("[ii] [70c210f3] [pprof] profiling CPU to `%s`...\n", _profileCpu) log.Printf ("[ii] [70c210f3] [pprof...] profiling CPU to `%s`...\n", _profileCpu)
_stream, _error := os.Create (_profileCpu) _stream, _error := os.Create (_profileCpu)
if _error != nil { if _error != nil {
AbortError (_error, "[fd4e0009] [pprof] failed opening CPU profile!") AbortError (_error, "[fd4e0009] [pprof...] failed opening CPU profile!")
} }
_error = pprof.StartCPUProfile (_stream) _error = pprof.StartCPUProfile (_stream)
if _error != nil { if _error != nil {
AbortError (_error, "[ac721629] [pprof] failed starting CPU profile!") AbortError (_error, "[ac721629] [pprof...] failed starting CPU profile!")
} }
defer pprof.StopCPUProfile () defer pprof.StopCPUProfile ()
} }
if _profileMem != "" { if _profileMem != "" {
log.Printf ("[ii] [9196ee90] [pprof] profiling MEM to `%s`...\n", _profileMem) log.Printf ("[ii] [9196ee90] [pprof...] profiling MEM to `%s`...\n", _profileMem)
_stream, _error := os.Create (_profileMem) _stream, _error := os.Create (_profileMem)
if _error != nil { if _error != nil {
AbortError (_error, "[907d08b5] [pprof] failed opening MEM profile!") AbortError (_error, "[907d08b5] [pprof...] failed opening MEM profile!")
} }
_profile := pprof.Lookup ("heap") _profile := pprof.Lookup ("heap")
defer func () () { defer func () () {
runtime.GC () runtime.GC ()
if _profile != nil { if _profile != nil {
if _error := _profile.WriteTo (_stream, 0); _error != nil { if _error := _profile.WriteTo (_stream, 0); _error != nil {
AbortError (_error, "[4b1e5112] [pprof] failed writing MEM profile!") AbortError (_error, "[4b1e5112] [pprof...] failed writing MEM profile!")
} }
} else { } else {
AbortError (nil, "[385dc8f0] [pprof] failed loading MEM profile!") AbortError (nil, "[385dc8f0] [pprof...] failed loading MEM profile!")
} }
_stream.Close () _stream.Close ()
} () } ()
@ -1341,17 +1341,17 @@ func main_0 () (error) {
if _certificate, _error := tls.LoadX509KeyPair (_tlsPublic, _tlsPrivate); _error == nil { if _certificate, _error := tls.LoadX509KeyPair (_tlsPublic, _tlsPrivate); _error == nil {
_tlsConfig.Certificates = append (_tlsConfig.Certificates, _certificate) _tlsConfig.Certificates = append (_tlsConfig.Certificates, _certificate)
} else { } else {
AbortError (_error, "[ecdf443d] [tls] failed loading TLS certificate!") AbortError (_error, "[ecdf443d] [tls.....] failed loading TLS certificate!")
} }
} }
if len (_tlsConfig.Certificates) == 0 { if len (_tlsConfig.Certificates) == 0 {
if !_quiet { if !_quiet {
log.Printf ("[ii] [344ba198] [tls] no TLS certificate specified; using self-signed!\n") log.Printf ("[ii] [344ba198] [tls.....] no TLS certificate specified; using self-signed!\n")
} }
if _certificate, _error := tls.X509KeyPair ([]byte (DefaultTlsCertificatePublic), []byte (DefaultTlsCertificatePrivate)); _error == nil { if _certificate, _error := tls.X509KeyPair ([]byte (DefaultTlsCertificatePublic), []byte (DefaultTlsCertificatePrivate)); _error == nil {
_tlsConfig.Certificates = append (_tlsConfig.Certificates, _certificate) _tlsConfig.Certificates = append (_tlsConfig.Certificates, _certificate)
} else { } else {
AbortError (_error, "[98ba6d23] [tls] failed parsing TLS certificate!") AbortError (_error, "[98ba6d23] [tls.....] failed parsing TLS certificate!")
} }
} }
} }
@ -1428,7 +1428,7 @@ func main_0 () (error) {
} }
if !_quiet { if !_quiet {
_https2Server.ErrorLog = log.New (os.Stderr, log.Prefix () + "[ee] [f734edc4] [gohttp] | ", 0) _https2Server.ErrorLog = log.New (os.Stderr, log.Prefix () + "[ee] [f734edc4] [go-http.] | ", 0)
} else { } else {
_https2Server.ErrorLog = log.New (ioutil.Discard, "", 0) _https2Server.ErrorLog = log.New (ioutil.Discard, "", 0)
} }
@ -1472,7 +1472,7 @@ func main_0 () (error) {
} }
if !_quiet { if !_quiet {
_quicServer.Server.ErrorLog = log.New (os.Stderr, log.Prefix () + "[ee] [a6af7354] [quic] | ", 0) _quicServer.Server.ErrorLog = log.New (os.Stderr, log.Prefix () + "[ee] [a6af7354] [quic-h3.] | ", 0)
} else { } else {
_quicServer.Server.ErrorLog = log.New (ioutil.Discard, "", 0) _quicServer.Server.ErrorLog = log.New (ioutil.Discard, "", 0)
} }
@ -1508,30 +1508,30 @@ func main_0 () (error) {
if !_quiet && (_debug || _isFirst) { if !_quiet && (_debug || _isFirst) {
if _bind != "" { if _bind != "" {
log.Printf ("[ii] [f11e4e37] [bind-0] listening on `http://%s/` (using FastHTTP supporting HTTP/1.1, HTTP/1.0);\n", _bind) log.Printf ("[ii] [f11e4e37] [bind-0..] listening on `http://%s/` (using FastHTTP supporting HTTP/1.1, HTTP/1.0);\n", _bind)
} }
if _bindTls != "" { if _bindTls != "" {
if !_http1Disabled && (!_http2Disabled && _bindTls2 == "") { if !_http1Disabled && (!_http2Disabled && _bindTls2 == "") {
log.Printf ("[ii] [21f050c3] [bind-1] listening on `https://%s/` (using FastHTTP supporting TLS with HTTP/1.1, HTTP/1.0, and HTTP/2 split);\n", _bindTls) log.Printf ("[ii] [21f050c3] [bind-1..] listening on `https://%s/` (using FastHTTP supporting TLS with HTTP/1.1, HTTP/1.0, and HTTP/2 split);\n", _bindTls)
} else if !_http1Disabled { } else if !_http1Disabled {
log.Printf ("[ii] [21f050c3] [bind-1] listening on `https://%s/` (using FastHTTP supporting TLS with HTTP/1.1, HTTP/1.0);\n", _bindTls) log.Printf ("[ii] [21f050c3] [bind-1..] listening on `https://%s/` (using FastHTTP supporting TLS with HTTP/1.1, HTTP/1.0);\n", _bindTls)
} else { } else {
panic ("[fc754170]") panic ("[fc754170]")
} }
} }
if _bindTls2 != "" { if _bindTls2 != "" {
if !_http1Disabled && !_http2Disabled { if !_http1Disabled && !_http2Disabled {
log.Printf ("[ii] [e7f03c99] [bind-2] listening on `https://%s/` (using Go HTTP supporting TLS with HTTP/2, HTTP/1.1, HTTP/1.0);\n", _bindTls2) log.Printf ("[ii] [e7f03c99] [bind-2..] listening on `https://%s/` (using Go HTTP supporting TLS with HTTP/2, HTTP/1.1, HTTP/1.0);\n", _bindTls2)
} else if !_http1Disabled { } else if !_http1Disabled {
log.Printf ("[ii] [477583ad] [bind-2] listening on `https://%s/` (using Go HTTP supporting TLS with HTTP/1.1, HTTP/1.0 only);\n", _bindTls2) log.Printf ("[ii] [477583ad] [bind-2..] listening on `https://%s/` (using Go HTTP supporting TLS with HTTP/1.1, HTTP/1.0 only);\n", _bindTls2)
} else if !_http2Disabled { } else if !_http2Disabled {
log.Printf ("[ii] [7d2c7ddb] [bind-2] listening on `https://%s/` (using Go HTTP supporting TLS with HTTP/2 only);\n", _bindTls2) log.Printf ("[ii] [7d2c7ddb] [bind-2..] listening on `https://%s/` (using Go HTTP supporting TLS with HTTP/2 only);\n", _bindTls2)
} else { } else {
panic ("[d784a82c]") panic ("[d784a82c]")
} }
} }
if _bindQuic != "" { if _bindQuic != "" {
log.Printf ("[ii] [b958617a] [bind-3] listening on `https://%s/` (using QUIC supporting TLS with HTTP/3 only);", _bindQuic) log.Printf ("[ii] [b958617a] [bind-3..] listening on `https://%s/` (using QUIC supporting TLS with HTTP/3 only);", _bindQuic)
} }
} }
@ -1541,7 +1541,7 @@ func main_0 () (error) {
if _listener_0, _error := reuseport.Listen ("tcp4", _bind); _error == nil { if _listener_0, _error := reuseport.Listen ("tcp4", _bind); _error == nil {
_httpListener = _listener_0 _httpListener = _listener_0
} else { } else {
AbortError (_error, "[d5f51e9f] [bind-0] failed creating TCP listener!") AbortError (_error, "[d5f51e9f] [bind-0..] failed creating TCP listener!")
} }
} }
@ -1550,7 +1550,7 @@ func main_0 () (error) {
if _listener_0, _error := reuseport.Listen ("tcp4", _bindTls); _error == nil { if _listener_0, _error := reuseport.Listen ("tcp4", _bindTls); _error == nil {
_httpsListener = _listener_0 _httpsListener = _listener_0
} else { } else {
AbortError (_error, "[e35cc693] [bind-1] failed creating TCP listener!") AbortError (_error, "[e35cc693] [bind-1..] failed creating TCP listener!")
} }
} }
@ -1559,7 +1559,7 @@ func main_0 () (error) {
if _listener_0, _error := reuseport.Listen ("tcp4", _bindTls2); _error == nil { if _listener_0, _error := reuseport.Listen ("tcp4", _bindTls2); _error == nil {
_https2Listener = _listener_0 _https2Listener = _listener_0
} else { } else {
AbortError (_error, "[63567445] [bind-2] failed creating TCP listener!") AbortError (_error, "[63567445] [bind-2..] failed creating TCP listener!")
} }
} }
@ -1568,17 +1568,17 @@ func main_0 () (error) {
if _listener_0, _error := net.ListenPacket ("udp4", _bindQuic); _error == nil { if _listener_0, _error := net.ListenPacket ("udp4", _bindQuic); _error == nil {
_quicListener = _listener_0 _quicListener = _listener_0
} else { } else {
AbortError (_error, "[3b1bfc15] [bind-3] failed creating UDP listener!") AbortError (_error, "[3b1bfc15] [bind-3..] failed creating UDP listener!")
} }
} }
var _splitListenerClose func () () var _splitListenerClose func () ()
if (_httpsListener != nil) && (_https2Listener == nil) && !_http2Disabled { if (_httpsListener != nil) && (_https2Listener == nil) && !_http2Disabled {
log.Printf ("[ii] [1098a405] [bind-1] listening on `https://%s/` (using Go HTTP supporting only HTTP/2 split);\n", _bindTls) log.Printf ("[ii] [1098a405] [bind-1..] listening on `https://%s/` (using Go HTTP supporting only HTTP/2 split);\n", _bindTls)
_tlsConfig.NextProtos = append ([]string { "h2" }, _tlsConfig.NextProtos ...) _tlsConfig.NextProtos = append ([]string { "h2" }, _tlsConfig.NextProtos ...)
if !_quiet { if !_quiet {
log.Printf ("[ii] [ba970bbb] [bind-1] advertising TLS next protocols: %s", _tlsConfig.NextProtos) log.Printf ("[ii] [ba970bbb] [bind-1..] advertising TLS next protocols: %s", _tlsConfig.NextProtos)
} }
_tlsListener := tls.NewListener (_httpsListener, _tlsConfig) _tlsListener := tls.NewListener (_httpsListener, _tlsConfig)
_httpsListener_0 := & splitListener { _httpsListener_0 := & splitListener {
@ -1591,7 +1591,7 @@ func main_0 () (error) {
} }
_splitListenerClose = func () () { _splitListenerClose = func () () {
if _error := _tlsListener.Close (); _error != nil { if _error := _tlsListener.Close (); _error != nil {
LogError (_error, "[a5bce477] [bind-1] failed closing TLS listener!") LogError (_error, "[a5bce477] [bind-1..] failed closing TLS listener!")
} }
} }
go func () () { go func () () {
@ -1601,23 +1601,23 @@ func main_0 () (error) {
_connection := _connection_0.(*tls.Conn) _connection := _connection_0.(*tls.Conn)
if _error := _connection.Handshake (); _error != nil { if _error := _connection.Handshake (); _error != nil {
if !_quiet { if !_quiet {
LogError (_error, "[d1c3dba3] [bind-1] failed negotiating TLS connection!") LogError (_error, "[d1c3dba3] [bind-1..] failed negotiating TLS connection!")
} }
} }
_protocol := _connection.ConnectionState () .NegotiatedProtocol _protocol := _connection.ConnectionState () .NegotiatedProtocol
if _protocol == "h2" { if _protocol == "h2" {
if _debug { if _debug {
log.Printf ("[dd] [df9f3e7e] [bind-1] dispatching HTTP/2 TLS connection!\n") log.Printf ("[dd] [df9f3e7e] [bind-1..] dispatching HTTP/2 TLS connection!\n")
} }
_https2Listener_0.queue <- _connection _https2Listener_0.queue <- _connection
} else if (_protocol == "http/1.1") || (_protocol == "http/1.0") || (_protocol == "") { } else if (_protocol == "http/1.1") || (_protocol == "http/1.0") || (_protocol == "") {
if _debug { if _debug {
log.Printf ("[dd] [d534c361] [bind-1] dispatching HTTP/1.x TLS connection!\n") log.Printf ("[dd] [d534c361] [bind-1..] dispatching HTTP/1.x TLS connection!\n")
} }
_httpsListener_0.queue <- _connection _httpsListener_0.queue <- _connection
} else { } else {
if !_quiet { if !_quiet {
log.Printf ("[ww] [5cc0ebde] [bind-1] unknown TLS protocol `%s`!\n", _protocol) log.Printf ("[ww] [5cc0ebde] [bind-1..] unknown TLS protocol `%s`!\n", _protocol)
} }
_connection.Close () _connection.Close ()
} }
@ -1625,7 +1625,7 @@ func main_0 () (error) {
} else if strings.Contains (_error.Error (), "use of closed network connection") { } else if strings.Contains (_error.Error (), "use of closed network connection") {
break break
} else { } else {
LogError (_error, "[04b6637f] [bind-1] failed accepting TLS connection!") LogError (_error, "[04b6637f] [bind-1..] failed accepting TLS connection!")
break break
} }
} }
@ -1635,13 +1635,13 @@ func main_0 () (error) {
} else { } else {
if _httpsListener != nil { if _httpsListener != nil {
if !_quiet { if !_quiet {
log.Printf ("[ii] [ceed854a] [bind-1] advertising TLS next protocols: %s", _tlsConfig.NextProtos) log.Printf ("[ii] [ceed854a] [bind-1..] advertising TLS next protocols: %s", _tlsConfig.NextProtos)
} }
_httpsListener = tls.NewListener (_httpsListener, _tlsConfig) _httpsListener = tls.NewListener (_httpsListener, _tlsConfig)
} }
if _https2Listener != nil { if _https2Listener != nil {
if !_quiet { if !_quiet {
log.Printf ("[ii] [8b97c977] [bind-2] advertising TLS next protocols: %s", _tls2Config.NextProtos) log.Printf ("[ii] [8b97c977] [bind-2..] advertising TLS next protocols: %s", _tls2Config.NextProtos)
} }
_https2Listener = tls.NewListener (_https2Listener, _tls2Config) _https2Listener = tls.NewListener (_https2Listener, _tls2Config)
} }
@ -1650,7 +1650,7 @@ func main_0 () (error) {
if _quicListener != nil { if _quicListener != nil {
if !_quiet { if !_quiet {
log.Printf ("[ii] [22feb826] [bind-3] advertising TLS next protocols: %s", _quicTlsConfig.NextProtos) log.Printf ("[ii] [22feb826] [bind-3..] advertising TLS next protocols: %s", _quicTlsConfig.NextProtos)
} }
} }
@ -1721,13 +1721,13 @@ func main_0 () (error) {
go func () () { go func () () {
defer _waiter.Done () defer _waiter.Done ()
if !_quiet { if !_quiet {
log.Printf ("[ii] [46ec2e41] [gohttp] starting Go HTTP server...\n") log.Printf ("[ii] [46ec2e41] [go-http.] starting Go HTTP server...\n")
} }
if _error := _server.https2Server.Serve (_https2Listener); (_error != nil) && (_error != http.ErrServerClosed) { if _error := _server.https2Server.Serve (_https2Listener); (_error != nil) && (_error != http.ErrServerClosed) {
AbortError (_error, "[9f6d28f4] [gohttp] failed executing server!") AbortError (_error, "[9f6d28f4] [go-http.] failed executing server!")
} }
if !_quiet { if !_quiet {
log.Printf ("[ii] [9a487770] [gohttp] stopped Go HTTP server;\n") log.Printf ("[ii] [9a487770] [go-http.] stopped Go HTTP server;\n")
} }
} () } ()
} }
@ -1737,13 +1737,13 @@ func main_0 () (error) {
go func () () { go func () () {
defer _waiter.Done () defer _waiter.Done ()
if !_quiet { if !_quiet {
log.Printf ("[ii] [4cf834b0] [quic] starting QUIC server...\n") log.Printf ("[ii] [4cf834b0] [quic-h3.] starting QUIC server...\n")
} }
if _error := _server.quicServer.Serve (_quicListener); (_error != nil) && (_error.Error () != "server closed") { if _error := _server.quicServer.Serve (_quicListener); (_error != nil) && (_error.Error () != "server closed") {
AbortError (_error, "[73e700c5] [quic] failed executing server!") AbortError (_error, "[73e700c5] [quic-h3.] failed executing server!")
} }
if !_quiet { if !_quiet {
log.Printf ("[ii] [0a9d72e9] [quic] stopped QUIC server;\n") log.Printf ("[ii] [0a9d72e9] [quic-h3.] stopped QUIC server;\n")
} }
} () } ()
} }
@ -1790,7 +1790,7 @@ func main_0 () (error) {
go func () () { go func () () {
defer _waiter.Done () defer _waiter.Done ()
if !_quiet { if !_quiet {
log.Printf ("[ii] [9ae5a25b] [gohttp] stopping Go HTTP server...\n") log.Printf ("[ii] [9ae5a25b] [go-http.] stopping Go HTTP server...\n")
} }
_server.https2Server.Shutdown (context.TODO ()) _server.https2Server.Shutdown (context.TODO ())
} () } ()
@ -1800,7 +1800,7 @@ func main_0 () (error) {
go func () () { go func () () {
defer _waiter.Done () defer _waiter.Done ()
if !_quiet { if !_quiet {
log.Printf ("[ii] [41dab8c2] [quic] stopping QUIC server...\n") log.Printf ("[ii] [41dab8c2] [quic-h3.] stopping QUIC server...\n")
} }
_server.quicServer.CloseGracefully (1 * time.Second) _server.quicServer.CloseGracefully (1 * time.Second)
time.Sleep (1 * time.Second) time.Sleep (1 * time.Second)
@ -1834,7 +1834,7 @@ func main_0 () (error) {
if _cdbReader != nil { if _cdbReader != nil {
_server.cdbReader = nil _server.cdbReader = nil
if _error := _cdbReader.Close (); _error != nil { if _error := _cdbReader.Close (); _error != nil {
AbortError (_error, "[a1031c39] [cdb] failed closing archive!") AbortError (_error, "[a1031c39] [cdb.....] failed closing archive!")
} }
} }

6
sources/lib/server/headers-magic.go
View file

@ -184,7 +184,7 @@ func _httpResponseWriterHeadersMagic_detect (_response http.ResponseWriter) {
case (_responsePackage == "net/http") && (_responseTypeName == "response") : { case (_responsePackage == "net/http") && (_responseTypeName == "response") : {
log.Printf ("[dd] [73f6be95] [magic] detected NetHttp1 (`%s.%s`) with type `%08x`;", _responsePackage, _responseTypeName, _responseRawType) log.Printf ("[dd] [73f6be95] [magic...] detected NetHttp1 (`%s.%s`) with type `%08x`;", _responsePackage, _responseTypeName, _responseRawType)
_handlerHeaderReflect := _responseReflect.FieldByName ("handlerHeader") _handlerHeaderReflect := _responseReflect.FieldByName ("handlerHeader")
_handlerHeaderAddress := unsafe.Pointer (_handlerHeaderReflect.UnsafeAddr ()) _handlerHeaderAddress := unsafe.Pointer (_handlerHeaderReflect.UnsafeAddr ())
@ -203,14 +203,14 @@ func _httpResponseWriterHeadersMagic_detect (_response http.ResponseWriter) {
case (_responsePackage == "net/http") && (_responseTypeName == "http2responseWriter") : { case (_responsePackage == "net/http") && (_responseTypeName == "http2responseWriter") : {
log.Printf ("[dd] [cfb457eb] [magic] detected NetHttp2 (`%s.%s`) with type `%08x`;", _responsePackage, _responseTypeName, _responseRawType) log.Printf ("[dd] [cfb457eb] [magic...] detected NetHttp2 (`%s.%s`) with type `%08x`;", _responsePackage, _responseTypeName, _responseRawType)
atomic.StoreUintptr (&_httpResponseWriterHeadersMagic_netHttp2_type, _responseRawType) atomic.StoreUintptr (&_httpResponseWriterHeadersMagic_netHttp2_type, _responseRawType)
} }
case (_responsePackage == "github.com/lucas-clemente/quic-go/http3") && (_responseTypeName == "responseWriter") : { case (_responsePackage == "github.com/lucas-clemente/quic-go/http3") && (_responseTypeName == "responseWriter") : {
log.Printf ("[dd] [90b8f7c6] [magic] detected QuicHttp3 (`%s.%s`) with type `%08x`;", _responsePackage, _responseTypeName, _responseRawType) log.Printf ("[dd] [90b8f7c6] [magic...] detected QuicHttp3 (`%s.%s`) with type `%08x`;", _responsePackage, _responseTypeName, _responseRawType)
atomic.StoreUintptr (&_httpResponseWriterHeadersMagic_quicHttp3_type, _responseRawType) atomic.StoreUintptr (&_httpResponseWriterHeadersMagic_quicHttp3_type, _responseRawType)
} }