51 static std::string dump_packet(const char* name, const char* func, apacket* p) {  in dump_packet()  argument
52     unsigned  command = p->msg.command;  in dump_packet()
53     int       len     = p->msg.data_length;  in dump_packet()
72     if (p->msg.arg0 < 256U)  in dump_packet()
73         snprintf(arg0, sizeof arg0, "%d", p->msg.arg0);  in dump_packet()
75         snprintf(arg0, sizeof arg0, "0x%x", p->msg.arg0);  in dump_packet()
77     if (p->msg.arg1 < 256U)  in dump_packet()
78         snprintf(arg1, sizeof arg1, "%d", p->msg.arg1);  in dump_packet()
80         snprintf(arg1, sizeof arg1, "0x%x", p->msg.arg1);  in dump_packet()
84     result += dump_hex(p->data, len);  in dump_packet()
96     char* p = reinterpret_cast<char*>(ppacket);  /* really read a packet address */  in read_packet()  local
99         int r = adb_read(fd, p, len);  in read_packet()
102             p += r;  in read_packet()
122     char* p = reinterpret_cast<char*>(ppacket);  /* we really write the packet address */  in write_packet()  local
125         int r = adb_write(fd, p, len);  in write_packet()
128             p += r;  in write_packet()
142         apacket *p = 0;  in transport_socket_events()  local
143         if(read_packet(fd, t->serial, &p)){  in transport_socket_events()
146             handle_packet(p, (atransport *) _t);  in transport_socket_events()
151 void send_packet(apacket *p, atransport *t)  in send_packet()  argument
157     p->msg.magic = p->msg.command ^ 0xffffffff;  in send_packet()
159     count = p->msg.data_length;  in send_packet()
160     x = (unsigned char *) p->data;  in send_packet()
165     p->msg.data_check = sum;  in send_packet()
167     print_packet("send", p);  in send_packet()
176     if(write_packet(t->transport_socket, t->serial, &p)){  in send_packet()
196     apacket *p;  in read_transport_thread()  local
202     p = get_apacket();  in read_transport_thread()
203     p->msg.command = A_SYNC;  in read_transport_thread()
204     p->msg.arg0 = 1;  in read_transport_thread()
205     p->msg.arg1 = ++(t->sync_token);  in read_transport_thread()
206     p->msg.magic = A_SYNC ^ 0xffffffff;  in read_transport_thread()
207     if(write_packet(t->fd, t->serial, &p)) {  in read_transport_thread()
208         put_apacket(p);  in read_transport_thread()
215         p = get_apacket();  in read_transport_thread()
217         if(t->read_from_remote(p, t) == 0){  in read_transport_thread()
220             if(write_packet(t->fd, t->serial, &p)){  in read_transport_thread()
221                 put_apacket(p);  in read_transport_thread()
227             put_apacket(p);  in read_transport_thread()
233     p = get_apacket();  in read_transport_thread()
234     p->msg.command = A_SYNC;  in read_transport_thread()
235     p->msg.arg0 = 0;  in read_transport_thread()
236     p->msg.arg1 = 0;  in read_transport_thread()
237     p->msg.magic = A_SYNC ^ 0xffffffff;  in read_transport_thread()
238     if(write_packet(t->fd, t->serial, &p)) {  in read_transport_thread()
239         put_apacket(p);  in read_transport_thread()
253     apacket *p;  in write_transport_thread()  local
262         if(read_packet(t->fd, t->serial, &p)) {  in write_transport_thread()
267         if(p->msg.command == A_SYNC){  in write_transport_thread()
268             if(p->msg.arg0 == 0) {  in write_transport_thread()
270                 put_apacket(p);  in write_transport_thread()
273                 if(p->msg.arg1 == t->sync_token) {  in write_transport_thread()
278                       t->serial, p->msg.arg1, t->sync_token);  in write_transport_thread()
284                 t->write_to_remote(p, t);  in write_transport_thread()
290         put_apacket(p);  in write_transport_thread()
363 device_tracker_enqueue( asocket*  socket, apacket*  p )  in device_tracker_enqueue()  argument
366     put_apacket(p);  in device_tracker_enqueue()
372     apacket* p = get_apacket();  in device_tracker_send()  local
375     snprintf(reinterpret_cast<char*>(p->data), 5, "%04x", static_cast<int>(string.size()));  in device_tracker_send()
376     memcpy(&p->data[4], string.data(), string.size());  in device_tracker_send()
377     p->len = 4 + string.size();  in device_tracker_send()
378     return peer->enqueue(peer, p);  in device_tracker_send()
444     char *p   = (char*)m;  in transport_read_action()  local
449         r = adb_read(fd, p, len);  in transport_read_action()
452             p   += r;  in transport_read_action()
464     char *p   = (char*)m;  in transport_write_action()  local
469         r = adb_write(fd, p, len);  in transport_write_action()
472             p   += r;  in transport_write_action()
886     for (const char* p = value; *p; ++p) {  in append_transport_info()  local
887         result->push_back((!sanitize || isalnum(*p)) ? *p : '_');  in append_transport_info()
1038 int check_header(apacket *p, atransport *t)  in check_header()  argument
1040     if(p->msg.magic != (p->msg.command ^ 0xffffffff)) {  in check_header()
1045     if(p->msg.data_length > t->get_max_payload()) {  in check_header()
1046         VLOG(RWX) << "check_header(): " << p->msg.data_length << " atransport::max_payload = "  in check_header()
1054 int check_data(apacket *p)  in check_data()  argument
1059     count = p->msg.data_length;  in check_data()
1060     x = p->data;  in check_data()
1066     if(sum != p->msg.data_check) {  in check_data()