Commit a3d6d29

Bogdandpgeorge

Bogdan

authored and

committed

urequests: Add timeout, passed to underlying socket if supported.

1 parent dbd8fff commit a3d6d29Copy full SHA for a3d6d29

File tree

+15

-1

lines changed

+15

-1

lines changed

Lines changed: 15 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,15 @@ def json(self):`
`34`	`34`
`35`	`35`
`36`	`36`	`def request(`
`37`		`- method, url, data=None, json=None, headers={}, stream=None, parse_headers=True, auth=None`
	`37`	`+ method,`
	`38`	`+ url,`
	`39`	`+ data=None,`
	`40`	`+ json=None,`
	`41`	`+ headers={},`
	`42`	`+ stream=None,`
	`43`	`+ auth=None,`
	`44`	`+ timeout=None,`
	`45`	`+ parse_headers=True,`
`38`	`46`	`):`
`39`	`47`	`redirect = None # redirection url, None means no redirection`
`40`	`48`	`chunked_data = data and getattr(data, "__iter__", None) and not getattr(data, "__len__", None)`
`@@ -73,6 +81,12 @@ def request(`
`73`	`81`	`resp_d = {}`
`74`	`82`
`75`	`83`	`s = usocket.socket(ai[0], usocket.SOCK_STREAM, ai[2])`
	`84`	`+`
	`85`	`+ if timeout is not None:`
	`86`	`+ # Note: settimeout is not supported on all platforms, will raise`
	`87`	`+ # an AttributeError if not available.`
	`88`	`+ s.settimeout(timeout)`
	`89`	`+`
`76`	`90`	`try:`
`77`	`91`	`s.connect(ai[-1])`
`78`	`92`	`if proto == "https:":`

Comments

(0)