(session *Session, handleID string, handle *QueryHandle)
| 135 | } |
| 136 | |
| 137 | func addQueryHandle(session *Session, handleID string, handle *QueryHandle) bool { |
| 138 | session.mu.Lock() |
| 139 | defer session.mu.Unlock() |
| 140 | if session.closed { |
| 141 | return false |
| 142 | } |
| 143 | session.queries[handleID] = handle |
| 144 | return true |
| 145 | } |
| 146 | |
| 147 | func addTrackedTransaction(session *Session, txnKey string, ttx *trackedTx) bool { |
| 148 | session.mu.Lock() |
no outgoing calls