dolysis
/
go-ipp
3
0
Fork 0
Code Issues Pull Requests Releases Activity

socket: make retry a public field so it can be changed

This commit is contained in:
Kory Prince 2021-04-27 10:37:02 -05:00
parent c951de4acf
commit b20b6caad7
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
adapter-socket.go
View File

@ -20,14 +20,15 @@ var (
DefaultCertSearchPaths = []string{"/etc/cups/certs/0", "/run/cups/certs/0"} DefaultCertSearchPaths = []string{"/etc/cups/certs/0", "/run/cups/certs/0"}
) )
const defaultRequestRetryLimit = 3 const DefaultRequestRetryLimit = 3
type SocketAdapter struct { type SocketAdapter struct {
host string host string
useTLS bool useTLS bool
SocketSearchPaths []string SocketSearchPaths []string
CertSearchPaths []string CertSearchPaths []string
requestRetryLimit int //RequestRetryLimit is the number of times a request will be retried when receiving an authorized status. This usually happens when a CUPs cert is expired, and a retry will use the newly generated cert. Default 3.
RequestRetryLimit int
} }
func NewSocketAdapter(host string, useTLS bool) *SocketAdapter { func NewSocketAdapter(host string, useTLS bool) *SocketAdapter {
@ -36,14 +37,14 @@ func NewSocketAdapter(host string, useTLS bool) *SocketAdapter {
useTLS: useTLS, useTLS: useTLS,
SocketSearchPaths: DefaultSocketSearchPaths, SocketSearchPaths: DefaultSocketSearchPaths,
CertSearchPaths: DefaultCertSearchPaths, CertSearchPaths: DefaultCertSearchPaths,
requestRetryLimit: defaultRequestRetryLimit, RequestRetryLimit: DefaultRequestRetryLimit,
} }
} }
//DoRequest performs the given IPP request to the given URL, returning the IPP response or an error if one occurred. //DoRequest performs the given IPP request to the given URL, returning the IPP response or an error if one occurred.
//Additional data will be written to an io.Writer if additionalData is not nil //Additional data will be written to an io.Writer if additionalData is not nil
func (h *SocketAdapter) SendRequest(url string, r *Request, additionalData io.Writer) (*Response, error) { func (h *SocketAdapter) SendRequest(url string, r *Request, additionalData io.Writer) (*Response, error) {
for i := 0; i < h.requestRetryLimit; i++ { for i := 0; i < h.RequestRetryLimit; i++ {
// encode request // encode request
payload, err := r.Encode() payload, err := r.Encode()
if err != nil { if err != nil {