Home
last modified time | relevance | path

Searched refs:transaction (Results 1 – 25 of 250) sorted by relevance

12345678910

/external/nist-sip/java/gov/nist/javax/sip/
DDialogFilter.java109 SIPServerTransaction transaction) { in sendRequestPendingResponse() argument
120 sipStack.addTransactionPendingAck(transaction); in sendRequestPendingResponse()
122 transaction.sendResponse(sipResponse); in sendRequestPendingResponse()
123 transaction.releaseSem(); in sendRequestPendingResponse()
126 transaction.releaseSem(); in sendRequestPendingResponse()
127 sipStack.removeTransaction(transaction); in sendRequestPendingResponse()
139 private void sendBadRequestResponse(SIPRequest sipRequest, SIPServerTransaction transaction, in sendBadRequestResponse() argument
150 sipStack.addTransactionPendingAck(transaction); in sendBadRequestResponse()
152 transaction.sendResponse(sipResponse); in sendBadRequestResponse()
153 transaction.releaseSem(); in sendBadRequestResponse()
[all …]
DSipProviderImpl.java168 public void handleEvent(EventObject sipEvent, SIPTransaction transaction) { in handleEvent() argument
172 + transaction + "this.sipListener = " in handleEvent()
185 EventWrapper eventWrapper = new EventWrapper(sipEvent, transaction); in handleEvent()
457 SIPServerTransaction transaction = null; in getNewServerTransaction() local
495 transaction = (SIPServerTransaction) ((SIPRequest) request) in getNewServerTransaction()
497 if (transaction == null) in getNewServerTransaction()
500 if (transaction.getOriginalRequest() == null) in getNewServerTransaction()
501 transaction.setOriginalRequest(sipRequest); in getNewServerTransaction()
503 sipStack.addTransaction(transaction); in getNewServerTransaction()
509 transaction.addEventListener(this); in getNewServerTransaction()
[all …]
DEventScanner.java153 + eventWrapper.transaction in deliverEvent()
206 SIPServerTransaction st = (SIPServerTransaction) eventWrapper.transaction; in deliverEvent()
211 sipRequest.setTransaction(eventWrapper.transaction); in deliverEvent()
221 "Calling listener " + eventWrapper.transaction); in deliverEvent()
231 if (eventWrapper.transaction != null) { in deliverEvent()
233 SIPDialog dialog = (SIPDialog) eventWrapper.transaction in deliverEvent()
252 if (eventWrapper.transaction != null in deliverEvent()
253 && ((SIPServerTransaction) eventWrapper.transaction) in deliverEvent()
255 ((SIPServerTransaction) eventWrapper.transaction) in deliverEvent()
259 if (eventWrapper.transaction != null) in deliverEvent()
[all …]
DEventWrapper.java37 protected SIPTransaction transaction; field in EventWrapper
39 EventWrapper(EventObject sipEvent, SIPTransaction transaction) { in EventWrapper() argument
41 this.transaction = transaction; in EventWrapper()
/external/webrtc/webrtc/base/
Dhttpserver_unittest.cc26 HttpServerTransaction* transaction; member
30 : transaction(NULL), server_closed(false), connection_closed(false) { in HttpServerMonitor()
40 ASSERT_FALSE(transaction); in OnRequest()
41 transaction = t; in OnRequest()
42 transaction->response.set_success(); in OnRequest()
43 transaction->response.setHeader(HH_CONNECTION, "Close"); in OnRequest()
46 ASSERT_EQ(transaction, t); in OnRequestComplete()
47 transaction = NULL; in OnRequestComplete()
65 EXPECT_FALSE(monitor.transaction); in CreateClientConnection()
81 ASSERT_TRUE(NULL != monitor.transaction); in TEST()
[all …]
Dhttpserver.cc55 HttpServer::Respond(HttpServerTransaction* transaction) { in Respond() argument
56 int connection_id = transaction->connection_id(); in Respond()
58 connection->Respond(transaction); in Respond()
60 delete transaction; in Respond()
148 HttpServer::Connection::Respond(HttpServerTransaction* transaction) { in Respond() argument
150 current_ = transaction; in Respond()
210 HttpServerTransaction* transaction = current_; in onHttpComplete() local
212 server_->SignalHttpRequest(server_, transaction); in onHttpComplete()
Dhttpclient.h64 HttpTransaction* transaction = NULL);
104 HttpTransaction* transaction() { return transaction_; } in transaction() function
105 const HttpTransaction* transaction() const { return transaction_; } in transaction() function
188 HttpTransaction* transaction = NULL);
/external/dbus/bus/
Ddriver.c43 BusTransaction *transaction,
50 BusTransaction *transaction, in bus_driver_send_service_owner_changed() argument
87 retval = bus_dispatch_matches (transaction, NULL, NULL, message, error); in bus_driver_send_service_owner_changed()
101 BusTransaction *transaction, in bus_driver_send_service_lost() argument
128 if (!bus_transaction_send_from_driver (transaction, connection, message)) in bus_driver_send_service_lost()
144 BusTransaction *transaction, in bus_driver_send_service_acquired() argument
171 if (!bus_transaction_send_from_driver (transaction, connection, message)) in bus_driver_send_service_acquired()
246 BusTransaction *transaction, in bus_driver_handle_hello() argument
309 if (!bus_driver_send_welcome_message (connection, message, transaction, error)) in bus_driver_handle_hello()
314 &unique_name, connection, 0, transaction, error); in bus_driver_handle_hello()
[all …]
Dconnection.c216 BusTransaction *transaction; in bus_connection_disconnected() local
223 while ((transaction = bus_transaction_new (d->connections->context)) == NULL) in bus_connection_disconnected()
227 transaction, &error)) in bus_connection_disconnected()
234 bus_transaction_cancel_and_free (transaction); in bus_connection_disconnected()
246 bus_transaction_execute_and_free (transaction); in bus_connection_disconnected()
1497 BusTransaction *transaction, in bus_pending_reply_send_no_reply() argument
1526 if (!bus_transaction_send_from_driver (transaction, pending->will_get_reply, in bus_pending_reply_send_no_reply()
1544 BusTransaction *transaction; in bus_pending_reply_expired() local
1557 transaction = bus_transaction_new (connections->context); in bus_pending_reply_expired()
1558 if (transaction == NULL) in bus_pending_reply_expired()
[all …]
Dconnection.h61 BusTransaction *transaction,
67 BusTransaction *transaction,
122 BusContext* bus_transaction_get_context (BusTransaction *transaction);
123 BusConnections* bus_transaction_get_connections (BusTransaction *transaction);
124 dbus_bool_t bus_transaction_send (BusTransaction *transaction,
127 dbus_bool_t bus_transaction_send_from_driver (BusTransaction *transaction,
130 dbus_bool_t bus_transaction_send_error_reply (BusTransaction *transaction,
134 void bus_transaction_cancel_and_free (BusTransaction *transaction);
135 void bus_transaction_execute_and_free (BusTransaction *transaction);
136 dbus_bool_t bus_transaction_add_cancel_hook (BusTransaction *transaction,
Dservices.c245 BusTransaction *transaction, in bus_registry_ensure() argument
253 _dbus_assert (transaction != NULL); in bus_registry_ensure()
285 transaction, error)) in bus_registry_ensure()
292 service->name, transaction, error)) in bus_registry_ensure()
299 transaction, error)) in bus_registry_ensure()
383 BusTransaction *transaction, in bus_registry_acquire_service() argument
503 transaction, error); in bus_registry_acquire_service()
551 transaction, error)) in bus_registry_acquire_service()
567 transaction, error)) in bus_registry_acquire_service()
573 transaction, error)) in bus_registry_acquire_service()
[all …]
Dservices.h45 BusTransaction *transaction,
58 BusTransaction *transaction,
64 BusTransaction *transaction,
74 BusTransaction *transaction,
78 BusTransaction *transaction,
82 BusTransaction *transaction,
Ddriver.h32 BusTransaction *transaction,
37 BusTransaction *transaction,
41 BusTransaction *transaction,
46 BusTransaction *transaction,
Dactivation.h48 BusTransaction *transaction,
55 BusTransaction *transaction,
65 BusTransaction *transaction,
Dstats.h29 BusTransaction *transaction,
34 BusTransaction *transaction,
Dstats.c182 BusTransaction *transaction, in bus_stats_handle_get_stats() argument
194 connections = bus_transaction_get_connections (transaction); in bus_stats_handle_get_stats()
239 if (!bus_transaction_send_from_driver (transaction, connection, reply)) in bus_stats_handle_get_stats()
255 BusTransaction *transaction, in bus_stats_handle_get_connection_stats() argument
337 if (!bus_transaction_send_from_driver (transaction, caller_connection, in bus_stats_handle_get_connection_stats()
Dactivation.c1054 add_restore_pending_to_transaction (BusTransaction *transaction, in add_restore_pending_to_transaction() argument
1069 !bus_transaction_add_cancel_hook (transaction, restore_pending, d, in add_restore_pending_to_transaction()
1084 BusTransaction *transaction, in bus_activation_service_created() argument
1134 if (!bus_transaction_send_from_driver (transaction, entry->connection, message)) in bus_activation_service_created()
1157 BusTransaction *transaction, in bus_activation_send_pending_auto_activation_messages() argument
1185 if (!bus_dispatch_matches (transaction, in bus_activation_send_pending_auto_activation_messages()
1195 if (!add_restore_pending_to_transaction (transaction, pending_activation)) in bus_activation_send_pending_auto_activation_messages()
1222 BusTransaction *transaction; in try_send_activation_failure() local
1226 transaction = bus_transaction_new (activation->context); in try_send_activation_failure()
1227 if (transaction == NULL) in try_send_activation_failure()
[all …]
/external/nist-sip/java/gov/nist/javax/sip/stack/
DSIPDialog.java389 SIPServerTransaction transaction; field in SIPDialog.DialogTimerTask
391 public DialogTimerTask(SIPServerTransaction transaction) { in DialogTimerTask() argument
392 this.transaction = transaction; in DialogTimerTask()
403 SIPServerTransaction transaction = this.transaction; in runTask() local
418 if (transaction != null in runTask()
419 && transaction.getState() != javax.sip.TransactionState.TERMINATED) { in runTask()
420 transaction.raiseErrorEvent(SIPTransactionErrorEvent.TIMEOUT_ERROR); in runTask()
422 } else if ((!dialog.ackSeen) && (transaction != null)) { in runTask()
424 SIPResponse response = transaction.getLastResponse(); in runTask()
429 if (dialog.toRetransmitFinalResponse(transaction.T2)) in runTask()
[all …]
DSIPTransaction.java285 SIPTransaction transaction = SIPTransaction.this; in runTask() local
287 SIPTransactionStack sipStack = transaction.getSIPStack(); in runTask()
294 if (transaction instanceof SIPClientTransaction) { in runTask()
295 sipStack.removeTransaction(transaction); in runTask()
296 transaction.close(); in runTask()
298 } else if (transaction instanceof ServerTransaction) { in runTask()
301 sipStack.getStackLogger().logDebug("removing" + transaction); in runTask()
302 sipStack.removeTransaction(transaction); in runTask()
304 && --transaction.encapsulatedChannel.useCount <= 0) { in runTask()
306 transaction.close(); in runTask()
[all …]
DSIPTransactionStack.java628 public SIPDialog createDialog(SIPTransaction transaction) { in createDialog() argument
632 if (transaction instanceof SIPClientTransaction) { in createDialog()
633 String dialogId = ((SIPRequest) transaction.getRequest()).getDialogId(false); in createDialog()
639 retval = new SIPDialog(transaction); in createDialog()
643 retval = new SIPDialog(transaction); in createDialog()
647 retval = new SIPDialog(transaction); in createDialog()
662 public SIPDialog createDialog(SIPClientTransaction transaction, SIPResponse sipResponse) { in createDialog() argument
663 String dialogId = ((SIPRequest) transaction.getRequest()).getDialogId(false); in createDialog()
672 retval = new SIPDialog(transaction, sipResponse); in createDialog()
983 SIPTransaction transaction = (SIPTransaction) li.next(); in findCancelTransaction() local
[all …]
/external/e2fsprogs/debugfs/
Dlogdump.c345 tid_t transaction; in dump_journal() local
390 transaction = be32_to_cpu(jsb->s_sequence); in dump_journal()
394 blocknr, transaction); in dump_journal()
419 if (sequence != transaction) { in dump_journal()
422 sequence, transaction, blocknr); in dump_journal()
437 transaction); in dump_journal()
441 transaction++; in dump_journal()
449 transaction); in dump_journal()
468 tid_t transaction) in dump_descriptor_block() argument
485 "block %u:\n", transaction, blocknr); in dump_descriptor_block()
[all …]
/external/e2fsprogs/lib/ext2fs/
Dtdb.c244 struct tdb_transaction *transaction; member
1169 if ((tdb->transaction == NULL) && (tdb->map_ptr != NULL)) { in tdb_parse_data()
1341 for (el=tdb->transaction->elements_last;el;el=el->prev) { in transaction_read()
1383 return tdb->transaction->io_methods->tdb_read(tdb, off, buf, len, cv); in transaction_read()
1388 tdb->transaction->transaction_error = 1; in transaction_read()
1410 memcpy(&tdb->transaction->hash_heads[chain], buf, len); in transaction_write()
1414 for (el=tdb->transaction->elements_last;el;el=el->prev) { in transaction_write()
1458 (off+len < tdb->transaction->old_map_size || in transaction_write()
1459 off > tdb->transaction->old_map_size)) { in transaction_write()
1466 tdb->transaction->transaction_error = 1; in transaction_write()
[all …]
/external/chromium-trace/catapult/third_party/Paste/docs/modules/
Dtransaction.txt1 :mod:`paste.transaction` -- DB-API transactions
4 .. automodule:: paste.transaction
/external/autotest/client/site_tests/cellular_MbimComplianceError/
Dcontrol.ERR038 MBIM Compliance Test: Validation of error message transaction Id.
22 Validation of error message transaction Id.
/external/e2fsprogs/e2fsck/
Drevoke.c438 transaction_t *transaction) in journal_write_revoke_records() argument
457 write_one_revoke_record(journal, transaction, in journal_write_revoke_records()
476 transaction_t *transaction, in write_one_revoke_record() argument
510 header->h_sequence = htonl(transaction->t_tid); in write_one_revoke_record()
514 journal_file_buffer(descriptor, transaction, BJ_LogCtl); in write_one_revoke_record()

12345678910