0001    /*
0002     The MIT License (MIT)
0003    
0004     Copyright (c) 2015 Shun Takebayashi
0005    
0006     Permission is hereby granted, free of charge, to any person obtaining a copy
0007     of this software and associated documentation files (the "Software"), to deal
0008     in the Software without restriction, including without limitation the rights
0009     to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
0010     copies of the Software, and to permit persons to whom the Software is
0011     furnished to do so, subject to the following conditions:
0012    
0013     The above copyright notice and this permission notice shall be included in all
0014     copies or substantial portions of the Software.
0015    
0016     THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
0017     IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
0018     FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
0019     AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
0020     LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
0021     OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
0022     SOFTWARE.
0023    */
0024    
0025    #if os(OSX)
0026        import Darwin
0027    #elseif os(Linux)
0028        import Glibc
0029    #endif
0030    
0031    public typealias HTTPHandler
HTTPServer.swift:52
    public func serve(handler: HTTPHandler) {
 = (HTTPRequest, HTTPResponseWriter) throws -> ()
0032    
0033    public struct HTTPServer {
0034    
0035        var socket
HTTPServer.swift:39
        self.socket = socket
HTTPServer.swift:54
            if (listen(socket.raw, 100) != 0) {
HTTPServer.swift:57
            let client = accept(socket.raw, nil, nil)
: Socket
0036        var address
HTTPServer.swift:40
        self.address = addr
HTTPServer.swift:47
        if !socket.bindAddress(&address.underlying, length: socklen_t(UInt8(sizeof(sockaddr_in)))) {
: SocketAddress
0037    
0038        public init?(socket: Socket, addr: SocketAddress) {
0039            self.socket = socket
0040            self.address = addr
0041    
0042            socket.setOption(SO_REUSEADDR, value: 1)
0043    #if !os(Linux)
0044            socket.setOption(SO_NOSIGPIPE, value: 1)
0045    #endif
0046    
0047            if !socket.bindAddress(&address.underlying, length: socklen_t(UInt8(sizeof(sockaddr_in)))) {
0048                return nil
0049            }
0050        }
0051    
0052        public func serve(handler: HTTPHandler) {
0053            while (true) {
0054                if (listen(socket.raw, 100) != 0) {
0055                    return
0056                }
0057                let client = accept(socket.raw, nil, nil)
0058                defer {
0059                    shutdown(client, Int32(SHUT_RDWR))
0060                    close(client)
0061                }
0062                do {
0063                    let reader = SocketReader(socket: Socket(raw: client))
0064                    let writer = HTTPResponseWriter(socket: client)
0065                    try handler(HTTPRequest.Parser.parse(reader), writer)
0066                }
0067                catch let ReaderError.GenericError(error: no) {
0068                    fputs("reading error: \(no)\n", stderr)
0069                }
0070                catch let WriterError.GenericError(error: no) {
0071                    fputs("writing error: \(no)\n", stderr)
0072                }
0073                catch let HTTPRequest.Parser.ParserError.InvalidRequest(details: details) {
0074                    fputs("Invalid HTTP request error: \(details)\n", stderr)
0075                }
0076                catch let e {
0077                    fputs("unknown error: \(e)\n", stderr)
0078                }
0079            }
0080        }
0081    }
0082