| /external/nist-sip/java/gov/nist/javax/sip/ |
| EventWrapper.java | 37 protected SIPTransaction transaction; field in class:EventWrapper
39 EventWrapper(EventObject sipEvent, SIPTransaction transaction) {
41 this.transaction = transaction;
|
| DialogFilter.java | 106 * @param transaction
109 SIPServerTransaction transaction) {
120 sipStack.addTransactionPendingAck(transaction);
122 transaction.sendResponse(sipResponse);
123 transaction.releaseSem();
126 transaction.releaseSem();
127 sipStack.removeTransaction(transaction);
135 * @param transaction
139 private void sendBadRequestResponse(SIPRequest sipRequest, SIPServerTransaction transaction,
150 sipStack.addTransactionPendingAck(transaction);
288 SIPServerTransaction transaction = (SIPServerTransaction) this.transactionChannel; local
1154 SIPClientTransaction transaction = (SIPClientTransaction) this.transactionChannel; local
1309 SIPClientTransaction transaction = (SIPClientTransaction) this.transactionChannel; local
[all...] |
| EventScanner.java | 144 // transaction
152 + " transaction "
153 + eventWrapper.transaction
160 // transaction already exists. If the listener chose
193 "transaction already exists! " + tx);
199 "transaction already exists!!");
205 // new transaction
206 SIPServerTransaction st = (SIPServerTransaction) eventWrapper.transaction;
210 // Set up a pointer to the transaction.
211 sipRequest.setTransaction(eventWrapper.transaction);
[all...] |
| SipProviderImpl.java | 71 import javax.sip.Transaction;
168 public void handleEvent(EventObject sipEvent, SIPTransaction transaction) {
172 + transaction + "this.sipListener = "
185 EventWrapper eventWrapper = new EventWrapper(sipEvent, transaction);
284 "Transaction already assigned to request");
286 throw new TransactionUnavailableException ("Cannot create client transaction for " + Request.ACK);
312 "Transaction already exists!");
338 "could not find existing transaction for "
349 "Cannot resolve next hop -- transaction unavailable");
352 "Cannot resolve next hop -- transaction unavailable", ex)
457 SIPServerTransaction transaction = null; local
902 SIPTransaction transaction = (SIPTransaction) transactionErrorEvent local
[all...] |
| /packages/apps/Mms/src/com/android/mms/transaction/ |
| Observer.java | 18 package com.android.mms.transaction;
21 * An interface for observing the state of a Transaction.
|
| AbstractRetryScheme.java | 18 package com.android.mms.transaction;
|
| MessageSender.java | 18 package com.android.mms.transaction;
|
| TransactionService.java | 18 package com.android.mms.transaction;
79 * the MMS transaction until the connection is established.</li>
87 * TransactionService when a Transaction is completed.
100 * when a Transaction is completed (TRANSACTION_COMPLETED_ACTION intents).
108 * when a Transaction is completed (TRANSACTION_COMPLETED_ACTION intents).
123 // How often to extend the use of the MMS APN while a transaction
129 private final ArrayList<Transaction> mProcessing = new ArrayList<Transaction>();
130 private final ArrayList<Transaction> mPending = new ArrayList<Transaction>();
373 Transaction transaction = (Transaction) observable; local
530 Transaction transaction = null; local
[all...] |
| PrivilegedSmsReceiver.java | 17 package com.android.mms.transaction;
|
| /external/webkit/WebCore/storage/ |
| ChangeVersionWrapper.cpp | 42 bool ChangeVersionWrapper::performPreflight(SQLTransaction* transaction)
44 ASSERT(transaction && transaction->database());
48 if (!transaction->database()->getVersionFromDatabase(actualVersion)) {
63 bool ChangeVersionWrapper::performPostflight(SQLTransaction* transaction)
65 ASSERT(transaction && transaction->database());
67 if (!transaction->database()->setVersionInDatabase(m_newVersion)) {
73 transaction->database()->setExpectedVersion(m_newVersion);
|
| SQLTransactionClient.cpp | 48 void SQLTransactionClient::didCommitTransaction(SQLTransaction* transaction)
50 ASSERT(currentThread() == transaction->database()->scriptExecutionContext()->databaseThread()->getThreadID());
51 Database* database = transaction->database();
56 void SQLTransactionClient::didExecuteStatement(SQLTransaction* transaction)
58 ASSERT(currentThread() == transaction->database()->scriptExecutionContext()->databaseThread()->getThreadID());
61 manager.markDatabase(transaction->database());
64 bool SQLTransactionClient::didExceedQuota(SQLTransaction* transaction)
66 ASSERT(transaction->database()->scriptExecutionContext()->isContextThread());
67 Database* database = transaction->database();
|
| SQLTransactionCoordinator.cpp | 46 static String getDatabaseIdentifier(SQLTransaction* transaction)
48 Database* database = transaction->database();
73 void SQLTransactionCoordinator::acquireLock(SQLTransaction* transaction)
75 String dbIdentifier = getDatabaseIdentifier(transaction);
84 info.pendingTransactions.append(transaction);
88 void SQLTransactionCoordinator::releaseLock(SQLTransaction* transaction)
93 String dbIdentifier = getDatabaseIdentifier(transaction);
99 if (transaction->isReadOnly()) {
100 ASSERT(info.activeReadTransactions.contains(transaction));
101 info.activeReadTransactions.remove(transaction);
[all...] |
| /external/webkit/WebCore/storage/chromium/ |
| SQLTransactionClientChromium.cpp | 64 void SQLTransactionClient::didCommitTransaction(SQLTransaction* transaction)
66 ASSERT(currentThread() == transaction->database()->scriptExecutionContext()->databaseThread()->getThreadID());
67 if (!transaction->isReadOnly()) {
68 transaction->database()->scriptExecutionContext()->postTask(NotifyDatabaseChangedTask::create(transaction->database()));
72 void SQLTransactionClient::didExecuteStatement(SQLTransaction* transaction)
76 ASSERT(currentThread() == transaction->database()->scriptExecutionContext()->databaseThread()->getThreadID());
79 bool SQLTransactionClient::didExceedQuota(SQLTransaction* transaction)
83 ASSERT(transaction->database()->scriptExecutionContext()->isContextThread());
|
| /external/dbus/bus/ |
| driver.h | 32 BusTransaction *transaction,
37 BusTransaction *transaction,
41 BusTransaction *transaction,
46 BusTransaction *transaction,
|
| activation.h | 39 BusTransaction *transaction,
46 BusTransaction *transaction,
54 BusTransaction *transaction,
|
| services.h | 45 BusTransaction *transaction,
58 BusTransaction *transaction,
64 BusTransaction *transaction,
74 BusTransaction *transaction,
78 BusTransaction *transaction,
82 BusTransaction *transaction,
|
| dispatch.h | 32 dbus_bool_t bus_dispatch_matches (BusTransaction *transaction,
|
| connection.h | 60 BusTransaction *transaction,
66 BusTransaction *transaction,
116 /* transaction API so we can send or not send a block of messages as a whole */
121 BusContext* bus_transaction_get_context (BusTransaction *transaction);
122 BusConnections* bus_transaction_get_connections (BusTransaction *transaction);
123 dbus_bool_t bus_transaction_send (BusTransaction *transaction,
126 dbus_bool_t bus_transaction_send_from_driver (BusTransaction *transaction,
129 dbus_bool_t bus_transaction_send_error_reply (BusTransaction *transaction,
133 void bus_transaction_cancel_and_free (BusTransaction *transaction);
134 void bus_transaction_execute_and_free (BusTransaction *transaction);
[all...] |
| /external/webkit/WebKitTools/Scripts/webkitpy/ |
| networktransaction_unittest.py | 38 transaction = NetworkTransaction()
39 self.assertEqual(transaction.run(lambda: 42), 42)
45 transaction = NetworkTransaction()
49 transaction.run(lambda: self._raise_exception())
65 transaction = NetworkTransaction(initial_backoff_seconds=0)
66 self.assertEqual(transaction.run(lambda: self._raise_http_error()), 42)
71 transaction = NetworkTransaction(initial_backoff_seconds=60*60, timeout_seconds=60)
75 transaction.run(lambda: self._raise_http_error())
|
| /external/chromium/net/http/ |
| http_cache_unittest.cc | 942 // Tests that disk failures after the transaction has started don't cause the
1004 // force this transaction to read from the cache
1005 MockTransaction transaction(kSimpleGET_Transaction);
1006 transaction.load_flags |= net::LOAD_ONLY_FROM_CACHE;
1010 RunTransactionTestWithLog(cache.http_cache(), transaction, log);
1035 // force this transaction to read from the cache
1036 MockTransaction transaction(kSimpleGET_Transaction);
1037 transaction.load_flags |= net::LOAD_ONLY_FROM_CACHE;
1039 MockHttpRequest request(transaction);
[all...] |
| /external/webkit/WebCore/bindings/js/ |
| JSCustomSQLStatementCallback.cpp | 58 void JSCustomSQLStatementCallback::handleEvent(SQLTransaction* transaction, SQLResultSet* resultSet, bool& raisedException)
67 args.append(toJS(exec, deprecatedGlobalObjectForPrototype(exec), transaction));
|
| JSCustomSQLStatementErrorCallback.cpp | 59 bool JSCustomSQLStatementErrorCallback::handleEvent(SQLTransaction* transaction, SQLError* error)
68 args.append(toJS(exec, deprecatedGlobalObjectForPrototype(exec), transaction));
|
| JSCustomSQLTransactionCallback.cpp | 69 void JSCustomSQLTransactionCallback::handleEvent(SQLTransaction* transaction, bool& raisedException)
78 args.append(toJS(exec, deprecatedGlobalObjectForPrototype(exec), transaction));
|
| /external/webkit/WebCore/bindings/v8/custom/ |
| V8CustomSQLStatementCallback.cpp | 55 void V8CustomSQLStatementCallback::handleEvent(SQLTransaction* transaction, SQLResultSet* resultSet, bool& raisedException)
66 toV8(transaction),
|
| V8CustomSQLStatementErrorCallback.cpp | 55 bool V8CustomSQLStatementErrorCallback::handleEvent(SQLTransaction* transaction, SQLError* error)
66 toV8(transaction),
|
