- (case (read-socket-value-int8 socket)
- (#.+completed-response-message+
- (return (values :completed (read-socket-value-string socket))))
- (#.+cursor-response-message+
- (setq cursor-name (read-socket-value-string socket)))
- (#.+row-description-message+
- (let* ((count (read-socket-value-int16 socket))
- (fields
- (loop repeat count
- collect
- (list
- (read-socket-value-string socket)
- (read-socket-value-int32 socket)
- (read-socket-value-int16 socket)
- (read-socket-value-int32 socket)))))
- (return
- (values :cursor
- (make-postgresql-cursor :connection connection
- :name cursor-name
- :fields fields)))))
- (#.+copy-in-response-message+
- (return :copy-in))
- (#.+copy-out-response-message+
- (return :copy-out))
- (#.+ready-for-query-message+
- (when error
- (error error))
- (return nil))
- (#.+error-response-message+
- (let ((message (read-socket-value-string socket)))
- (setq error
- (make-condition 'postgresql-error
- :connection connection :message message))))
- (#.+notice-response-message+
- (let ((message (read-socket-value-string socket)))
- (unless (eq :ignore clsql-sys:*backend-warning-behavior*)
- (warn 'postgresql-warning
- :connection connection :message message))))
- (#.+notification-response-message+
- (let ((pid (read-socket-value-int32 socket))
- (message (read-socket-value-string socket)))
- (when (= pid (postgresql-connection-pid connection))
- (signal 'postgresql-notification :connection connection
- :message message))))
- (t
- (close-postgresql-connection connection)
- (error 'postgresql-fatal-error :connection connection
- :message "Received garbled message from backend"))))))
+ (case (read-socket-value-int8 socket)
+ (#.+completed-response-message+
+ (return (values :completed (read-socket-value-string socket))))
+ (#.+cursor-response-message+
+ (setq cursor-name (read-socket-value-string socket)))
+ (#.+row-description-message+
+ (let* ((count (read-socket-value-int16 socket))
+ (fields
+ (loop repeat count
+ collect
+ (list
+ (read-socket-value-string socket)
+ (read-socket-value-int32 socket)
+ (read-socket-value-int16 socket)
+ (read-socket-value-int32 socket)))))
+ (return
+ (values :cursor
+ (make-postgresql-cursor :connection connection
+ :name cursor-name
+ :fields fields)))))
+ (#.+copy-in-response-message+
+ (return :copy-in))
+ (#.+copy-out-response-message+
+ (return :copy-out))
+ (#.+ready-for-query-message+
+ (when error
+ (error error))
+ (return nil))
+ (#.+error-response-message+
+ (let ((message (read-socket-value-string socket)))
+ (setq error
+ (make-condition 'postgresql-error
+ :connection connection :message message))))
+ (#.+notice-response-message+
+ (let ((message (read-socket-value-string socket)))
+ (unless (eq :ignore clsql-sys:*backend-warning-behavior*)
+ (warn 'postgresql-warning
+ :connection connection :message message))))
+ (#.+notification-response-message+
+ (let ((pid (read-socket-value-int32 socket))
+ (message (read-socket-value-string socket)))
+ (when (= pid (postgresql-connection-pid connection))
+ (signal 'postgresql-notification :connection connection
+ :message message))))
+ (t
+ (close-postgresql-connection connection)
+ (error 'postgresql-fatal-error :connection connection
+ :message "Received garbled message from backend"))))))