Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add asynchronous execution #109

Merged
merged 24 commits into from
Jun 12, 2019
Merged

Add asynchronous execution #109

Changes from 1 commit
Commits
Show all changes
24 commits
Select commit Hold shift + click to select a range
1119272
Simplify load! loop slightly
iamed2 May 23, 2019
ca37d9d
Bump version to 0.10
iamed2 May 30, 2019
14b2f44
Add asynchronous execution
iamed2 May 30, 2019
6ea1c08
Don't dup the fd
iamed2 May 31, 2019
ec243fa
Add sanity checks for async connection lock
iamed2 Jun 3, 2019
93c0c5d
Add missing database user to tests
iamed2 Jun 3, 2019
4bbdcd2
Return correct socket type on Windows
iamed2 Jun 3, 2019
87ae2c8
Style fixes
iamed2 Jun 3, 2019
350f847
Fix socket int size for 32-bit
iamed2 Jun 3, 2019
cbffa5a
More async docstrings
iamed2 Jun 5, 2019
b4ee110
More async tests
iamed2 Jun 5, 2019
1c99b21
Shuffle async result processing for simpler async and locking
iamed2 Jun 7, 2019
35b440d
Tweak cancel test queries for Windows
iamed2 Jun 10, 2019
8585958
Increase testing platforms
iamed2 Jun 10, 2019
87ee664
Ignore root Manifest.toml
iamed2 Jun 10, 2019
d3c0f88
Route PQconsumeInput error message through LOGGER
iamed2 Jun 11, 2019
6f35f8d
fill --> zeros
iamed2 Jun 11, 2019
f365bcf
Base.Callable --> Function
iamed2 Jun 11, 2019
4b1213c
Remove code that sets jl_conn.async_result early
iamed2 Jun 11, 2019
53e626e
Make trywait a test-only function
iamed2 Jun 11, 2019
c2abc31
Make _async_execute shorter
iamed2 Jun 11, 2019
7f0114c
Add comment to cancel
iamed2 Jun 11, 2019
5090c12
Fix an error message check for PostgreSQL 12
iamed2 Jun 11, 2019
69a7b61
Add some documentation on asynchronous queries
iamed2 Jun 11, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 8 additions & 1 deletion src/connections.jl
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -630,4 +630,11 @@ function Base.show(io::IO, jl_conn::Connection)
end
end

socket(jl_conn::Connection) = RawFD(libpq_c.PQsocket(jl_conn.conn))
function socket(jl_conn::Connection)
socket_int = libpq_c.PQsocket(jl_conn.conn)
@static if Sys.iswindows()
Base.WindowsRawSocket(Ptr{Cvoid}(UInt64(socket_int)))
else
RawFD(socket_int)
iamed2 marked this conversation as resolved.
Show resolved Hide resolved
end
end