Con Kolivas
|
e9441f2e1a
|
Drop passthrough proxy connection from stratifier
|
10 years ago |
|
Con Kolivas
|
8bb50fa058
|
Process epoll read messages before hangups and errors and add more info about the type of hang up, increasing verbosity when it's an unexpected error
|
10 years ago |
|
Con Kolivas
|
0b96be0144
|
Use non blocking receive in parse_client_msg as we check for read readiness with wait_read_select first, and there is the unlikely event the state changes
|
10 years ago |
|
Con Kolivas
|
6e7f39321d
|
We are not interested in POLLIN in wait_close but any mode of a closed socket
|
10 years ago |
|
Con Kolivas
|
2cc42376bd
|
Check also for POLLRDHUP in wait/read write select helpers
|
10 years ago |
|
Con Kolivas
|
24d89a3e72
|
Don't use MSG_WAITALL on unix sockets
|
10 years ago |
|
Con Kolivas
|
da2f62aea9
|
Pass through the downstream clients' address and server
|
10 years ago |
|
Con Kolivas
|
ae2b00842b
|
Allow unauthorised clients to send other messages till they've authorised but silently ignore them
|
10 years ago |
kanoi
|
040dddc6ec
|
ckdb - allocate seqnam with the full name and use it
|
10 years ago |
|
Con Kolivas
|
bf72ebbee6
|
Reinstate checking for zero as a return from recv for cleanly disconnected clients
|
10 years ago |
|
Con Kolivas
|
52a380a90b
|
Merge branch 'master' of bitbucket.org:ckolivas/ckpool
|
10 years ago |
|
Con Kolivas
|
70379428d6
|
Steal copied id_vals in the stratifier to avoid needing to copy them again, thus allowing opaque objects to be used as id values
|
10 years ago |
|
kanoi
|
20397ff4a4
|
Merge branch 'master' of https://bitbucket.org/ckolivas/ckpool
|
10 years ago |
|
kanoi
|
1c32d78295
|
ckdb - remove 'maybe'-not warnings by NULLing variables
|
10 years ago |
|
Con Kolivas
|
75d24d1d07
|
Reference clients in the epoll list by their client id to avoid double lookup and possible wrong client selection
|
10 years ago |
|
Con Kolivas
|
88fcb55faa
|
Revert "Check clients match in epoll loop"
This reverts commit b50f2ba86c.
Wrong
|
10 years ago |
|
Con Kolivas
|
138f5f99ac
|
Merge branch 'master' of bitbucket.org:ckolivas/ckpool
|
10 years ago |
|
Con Kolivas
|
b50f2ba86c
|
Check clients match in epoll loop
|
10 years ago |
|
Con Kolivas
|
e012108280
|
Explicitly check for EPOLLRDHUP as well
|
10 years ago |
|
kanoi
|
a83c283b1f
|
ckdb - report the set number of new seqsets
|
10 years ago |
|
kanoi
|
c43375e1ac
|
ckdb - text typo
|
10 years ago |
|
kanoi
|
3a8b793fbb
|
Merge branch 'master' of https://bitbucket.org/ckolivas/ckpool
|
10 years ago |
|
kanoi
|
1d25cb88b0
|
ckdb - ensure expected duplicates are debug only and don't stop the reload early
|
10 years ago |
|
ckolivas
|
91d2aca51f
|
Detect pollhup in wait_read_select and not through recv fail conditions
|
10 years ago |
|
ckolivas
|
57e3aa83c6
|
Differentiate pollin from pollhup in wait_read_select
|
10 years ago |
|
ckolivas
|
8313628629
|
Differentiate ready for writes from hangups in wait_write_select
|
10 years ago |
|
ckolivas
|
49ce587949
|
nolinger client sockets when we're about to close them
|
10 years ago |
|
kanoi
|
caeee9b322
|
ckdb - add klist insert_after and general null checking to report calling line
|
10 years ago |
|
ckolivas
|
da20ac7f3e
|
Disable user of nolinger on client sockets
|
10 years ago |
|
kanoi
|
f1c6fec720
|
Merge branch 'master' of https://bitbucket.org/ckolivas/ckpool
|
10 years ago |
|
kanoi
|
19bce29d1c
|
ckdb - add a share status console report command shsta
|
10 years ago |
|
kanoi
|
fa38324af4
|
ckdb - make the terminate sequence report external
|
10 years ago |
|
Con Kolivas
|
45ea2ff4f9
|
Merge branch 'master' into multiproxy
|
10 years ago |
|
Con Kolivas
|
15a735f805
|
Broadcast in message queues instead of signalling for when there are multiple queue parsing threads
|
10 years ago |
|
kanoi
|
998a3587e4
|
ckdb - add dup inimical message
|
10 years ago |
|
kanoi
|
6fb7879a7e
|
ckdb - complete the reload to the end of the log file
|
10 years ago |
|
kanoi
|
2b225d8fec
|
Merge branch 'master' of https://bitbucket.org/ckolivas/ckpool
|
10 years ago |
|
kanoi
|
da2d33a497
|
ckdb - use safe_text_null where trailing null isn't needed
|
10 years ago |
|
kanoi
|
3bc394ffb9
|
ckdb - abort code that adds an item already in a list/store
|
10 years ago |
|
kanoi
|
15d16df1fe
|
ckdb - process/report sequence numbers and #define some db/transfer names
|
10 years ago |
|
Con Kolivas
|
690870bc92
|
Convert the proxy_loop to use unix receive queues
|
10 years ago |
|
Con Kolivas
|
24c2a4a7bf
|
Convert the generator loop to use unix receive queues
|
10 years ago |
|
Con Kolivas
|
83fee96e2c
|
Merge branch 'master' into multiproxy
Conflicts:
src/stratifier.c
|
10 years ago |
|
Con Kolivas
|
281f70e17d
|
Move inappropriate placement of ckpool definition from libckpool header
|
10 years ago |
|
Con Kolivas
|
e6c3c2a672
|
Do not wait for other end to close when sending a one way unix message with receive queues now in place
|
10 years ago |
|
Con Kolivas
|
cd754e98e4
|
Move connector to using unix receive queues
|
10 years ago |
|
Con Kolivas
|
0ea4ab043e
|
Move stratifier to use unix message receiving queues
|
10 years ago |
|
Con Kolivas
|
39a8b0ebef
|
Create general function for receiving unix messages from the receive queue
|
10 years ago |
|
Con Kolivas
|
ba7e48c492
|
Create basic unix receive message thread for queueing messages to be handled asynchronously
|
10 years ago |
|
Con Kolivas
|
3630b49d9b
|
Revert to synchronous sending of unix messages
|
10 years ago |
