Home
last modified time | relevance | path

Searched refs:tx (Results 1 – 19 of 19) sorted by relevance

/system/libfmq/tests/
Dfmq_unit_tests.cpp343 MessageQueueSync::MemTransaction tx; in TEST_F() local
344 ASSERT_TRUE(mQueue->beginWrite(dataLen, &tx)); in TEST_F()
346 ASSERT_TRUE(tx.copyTo(data, 0 /* startIdx */, dataLen)); in TEST_F()
352 ASSERT_TRUE(mQueue->beginRead(dataLen, &tx)); in TEST_F()
354 ASSERT_TRUE(tx.copyFrom(readData, 0 /* startIdx */, dataLen)); in TEST_F()
371 MessageQueueSync::MemTransaction tx; in TEST_F() local
372 ASSERT_TRUE(mQueue->beginWrite(dataLen, &tx)); in TEST_F()
374 auto first = tx.getFirstRegion(); in TEST_F()
375 auto second = tx.getSecondRegion(); in TEST_F()
379 uint8_t* ptr = tx.getSlot(i); in TEST_F()
[all …]
Dmsgq_test_client.cpp440 MessageQueueSync::MemTransaction tx; in TEST_F() local
441 ASSERT_TRUE(mQueue->beginRead(dataLen, &tx)); in TEST_F()
443 auto first = tx.getFirstRegion(); in TEST_F()
444 auto second = tx.getSecondRegion(); in TEST_F()
486 MessageQueueSync::MemTransaction tx; in TEST_F() local
487 ASSERT_TRUE(mQueue->beginWrite(dataLen, &tx)); in TEST_F()
489 auto first = tx.getFirstRegion(); in TEST_F()
490 auto second = tx.getSecondRegion(); in TEST_F()
670 MessageQueueSync::MemTransaction tx; in TEST_F() local
671 ASSERT_TRUE(mQueue->beginWrite(mNumMessagesMax, &tx)); in TEST_F()
[all …]
/system/core/libpixelflinger/
Dpicker.cpp135 const texture_t& tx = c->state.texture[i]; in ggl_pick() local
136 if (tx.enable) { in ggl_pick()
138 t |= GGL_BUILD_NEEDS(tx.surface.format, T_FORMAT); in ggl_pick()
139 t |= GGL_BUILD_NEEDS(ggl_env_to_needs(tx.env), T_ENV); in ggl_pick()
141 if (tx.s_coord==GGL_ONE_TO_ONE && tx.t_coord==GGL_ONE_TO_ONE) { in ggl_pick()
146 t |= GGL_BUILD_NEEDS(ggl_wrap_to_needs(tx.s_wrap), T_S_WRAP); in ggl_pick()
147 t |= GGL_BUILD_NEEDS(ggl_wrap_to_needs(tx.t_wrap), T_T_WRAP); in ggl_pick()
149 if (tx.mag_filter == GGL_LINEAR) { in ggl_pick()
152 if (tx.min_filter == GGL_LINEAR) { in ggl_pick()
Dscanline.cpp717 texture_t& tx = c->state.texture[i]; in scanline() local
718 if (!tx.enable) in scanline()
720 texture_iterators_t& ti = tx.iterators; in scanline()
724 if (tx.s_coord != GGL_ONE_TO_ONE) { in scanline()
725 const int w = tx.surface.width; in scanline()
726 u = wrapping(tc[i].s, w, tx.s_wrap); in scanline()
729 u = (((tx.shade.is0>>16) + x)<<16) + FIXED_HALF; in scanline()
733 if (tx.t_coord != GGL_ONE_TO_ONE) { in scanline()
734 const int h = tx.surface.height; in scanline()
735 v = wrapping(tc[i].t, h, tx.t_wrap); in scanline()
[all …]
/system/core/trusty/storage/lib/
Dstorage.c148 struct iovec tx[3] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}, {(void *)name, strlen(name)}}; in storage_open_file() local
152 ssize_t rc = send_reqv(session, tx, 3, rx, 2); in storage_open_file()
170 struct iovec tx[2] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}}; in storage_close_file() local
173 ssize_t rc = send_reqv(_to_session(fh), tx, 2, rx, 1); in storage_close_file()
184 struct iovec tx[3] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}, {(void *)name, strlen(name)}}; in storage_delete_file() local
187 ssize_t rc = send_reqv(session, tx, 3, rx, 1); in storage_delete_file()
195 struct iovec tx[2] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}}; in _read_chunk() local
198 ssize_t rc = send_reqv(_to_session(fh), tx, 2, rx, 2); in _read_chunk()
230 struct iovec tx[3] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}, {(void *)buf, size}}; in _write_req() local
233 ssize_t rc = send_reqv(_to_session(fh), tx, 3, rx, 1); in _write_req()
[all …]
/system/bt/stack/rfcomm/
Dport_utils.cc123 memset(&p_port->tx, 0, sizeof(p_port->tx)); in port_set_defaults()
125 p_port->tx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
215 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue)) != in port_release_port()
219 p_port->tx.queue_size = 0; in port_release_port()
237 fixed_queue_free(p_port->tx.queue, nullptr); in port_release_port()
238 p_port->tx.queue = nullptr; in port_release_port()
388 bool fc = p_port->tx.peer_fc || !p_port->rfc.p_mcb || in port_flow_control_user()
390 (p_port->tx.queue_size > PORT_TX_HIGH_WM) || in port_flow_control_user()
391 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user()
393 if (p_port->tx.user_fc == fc) return (0); in port_flow_control_user()
[all …]
Dport_api.cc782 if (p_port->tx.peer_fc || !p_port->rfc.p_mcb || in port_write()
787 if ((p_port->tx.queue_size > PORT_TX_CRITICAL_WM) || in port_write()
788 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_CRITICAL_WM)) { in port_write()
789 RFCOMM_TRACE_WARNING("PORT_Write: Queue size: %d", p_port->tx.queue_size); in port_write()
802 p_port->tx.peer_fc, in port_write()
806 fixed_queue_enqueue(p_port->tx.queue, p_buf); in port_write()
807 p_port->tx.queue_size += p_buf->len; in port_write()
877 p_buf = (BT_HDR*)fixed_queue_try_peek_last(p_port->tx.queue); in PORT_WriteDataCO()
897 p_port->tx.queue_size += (uint16_t)available; in PORT_WriteDataCO()
915 if ((p_port->tx.queue_size > PORT_TX_HIGH_WM) || in PORT_WriteDataCO()
[all …]
Dport_rfc.cc860 p_port->tx.peer_fc = !enable_data; in PORT_FlowInd()
903 if (p_port->tx.queue_size > 0) { in port_rfc_send_tx_data()
905 while (!p_port->tx.peer_fc && p_port->rfc.p_mcb && in port_rfc_send_tx_data()
910 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue); in port_rfc_send_tx_data()
912 p_port->tx.queue_size -= p_buf->len; in port_rfc_send_tx_data()
917 p_port->tx.queue_size); in port_rfc_send_tx_data()
923 if (p_port->tx.queue_size == 0) { in port_rfc_send_tx_data()
1022 if (p_port->credit_tx == 0) p_port->tx.peer_fc = true; in port_get_credits()
Drfc_utils.cc383 if (p_port->tx.peer_fc) PORT_FlowInd(p_port->rfc.p_mcb, p_port->dlci, true); in rfc_inc_credit()
402 if (p_port->credit_tx == 0) p_port->tx.peer_fc = true; in rfc_dec_credit()
Dport_int.h151 tPORT_DATA tx; /* Control block for data from app to peer */ member
Drfc_port_fsm.cc767 if (new_peer_fc != p_port->tx.peer_fc) in rfc_process_msc()
/system/bt/gd/common/
Dbidi_queue.h33 …BidiQueueEnd(::bluetooth::os::IQueueEnqueue<TENQUEUE>* tx, ::bluetooth::os::IQueueDequeue<TDEQUEUE… in BidiQueueEnd() argument
34 : tx_(tx), rx_(rx) {} in BidiQueueEnd()
/system/libfmq/include/fmq/
DMessageQueueBase.h713 MemTransaction tx; in write() local
714 return beginWrite(nMessages, &tx) && tx.copyTo(data, 0 /* startIdx */, nMessages) && in write()
1049 MemTransaction tx; in read() local
1050 return beginRead(nMessages, &tx) && tx.copyFrom(data, 0 /* startIdx */, nMessages) && in read()
/system/libziparchive/cli-tests/
Dzipinfo.test52 -rw-r----- 3.0 unx 1024 tx defN 2017-06-04 08:45 d1/d2/x.txt
/system/core/liblog/tests/
Dliblog_benchmark.cpp687 log_time* tx = reinterpret_cast<log_time*>(eventData + 4 + 1); in BM_log_latency() local
688 if (ts != *tx) { in BM_log_latency()
760 log_time* tx = reinterpret_cast<log_time*>(eventData + 4 + 1); in BM_log_delay() local
761 if (ts != *tx) { in BM_log_delay()
Dliblog_test.cpp273 log_time* tx = reinterpret_cast<log_time*>(&eventData->payload.data); in TEST() local
274 if (ts == *tx) { in TEST()
276 } else if (ts1 == *tx) { in TEST()
1551 log_time tx(reinterpret_cast<char*>(&eventData->payload.data)); in count_matching_ts()
1552 if (ts != tx) continue; in count_matching_ts()
1856 log_time tx(reinterpret_cast<char*>(&eventData->payload.data)); in TEST()
1857 if (ts == tx) { in TEST()
/system/core/libpixelflinger/codeflinger/
DGGLAssembler.cpp374 int tx = scratches.obtain(); in build_scanline_prolog() local
376 AND(AL, 0, tx, Rx, imm(GGL_DITHER_MASK)); in build_scanline_prolog()
378 ADD(AL, 0, tx, tx, reg_imm(ty, LSL, GGL_DITHER_ORDER_SHIFT)); in build_scanline_prolog()
379 ORR(AL, 0, parts.count.reg, tx, reg_imm(parts.count.reg, LSL, 16)); in build_scanline_prolog()
/system/core/logcat/tests/
Dlogcat_test.cpp481 log_time* tx = reinterpret_cast<log_time*>(&t); in TEST() local
482 if (ts == *tx) { in TEST()
527 log_time* tx = reinterpret_cast<log_time*>(&t); in TEST() local
528 if (ts == *tx) { in TEST()
/system/core/logcat/
Devent.logtags107 52001 http_stats (useragent|3),(response|2|3),(processing|2|3),(tx|1|2),(rx|1|2)