Searched refs:tx (Results 1 – 8 of 8) sorted by relevance
65 void beginClientTransaction(AsyncTransaction tx) { in beginClientTransaction() argument67 tx.setTransactionInfo(nextTransactionId(), mConnection); in beginClientTransaction()68 mClientTransactions.put(tx.getId(), tx); in beginClientTransaction() local77 void endClientTransaction(AsyncTransaction tx) { in endClientTransaction() argument79 mClientTransactions.remove(tx.getId()); in endClientTransaction()85 AsyncTransaction tx = mClientTransactions.remove(p.getTransactionID()); in reassignTransactionId() local86 if(tx != null) { in reassignTransactionId()88 tx.setTransactionInfo(newId, mConnection); in reassignTransactionId()90 mClientTransactions.put(newId, tx); in reassignTransactionId()104 AsyncTransaction tx; in notifyErrorResponse() local[all …]
52 AsyncTransaction tx = new AsyncTransaction(mTransactionManager) { in addGroupMemberAsync() local63 tx.sendRequest(request); in addGroupMemberAsync()74 AsyncTransaction tx = new AsyncTransaction(mTransactionManager) { in createChatGroupAsync() local92 tx.sendRequest(primitive); in createChatGroupAsync()100 AsyncTransaction tx = new AsyncTransaction(mTransactionManager) { in deleteChatGroupAsync() local112 tx.sendRequest(request); in deleteChatGroupAsync()119 AsyncTransaction tx = new AsyncTransaction(mTransactionManager){ in inviteUserAsync() local130 tx.sendRequest(request); in inviteUserAsync()150 AsyncTransaction tx = new AsyncTransaction(mTransactionManager){ in sendInvitationResposne() local160 tx.sendRequest(response); in sendInvitationResposne()[all …]
97 AsyncTransaction tx = new AsyncTransaction(mTransactionManager) { in loadContactListsAsync() local124 tx.sendRequest(request); in loadContactListsAsync()165 AsyncTransaction tx = new AsyncTransaction(mTransactionManager){ in fetchPresence() local176 tx.sendRequest(request); in fetchPresence()237 AsyncTransaction tx = new AsyncTransaction(mTransactionManager){ in handleSubscriptionRequest() local262 tx.sendRequest(request); in handleSubscriptionRequest()294 AsyncTransaction tx = new AsyncTransaction(mTransactionManager) { in subscribeToListsAsync() local322 tx.sendRequest(request); in subscribeToListsAsync()328 SimpleAsyncTransaction tx = new SimpleAsyncTransaction(mTransactionManager, completion); in subscribeToContactsAsync() local330 tx.sendRequest(request); in subscribeToContactsAsync()[all …]
177 AsyncTransaction tx = new AsyncTransaction(tm) { in sendKeepAlive() local188 tx.sendRequest(mKeepAlivePrimitive); in sendKeepAlive()251 PendingTransaction tx = iter.next(); in removePendingTransaction() local252 if (tx.mTransId.equals(transId)) { in removePendingTransaction()264 PendingTransaction tx = iter.next(); in checkTimeout() local265 if (tx.isExpired(mReplyTimeout)) { in checkTimeout()266 notifyTimeout(tx); in checkTimeout()274 private void notifyTimeout(PendingTransaction tx) { in notifyTimeout() argument275 String transId = tx.mTransId; in notifyTimeout()
61 AsyncTransaction tx = new AsyncTransaction(mTransactionManager) { in sendMessageAsync() local72 tx.sendRequest(primitive); in sendMessageAsync()75 public void notifyServerTransaction(ServerTransaction tx) { in notifyServerTransaction() argument76 Primitive primitive = tx.getRequest(); in notifyServerTransaction()84 tx.sendResponse(response); in notifyServerTransaction()94 tx.sendStatusResponse(ImpsConstants.SUCCESS_CODE); in notifyServerTransaction()
422 AsyncTransaction tx = new SimpleAsyncTransaction(mTransactionManager, in sendLogoutRequest() local425 tx.sendRequest(logoutPrimitive); in sendLogoutRequest()635 AsyncTransaction tx = new AsyncTransaction(mTransactionManager) { in doUpdateUserPresenceAsync() local648 tx.sendRequest(request); in doUpdateUserPresenceAsync()662 AsyncTransaction tx = new AsyncTransaction(mTransactionManager){ in retrieveUserPresenceAsync() local696 tx.sendRequest(request); in retrieveUserPresenceAsync()702 AsyncTransaction tx = new SimpleAsyncTransaction(mTransactionManager, in updateClientInfoAsync() local704 tx.sendRequest(updatePresenceRequest); in updateClientInfoAsync()
312 AsyncTransaction tx = new AsyncTransaction( in negotiateCapabilityAsync() local324 tx.sendRequest(capabilityRequest); in negotiateCapabilityAsync()334 AsyncTransaction tx = new AsyncTransaction( in negotiateServiceAsync() local346 tx.sendRequest(serviceRequest); in negotiateServiceAsync()
289 AsyncTransaction tx = new AsyncTransaction(tm) { in sendKeepAlive() local300 tx.sendRequest(mKeepAlivePrimitive); in sendKeepAlive()