OSDN Git Service

Teleca 2b changes.
[android-x86/hardware-ril.git] / libril / ril.cpp
1 /* //device/libs/telephony/ril.cpp
2 **
3 ** Copyright 2006, The Android Open Source Project
4 **
5 ** Licensed under the Apache License, Version 2.0 (the "License"); 
6 ** you may not use this file except in compliance with the License. 
7 ** You may obtain a copy of the License at 
8 **
9 **     http://www.apache.org/licenses/LICENSE-2.0 
10 **
11 ** Unless required by applicable law or agreed to in writing, software 
12 ** distributed under the License is distributed on an "AS IS" BASIS, 
13 ** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 
14 ** See the License for the specific language governing permissions and 
15 ** limitations under the License.
16 */
17
18 #define LOG_TAG "RILC"
19
20 #include <hardware_legacy/power.h>
21
22 #include <telephony/ril.h>
23 #include <telephony/ril_cdma_sms.h>
24 #include <cutils/sockets.h>
25 #include <cutils/jstring.h>
26 #include <cutils/record_stream.h>
27 #include <utils/Log.h>
28 #include <utils/SystemClock.h>
29 #include <pthread.h>
30 #include <utils/Parcel.h>
31 #include <cutils/jstring.h>
32
33 #include <sys/types.h>
34 #include <pwd.h>
35
36 #include <stdio.h>
37 #include <stdlib.h>
38 #include <stdarg.h>
39 #include <string.h>
40 #include <unistd.h>
41 #include <fcntl.h>
42 #include <time.h>
43 #include <errno.h>
44 #include <assert.h>
45 #include <ctype.h>
46 #include <alloca.h>
47 #include <sys/un.h>
48 #include <assert.h>
49 #include <netinet/in.h>
50 #include <cutils/properties.h>
51
52 #include <ril_event.h>
53
54 namespace android {
55
56 #define PHONE_PROCESS "radio"
57
58 #define SOCKET_NAME_RIL "rild"
59 #define SOCKET_NAME_RIL_DEBUG "rild-debug"
60
61 #define ANDROID_WAKE_LOCK_NAME "radio-interface"
62
63
64 #define PROPERTY_RIL_IMPL "gsm.version.ril-impl"
65
66 // match with constant in RIL.java
67 #define MAX_COMMAND_BYTES (8 * 1024)
68
69 // Basically: memset buffers that the client library
70 // shouldn't be using anymore in an attempt to find
71 // memory usage issues sooner.
72 #define MEMSET_FREED 1
73
74 #define NUM_ELEMS(a)     (sizeof (a) / sizeof (a)[0])
75
76 #define MIN(a,b) ((a)<(b) ? (a) : (b))
77
78 /* Constants for response types */
79 #define RESPONSE_SOLICITED 0
80 #define RESPONSE_UNSOLICITED 1
81
82 /* Negative values for private RIL errno's */
83 #define RIL_ERRNO_INVALID_RESPONSE -1
84
85 // request, response, and unsolicited msg print macro
86 #define PRINTBUF_SIZE 8096
87
88 // Enable RILC log
89 #define RILC_LOG 0
90
91 #if RILC_LOG
92     #define startRequest           sprintf(printBuf, "(")
93     #define closeRequest           sprintf(printBuf, "%s)", printBuf)
94     #define printRequest(token, req)           \
95             LOGD("[%04d]> %s %s", token, requestToString(req), printBuf)
96
97     #define startResponse           sprintf(printBuf, "%s {", printBuf)
98     #define closeResponse           sprintf(printBuf, "%s}", printBuf)
99     #define printResponse           LOGD("%s", printBuf)
100
101     #define clearPrintBuf           printBuf[0] = 0
102     #define removeLastChar          printBuf[strlen(printBuf)-1] = 0
103     #define appendPrintBuf(x...)    sprintf(printBuf, x)
104 #else
105     #define startRequest
106     #define closeRequest
107     #define printRequest(token, req)
108     #define startResponse
109     #define closeResponse
110     #define printResponse
111     #define clearPrintBuf
112     #define removeLastChar
113     #define appendPrintBuf(x...)
114 #endif
115
116 enum WakeType {DONT_WAKE, WAKE_PARTIAL};
117
118 typedef struct {
119     int requestNumber;
120     void (*dispatchFunction) (Parcel &p, struct RequestInfo *pRI);
121     int(*responseFunction) (Parcel &p, void *response, size_t responselen);
122 } CommandInfo;
123
124 typedef struct {
125     int requestNumber;
126     int (*responseFunction) (Parcel &p, void *response, size_t responselen);
127     WakeType wakeType;
128 } UnsolResponseInfo;
129
130 typedef struct RequestInfo {
131     int32_t token;      //this is not RIL_Token 
132     CommandInfo *pCI;
133     struct RequestInfo *p_next;
134     char cancelled;
135     char local;         // responses to local commands do not go back to command process
136 } RequestInfo;
137
138 typedef struct UserCallbackInfo {
139     RIL_TimedCallback p_callback;
140     void *userParam;
141     struct ril_event event;
142     struct UserCallbackInfo *p_next;
143 } UserCallbackInfo;
144
145
146 /*******************************************************************/
147
148 RIL_RadioFunctions s_callbacks = {0, NULL, NULL, NULL, NULL, NULL};
149 static int s_registerCalled = 0;
150
151 static pthread_t s_tid_dispatch;
152 static pthread_t s_tid_reader;
153 static int s_started = 0;
154
155 static int s_fdListen = -1;
156 static int s_fdCommand = -1;
157 static int s_fdDebug = -1;
158
159 static int s_fdWakeupRead;
160 static int s_fdWakeupWrite;
161
162 static struct ril_event s_commands_event;
163 static struct ril_event s_wakeupfd_event;
164 static struct ril_event s_listen_event;
165 static struct ril_event s_wake_timeout_event;
166 static struct ril_event s_debug_event;
167
168
169 static const struct timeval TIMEVAL_WAKE_TIMEOUT = {1,0};
170
171 static pthread_mutex_t s_pendingRequestsMutex = PTHREAD_MUTEX_INITIALIZER;
172 static pthread_mutex_t s_writeMutex = PTHREAD_MUTEX_INITIALIZER;
173 static pthread_mutex_t s_startupMutex = PTHREAD_MUTEX_INITIALIZER;
174 static pthread_cond_t s_startupCond = PTHREAD_COND_INITIALIZER;
175
176 static pthread_mutex_t s_dispatchMutex = PTHREAD_MUTEX_INITIALIZER;
177 static pthread_cond_t s_dispatchCond = PTHREAD_COND_INITIALIZER;
178
179 static RequestInfo *s_pendingRequests = NULL;
180
181 static RequestInfo *s_toDispatchHead = NULL;
182 static RequestInfo *s_toDispatchTail = NULL;
183
184 static UserCallbackInfo *s_last_wake_timeout_info = NULL;
185
186 static void *s_lastNITZTimeData = NULL;
187 static size_t s_lastNITZTimeDataSize;
188
189 #if RILC_LOG
190     static char printBuf[PRINTBUF_SIZE];
191 #endif
192
193 /*******************************************************************/
194
195 static void dispatchVoid (Parcel& p, RequestInfo *pRI);
196 static void dispatchString (Parcel& p, RequestInfo *pRI);
197 static void dispatchStrings (Parcel& p, RequestInfo *pRI);
198 static void dispatchInts (Parcel& p, RequestInfo *pRI);
199 static void dispatchDial (Parcel& p, RequestInfo *pRI);
200 static void dispatchSIM_IO (Parcel& p, RequestInfo *pRI);
201 static void dispatchCallForward(Parcel& p, RequestInfo *pRI);
202 static void dispatchRaw(Parcel& p, RequestInfo *pRI);
203 static void dispatchSmsWrite (Parcel &p, RequestInfo *pRI);
204
205 static void dispatchCdmaSms(Parcel &p, RequestInfo *pRI);
206 static void dispatchCdmaSmsAck(Parcel &p, RequestInfo *pRI);
207 static void dispatchBrSmsCnf(Parcel &p, RequestInfo *pRI);
208 static void dispatchCdmaBrSmsCnf(Parcel &p, RequestInfo *pRI);
209 static void dispatchRilCdmaSmsWriteArgs(Parcel &p, RequestInfo *pRI);
210 static int responseInts(Parcel &p, void *response, size_t responselen);
211 static int responseStrings(Parcel &p, void *response, size_t responselen);
212 static int responseString(Parcel &p, void *response, size_t responselen);
213 static int responseVoid(Parcel &p, void *response, size_t responselen);
214 static int responseCallList(Parcel &p, void *response, size_t responselen);
215 static int responseSMS(Parcel &p, void *response, size_t responselen);
216 static int responseSIM_IO(Parcel &p, void *response, size_t responselen);
217 static int responseCallForwards(Parcel &p, void *response, size_t responselen);
218 static int responseDataCallList(Parcel &p, void *response, size_t responselen);
219 static int responseRaw(Parcel &p, void *response, size_t responselen);
220 static int responseSsn(Parcel &p, void *response, size_t responselen);
221 static int responseSimStatus(Parcel &p, void *response, size_t responselen);
222 static int responseBrSmsCnf(Parcel &p, void *response, size_t responselen);
223 static int responseCdmaBrCnf(Parcel &p, void *response, size_t responselen);
224 static int responseCdmaSms(Parcel &p, void *response, size_t responselen);
225 static int responseCellList(Parcel &p, void *response, size_t responselen);
226 static int responseCdmaInformationRecords(Parcel &p,void *response, size_t responselen);
227 static int responseRilSignalStrength(Parcel &p,void *response, size_t responselen);
228 static int responseCallRing(Parcel &p, void *response, size_t responselen);
229 static int responseCdmaSignalInfoRecord(Parcel &p,void *response, size_t responselen);
230 static int responseCdmaCallWaiting(Parcel &p,void *response, size_t responselen);
231
232 extern "C" const char * requestToString(int request);
233 extern "C" const char * failCauseToString(RIL_Errno);
234 extern "C" const char * callStateToString(RIL_CallState);
235 extern "C" const char * radioStateToString(RIL_RadioState);
236
237 #ifdef RIL_SHLIB
238 extern "C" void RIL_onUnsolicitedResponse(int unsolResponse, void *data, 
239                                 size_t datalen);
240 #endif
241
242 static UserCallbackInfo * internalRequestTimedCallback 
243     (RIL_TimedCallback callback, void *param, 
244         const struct timeval *relativeTime);
245
246 /** Index == requestNumber */
247 static CommandInfo s_commands[] = {
248 #include "ril_commands.h"
249 };
250
251 static UnsolResponseInfo s_unsolResponses[] = {
252 #include "ril_unsol_commands.h"
253 };
254
255
256 static char *
257 strdupReadString(Parcel &p) {
258     size_t stringlen;
259     const char16_t *s16;
260             
261     s16 = p.readString16Inplace(&stringlen);
262     
263     return strndup16to8(s16, stringlen);
264 }
265
266 static void writeStringToParcel(Parcel &p, const char *s) {
267     char16_t *s16;
268     size_t s16_len;
269     s16 = strdup8to16(s, &s16_len);
270     p.writeString16(s16, s16_len);
271     free(s16);
272 }
273
274
275 static void
276 memsetString (char *s) {
277     if (s != NULL) {
278         memset (s, 0, strlen(s));
279     }
280 }
281
282 void   nullParcelReleaseFunction (const uint8_t* data, size_t dataSize,
283                                     const size_t* objects, size_t objectsSize,
284                                         void* cookie) {
285     // do nothing -- the data reference lives longer than the Parcel object
286 }
287
288 /** 
289  * To be called from dispatch thread
290  * Issue a single local request, ensuring that the response
291  * is not sent back up to the command process 
292  */
293 static void
294 issueLocalRequest(int request, void *data, int len) {
295     RequestInfo *pRI;
296     int ret;
297
298     pRI = (RequestInfo *)calloc(1, sizeof(RequestInfo));
299
300     pRI->local = 1;
301     pRI->token = 0xffffffff;        // token is not used in this context
302     pRI->pCI = &(s_commands[request]);
303
304     ret = pthread_mutex_lock(&s_pendingRequestsMutex);
305     assert (ret == 0);
306
307     pRI->p_next = s_pendingRequests;
308     s_pendingRequests = pRI;
309
310     ret = pthread_mutex_unlock(&s_pendingRequestsMutex);
311     assert (ret == 0);
312
313     LOGD("C[locl]> %s", requestToString(request));
314
315     s_callbacks.onRequest(request, data, len, pRI);
316 }
317
318
319
320 static int
321 processCommandBuffer(void *buffer, size_t buflen) {
322     Parcel p;
323     status_t status;
324     int32_t request;
325     int32_t token;
326     RequestInfo *pRI;
327     int ret;
328
329     p.setData((uint8_t *) buffer, buflen);
330
331     // status checked at end
332     status = p.readInt32(&request);
333     status = p.readInt32 (&token);
334
335     if (status != NO_ERROR) {
336         LOGE("invalid request block");
337         return 0;
338     }
339
340     if (request < 1 || request >= (int32_t)NUM_ELEMS(s_commands)) {
341         LOGE("unsupported request code %d token %d", request, token);
342         // FIXME this should perhaps return a response
343         return 0;
344     }
345
346
347     pRI = (RequestInfo *)calloc(1, sizeof(RequestInfo));
348
349     pRI->token = token;
350     pRI->pCI = &(s_commands[request]);
351
352     ret = pthread_mutex_lock(&s_pendingRequestsMutex);
353     assert (ret == 0);
354
355     pRI->p_next = s_pendingRequests;
356     s_pendingRequests = pRI;
357
358     ret = pthread_mutex_unlock(&s_pendingRequestsMutex);
359     assert (ret == 0);
360
361 /*    sLastDispatchedToken = token; */
362
363     pRI->pCI->dispatchFunction(p, pRI);    
364
365     return 0;
366 }
367
368 static void
369 invalidCommandBlock (RequestInfo *pRI) {
370     LOGE("invalid command block for token %d request %s", 
371                 pRI->token, requestToString(pRI->pCI->requestNumber));
372 }
373
374 /** Callee expects NULL */
375 static void 
376 dispatchVoid (Parcel& p, RequestInfo *pRI) {
377     clearPrintBuf;
378     printRequest(pRI->token, pRI->pCI->requestNumber);
379     s_callbacks.onRequest(pRI->pCI->requestNumber, NULL, 0, pRI);
380 }
381
382 /** Callee expects const char * */
383 static void
384 dispatchString (Parcel& p, RequestInfo *pRI) {
385     status_t status;
386     size_t datalen;
387     size_t stringlen;
388     char *string8 = NULL;
389
390     string8 = strdupReadString(p);
391
392     startRequest;
393     appendPrintBuf("%s%s", printBuf, string8);
394     closeRequest;
395     printRequest(pRI->token, pRI->pCI->requestNumber);
396
397     s_callbacks.onRequest(pRI->pCI->requestNumber, string8,
398                        sizeof(char *), pRI);
399
400 #ifdef MEMSET_FREED
401     memsetString(string8);
402 #endif
403
404     free(string8);
405     return;
406 invalid:
407     invalidCommandBlock(pRI);
408     return;
409 }
410
411 /** Callee expects const char ** */
412 static void
413 dispatchStrings (Parcel &p, RequestInfo *pRI) {
414     int32_t countStrings;
415     status_t status;
416     size_t datalen;
417     char **pStrings;
418
419     status = p.readInt32 (&countStrings);
420
421     if (status != NO_ERROR) {
422         goto invalid;
423     }
424
425     startRequest;
426     if (countStrings == 0) {
427         // just some non-null pointer
428         pStrings = (char **)alloca(sizeof(char *));
429         datalen = 0;
430     } else if (((int)countStrings) == -1) {
431         pStrings = NULL;
432         datalen = 0;
433     } else {
434         datalen = sizeof(char *) * countStrings;
435     
436         pStrings = (char **)alloca(datalen);
437
438         for (int i = 0 ; i < countStrings ; i++) {
439             pStrings[i] = strdupReadString(p);
440             appendPrintBuf("%s%s,", printBuf, pStrings[i]);
441         }
442     }
443     removeLastChar;
444     closeRequest;
445     printRequest(pRI->token, pRI->pCI->requestNumber);
446
447     s_callbacks.onRequest(pRI->pCI->requestNumber, pStrings, datalen, pRI);
448
449     if (pStrings != NULL) {
450         for (int i = 0 ; i < countStrings ; i++) {
451 #ifdef MEMSET_FREED
452             memsetString (pStrings[i]);
453 #endif
454             free(pStrings[i]);
455         }
456
457 #ifdef MEMSET_FREED
458         memset(pStrings, 0, datalen);
459 #endif
460     }
461     
462     return;
463 invalid:
464     invalidCommandBlock(pRI);
465     return;
466 }
467
468 /** Callee expects const int * */
469 static void
470 dispatchInts (Parcel &p, RequestInfo *pRI) {
471     int32_t count;
472     status_t status;
473     size_t datalen;
474     int *pInts;
475
476     status = p.readInt32 (&count);
477
478     if (status != NO_ERROR || count == 0) {
479         goto invalid;
480     }
481
482     datalen = sizeof(int) * count;
483     pInts = (int *)alloca(datalen);
484
485     startRequest;
486     for (int i = 0 ; i < count ; i++) {
487         int32_t t;
488
489         status = p.readInt32(&t);
490         pInts[i] = (int)t;
491         appendPrintBuf("%s%d,", printBuf, t);
492
493         if (status != NO_ERROR) {
494             goto invalid;
495         }
496    }
497    removeLastChar;
498    closeRequest;
499    printRequest(pRI->token, pRI->pCI->requestNumber);
500
501    s_callbacks.onRequest(pRI->pCI->requestNumber, const_cast<int *>(pInts), 
502                        datalen, pRI);
503
504 #ifdef MEMSET_FREED
505     memset(pInts, 0, datalen);
506 #endif
507
508     return;
509 invalid:
510     invalidCommandBlock(pRI);
511     return;
512 }
513
514
515 /** 
516  * Callee expects const RIL_SMS_WriteArgs * 
517  * Payload is:
518  *   int32_t status
519  *   String pdu
520  */
521 static void
522 dispatchSmsWrite (Parcel &p, RequestInfo *pRI) {
523     RIL_SMS_WriteArgs args;
524     int32_t t;
525     status_t status;
526
527     memset (&args, 0, sizeof(args));
528
529     status = p.readInt32(&t);
530     args.status = (int)t;
531
532     args.pdu = strdupReadString(p);
533
534     if (status != NO_ERROR || args.pdu == NULL) {
535         goto invalid;
536     }
537
538     args.smsc = strdupReadString(p);
539
540     startRequest;
541     appendPrintBuf("%s%d,%s,smsc=%s", printBuf, args.status,
542         (char*)args.pdu,  (char*)args.smsc);
543     closeRequest;
544     printRequest(pRI->token, pRI->pCI->requestNumber);
545     
546     s_callbacks.onRequest(pRI->pCI->requestNumber, &args, sizeof(args), pRI);
547
548 #ifdef MEMSET_FREED
549     memsetString (args.pdu);
550 #endif
551
552     free (args.pdu);
553     
554 #ifdef MEMSET_FREED
555     memset(&args, 0, sizeof(args));
556 #endif
557
558     return;
559 invalid:
560     invalidCommandBlock(pRI);
561     return;
562 }
563
564 /** 
565  * Callee expects const RIL_Dial * 
566  * Payload is:
567  *   String address
568  *   int32_t clir
569  */
570 static void
571 dispatchDial (Parcel &p, RequestInfo *pRI) {
572     RIL_Dial dial;
573     int32_t t;
574     status_t status;
575
576     memset (&dial, 0, sizeof(dial));
577
578     dial.address = strdupReadString(p);
579
580     status = p.readInt32(&t);
581     dial.clir = (int)t;
582
583     if (status != NO_ERROR || dial.address == NULL) {
584         goto invalid;
585     }
586
587     startRequest;
588     appendPrintBuf("%snum=%s,clir=%d", printBuf, dial.address, dial.clir);
589     closeRequest;
590     printRequest(pRI->token, pRI->pCI->requestNumber);
591
592     s_callbacks.onRequest(pRI->pCI->requestNumber, &dial, sizeof(dial), pRI);
593
594 #ifdef MEMSET_FREED
595     memsetString (dial.address);
596 #endif
597
598     free (dial.address);
599     
600 #ifdef MEMSET_FREED
601     memset(&dial, 0, sizeof(dial));
602 #endif
603
604     return;
605 invalid:
606     invalidCommandBlock(pRI);
607     return;
608 }
609
610 /** 
611  * Callee expects const RIL_SIM_IO * 
612  * Payload is:
613  *   int32_t command
614  *   int32_t fileid
615  *   String path
616  *   int32_t p1, p2, p3
617  *   String data 
618  *   String pin2 
619  */
620 static void
621 dispatchSIM_IO (Parcel &p, RequestInfo *pRI) {
622     RIL_SIM_IO simIO;
623     int32_t t;
624     status_t status;
625
626     memset (&simIO, 0, sizeof(simIO));
627
628     // note we only check status at the end 
629     
630     status = p.readInt32(&t);
631     simIO.command = (int)t;
632
633     status = p.readInt32(&t);
634     simIO.fileid = (int)t;
635
636     simIO.path = strdupReadString(p);
637
638     status = p.readInt32(&t);
639     simIO.p1 = (int)t;
640
641     status = p.readInt32(&t);
642     simIO.p2 = (int)t;
643
644     status = p.readInt32(&t);
645     simIO.p3 = (int)t;
646
647     simIO.data = strdupReadString(p);
648     simIO.pin2 = strdupReadString(p);
649
650     startRequest;
651     appendPrintBuf("%scmd=0x%X,efid=0x%X,path=%s,%d,%d,%d,%s,pin2=%s", printBuf,
652         simIO.command, simIO.fileid, (char*)simIO.path,
653         simIO.p1, simIO.p2, simIO.p3,
654         (char*)simIO.data,  (char*)simIO.pin2);
655     closeRequest;
656     printRequest(pRI->token, pRI->pCI->requestNumber);
657     
658     if (status != NO_ERROR) {
659         goto invalid;
660     }
661
662        s_callbacks.onRequest(pRI->pCI->requestNumber, &simIO, sizeof(simIO), pRI);
663
664 #ifdef MEMSET_FREED
665     memsetString (simIO.path);
666     memsetString (simIO.data);
667     memsetString (simIO.pin2);
668 #endif
669
670     free (simIO.path);
671     free (simIO.data);
672     free (simIO.pin2);
673     
674 #ifdef MEMSET_FREED
675     memset(&simIO, 0, sizeof(simIO));
676 #endif
677
678     return;
679 invalid:
680     invalidCommandBlock(pRI);
681     return;
682 }
683
684 /**
685  * Callee expects const RIL_CallForwardInfo *
686  * Payload is:
687  *  int32_t status/action
688  *  int32_t reason
689  *  int32_t serviceCode
690  *  int32_t toa
691  *  String number  (0 length -> null)
692  *  int32_t timeSeconds
693  */
694 static void 
695 dispatchCallForward(Parcel &p, RequestInfo *pRI) {
696     RIL_CallForwardInfo cff;
697     int32_t t;
698     status_t status;
699
700     memset (&cff, 0, sizeof(cff));
701
702     // note we only check status at the end 
703
704     status = p.readInt32(&t);
705     cff.status = (int)t;
706     
707     status = p.readInt32(&t);
708     cff.reason = (int)t;
709
710     status = p.readInt32(&t);
711     cff.serviceClass = (int)t;
712
713     status = p.readInt32(&t);
714     cff.toa = (int)t;
715
716     cff.number = strdupReadString(p);
717
718     status = p.readInt32(&t);
719     cff.timeSeconds = (int)t;
720
721     if (status != NO_ERROR) {
722         goto invalid;
723     }
724
725     // special case: number 0-length fields is null
726
727     if (cff.number != NULL && strlen (cff.number) == 0) {
728         cff.number = NULL;
729     }
730
731     startRequest;
732     appendPrintBuf("%sstat=%d,reason=%d,serv=%d,toa=%d,%s,tout=%d", printBuf,
733         cff.status, cff.reason, cff.serviceClass, cff.toa,
734         (char*)cff.number, cff.timeSeconds);
735     closeRequest;
736     printRequest(pRI->token, pRI->pCI->requestNumber);
737
738     s_callbacks.onRequest(pRI->pCI->requestNumber, &cff, sizeof(cff), pRI);
739
740 #ifdef MEMSET_FREED
741     memsetString(cff.number);
742 #endif
743
744     free (cff.number);
745
746 #ifdef MEMSET_FREED
747     memset(&cff, 0, sizeof(cff));
748 #endif
749
750     return;
751 invalid:
752     invalidCommandBlock(pRI);
753     return;
754 }
755
756
757 static void 
758 dispatchRaw(Parcel &p, RequestInfo *pRI) {
759     int32_t len;
760     status_t status;
761     const void *data;
762
763     status = p.readInt32(&len);
764
765     if (status != NO_ERROR) {
766         goto invalid;
767     }
768
769     // The java code writes -1 for null arrays
770     if (((int)len) == -1) {
771         data = NULL;
772         len = 0;
773     } 
774
775     data = p.readInplace(len);
776
777     startRequest;
778     appendPrintBuf("%sraw_size=%d", printBuf, len);
779     closeRequest;
780     printRequest(pRI->token, pRI->pCI->requestNumber);
781
782     s_callbacks.onRequest(pRI->pCI->requestNumber, const_cast<void *>(data), len, pRI);
783
784     return;
785 invalid:
786     invalidCommandBlock(pRI);
787     return;
788 }
789
790 static void 
791 dispatchCdmaSms(Parcel &p, RequestInfo *pRI) {
792     RIL_CDMA_SMS_Message rcsm;
793     int32_t  t;
794     uint8_t ut;
795     status_t status;
796     int32_t digitCount;
797     int digitLimit;
798     
799     memset(&rcsm, 0, sizeof(rcsm));
800
801     status = p.readInt32(&t);
802     rcsm.uTeleserviceID = (int) t;
803
804     status = p.read(&ut,sizeof(ut));
805     rcsm.bIsServicePresent = (uint8_t) ut;
806
807     status = p.readInt32(&t);
808     rcsm.uServicecategory = (int) t;
809
810     status = p.readInt32(&t);
811     rcsm.sAddress.digit_mode = (RIL_CDMA_SMS_DigitMode) t;
812
813     status = p.readInt32(&t);
814     rcsm.sAddress.number_mode = (RIL_CDMA_SMS_NumberMode) t;
815
816     status = p.readInt32(&t);
817     rcsm.sAddress.number_type = (RIL_CDMA_SMS_NumberType) t;
818
819     status = p.readInt32(&t);
820     rcsm.sAddress.number_plan = (RIL_CDMA_SMS_NumberPlan) t;
821
822     status = p.read(&ut,sizeof(ut));
823     rcsm.sAddress.number_of_digits= (uint8_t) ut;
824
825     digitLimit= MIN((rcsm.sAddress.number_of_digits), RIL_CDMA_SMS_ADDRESS_MAX);
826     for(digitCount =0 ; digitCount < digitLimit; digitCount ++) {
827         status = p.read(&ut,sizeof(ut));
828         rcsm.sAddress.digits[digitCount] = (uint8_t) ut;
829     }
830
831     status = p.readInt32(&t); 
832     rcsm.sSubAddress.subaddressType = (RIL_CDMA_SMS_SubaddressType) t;
833
834     status = p.read(&ut,sizeof(ut)); 
835     rcsm.sSubAddress.odd = (uint8_t) ut;
836
837     status = p.read(&ut,sizeof(ut));
838     rcsm.sSubAddress.number_of_digits = (uint8_t) ut;
839
840     digitLimit= MIN((rcsm.sSubAddress.number_of_digits), RIL_CDMA_SMS_SUBADDRESS_MAX);
841     for(digitCount =0 ; digitCount < digitLimit; digitCount ++) {   
842         status = p.read(&ut,sizeof(ut)); 
843         rcsm.sSubAddress.digits[digitCount] = (uint8_t) ut;
844     }
845
846     status = p.readInt32(&t); 
847     rcsm.uBearerDataLen = (int) t;
848
849     digitLimit= MIN((rcsm.uBearerDataLen), RIL_CDMA_SMS_BEARER_DATA_MAX);
850     for(digitCount =0 ; digitCount < digitLimit; digitCount ++) {     
851         status = p.read(&ut, sizeof(ut)); 
852         rcsm.aBearerData[digitCount] = (uint8_t) ut;
853     }
854
855     if (status != NO_ERROR) {
856         goto invalid;
857     }
858
859     startRequest;
860     appendPrintBuf("%suTeleserviceID=%d, bIsServicePresent=%d, uServicecategory=%d, \
861             sAddress.digit_mode=%d, sAddress.Number_mode=%d, sAddress.number_type=%d, ",
862             printBuf, rcsm.uTeleserviceID,rcsm.bIsServicePresent,rcsm.uServicecategory,
863             rcsm.sAddress.digit_mode, rcsm.sAddress.number_mode,rcsm.sAddress.number_type);
864     closeRequest;
865    
866     printRequest(pRI->token, pRI->pCI->requestNumber);
867
868     s_callbacks.onRequest(pRI->pCI->requestNumber, &rcsm, sizeof(rcsm),pRI);
869
870 #ifdef MEMSET_FREED
871     memset(&rcsm, 0, sizeof(rcsm));
872 #endif
873
874     return;
875
876 invalid:
877     invalidCommandBlock(pRI);
878     return;
879 }
880
881 static void 
882 dispatchCdmaSmsAck(Parcel &p, RequestInfo *pRI) {
883     RIL_CDMA_SMS_Ack rcsa;
884     int32_t  t;
885     status_t status;
886     int32_t digitCount;
887
888     memset(&rcsa, 0, sizeof(rcsa));
889
890     status = p.readInt32(&t);
891     rcsa.uErrorClass = (RIL_CDMA_SMS_ErrorClass) t;
892
893     status = p.readInt32(&t);
894     rcsa.uSMSCauseCode = (int) t;
895
896     if (status != NO_ERROR) {
897         goto invalid;
898     }
899
900     startRequest;
901     appendPrintBuf("%suErrorClass=%d, uTLStatus=%d, ",
902             printBuf, rcsa.uErrorClass, rcsa.uSMSCauseCode);
903     closeRequest;
904
905     printRequest(pRI->token, pRI->pCI->requestNumber);
906
907     s_callbacks.onRequest(pRI->pCI->requestNumber, &rcsa, sizeof(rcsa),pRI);
908
909 #ifdef MEMSET_FREED
910     memset(&rcsa, 0, sizeof(rcsa));
911 #endif
912
913     return;
914
915 invalid:
916     invalidCommandBlock(pRI);
917     return;
918 }
919
920 static void 
921 dispatchBrSmsCnf(Parcel &p, RequestInfo *pRI) {
922     RIL_BroadcastSMSConfig rbsc;
923     int32_t  t;
924     uint8_t ut;
925     status_t status;
926     int32_t digitCount;
927
928     memset(&rbsc, 0, sizeof(rbsc));
929
930     status = p.readInt32(&t);
931     rbsc.size = (int) t;
932
933     status = p.readInt32(&t);
934     rbsc.entries->uFromServiceID = (int) t;
935
936     status = p.readInt32(&t);
937     rbsc.entries->uToserviceID = (int) t;
938
939     //usage of read function on assumption that it reads any length given as 2nd argument
940     status = p.read(&ut,sizeof(ut));
941     rbsc.entries->bSelected = (uint8_t) ut;
942
943     if (status != NO_ERROR) {
944         goto invalid;
945     }
946
947     startRequest;
948     appendPrintBuf("%ssize=%d, entries.uFromServiceID=%d, \
949             entries.uToserviceID=%d, entries.bSelected =%d, ", printBuf,
950             rbsc.size,rbsc.entries->uFromServiceID, rbsc.entries->uToserviceID,
951             rbsc.entries->bSelected);
952     closeRequest;
953
954     printRequest(pRI->token, pRI->pCI->requestNumber);
955
956     s_callbacks.onRequest(pRI->pCI->requestNumber, &rbsc, sizeof(rbsc),pRI);
957
958 #ifdef MEMSET_FREED
959     memset(&rbsc, 0, sizeof(rbsc));
960 #endif
961
962     return;
963
964 invalid:
965     invalidCommandBlock(pRI);
966     return;
967
968 }
969
970 static void 
971 dispatchCdmaBrSmsCnf(Parcel &p, RequestInfo *pRI) {
972     RIL_CDMA_BroadcastSMSConfig rcbsc;
973     int32_t  t;
974     uint8_t ut;
975     status_t status;
976     int32_t digitCount;
977
978     status = p.readInt32(&t);
979     rcbsc.size = (int) t;
980
981     if (rcbsc.size != 0) {
982         RIL_CDMA_BroadcastServiceInfo cdmaBsi[rcbsc.size];
983         for (int i = 0 ; i < rcbsc.size ; i++ ) {
984             status = p.readInt32(&t);
985             cdmaBsi[i].uServiceCategory = (int) t;
986
987             status = p.readInt32(&t);
988             cdmaBsi[i].uLanguage = (int) t;
989
990             status = p.readInt32(&t);
991             cdmaBsi[i].bSelected = (uint8_t) t;
992
993             startRequest;
994             appendPrintBuf("%sentries.uServicecategory=%d, entries.uLanguage =%d, \
995                 entries.bSelected =%d, ", printBuf, cdmaBsi[i].uServiceCategory,
996                 cdmaBsi[i].uLanguage, cdmaBsi[i].bSelected);
997             closeRequest;
998         }
999         rcbsc.entries = (RIL_CDMA_BroadcastServiceInfo *)calloc(rcbsc.size,
1000                 sizeof(RIL_CDMA_BroadcastServiceInfo));
1001         memcpy(rcbsc.entries, cdmaBsi, (sizeof(RIL_CDMA_BroadcastServiceInfo) * rcbsc.size));
1002     } else {
1003         rcbsc.entries = NULL;
1004     }
1005
1006     if (status != NO_ERROR) {
1007         goto invalid;
1008     }
1009
1010     s_callbacks.onRequest(pRI->pCI->requestNumber,
1011                           &rcbsc,
1012                           (sizeof(RIL_CDMA_BroadcastServiceInfo) * rcbsc.size) + sizeof(int),
1013                           pRI);
1014
1015 #ifdef MEMSET_FREED
1016     memset(&rcbsc, 0, sizeof(rcbsc));
1017 #endif
1018
1019     return;
1020
1021 invalid:
1022     invalidCommandBlock(pRI);
1023     return;
1024
1025 }
1026
1027 static void dispatchRilCdmaSmsWriteArgs(Parcel &p, RequestInfo *pRI) {
1028     RIL_CDMA_SMS_WriteArgs rcsw;
1029     int32_t  t;
1030     uint32_t ut;
1031     uint8_t  uct;
1032     status_t status;
1033     int32_t  digitCount;
1034
1035     memset(&rcsw, 0, sizeof(rcsw));
1036
1037     status = p.readInt32(&t);
1038     rcsw.status = t;
1039     
1040     status = p.readInt32(&t);
1041     rcsw.message.uTeleserviceID = (int) t;
1042
1043     status = p.read(&uct,sizeof(uct));
1044     rcsw.message.bIsServicePresent = (uint8_t) uct;
1045
1046     status = p.readInt32(&t);
1047     rcsw.message.uServicecategory = (int) t;
1048
1049     status = p.readInt32(&t);
1050     rcsw.message.sAddress.digit_mode = (RIL_CDMA_SMS_DigitMode) t;
1051
1052     status = p.readInt32(&t);
1053     rcsw.message.sAddress.number_mode = (RIL_CDMA_SMS_NumberMode) t;
1054
1055     status = p.readInt32(&t);
1056     rcsw.message.sAddress.number_type = (RIL_CDMA_SMS_NumberType) t;
1057
1058     status = p.readInt32(&t);
1059     rcsw.message.sAddress.number_plan = (RIL_CDMA_SMS_NumberPlan) t;
1060
1061     status = p.read(&uct,sizeof(uct));
1062     rcsw.message.sAddress.number_of_digits = (uint8_t) uct;
1063
1064     for(digitCount = 0 ; digitCount < RIL_CDMA_SMS_ADDRESS_MAX; digitCount ++) {
1065         status = p.read(&uct,sizeof(uct));
1066         rcsw.message.sAddress.digits[digitCount] = (uint8_t) uct;
1067     }
1068
1069     status = p.readInt32(&t); 
1070     rcsw.message.sSubAddress.subaddressType = (RIL_CDMA_SMS_SubaddressType) t;
1071
1072     status = p.read(&uct,sizeof(uct)); 
1073     rcsw.message.sSubAddress.odd = (uint8_t) uct;
1074
1075     status = p.read(&uct,sizeof(uct));
1076     rcsw.message.sSubAddress.number_of_digits = (uint8_t) uct;
1077
1078     for(digitCount = 0 ; digitCount < RIL_CDMA_SMS_SUBADDRESS_MAX; digitCount ++) {
1079         status = p.read(&uct,sizeof(uct)); 
1080         rcsw.message.sSubAddress.digits[digitCount] = (uint8_t) uct;
1081     }
1082
1083     status = p.readInt32(&t); 
1084     rcsw.message.uBearerDataLen = (int) t;
1085
1086     for(digitCount = 0 ; digitCount < RIL_CDMA_SMS_BEARER_DATA_MAX; digitCount ++) {
1087         status = p.read(&uct, sizeof(uct)); 
1088         rcsw.message.aBearerData[digitCount] = (uint8_t) uct;
1089     }
1090
1091     if (status != NO_ERROR) {
1092         goto invalid;
1093     }
1094
1095     startRequest;
1096     appendPrintBuf("%sstatus=%d, message.uTeleserviceID=%d, message.bIsServicePresent=%d, \
1097             message.uServicecategory=%d, message.sAddress.digit_mode=%d, \
1098             message.sAddress.number_mode=%d, \
1099             message.sAddress.number_type=%d, ",
1100             printBuf, rcsw.status, rcsw.message.uTeleserviceID, rcsw.message.bIsServicePresent,
1101             rcsw.message.uServicecategory, rcsw.message.sAddress.digit_mode,
1102             rcsw.message.sAddress.number_mode,
1103             rcsw.message.sAddress.number_type);
1104     closeRequest;
1105
1106     printRequest(pRI->token, pRI->pCI->requestNumber);
1107
1108     s_callbacks.onRequest(pRI->pCI->requestNumber, &rcsw, sizeof(rcsw),pRI);
1109
1110 #ifdef MEMSET_FREED
1111     memset(&rcsw, 0, sizeof(rcsw));
1112 #endif
1113
1114     return;
1115
1116 invalid:
1117     invalidCommandBlock(pRI);
1118     return;
1119
1120 }
1121
1122 static int
1123 blockingWrite(int fd, const void *buffer, size_t len) {
1124     size_t writeOffset = 0; 
1125     const uint8_t *toWrite;
1126
1127     toWrite = (const uint8_t *)buffer;
1128
1129     while (writeOffset < len) {
1130         ssize_t written;
1131         do {
1132             written = write (fd, toWrite + writeOffset,
1133                                 len - writeOffset);
1134         } while (written < 0 && errno == EINTR);
1135
1136         if (written >= 0) {
1137             writeOffset += written;
1138         } else {   // written < 0
1139             LOGE ("RIL Response: unexpected error on write errno:%d", errno);
1140             close(fd);
1141             return -1;
1142         }
1143     }
1144
1145     return 0;
1146 }
1147
1148 static int
1149 sendResponseRaw (const void *data, size_t dataSize) {
1150     int fd = s_fdCommand;
1151     int ret;
1152     uint32_t header;
1153
1154     if (s_fdCommand < 0) {
1155         return -1;
1156     }
1157
1158     if (dataSize > MAX_COMMAND_BYTES) {
1159         LOGE("RIL: packet larger than %u (%u)",
1160                 MAX_COMMAND_BYTES, (unsigned int )dataSize);
1161
1162         return -1;
1163     }
1164     
1165
1166     // FIXME is blocking here ok? issue #550970
1167
1168     pthread_mutex_lock(&s_writeMutex);
1169
1170     header = htonl(dataSize);
1171
1172     ret = blockingWrite(fd, (void *)&header, sizeof(header));
1173
1174     if (ret < 0) {
1175         return ret;
1176     }
1177
1178     blockingWrite(fd, data, dataSize);
1179
1180     if (ret < 0) {
1181         return ret;
1182     }
1183
1184     pthread_mutex_unlock(&s_writeMutex);
1185
1186     return 0;
1187 }
1188
1189 static int
1190 sendResponse (Parcel &p) {
1191     printResponse;
1192     return sendResponseRaw(p.data(), p.dataSize());
1193 }
1194
1195 /** response is an int* pointing to an array of ints*/
1196  
1197 static int 
1198 responseInts(Parcel &p, void *response, size_t responselen) {
1199     int numInts;
1200
1201     if (response == NULL && responselen != 0) {
1202         LOGE("invalid response: NULL");
1203         return RIL_ERRNO_INVALID_RESPONSE;
1204     }
1205     if (responselen % sizeof(int) != 0) {
1206         LOGE("invalid response length %d expected multiple of %d\n", 
1207             (int)responselen, (int)sizeof(int));
1208         return RIL_ERRNO_INVALID_RESPONSE;
1209     }
1210
1211     int *p_int = (int *) response;
1212
1213     numInts = responselen / sizeof(int *);
1214     p.writeInt32 (numInts);
1215
1216     /* each int*/
1217     startResponse;
1218     for (int i = 0 ; i < numInts ; i++) {
1219         appendPrintBuf("%s%d,", printBuf, p_int[i]);
1220         p.writeInt32(p_int[i]);
1221     }
1222     removeLastChar;
1223     closeResponse;
1224
1225     return 0;
1226 }
1227
1228 /** response is a char **, pointing to an array of char *'s */
1229 static int responseStrings(Parcel &p, void *response, size_t responselen) {
1230     int numStrings;
1231     
1232     if (response == NULL && responselen != 0) {
1233         LOGE("invalid response: NULL");
1234         return RIL_ERRNO_INVALID_RESPONSE;
1235     }
1236     if (responselen % sizeof(char *) != 0) {
1237         LOGE("invalid response length %d expected multiple of %d\n", 
1238             (int)responselen, (int)sizeof(char *));
1239         return RIL_ERRNO_INVALID_RESPONSE;
1240     }
1241
1242     if (response == NULL) {
1243         p.writeInt32 (0);
1244     } else {
1245         char **p_cur = (char **) response;
1246
1247         numStrings = responselen / sizeof(char *);
1248         p.writeInt32 (numStrings);
1249
1250         /* each string*/
1251         startResponse;
1252         for (int i = 0 ; i < numStrings ; i++) {
1253             appendPrintBuf("%s%s,", printBuf, (char*)p_cur[i]);
1254             writeStringToParcel (p, p_cur[i]);
1255         }
1256         removeLastChar;
1257         closeResponse;
1258     }
1259     return 0;
1260 }
1261
1262
1263 /**
1264  * NULL strings are accepted 
1265  * FIXME currently ignores responselen
1266  */
1267 static int responseString(Parcel &p, void *response, size_t responselen) {
1268     /* one string only */
1269     startResponse;
1270     appendPrintBuf("%s%s", printBuf, (char*)response);
1271     closeResponse;
1272
1273     writeStringToParcel(p, (const char *)response);
1274
1275     return 0;
1276 }
1277
1278 static int responseVoid(Parcel &p, void *response, size_t responselen) {
1279     startResponse;
1280     removeLastChar;
1281     return 0;
1282 }
1283
1284 static int responseCallList(Parcel &p, void *response, size_t responselen) {
1285     int num;
1286
1287     if (response == NULL && responselen != 0) {
1288         LOGE("invalid response: NULL");
1289         return RIL_ERRNO_INVALID_RESPONSE;
1290     }
1291
1292     if (responselen % sizeof (RIL_Call *) != 0) {
1293         LOGE("invalid response length %d expected multiple of %d\n",
1294             (int)responselen, (int)sizeof (RIL_Call *));
1295         return RIL_ERRNO_INVALID_RESPONSE;
1296     }
1297
1298     startResponse;
1299     /* number of call info's */
1300     num = responselen / sizeof(RIL_Call *);
1301     p.writeInt32(num);
1302
1303     for (int i = 0 ; i < num ; i++) {
1304     /* NEWRIL:TODO Remove this conditional and the else clause when we have the new ril */
1305 #if NEWRIL
1306         LOGD("Compilied for NEWRIL"); // NEWRIL:TODO remove when we have the new ril
1307         RIL_Call *p_cur = ((RIL_Call **) response)[i];
1308         /* each call info */
1309         p.writeInt32(p_cur->state);
1310         p.writeInt32(p_cur->index);
1311         p.writeInt32(p_cur->toa);
1312         p.writeInt32(p_cur->isMpty);
1313         p.writeInt32(p_cur->isMT);
1314         p.writeInt32(p_cur->als);
1315         p.writeInt32(p_cur->isVoice);
1316         p.writeInt32(p_cur->isVoicePrivacy);
1317         writeStringToParcel(p, p_cur->number);
1318         p.writeInt32(p_cur->numberPresentation);
1319         writeStringToParcel(p, p_cur->name);
1320         p.writeInt32(p_cur->namePresentation);
1321         appendPrintBuf("%s[id=%d,%s,toa=%d,",
1322             printBuf,
1323             p_cur->index,
1324             callStateToString(p_cur->state),
1325             p_cur->toa);
1326         appendPrintBuf("%s%s,%s,als=%d,%s,%s,",
1327             printBuf,
1328             (p_cur->isMpty)?"conf":"norm",
1329             (p_cur->isMT)?"mt":"mo",
1330             p_cur->als,
1331             (p_cur->isVoice)?"voc":"nonvoc",
1332             (p_cur->isVoicePrivacy)?"evp":"noevp");
1333         appendPrintBuf("%s%s,cli=%d,name='%s',%d]",
1334             printBuf,
1335             p_cur->number,
1336             p_cur->numberPresentation,
1337             p_cur->name,
1338             p_cur->namePresentation);
1339 #else
1340         LOGD("Old RIL");
1341         RIL_CallOld *p_cur = ((RIL_CallOld **) response)[i];
1342         /* each call info */
1343         p.writeInt32(p_cur->state);
1344         p.writeInt32(p_cur->index);
1345         p.writeInt32(p_cur->toa);
1346         p.writeInt32(p_cur->isMpty);
1347         p.writeInt32(p_cur->isMT);
1348         p.writeInt32(p_cur->als);
1349         p.writeInt32(p_cur->isVoice);
1350         p.writeInt32(0); // p_cur->isVoicePrivacy);
1351         writeStringToParcel (p, p_cur->number);
1352         p.writeInt32(p_cur->numberPresentation);
1353         writeStringToParcel (p, "a-person");
1354         p.writeInt32(2); // p_cur->namePresentation);
1355         appendPrintBuf("%s[id=%d,%s,toa=%d,",
1356             printBuf,
1357             p_cur->index,
1358             callStateToString(p_cur->state),
1359             p_cur->toa);
1360         appendPrintBuf("%s%s,%s,als=%d,%s,%s,",
1361             printBuf,
1362             (p_cur->isMpty)?"conf":"norm",
1363             (p_cur->isMT)?"mt":"mo",
1364             p_cur->als,
1365             (p_cur->isVoice)?"voc":"nonvoc");
1366         appendPrintBuf("%s%s,cli=%d]",
1367             printBuf,
1368             p_cur->number,
1369             p_cur->numberPresentation);
1370 #endif
1371     }
1372     removeLastChar;
1373     closeResponse;
1374
1375     return 0;
1376 }
1377
1378 static int responseSMS(Parcel &p, void *response, size_t responselen) {
1379     if (response == NULL) {
1380         LOGE("invalid response: NULL");
1381         return RIL_ERRNO_INVALID_RESPONSE;
1382     }
1383
1384     if (responselen != sizeof (RIL_SMS_Response) ) {
1385         LOGE("invalid response length %d expected %d", 
1386                 (int)responselen, (int)sizeof (RIL_SMS_Response));
1387         return RIL_ERRNO_INVALID_RESPONSE;
1388     }
1389
1390     RIL_SMS_Response *p_cur = (RIL_SMS_Response *) response;
1391
1392     p.writeInt32(p_cur->messageRef);
1393     writeStringToParcel(p, p_cur->ackPDU);
1394
1395     startResponse;
1396     appendPrintBuf("%s%d,%s", printBuf, p_cur->messageRef,
1397         (char*)p_cur->ackPDU);
1398     closeResponse;
1399
1400     return 0;
1401 }
1402
1403 static int responseDataCallList(Parcel &p, void *response, size_t responselen)
1404 {
1405     if (response == NULL && responselen != 0) {
1406         LOGE("invalid response: NULL");
1407         return RIL_ERRNO_INVALID_RESPONSE;
1408     }
1409
1410     if (responselen % sizeof(RIL_Data_Call_Response) != 0) {
1411         LOGE("invalid response length %d expected multiple of %d", 
1412                 (int)responselen, (int)sizeof(RIL_Data_Call_Response));
1413         return RIL_ERRNO_INVALID_RESPONSE;
1414     }
1415
1416     int num = responselen / sizeof(RIL_Data_Call_Response);
1417     p.writeInt32(num);
1418
1419     RIL_Data_Call_Response *p_cur = (RIL_Data_Call_Response *) response;
1420     startResponse;
1421     int i;
1422     for (i = 0; i < num; i++) {
1423         p.writeInt32(p_cur[i].cid);
1424         p.writeInt32(p_cur[i].active);
1425         writeStringToParcel(p, p_cur[i].type);
1426         writeStringToParcel(p, p_cur[i].apn);
1427         writeStringToParcel(p, p_cur[i].address);
1428         appendPrintBuf("%s[cid=%d,%s,%s,%s,%s],", printBuf,
1429             p_cur[i].cid,
1430             (p_cur[i].active==0)?"down":"up",
1431             (char*)p_cur[i].type,
1432             (char*)p_cur[i].apn,
1433             (char*)p_cur[i].address);
1434     }
1435     removeLastChar;
1436     closeResponse;
1437
1438     return 0;
1439 }
1440
1441 static int responseRaw(Parcel &p, void *response, size_t responselen) {
1442     if (response == NULL && responselen != 0) {
1443         LOGE("invalid response: NULL with responselen != 0");
1444         return RIL_ERRNO_INVALID_RESPONSE;
1445     }
1446
1447     // The java code reads -1 size as null byte array
1448     if (response == NULL) {
1449         p.writeInt32(-1);       
1450     } else {
1451         p.writeInt32(responselen);
1452         p.write(response, responselen);
1453     }
1454
1455     return 0;
1456 }
1457
1458
1459 static int responseSIM_IO(Parcel &p, void *response, size_t responselen) {
1460     if (response == NULL) {
1461         LOGE("invalid response: NULL");
1462         return RIL_ERRNO_INVALID_RESPONSE;
1463     }
1464
1465     if (responselen != sizeof (RIL_SIM_IO_Response) ) {
1466         LOGE("invalid response length was %d expected %d",
1467                 (int)responselen, (int)sizeof (RIL_SIM_IO_Response));
1468         return RIL_ERRNO_INVALID_RESPONSE;
1469     }
1470
1471     RIL_SIM_IO_Response *p_cur = (RIL_SIM_IO_Response *) response;
1472     p.writeInt32(p_cur->sw1);
1473     p.writeInt32(p_cur->sw2);
1474     writeStringToParcel(p, p_cur->simResponse);
1475
1476     startResponse;
1477     appendPrintBuf("%ssw1=0x%X,sw2=0x%X,%s", printBuf, p_cur->sw1, p_cur->sw2,
1478         (char*)p_cur->simResponse);
1479     closeResponse;
1480
1481
1482     return 0;
1483 }
1484
1485 static int responseCallForwards(Parcel &p, void *response, size_t responselen) {
1486     int num;
1487     
1488     if (response == NULL && responselen != 0) {
1489         LOGE("invalid response: NULL");
1490         return RIL_ERRNO_INVALID_RESPONSE;
1491     }
1492
1493     if (responselen % sizeof(RIL_CallForwardInfo *) != 0) {
1494         LOGE("invalid response length %d expected multiple of %d", 
1495                 (int)responselen, (int)sizeof(RIL_CallForwardInfo *));
1496         return RIL_ERRNO_INVALID_RESPONSE;
1497     }
1498
1499     /* number of call info's */
1500     num = responselen / sizeof(RIL_CallForwardInfo *);
1501     p.writeInt32(num);
1502
1503     startResponse;
1504     for (int i = 0 ; i < num ; i++) {
1505         RIL_CallForwardInfo *p_cur = ((RIL_CallForwardInfo **) response)[i];
1506
1507         p.writeInt32(p_cur->status);
1508         p.writeInt32(p_cur->reason);
1509         p.writeInt32(p_cur->serviceClass);
1510         p.writeInt32(p_cur->toa);
1511         writeStringToParcel(p, p_cur->number);
1512         p.writeInt32(p_cur->timeSeconds);
1513         appendPrintBuf("%s[%s,reason=%d,cls=%d,toa=%d,%s,tout=%d],", printBuf,
1514             (p_cur->status==1)?"enable":"disable",
1515             p_cur->reason, p_cur->serviceClass, p_cur->toa,
1516             (char*)p_cur->number,
1517             p_cur->timeSeconds);
1518     }
1519     removeLastChar;
1520     closeResponse;
1521     
1522     return 0;
1523 }
1524
1525 static int responseSsn(Parcel &p, void *response, size_t responselen) {
1526     if (response == NULL) {
1527         LOGE("invalid response: NULL");
1528         return RIL_ERRNO_INVALID_RESPONSE;
1529     }
1530
1531     if (responselen != sizeof(RIL_SuppSvcNotification)) {
1532         LOGE("invalid response length was %d expected %d",
1533                 (int)responselen, (int)sizeof (RIL_SuppSvcNotification));
1534         return RIL_ERRNO_INVALID_RESPONSE;
1535     }
1536
1537     RIL_SuppSvcNotification *p_cur = (RIL_SuppSvcNotification *) response;
1538     p.writeInt32(p_cur->notificationType);
1539     p.writeInt32(p_cur->code);
1540     p.writeInt32(p_cur->index);
1541     p.writeInt32(p_cur->type);
1542     writeStringToParcel(p, p_cur->number);
1543
1544     startResponse;
1545     appendPrintBuf("%s%s,code=%d,id=%d,type=%d,%s", printBuf,
1546         (p_cur->notificationType==0)?"mo":"mt",
1547          p_cur->code, p_cur->index, p_cur->type,
1548         (char*)p_cur->number);
1549     closeResponse;
1550
1551     return 0;
1552 }
1553
1554 static int responseCellList(Parcel &p, void *response, size_t responselen) {
1555     int num;
1556
1557     if (response == NULL && responselen != 0) {
1558         LOGE("invalid response: NULL");
1559         return RIL_ERRNO_INVALID_RESPONSE;
1560     }
1561
1562     if (responselen % sizeof (RIL_NeighboringCell *) != 0) {
1563         LOGE("invalid response length %d expected multiple of %d\n",
1564             (int)responselen, (int)sizeof (RIL_NeighboringCell *));
1565         return RIL_ERRNO_INVALID_RESPONSE;
1566     }
1567
1568     startResponse;
1569     /* number of records */
1570     num = responselen / sizeof(RIL_NeighboringCell *);
1571     p.writeInt32(num);
1572
1573     for (int i = 0 ; i < num ; i++) {
1574         RIL_NeighboringCell *p_cur = ((RIL_NeighboringCell **) response)[i];
1575
1576         p.writeInt32(p_cur->rssi);
1577         writeStringToParcel (p, p_cur->cid);
1578
1579         appendPrintBuf("%s[cid=%s,rssi=%d],", printBuf,
1580             p_cur->cid, p_cur->rssi);
1581     }
1582     removeLastChar;
1583     closeResponse;
1584
1585     return 0;
1586 }
1587
1588 /**
1589  * Marshall the signalInfoRecord into the parcel if it exists.
1590  */
1591 static void marshallSignalInfoRecord(Parcel &p, RIL_CDMA_SignalInfoRecord &p_signalInfoRecord) {
1592     p.writeInt32(p_signalInfoRecord.isPresent);
1593     p.writeInt32(p_signalInfoRecord.signalType);
1594     p.writeInt32(p_signalInfoRecord.alertPitch);
1595     p.writeInt32(p_signalInfoRecord.signal);
1596 }
1597
1598 static int responseCdmaInformationRecords(Parcel &p,void *response, size_t responselen) {
1599     int num;
1600     int digitCount;
1601     int digitLimit;
1602
1603     if (response == NULL && responselen != 0) {
1604         LOGE("invalid response: NULL");
1605         return RIL_ERRNO_INVALID_RESPONSE;
1606     }
1607
1608     if (responselen != sizeof(RIL_CDMA_InformationRecords)) {
1609         LOGE("invalid response length %d expected %d\n",
1610             (int)responselen, (int)sizeof (RIL_CDMA_InformationRecords));
1611         return RIL_ERRNO_INVALID_RESPONSE;
1612     }
1613
1614
1615     /* TODO(Teleca): Wink believes this should be deleted? */
1616 //    num = responselen / sizeof(RIL_CDMA_InformationRecords *);
1617 //    p.writeInt32(num);
1618
1619     RIL_CDMA_InformationRecords *p_cur = ((RIL_CDMA_InformationRecords *) response);
1620
1621     /* Number of records */
1622     p.writeInt32(p_cur->numberOfInfoRecs);
1623
1624     startResponse;
1625
1626     digitLimit = MIN((p_cur->numberOfInfoRecs),RIL_CDMA_MAX_NUMBER_OF_INFO_RECS);
1627     for (digitCount = 0 ; digitCount < digitLimit; digitCount ++) {
1628         switch(p_cur->infoRec[digitCount].name){
1629             case RIL_CDMA_DISPLAY_INFO_REC:
1630                 p.writeInt32(p_cur->infoRec[digitCount].rec.display.alpha_len);
1631                 for(int i =0;i<(int)(p_cur->infoRec[digitCount].rec.display.alpha_len);i++){
1632                     p.writeInt32(p_cur->infoRec[digitCount].rec.display.alpha_buf[i]);
1633                 }
1634                 appendPrintBuf("%s[rec.display.alpha_len%c, rec.display.alpha_buf%s],",
1635                         printBuf,
1636                     p_cur->infoRec[digitCount].rec.display.alpha_len,
1637                     p_cur->infoRec[digitCount].rec.display.alpha_buf);
1638                 break;
1639             case RIL_CDMA_CALLED_PARTY_NUMBER_INFO_REC:
1640                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.len);
1641                 for(int i =0;i<(int)(p_cur->infoRec[digitCount].rec.number.len);i++){
1642                     p.writeInt32(p_cur->infoRec[digitCount].rec.number.buf[i]);
1643                 }
1644                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.number_type);
1645                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.number_plan);
1646                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.pi);
1647                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.si);
1648                 appendPrintBuf("%s[len=%c,buf=%s,number_type=%c,number_plan=%c,",
1649                         printBuf,
1650                         p_cur->infoRec[digitCount].rec.number.len,
1651                         p_cur->infoRec[digitCount].rec.number.buf,
1652                         p_cur->infoRec[digitCount].rec.number.number_type,
1653                         p_cur->infoRec[digitCount].rec.number.number_plan);
1654                 appendPrintBuf("%spi=%c,si=%c]",
1655                         printBuf,
1656                         p_cur->infoRec[digitCount].rec.number.pi,
1657                         p_cur->infoRec[digitCount].rec.number.si);
1658                 break;
1659             case RIL_CDMA_CALLING_PARTY_NUMBER_INFO_REC:
1660                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.len);
1661                 for (int i =0;i<(int)(p_cur->infoRec[digitCount].rec.number.len);i++) {
1662                     p.writeInt32(p_cur->infoRec[digitCount].rec.number.buf[i]);
1663                 }
1664                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.number_type);
1665                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.number_plan);
1666                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.pi);
1667                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.si);
1668                 appendPrintBuf("%s[len=%c,buf=%s,number_type=%c,number_plan=%c,",
1669                         printBuf,
1670                         p_cur->infoRec[digitCount].rec.number.len,
1671                         p_cur->infoRec[digitCount].rec.number.buf,
1672                         p_cur->infoRec[digitCount].rec.number.number_type,
1673                         p_cur->infoRec[digitCount].rec.number.number_plan);
1674                 appendPrintBuf("%spi=%c,si=%c]",
1675                         printBuf,
1676                         p_cur->infoRec[digitCount].rec.number.pi,
1677                         p_cur->infoRec[digitCount].rec.number.si);
1678                 break;
1679             case RIL_CDMA_CONNECTED_NUMBER_INFO_REC:
1680                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.len);
1681                 for(int i =0;i<(int)(p_cur->infoRec[digitCount].rec.number.len);i++){
1682                     p.writeInt32(p_cur->infoRec[digitCount].rec.number.buf[i]);
1683                 }
1684                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.number_type);
1685                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.number_plan);
1686                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.pi);
1687                 p.writeInt32(p_cur->infoRec[digitCount].rec.number.si);
1688                 appendPrintBuf("%s[len=%c,buf=%s,number_type=%c,number_plan=%c,",
1689                         printBuf,
1690                         p_cur->infoRec[digitCount].rec.number.len,
1691                         p_cur->infoRec[digitCount].rec.number.buf,
1692                         p_cur->infoRec[digitCount].rec.number.number_type,
1693                         p_cur->infoRec[digitCount].rec.number.number_plan);
1694                 appendPrintBuf("%spi=%c,si=%c]",
1695                         printBuf,
1696                         p_cur->infoRec[digitCount].rec.number.pi,
1697                         p_cur->infoRec[digitCount].rec.number.si);
1698                 break;
1699             case RIL_CDMA_SIGNAL_INFO_REC:
1700                 marshallSignalInfoRecord(p, p_cur->infoRec[digitCount].rec.signal);
1701                 appendPrintBuf("%s[isPresent=%c,signalType=%c,alertPitch=%c,signal=%c]",
1702                         printBuf,
1703                         p_cur->infoRec[digitCount].rec.signal.isPresent,
1704                         p_cur->infoRec[digitCount].rec.signal.signalType,
1705                         p_cur->infoRec[digitCount].rec.signal.alertPitch,
1706                         p_cur->infoRec[digitCount].rec.signal.signal);
1707                 break;
1708             case RIL_CDMA_REDIRECTING_NUMBER_INFO_REC:
1709                 p.writeInt32(p_cur->infoRec[digitCount].rec.redir.redirectingNumber.len);
1710                 for (int i =0;\
1711                         i<(int)(p_cur->infoRec[digitCount].rec.redir.redirectingNumber.len);i++){
1712                 p.writeInt32(p_cur->infoRec[digitCount].rec.redir.redirectingNumber.buf[i]);
1713                 }
1714                 p.writeInt32(p_cur->infoRec[digitCount].rec.redir.redirectingNumber.number_type);
1715                 p.writeInt32(p_cur->infoRec[digitCount].rec.redir.redirectingNumber.number_plan);
1716                 p.writeInt32(p_cur->infoRec[digitCount].rec.redir.redirectingNumber.pi);
1717                 p.writeInt32(p_cur->infoRec[digitCount].rec.redir.redirectingNumber.si);
1718                 p.writeInt32(p_cur->infoRec[digitCount].rec.redir.redirectingReason);
1719                 appendPrintBuf("%s[len=%c,buf=%s,number_type=%c,number_plan=%c,",
1720                         printBuf,
1721                         p_cur->infoRec[digitCount].rec.number.len,
1722                         p_cur->infoRec[digitCount].rec.number.buf,
1723                         p_cur->infoRec[digitCount].rec.number.number_type,
1724                         p_cur->infoRec[digitCount].rec.number.number_plan);
1725                 appendPrintBuf("%spi=%c,si=%c]",
1726                         printBuf,
1727                         p_cur->infoRec[digitCount].rec.number.pi,
1728                         p_cur->infoRec[digitCount].rec.number.si);
1729                 break;
1730             case RIL_CDMA_LINE_CONTROL_INFO_REC:
1731                 p.writeInt32(p_cur->infoRec[digitCount].rec.lineCtrl.lineCtrlPolarityIncluded);
1732                 p.writeInt32(p_cur->infoRec[digitCount].rec.lineCtrl.lineCtrlToggle);
1733                 p.writeInt32(p_cur->infoRec[digitCount].rec.lineCtrl.lineCtrlReverse);
1734                 p.writeInt32( p_cur->infoRec[digitCount].rec.lineCtrl.lineCtrlPowerDenial);
1735                 appendPrintBuf("%s[PolarityIncluded=%c,CtrlToggle=%c,CtrlReverse=%c,\
1736                         CtrlPowerDenial=%c]",
1737                         printBuf,
1738                         p_cur->infoRec[digitCount].rec.lineCtrl.lineCtrlPolarityIncluded,
1739                         p_cur->infoRec[digitCount].rec.lineCtrl.lineCtrlToggle,
1740                         p_cur->infoRec[digitCount].rec.lineCtrl.lineCtrlReverse,
1741                         p_cur->infoRec[digitCount].rec.lineCtrl.lineCtrlPowerDenial);
1742                 break;
1743             case RIL_CDMA_EXTENDED_DISPLAY_INFO_REC:
1744                 break;
1745             case RIL_CDMA_T53_CLIR_INFO_REC:
1746                 p.writeInt32(p_cur->infoRec[digitCount].rec.clir.cause);
1747                 appendPrintBuf("%s[cause=%c]",printBuf,p_cur->infoRec[digitCount].rec.clir.cause);
1748                 break;
1749
1750             case RIL_CDMA_T53_RELEASE_INFO_REC:
1751                 break;
1752             case RIL_CDMA_T53_AUDIO_CONTROL_INFO_REC:
1753                 p.writeInt32(p_cur->infoRec[digitCount].rec.audioCtrl.upLink);
1754                 p.writeInt32(p_cur->infoRec[digitCount].rec.audioCtrl.downLink);
1755                 appendPrintBuf("%s[uplink=%c,downlink=%c]",
1756                         printBuf,p_cur->infoRec[digitCount].rec.audioCtrl.upLink,
1757                         p_cur->infoRec[digitCount].rec.audioCtrl.downLink);
1758                  break;
1759             default:
1760                 LOGE ("Invalid request");
1761                 break;
1762         }
1763     }
1764
1765
1766    closeResponse;
1767
1768   return 0;
1769 }
1770
1771 static int responseRilSignalStrength(Parcel &p, void *response, size_t responselen) {
1772      if (response == NULL && responselen != 0) {
1773         LOGE("invalid response: NULL");
1774         return RIL_ERRNO_INVALID_RESPONSE;
1775     }
1776
1777     if ((responselen != sizeof (RIL_SignalStrength))
1778          && (responselen % sizeof (void *) == 0)) {
1779         // Old RIL deprecated
1780         RIL_GW_SignalStrength *p_cur = ((RIL_GW_SignalStrength *) response);
1781
1782         p.writeInt32(7);
1783         p.writeInt32(p_cur->signalStrength);
1784         p.writeInt32(p_cur->bitErrorRate);
1785         for (int i = 0; i < 5; i++) {
1786             p.writeInt32(0);
1787         }
1788     } else if (responselen == sizeof (RIL_SignalStrength)) {
1789         // New RIL
1790         RIL_SignalStrength *p_cur = ((RIL_SignalStrength *) response);
1791
1792         p.writeInt32(7);
1793         p.writeInt32(p_cur->GW_SignalStrength.signalStrength);
1794         p.writeInt32(p_cur->GW_SignalStrength.bitErrorRate);
1795         p.writeInt32(p_cur->CDMA_SignalStrength.dbm);
1796         p.writeInt32(p_cur->CDMA_SignalStrength.ecio);
1797         p.writeInt32(p_cur->EVDO_SignalStrength.dbm);
1798         p.writeInt32(p_cur->EVDO_SignalStrength.ecio);
1799         p.writeInt32(p_cur->EVDO_SignalStrength.signalNoiseRatio);
1800     } else {
1801         LOGE("invalid response length");
1802         return RIL_ERRNO_INVALID_RESPONSE;
1803     }
1804
1805     startResponse;
1806     appendPrintBuf("%s[signalStrength=%d,bitErrorRate=%d,\
1807             CDMA_SignalStrength.dbm=%d,CDMA_SignalStrength.ecio=%d,\
1808             EVDO_SignalStrength.dbm =%d,EVDO_SignalStrength.ecio=%d,\
1809             EVDO_SignalStrength.signalNoiseRatio=%d]",
1810             printBuf,
1811             p_cur->GW_SignalStrength.signalStrength,
1812             p_cur->GW_SignalStrength.bitErrorRate,
1813             p_cur->CDMA_SignalStrength.dbm,
1814             p_cur->CDMA_SignalStrength.ecio,
1815             p_cur->EVDO_SignalStrength.dbm,
1816             p_cur->EVDO_SignalStrength.ecio,
1817             p_cur->EVDO_SignalStrength.signalNoiseRatio);
1818
1819     closeResponse;
1820
1821     return 0;
1822 }
1823
1824 static int responseCallRing(Parcel &p, void *response, size_t responselen) {
1825     if ((response == NULL) || (responselen == 0)) {
1826         return responseVoid(p, response, responselen);
1827     } else {
1828         return responseCdmaSignalInfoRecord(p, response, responselen);
1829     }
1830 }
1831
1832 static int responseCdmaSignalInfoRecord(Parcel &p, void *response, size_t responselen) {
1833     if (response == NULL || responselen == 0) {
1834         LOGE("invalid response: NULL");
1835         return RIL_ERRNO_INVALID_RESPONSE;
1836     }
1837
1838     if (responselen != sizeof (RIL_CDMA_SignalInfoRecord)) {
1839         LOGE("invalid response length %d expected sizeof (RIL_CDMA_SignalInfoRecord) of %d\n",
1840             (int)responselen, (int)sizeof (RIL_CDMA_SignalInfoRecord));
1841         return RIL_ERRNO_INVALID_RESPONSE;
1842     }
1843
1844     startResponse;
1845
1846     RIL_CDMA_SignalInfoRecord *p_cur = ((RIL_CDMA_SignalInfoRecord *) response);
1847     marshallSignalInfoRecord(p, *p_cur);
1848
1849     appendPrintBuf("%s[isPresent=%d,signalType=%d,alertPitch=%d\
1850               signal=%d]",
1851               printBuf,
1852               p_cur->isPresent,
1853               p_cur->signalType,
1854               p_cur->alertPitch,
1855               p_cur->signal);
1856
1857     closeResponse;
1858     return 0;
1859 }
1860
1861 static int responseCdmaCallWaiting(Parcel &p,void *response, size_t responselen) {
1862     if (response == NULL && responselen != 0) {
1863         LOGE("invalid response: NULL");
1864         return RIL_ERRNO_INVALID_RESPONSE;
1865     }
1866
1867     if (responselen != sizeof(RIL_CDMA_CallWaiting)) {
1868         LOGE("invalid response length %d expected %d\n",
1869             (int)responselen, (int)sizeof(RIL_CDMA_CallWaiting));
1870         return RIL_ERRNO_INVALID_RESPONSE;
1871     }
1872
1873     startResponse;
1874     RIL_CDMA_CallWaiting *p_cur = ((RIL_CDMA_CallWaiting *) response);
1875
1876     writeStringToParcel (p, p_cur->number);
1877     p.writeInt32(p_cur->numberPresentation);
1878     writeStringToParcel (p, p_cur->name);
1879     marshallSignalInfoRecord(p, p_cur->signalInfoRecord);
1880
1881     appendPrintBuf("%snumber=%s,numberPresentation=%d, name=%s,\
1882             signalInfoRecord[isPresent=%d,signalType=%d,alertPitch=%d\
1883             signal=%d]",
1884             printBuf,
1885             p_cur->number,
1886             p_cur->numberPresentation,
1887             p_cur->name,
1888             p_cur->signalInfoRecord.isPresent,
1889             p_cur->signalInfoRecord.signalType,
1890             p_cur->signalInfoRecord.alertPitch,
1891             p_cur->signalInfoRecord.signal);
1892
1893     closeResponse;
1894
1895     return 0;
1896 }
1897
1898 static void triggerEvLoop() {
1899     int ret;
1900     if (!pthread_equal(pthread_self(), s_tid_dispatch)) {
1901         /* trigger event loop to wakeup. No reason to do this,
1902          * if we're in the event loop thread */
1903          do {
1904             ret = write (s_fdWakeupWrite, " ", 1);
1905          } while (ret < 0 && errno == EINTR);
1906     }
1907 }
1908
1909 static void rilEventAddWakeup(struct ril_event *ev) {
1910     ril_event_add(ev);
1911     triggerEvLoop();
1912 }
1913
1914 static int responseSimStatus(Parcel &p, void *response, size_t responselen) {
1915     int i;
1916
1917     if (response == NULL && responselen != 0) {
1918         LOGE("invalid response: NULL");
1919         return RIL_ERRNO_INVALID_RESPONSE;
1920     }
1921
1922     if (responselen % sizeof (RIL_CardStatus *) != 0) {
1923         LOGE("invalid response length %d expected multiple of %d\n",
1924             (int)responselen, (int)sizeof (RIL_CardStatus *));
1925         return RIL_ERRNO_INVALID_RESPONSE;
1926     }
1927
1928     RIL_CardStatus *p_cur = ((RIL_CardStatus *) response);
1929
1930     p.writeInt32(p_cur->card_state);
1931     p.writeInt32(p_cur->universal_pin_state);
1932     p.writeInt32(p_cur->gsm_umts_subscription_app_index);
1933     p.writeInt32(p_cur->cdma_subscription_app_index);
1934     p.writeInt32(p_cur->num_applications);
1935
1936     startResponse;
1937     for (i = 0; i < p_cur->num_applications; i++) {
1938         p.writeInt32(p_cur->applications[i].app_type);
1939         p.writeInt32(p_cur->applications[i].app_state);
1940         p.writeInt32(p_cur->applications[i].perso_substate);
1941         writeStringToParcel (p, (const char*)(p_cur->applications[i].aid_ptr));
1942         writeStringToParcel (p, (const char*)(p_cur->applications[i].app_label_ptr));
1943         p.writeInt32(p_cur->applications[i].pin1_replaced);
1944         p.writeInt32(p_cur->applications[i].pin1);
1945         p.writeInt32(p_cur->applications[i].pin2);
1946         appendPrintBuf("%s[app_type=%d,app_state=%d,perso_substate=%d,aid_ptr=%s,\
1947                 app_label_ptr=%s,pin1_replaced=%d,pin1=%d,pin2=%d],",
1948                 printBuf,
1949                 p_cur->applications[i].app_type,
1950                 p_cur->applications[i].app_state,
1951                 p_cur->applications[i].perso_substate,
1952                 p_cur->applications[i].aid_ptr,
1953                 p_cur->applications[i].app_label_ptr,
1954                 p_cur->applications[i].pin1_replaced,
1955                 p_cur->applications[i].pin1,
1956                 p_cur->applications[i].pin2);
1957     }
1958     closeResponse;
1959
1960     return 0;
1961 }
1962
1963 static int responseBrSmsCnf(Parcel &p, void *response, size_t responselen) {
1964     int num;
1965
1966     if (response == NULL && responselen != 0) {
1967         LOGE("invalid response: NULL");
1968         return RIL_ERRNO_INVALID_RESPONSE;
1969     }
1970
1971     if (responselen % sizeof(RIL_BroadcastSMSConfig) != 0) {
1972         LOGE("invalid response length %d expected multiple of %d",
1973                 (int)responselen, (int)sizeof(RIL_BroadcastSMSConfig));
1974         return RIL_ERRNO_INVALID_RESPONSE;
1975     }
1976
1977     /* number of call info's */
1978     num = responselen / sizeof(RIL_BroadcastSMSConfig *);
1979     p.writeInt32(num);
1980
1981     RIL_BroadcastSMSConfig *p_cur = (RIL_BroadcastSMSConfig *) response;
1982     p.writeInt32(p_cur->size);
1983     p.writeInt32(p_cur->entries->uFromServiceID);
1984     p.writeInt32(p_cur->entries->uToserviceID);
1985     p.write(&(p_cur->entries->bSelected),sizeof(p_cur->entries->bSelected));
1986
1987     startResponse;
1988     appendPrintBuf("%s size=%d, entries.uFromServiceID=%d, \
1989             entries.uToserviceID=%d, entries.bSelected =%d, ",
1990             printBuf, p_cur->size,p_cur->entries->uFromServiceID,
1991             p_cur->entries->uToserviceID, p_cur->entries->bSelected);
1992     closeResponse;
1993
1994     return 0;
1995 }
1996
1997 static int responseCdmaBrCnf(Parcel &p, void *response, size_t responselen) {
1998     int numServiceCategories;
1999
2000     if (response == NULL && responselen != 0) {
2001         LOGE("invalid response: NULL");
2002         return RIL_ERRNO_INVALID_RESPONSE;
2003     }
2004
2005     if (responselen == 0) {
2006         LOGE("invalid response length %d expected >= of %d",
2007                 (int)responselen, (int)sizeof(RIL_BroadcastSMSConfig));
2008         return RIL_ERRNO_INVALID_RESPONSE;
2009     }
2010
2011     RIL_CDMA_BroadcastSMSConfig *p_cur = (RIL_CDMA_BroadcastSMSConfig *) response;
2012
2013     numServiceCategories = p_cur->size;
2014     p.writeInt32(p_cur->size);
2015
2016     startResponse;
2017     appendPrintBuf("%ssize=%d ", printBuf,p_cur->size);
2018     closeResponse;
2019
2020     if (numServiceCategories != 0) {
2021         RIL_CDMA_BroadcastServiceInfo cdmaBsi[numServiceCategories];
2022         memcpy(cdmaBsi, p_cur->entries,
2023                  sizeof(RIL_CDMA_BroadcastServiceInfo) * numServiceCategories);
2024
2025         for (int i = 0 ; i < numServiceCategories ; i++ ) {
2026             p.writeInt32(cdmaBsi[i].uServiceCategory);
2027             p.writeInt32(cdmaBsi[i].uLanguage);
2028             p.writeInt32(cdmaBsi[i].bSelected);
2029
2030             startResponse;
2031             appendPrintBuf("%sentries[%d].uServicecategory=%d, entries[%d].uLanguage =%d, \
2032                 entries[%d].bSelected =%d, ", printBuf, i, cdmaBsi[i].uServiceCategory, i,
2033                 cdmaBsi[i].uLanguage, i, cdmaBsi[i].bSelected);
2034             closeResponse;
2035         }
2036     } else {
2037         p.writeInt32(NULL);
2038     }
2039
2040     return 0;
2041 }
2042
2043 static int responseCdmaSms(Parcel &p, void *response, size_t responselen) {
2044     int num;
2045     int digitCount;
2046     int digitLimit;
2047     uint8_t uct;
2048     void* dest;
2049
2050     LOGD("Inside responseCdmaSms");
2051
2052     if (response == NULL && responselen != 0) {
2053         LOGE("invalid response: NULL");
2054         return RIL_ERRNO_INVALID_RESPONSE;
2055     }
2056
2057     if (responselen != sizeof(RIL_CDMA_SMS_Message)) {
2058         LOGE("invalid response length was %d expected %d",
2059                 (int)responselen, (int)sizeof(RIL_CDMA_SMS_Message));
2060         return RIL_ERRNO_INVALID_RESPONSE;
2061     }
2062
2063     RIL_CDMA_SMS_Message *p_cur = (RIL_CDMA_SMS_Message *) response;
2064     p.writeInt32(p_cur->uTeleserviceID);
2065     p.write(&(p_cur->bIsServicePresent),sizeof(uct));
2066     p.writeInt32(p_cur->uServicecategory);
2067     p.writeInt32(p_cur->sAddress.digit_mode);
2068     p.writeInt32(p_cur->sAddress.number_mode);
2069     p.writeInt32(p_cur->sAddress.number_type);
2070     p.writeInt32(p_cur->sAddress.number_plan);
2071     p.write(&(p_cur->sAddress.number_of_digits), sizeof(uct));
2072     digitLimit= MIN((p_cur->sAddress.number_of_digits), RIL_CDMA_SMS_ADDRESS_MAX);
2073     for(digitCount =0 ; digitCount < digitLimit; digitCount ++) {
2074         p.write(&(p_cur->sAddress.digits[digitCount]),sizeof(uct));
2075     }
2076
2077     p.writeInt32(p_cur->sSubAddress.subaddressType);
2078     p.write(&(p_cur->sSubAddress.odd),sizeof(uct));
2079     p.write(&(p_cur->sSubAddress.number_of_digits),sizeof(uct));
2080     digitLimit= MIN((p_cur->sSubAddress.number_of_digits), RIL_CDMA_SMS_SUBADDRESS_MAX);
2081     for(digitCount =0 ; digitCount < digitLimit; digitCount ++) {
2082         p.write(&(p_cur->sSubAddress.digits[digitCount]),sizeof(uct));
2083     }
2084
2085     digitLimit= MIN((p_cur->uBearerDataLen), RIL_CDMA_SMS_BEARER_DATA_MAX);
2086     p.writeInt32(p_cur->uBearerDataLen);
2087     for(digitCount =0 ; digitCount < digitLimit; digitCount ++) {
2088        p.write(&(p_cur->aBearerData[digitCount]), sizeof(uct));
2089     }
2090
2091     startResponse;
2092     appendPrintBuf("%suTeleserviceID=%d, bIsServicePresent=%d, uServicecategory=%d, \
2093             sAddress.digit_mode=%d, sAddress.number_mode=%d, sAddress.number_type=%d, ",
2094             printBuf, p_cur->uTeleserviceID,p_cur->bIsServicePresent,p_cur->uServicecategory,
2095             p_cur->sAddress.digit_mode, p_cur->sAddress.number_mode,p_cur->sAddress.number_type);
2096     closeResponse;
2097
2098     return 0;
2099 }
2100
2101 /**
2102  * A write on the wakeup fd is done just to pop us out of select()
2103  * We empty the buffer here and then ril_event will reset the timers on the
2104  * way back down
2105  */
2106 static void processWakeupCallback(int fd, short flags, void *param) {
2107     char buff[16];
2108     int ret;
2109
2110     LOGV("processWakeupCallback");
2111
2112     /* empty our wakeup socket out */
2113     do {
2114         ret = read(s_fdWakeupRead, &buff, sizeof(buff));
2115     } while (ret > 0 || (ret < 0 && errno == EINTR)); 
2116 }
2117
2118 static void onCommandsSocketClosed() {
2119     int ret;
2120     RequestInfo *p_cur;
2121
2122     /* mark pending requests as "cancelled" so we dont report responses */
2123
2124     ret = pthread_mutex_lock(&s_pendingRequestsMutex);
2125     assert (ret == 0);
2126
2127     p_cur = s_pendingRequests;
2128
2129     for (p_cur = s_pendingRequests 
2130             ; p_cur != NULL
2131             ; p_cur  = p_cur->p_next
2132     ) {
2133         p_cur->cancelled = 1;
2134     }
2135
2136     ret = pthread_mutex_unlock(&s_pendingRequestsMutex);
2137     assert (ret == 0);
2138 }
2139
2140 static void processCommandsCallback(int fd, short flags, void *param) {
2141     RecordStream *p_rs;
2142     void *p_record;
2143     size_t recordlen;
2144     int ret;
2145
2146     assert(fd == s_fdCommand);
2147
2148     p_rs = (RecordStream *)param;
2149
2150     for (;;) {
2151         /* loop until EAGAIN/EINTR, end of stream, or other error */
2152         ret = record_stream_get_next(p_rs, &p_record, &recordlen);
2153
2154         if (ret == 0 && p_record == NULL) {
2155             /* end-of-stream */
2156             break;
2157         } else if (ret < 0) {
2158             break;
2159         } else if (ret == 0) { /* && p_record != NULL */
2160             processCommandBuffer(p_record, recordlen);
2161         }
2162     }
2163
2164     if (ret == 0 || !(errno == EAGAIN || errno == EINTR)) {
2165         /* fatal error or end-of-stream */
2166         if (ret != 0) {
2167             LOGE("error on reading command socket errno:%d\n", errno);
2168         } else {
2169             LOGW("EOS.  Closing command socket.");
2170         }
2171         
2172         close(s_fdCommand);
2173         s_fdCommand = -1;
2174
2175         ril_event_del(&s_commands_event);
2176
2177         record_stream_free(p_rs);
2178
2179         /* start listening for new connections again */
2180         rilEventAddWakeup(&s_listen_event);
2181
2182         onCommandsSocketClosed();
2183     }
2184 }
2185
2186
2187 static void onNewCommandConnect() {
2188     // implicit radio state changed
2189     RIL_onUnsolicitedResponse(RIL_UNSOL_RESPONSE_RADIO_STATE_CHANGED,
2190                                     NULL, 0);
2191
2192     // Send last NITZ time data, in case it was missed
2193     if (s_lastNITZTimeData != NULL) {
2194         sendResponseRaw(s_lastNITZTimeData, s_lastNITZTimeDataSize);
2195
2196         free(s_lastNITZTimeData);
2197         s_lastNITZTimeData = NULL;
2198     }
2199
2200     // Get version string
2201     if (s_callbacks.getVersion != NULL) {
2202         const char *version;
2203         version = s_callbacks.getVersion();
2204         LOGI("RIL Daemon version: %s\n", version);
2205         
2206         property_set(PROPERTY_RIL_IMPL, version);
2207     } else {
2208         LOGI("RIL Daemon version: unavailable\n");
2209         property_set(PROPERTY_RIL_IMPL, "unavailable");
2210     }
2211
2212 }
2213
2214 static void listenCallback (int fd, short flags, void *param) {
2215     int ret;
2216     int err;
2217     int is_phone_socket;
2218     RecordStream *p_rs;
2219
2220     struct sockaddr_un peeraddr;
2221     socklen_t socklen = sizeof (peeraddr);
2222
2223     struct ucred creds;
2224     socklen_t szCreds = sizeof(creds);
2225
2226     struct passwd *pwd = NULL;
2227
2228     assert (s_fdCommand < 0);
2229     assert (fd == s_fdListen);
2230     
2231     s_fdCommand = accept(s_fdListen, (sockaddr *) &peeraddr, &socklen);
2232
2233     if (s_fdCommand < 0 ) {
2234         LOGE("Error on accept() errno:%d", errno);
2235         /* start listening for new connections again */
2236         rilEventAddWakeup(&s_listen_event);
2237               return;
2238     }
2239
2240     /* check the credential of the other side and only accept socket from
2241      * phone process
2242      */ 
2243     errno = 0;
2244     is_phone_socket = 0;
2245
2246     err = getsockopt(s_fdCommand, SOL_SOCKET, SO_PEERCRED, &creds, &szCreds);
2247
2248     if (err == 0 && szCreds > 0) {
2249         errno = 0;
2250         pwd = getpwuid(creds.uid);
2251         if (pwd != NULL) {
2252             if (strcmp(pwd->pw_name, PHONE_PROCESS) == 0) {
2253                 is_phone_socket = 1;
2254             } else {
2255                 LOGE("RILD can't accept socket from process %s", pwd->pw_name);
2256             }
2257         } else {
2258             LOGE("Error on getpwuid() errno: %d", errno);
2259         }
2260     } else {
2261         LOGD("Error on getsockopt() errno: %d", errno);
2262     }
2263
2264     if ( !is_phone_socket ) {
2265       LOGE("RILD must accept socket from %s", PHONE_PROCESS);
2266         
2267       close(s_fdCommand);
2268       s_fdCommand = -1;
2269
2270       onCommandsSocketClosed();
2271
2272       /* start listening for new connections again */
2273       rilEventAddWakeup(&s_listen_event);
2274
2275       return;
2276     }
2277
2278     ret = fcntl(s_fdCommand, F_SETFL, O_NONBLOCK);
2279
2280     if (ret < 0) {
2281         LOGE ("Error setting O_NONBLOCK errno:%d", errno);
2282     }
2283
2284     LOGI("libril: new connection");
2285
2286     p_rs = record_stream_new(s_fdCommand, MAX_COMMAND_BYTES);
2287
2288     ril_event_set (&s_commands_event, s_fdCommand, 1, 
2289         processCommandsCallback, p_rs);
2290
2291     rilEventAddWakeup (&s_commands_event);
2292
2293     onNewCommandConnect();
2294 }
2295
2296 static void freeDebugCallbackArgs(int number, char **args) {
2297     for (int i = 0; i < number; i++) {
2298         if (args[i] != NULL) {
2299             free(args[i]);
2300         }
2301     }
2302     free(args);
2303 }
2304
2305 static void debugCallback (int fd, short flags, void *param) {
2306     int acceptFD, option;
2307     struct sockaddr_un peeraddr;
2308     socklen_t socklen = sizeof (peeraddr);
2309     int data;
2310     unsigned int qxdm_data[6];
2311     const char *deactData[1] = {"1"};
2312     char *actData[1];
2313     RIL_Dial dialData;
2314     int hangupData[1] = {1};
2315     int number;
2316     char **args;
2317
2318     acceptFD = accept (fd,  (sockaddr *) &peeraddr, &socklen);
2319
2320     if (acceptFD < 0) {
2321         LOGE ("error accepting on debug port: %d\n", errno);
2322         return;
2323     }
2324
2325     if (recv(acceptFD, &number, sizeof(int), 0) != sizeof(int)) {
2326         LOGE ("error reading on socket: number of Args: \n");
2327         return;
2328     }
2329     args = (char **) malloc(sizeof(char*) * number);
2330
2331     for (int i = 0; i < number; i++) {
2332         int len;
2333         if (recv(acceptFD, &len, sizeof(int), 0) != sizeof(int)) {
2334             LOGE ("error reading on socket: Len of Args: \n");
2335             freeDebugCallbackArgs(i, args);
2336             return;
2337         }
2338         // +1 for null-term
2339         args[i] = (char *) malloc((sizeof(char) * len) + 1);
2340         if (recv(acceptFD, args[i], sizeof(char) * len, 0) 
2341             != (int)sizeof(char) * len) {
2342             LOGE ("error reading on socket: Args[%d] \n", i);
2343             freeDebugCallbackArgs(i, args);
2344             return;
2345         }
2346         char * buf = args[i];
2347         buf[len] = 0;
2348     }
2349
2350     switch (atoi(args[0])) {
2351         case 0:
2352             LOGI ("Connection on debug port: issuing reset.");
2353             issueLocalRequest(RIL_REQUEST_RESET_RADIO, NULL, 0);
2354             break;
2355         case 1:
2356             LOGI ("Connection on debug port: issuing radio power off.");
2357             data = 0;
2358             issueLocalRequest(RIL_REQUEST_RADIO_POWER, &data, sizeof(int));
2359             // Close the socket
2360             close(s_fdCommand);
2361             s_fdCommand = -1;
2362             break;
2363         case 2:
2364             LOGI ("Debug port: issuing unsolicited network change.");
2365             RIL_onUnsolicitedResponse(RIL_UNSOL_RESPONSE_NETWORK_STATE_CHANGED,
2366                                       NULL, 0);
2367             break;
2368         case 3:
2369             LOGI ("Debug port: QXDM log enable.");
2370             qxdm_data[0] = 65536;
2371             qxdm_data[1] = 16;
2372             qxdm_data[2] = 1;
2373             qxdm_data[3] = 32;
2374             qxdm_data[4] = 0;
2375             qxdm_data[4] = 8;
2376             issueLocalRequest(RIL_REQUEST_OEM_HOOK_RAW, qxdm_data, 
2377                               6 * sizeof(int));
2378             break;
2379         case 4:
2380             LOGI ("Debug port: QXDM log disable.");
2381             qxdm_data[0] = 65536;
2382             qxdm_data[1] = 16;
2383             qxdm_data[2] = 0;
2384             qxdm_data[3] = 32;
2385             qxdm_data[4] = 0;
2386             qxdm_data[4] = 8;
2387             issueLocalRequest(RIL_REQUEST_OEM_HOOK_RAW, qxdm_data,
2388                               6 * sizeof(int));
2389             break;
2390         case 5:
2391             LOGI("Debug port: Radio On");
2392             data = 1;
2393             issueLocalRequest(RIL_REQUEST_RADIO_POWER, &data, sizeof(int));
2394             sleep(2);
2395             // Set network selection automatic.
2396             issueLocalRequest(RIL_REQUEST_SET_NETWORK_SELECTION_AUTOMATIC, NULL, 0);
2397             break;
2398         case 6:
2399             LOGI("Debug port: Setup Data Call, Apn :%s\n", args[1]);
2400             actData[0] = args[1];
2401             issueLocalRequest(RIL_REQUEST_SETUP_DATA_CALL, &actData, 
2402                               sizeof(actData));
2403             break;
2404         case 7:
2405             LOGI("Debug port: Deactivate Data Call");
2406             issueLocalRequest(RIL_REQUEST_DEACTIVATE_DATA_CALL, &deactData, 
2407                               sizeof(deactData));
2408             break;
2409         case 8:
2410             LOGI("Debug port: Dial Call");
2411             dialData.clir = 0;
2412             dialData.address = args[1];
2413             issueLocalRequest(RIL_REQUEST_DIAL, &dialData, sizeof(dialData));
2414             break;
2415         case 9:
2416             LOGI("Debug port: Answer Call");
2417             issueLocalRequest(RIL_REQUEST_ANSWER, NULL, 0);
2418             break;
2419         case 10:
2420             LOGI("Debug port: End Call");
2421             issueLocalRequest(RIL_REQUEST_HANGUP, &hangupData, 
2422                               sizeof(hangupData));
2423             break;
2424         default:
2425             LOGE ("Invalid request");
2426             break;
2427     }
2428     freeDebugCallbackArgs(number, args);
2429     close(acceptFD);
2430 }
2431
2432
2433 static void userTimerCallback (int fd, short flags, void *param) {
2434     UserCallbackInfo *p_info;
2435
2436     p_info = (UserCallbackInfo *)param;
2437
2438     p_info->p_callback(p_info->userParam);
2439
2440
2441     // FIXME generalize this...there should be a cancel mechanism
2442     if (s_last_wake_timeout_info != NULL && s_last_wake_timeout_info == p_info) {
2443         s_last_wake_timeout_info = NULL;
2444     }
2445
2446     free(p_info);
2447 }
2448
2449
2450 static void *
2451 eventLoop(void *param) {
2452     int ret;
2453     int filedes[2];
2454
2455     ril_event_init();
2456
2457     pthread_mutex_lock(&s_startupMutex);
2458
2459     s_started = 1;
2460     pthread_cond_broadcast(&s_startupCond);
2461
2462     pthread_mutex_unlock(&s_startupMutex);
2463
2464     ret = pipe(filedes);
2465
2466     if (ret < 0) {
2467         LOGE("Error in pipe() errno:%d", errno);
2468         return NULL;
2469     }
2470
2471     s_fdWakeupRead = filedes[0];
2472     s_fdWakeupWrite = filedes[1];
2473
2474     fcntl(s_fdWakeupRead, F_SETFL, O_NONBLOCK);
2475
2476     ril_event_set (&s_wakeupfd_event, s_fdWakeupRead, true,
2477                 processWakeupCallback, NULL);
2478
2479     rilEventAddWakeup (&s_wakeupfd_event);
2480
2481     // Only returns on error
2482     ril_event_loop();
2483     LOGE ("error in event_loop_base errno:%d", errno);
2484
2485     return NULL;
2486 }
2487
2488 extern "C" void 
2489 RIL_startEventLoop(void) {
2490     int ret;
2491     pthread_attr_t attr;
2492     
2493     /* spin up eventLoop thread and wait for it to get started */
2494     s_started = 0;
2495     pthread_mutex_lock(&s_startupMutex);
2496
2497     pthread_attr_init (&attr);
2498     pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);    
2499     ret = pthread_create(&s_tid_dispatch, &attr, eventLoop, NULL);
2500
2501     while (s_started == 0) {
2502         pthread_cond_wait(&s_startupCond, &s_startupMutex);
2503     }
2504
2505     pthread_mutex_unlock(&s_startupMutex);
2506
2507     if (ret < 0) {
2508         LOGE("Failed to create dispatch thread errno:%d", errno);
2509         return;
2510     }
2511 }
2512
2513 // Used for testing purpose only.
2514 extern "C" void RIL_setcallbacks (const RIL_RadioFunctions *callbacks) {
2515     memcpy(&s_callbacks, callbacks, sizeof (RIL_RadioFunctions));
2516 }
2517
2518 extern "C" void 
2519 RIL_register (const RIL_RadioFunctions *callbacks) {
2520     int ret;
2521     int flags;
2522
2523     if (callbacks == NULL 
2524         || ! (callbacks->version == RIL_VERSION || callbacks->version == 1)
2525     ) {
2526         LOGE(
2527             "RIL_register: RIL_RadioFunctions * null or invalid version"
2528             " (expected %d)", RIL_VERSION);
2529         return;
2530     }
2531
2532     if (s_registerCalled > 0) {
2533         LOGE("RIL_register has been called more than once. "
2534                 "Subsequent call ignored");
2535         return;
2536     }
2537
2538     memcpy(&s_callbacks, callbacks, sizeof (RIL_RadioFunctions));
2539
2540     s_registerCalled = 1;
2541
2542     // Little self-check
2543
2544     for (int i = 0; i < (int)NUM_ELEMS(s_commands); i++) {
2545         assert(i == s_commands[i].requestNumber);
2546     }
2547
2548     for (int i = 0; i < (int)NUM_ELEMS(s_unsolResponses); i++) {
2549         assert(i + RIL_UNSOL_RESPONSE_BASE 
2550                 == s_unsolResponses[i].requestNumber);
2551     }
2552
2553     // New rild impl calls RIL_startEventLoop() first
2554     // old standalone impl wants it here.
2555
2556     if (s_started == 0) {
2557         RIL_startEventLoop();
2558     }
2559
2560     // start listen socket
2561
2562 #if 0
2563     ret = socket_local_server (SOCKET_NAME_RIL, 
2564             ANDROID_SOCKET_NAMESPACE_ABSTRACT, SOCK_STREAM);
2565
2566     if (ret < 0) {
2567         LOGE("Unable to bind socket errno:%d", errno);
2568         exit (-1);
2569     }
2570     s_fdListen = ret;
2571
2572 #else
2573     s_fdListen = android_get_control_socket(SOCKET_NAME_RIL);
2574     if (s_fdListen < 0) {
2575         LOGE("Failed to get socket '" SOCKET_NAME_RIL "'");
2576         exit(-1);
2577     }
2578
2579     ret = listen(s_fdListen, 4);
2580
2581     if (ret < 0) {
2582         LOGE("Failed to listen on control socket '%d': %s",
2583              s_fdListen, strerror(errno));
2584         exit(-1);
2585     }
2586 #endif
2587
2588
2589     /* note: non-persistent so we can accept only one connection at a time */
2590     ril_event_set (&s_listen_event, s_fdListen, false, 
2591                 listenCallback, NULL);
2592
2593     rilEventAddWakeup (&s_listen_event);
2594
2595 #if 1
2596     // start debug interface socket
2597
2598     s_fdDebug = android_get_control_socket(SOCKET_NAME_RIL_DEBUG);
2599     if (s_fdDebug < 0) {
2600         LOGE("Failed to get socket '" SOCKET_NAME_RIL_DEBUG "' errno:%d", errno);
2601         exit(-1);
2602     }
2603
2604     ret = listen(s_fdDebug, 4);
2605
2606     if (ret < 0) {
2607         LOGE("Failed to listen on ril debug socket '%d': %s",
2608              s_fdDebug, strerror(errno));
2609         exit(-1);
2610     }
2611
2612     ril_event_set (&s_debug_event, s_fdDebug, true,
2613                 debugCallback, NULL);
2614
2615     rilEventAddWakeup (&s_debug_event);
2616 #endif
2617
2618 }
2619
2620 static int
2621 checkAndDequeueRequestInfo(struct RequestInfo *pRI) {
2622     int ret = 0;
2623     
2624     if (pRI == NULL) {
2625         return 0;
2626     }
2627
2628     pthread_mutex_lock(&s_pendingRequestsMutex);
2629
2630     for(RequestInfo **ppCur = &s_pendingRequests 
2631         ; *ppCur != NULL 
2632         ; ppCur = &((*ppCur)->p_next)
2633     ) {
2634         if (pRI == *ppCur) {
2635             ret = 1;
2636
2637             *ppCur = (*ppCur)->p_next;
2638             break;
2639         }
2640     }
2641
2642     pthread_mutex_unlock(&s_pendingRequestsMutex);
2643
2644     return ret;
2645 }
2646
2647
2648 extern "C" void
2649 RIL_onRequestComplete(RIL_Token t, RIL_Errno e, void *response, size_t responselen) {
2650     RequestInfo *pRI;
2651     int ret;
2652     size_t errorOffset;
2653
2654     pRI = (RequestInfo *)t;
2655
2656     if (!checkAndDequeueRequestInfo(pRI)) {
2657         LOGE ("RIL_onRequestComplete: invalid RIL_Token");
2658         return;
2659     }
2660
2661     if (pRI->local > 0) {
2662         // Locally issued command...void only!
2663         // response does not go back up the command socket
2664         LOGD("C[locl]< %s", requestToString(pRI->pCI->requestNumber));
2665
2666         goto done;
2667     }
2668
2669     appendPrintBuf("[%04d]< %s",
2670         pRI->token, requestToString(pRI->pCI->requestNumber));
2671
2672     if (pRI->cancelled == 0) {
2673         Parcel p;
2674
2675         p.writeInt32 (RESPONSE_SOLICITED);
2676         p.writeInt32 (pRI->token);
2677         errorOffset = p.dataPosition();
2678
2679         p.writeInt32 (e);
2680
2681         if (e == RIL_E_SUCCESS) {
2682             /* process response on success */
2683             ret = pRI->pCI->responseFunction(p, response, responselen);
2684
2685             /* if an error occurred, rewind and mark it */
2686             if (ret != 0) {
2687                 p.setDataPosition(errorOffset);
2688                 p.writeInt32 (ret);
2689             }
2690         } else {
2691             appendPrintBuf("%s returns %s", printBuf, failCauseToString(e));
2692         }
2693
2694         if (s_fdCommand < 0) {
2695             LOGD ("RIL onRequestComplete: Command channel closed");
2696         }
2697         sendResponse(p);
2698     }
2699
2700 done:
2701     free(pRI);
2702 }
2703
2704
2705 static void
2706 grabPartialWakeLock() {
2707     acquire_wake_lock(PARTIAL_WAKE_LOCK, ANDROID_WAKE_LOCK_NAME);
2708 }
2709
2710 static void
2711 releaseWakeLock() {
2712     release_wake_lock(ANDROID_WAKE_LOCK_NAME);
2713 }
2714
2715 /**
2716  * Timer callback to put us back to sleep before the default timeout
2717  */
2718 static void
2719 wakeTimeoutCallback (void *param) {
2720     // We're using "param != NULL" as a cancellation mechanism
2721     if (param == NULL) {
2722         //LOGD("wakeTimeout: releasing wake lock");
2723
2724         releaseWakeLock();
2725     } else {
2726         //LOGD("wakeTimeout: releasing wake lock CANCELLED");
2727     }
2728 }
2729
2730 extern "C"
2731 void RIL_onUnsolicitedResponse(int unsolResponse, void *data,
2732                                 size_t datalen)
2733 {
2734     int unsolResponseIndex;
2735     int ret;
2736     int64_t timeReceived = 0;
2737     bool shouldScheduleTimeout = false;
2738
2739     if (s_registerCalled == 0) {
2740         // Ignore RIL_onUnsolicitedResponse before RIL_register
2741         LOGW("RIL_onUnsolicitedResponse called before RIL_register");
2742         return;
2743     }
2744                 
2745     unsolResponseIndex = unsolResponse - RIL_UNSOL_RESPONSE_BASE;
2746
2747     if ((unsolResponseIndex < 0)
2748         || (unsolResponseIndex >= (int32_t)NUM_ELEMS(s_unsolResponses))) {
2749         LOGE("unsupported unsolicited response code %d", unsolResponse);
2750         return;
2751     }
2752
2753     // Grab a wake lock if needed for this reponse,
2754     // as we exit we'll either release it immediately
2755     // or set a timer to release it later.
2756     switch (s_unsolResponses[unsolResponseIndex].wakeType) {
2757         case WAKE_PARTIAL:
2758             grabPartialWakeLock();
2759             shouldScheduleTimeout = true;
2760         break;
2761
2762         case DONT_WAKE:
2763         default:
2764             // No wake lock is grabed so don't set timeout
2765             shouldScheduleTimeout = false;
2766             break;
2767     }
2768
2769     // Mark the time this was received, doing this
2770     // after grabing the wakelock incase getting
2771     // the elapsedRealTime might cause us to goto
2772     // sleep.
2773     if (unsolResponse == RIL_UNSOL_NITZ_TIME_RECEIVED) {
2774         timeReceived = elapsedRealtime();
2775     }
2776
2777     appendPrintBuf("[UNSL]< %s", requestToString(unsolResponse));
2778
2779     Parcel p;
2780
2781     p.writeInt32 (RESPONSE_UNSOLICITED);
2782     p.writeInt32 (unsolResponse);
2783
2784     ret = s_unsolResponses[unsolResponseIndex]
2785                 .responseFunction(p, data, datalen);
2786     if (ret != 0) {
2787         // Problem with the response. Don't continue;
2788         goto error_exit;
2789     }
2790
2791     // some things get more payload
2792     switch(unsolResponse) {
2793         case RIL_UNSOL_RESPONSE_RADIO_STATE_CHANGED:
2794             p.writeInt32(s_callbacks.onStateRequest());
2795             appendPrintBuf("%s {%s}", printBuf,
2796                 radioStateToString(s_callbacks.onStateRequest()));
2797         break;
2798
2799
2800         case RIL_UNSOL_NITZ_TIME_RECEIVED:
2801             // Store the time that this was received so the
2802             // handler of this message can account for
2803             // the time it takes to arrive and process. In
2804             // particular the system has been known to sleep
2805             // before this message can be processed.
2806             p.writeInt64(timeReceived);
2807         break;
2808     }
2809
2810     ret = sendResponse(p);
2811     if (ret != 0 && unsolResponse == RIL_UNSOL_NITZ_TIME_RECEIVED) {
2812
2813         // Unfortunately, NITZ time is not poll/update like everything
2814         // else in the system. So, if the upstream client isn't connected,
2815         // keep a copy of the last NITZ response (with receive time noted
2816         // above) around so we can deliver it when it is connected
2817
2818         if (s_lastNITZTimeData != NULL) {
2819             free (s_lastNITZTimeData);
2820             s_lastNITZTimeData = NULL;
2821         }
2822
2823         s_lastNITZTimeData = malloc(p.dataSize());
2824         s_lastNITZTimeDataSize = p.dataSize();
2825         memcpy(s_lastNITZTimeData, p.data(), p.dataSize());
2826     }
2827
2828     // For now, we automatically go back to sleep after TIMEVAL_WAKE_TIMEOUT
2829     // FIXME The java code should handshake here to release wake lock
2830
2831     if (shouldScheduleTimeout) {
2832         // Cancel the previous request
2833         if (s_last_wake_timeout_info != NULL) {
2834             s_last_wake_timeout_info->userParam = (void *)1;
2835         }
2836
2837         s_last_wake_timeout_info
2838             = internalRequestTimedCallback(wakeTimeoutCallback, NULL,
2839                                             &TIMEVAL_WAKE_TIMEOUT);
2840     }
2841
2842     // Normal exit
2843     return;
2844
2845 error_exit:
2846     if (shouldScheduleTimeout) {
2847         releaseWakeLock();
2848     }
2849 }
2850
2851 /** FIXME generalize this if you track UserCAllbackInfo, clear it  
2852     when the callback occurs 
2853 */
2854 static UserCallbackInfo *
2855 internalRequestTimedCallback (RIL_TimedCallback callback, void *param, 
2856                                 const struct timeval *relativeTime)
2857 {
2858     struct timeval myRelativeTime;
2859     UserCallbackInfo *p_info;
2860
2861     p_info = (UserCallbackInfo *) malloc (sizeof(UserCallbackInfo));
2862
2863     p_info->p_callback = callback; 
2864     p_info->userParam = param;
2865
2866     if (relativeTime == NULL) {
2867         /* treat null parameter as a 0 relative time */
2868         memset (&myRelativeTime, 0, sizeof(myRelativeTime));
2869     } else {
2870         /* FIXME I think event_add's tv param is really const anyway */
2871         memcpy (&myRelativeTime, relativeTime, sizeof(myRelativeTime));
2872     }
2873
2874     ril_event_set(&(p_info->event), -1, false, userTimerCallback, p_info);
2875
2876     ril_timer_add(&(p_info->event), &myRelativeTime);
2877
2878     triggerEvLoop();
2879     return p_info;
2880 }
2881
2882
2883 extern "C" void
2884 RIL_requestTimedCallback (RIL_TimedCallback callback, void *param, 
2885                                 const struct timeval *relativeTime) {
2886     internalRequestTimedCallback (callback, param, relativeTime);
2887 }
2888
2889 const char *
2890 failCauseToString(RIL_Errno e) {
2891     switch(e) {
2892         case RIL_E_SUCCESS: return "E_SUCCESS";
2893         case RIL_E_RADIO_NOT_AVAILABLE: return "E_RAIDO_NOT_AVAILABLE";
2894         case RIL_E_GENERIC_FAILURE: return "E_GENERIC_FAILURE";
2895         case RIL_E_PASSWORD_INCORRECT: return "E_PASSWORD_INCORRECT";
2896         case RIL_E_SIM_PIN2: return "E_SIM_PIN2";
2897         case RIL_E_SIM_PUK2: return "E_SIM_PUK2";
2898         case RIL_E_REQUEST_NOT_SUPPORTED: return "E_REQUEST_NOT_SUPPORTED";
2899         case RIL_E_CANCELLED: return "E_CANCELLED";
2900         case RIL_E_OP_NOT_ALLOWED_DURING_VOICE_CALL: return "E_OP_NOT_ALLOWED_DURING_VOICE_CALL";
2901         case RIL_E_OP_NOT_ALLOWED_BEFORE_REG_TO_NW: return "E_OP_NOT_ALLOWED_BEFORE_REG_TO_NW";
2902         case RIL_E_SMS_SEND_FAIL_RETRY: return "E_SMS_SEND_FAIL_RETRY";
2903         case RIL_E_SIM_ABSENT:return "E_SIM_ABSENT";
2904 #ifdef FEATURE_MULTIMODE_ANDROID 
2905         case RIL_E_SUBSCRIPTION_NOT_AVAILABLE:return "E_SUBSCRIPTION_NOT_AVAILABLE";
2906         case RIL_E_MODE_NOT_SUPPORTED:return "E_MODE_NOT_SUPPORTED";
2907 #endif
2908         default: return "<unknown error>";
2909     }
2910 }
2911
2912 const char *
2913 radioStateToString(RIL_RadioState s) {
2914     switch(s) {
2915         case RADIO_STATE_OFF: return "RADIO_OFF";
2916         case RADIO_STATE_UNAVAILABLE: return "RADIO_UNAVAILABLE";
2917         case RADIO_STATE_SIM_NOT_READY: return "RADIO_SIM_NOT_READY";
2918         case RADIO_STATE_SIM_LOCKED_OR_ABSENT: return "RADIO_SIM_LOCKED_OR_ABSENT";
2919         case RADIO_STATE_SIM_READY: return "RADIO_SIM_READY";
2920         case RADIO_STATE_RUIM_NOT_READY:return"RADIO_RUIM_NOT_READY";
2921         case RADIO_STATE_RUIM_READY:return"RADIO_RUIM_READY";
2922         case RADIO_STATE_RUIM_LOCKED_OR_ABSENT:return"RADIO_RUIM_LOCKED_OR_ABSENT";
2923         case RADIO_STATE_NV_NOT_READY:return"RADIO_NV_NOT_READY";
2924         case RADIO_STATE_NV_READY:return"RADIO_NV_READY";
2925         default: return "<unknown state>";
2926     }
2927 }
2928
2929 const char *
2930 callStateToString(RIL_CallState s) {
2931     switch(s) {
2932         case RIL_CALL_ACTIVE : return "ACTIVE";
2933         case RIL_CALL_HOLDING: return "HOLDING";
2934         case RIL_CALL_DIALING: return "DIALING";
2935         case RIL_CALL_ALERTING: return "ALERTING";
2936         case RIL_CALL_INCOMING: return "INCOMING";
2937         case RIL_CALL_WAITING: return "WAITING";
2938         default: return "<unknown state>";
2939     }
2940 }
2941
2942 const char *
2943 requestToString(int request) {
2944 /*
2945  cat libs/telephony/ril_commands.h \
2946  | egrep "^ *{RIL_" \
2947  | sed -re 's/\{RIL_([^,]+),[^,]+,([^}]+).+/case RIL_\1: return "\1";/'
2948
2949
2950  cat libs/telephony/ril_unsol_commands.h \
2951  | egrep "^ *{RIL_" \
2952  | sed -re 's/\{RIL_([^,]+),([^}]+).+/case RIL_\1: return "\1";/'
2953
2954 */
2955     switch(request) {
2956         case RIL_REQUEST_GET_SIM_STATUS: return "GET_SIM_STATUS";
2957         case RIL_REQUEST_ENTER_SIM_PIN: return "ENTER_SIM_PIN";
2958         case RIL_REQUEST_ENTER_SIM_PUK: return "ENTER_SIM_PUK";
2959         case RIL_REQUEST_ENTER_SIM_PIN2: return "ENTER_SIM_PIN2";
2960         case RIL_REQUEST_ENTER_SIM_PUK2: return "ENTER_SIM_PUK2";
2961         case RIL_REQUEST_CHANGE_SIM_PIN: return "CHANGE_SIM_PIN";
2962         case RIL_REQUEST_CHANGE_SIM_PIN2: return "CHANGE_SIM_PIN2";
2963         case RIL_REQUEST_ENTER_NETWORK_DEPERSONALIZATION: return "ENTER_NETWORK_DEPERSONALIZATION";
2964         case RIL_REQUEST_GET_CURRENT_CALLS: return "GET_CURRENT_CALLS";
2965         case RIL_REQUEST_DIAL: return "DIAL";
2966         case RIL_REQUEST_GET_IMSI: return "GET_IMSI";
2967         case RIL_REQUEST_HANGUP: return "HANGUP";
2968         case RIL_REQUEST_HANGUP_WAITING_OR_BACKGROUND: return "HANGUP_WAITING_OR_BACKGROUND";
2969         case RIL_REQUEST_HANGUP_FOREGROUND_RESUME_BACKGROUND: return "HANGUP_FOREGROUND_RESUME_BACKGROUND";
2970         case RIL_REQUEST_SWITCH_WAITING_OR_HOLDING_AND_ACTIVE: return "SWITCH_WAITING_OR_HOLDING_AND_ACTIVE";
2971         case RIL_REQUEST_CONFERENCE: return "CONFERENCE";
2972         case RIL_REQUEST_UDUB: return "UDUB";
2973         case RIL_REQUEST_LAST_CALL_FAIL_CAUSE: return "LAST_CALL_FAIL_CAUSE";
2974         case RIL_REQUEST_SIGNAL_STRENGTH: return "SIGNAL_STRENGTH";
2975         case RIL_REQUEST_REGISTRATION_STATE: return "REGISTRATION_STATE";
2976         case RIL_REQUEST_GPRS_REGISTRATION_STATE: return "GPRS_REGISTRATION_STATE";
2977         case RIL_REQUEST_OPERATOR: return "OPERATOR";
2978         case RIL_REQUEST_RADIO_POWER: return "RADIO_POWER";
2979         case RIL_REQUEST_DTMF: return "DTMF";
2980         case RIL_REQUEST_SEND_SMS: return "SEND_SMS";
2981         case RIL_REQUEST_SEND_SMS_EXPECT_MORE: return "SEND_SMS_EXPECT_MORE";
2982         case RIL_REQUEST_SETUP_DATA_CALL: return "SETUP_DATA_CALL";
2983         case RIL_REQUEST_SIM_IO: return "SIM_IO";
2984         case RIL_REQUEST_SEND_USSD: return "SEND_USSD";
2985         case RIL_REQUEST_CANCEL_USSD: return "CANCEL_USSD";
2986         case RIL_REQUEST_GET_CLIR: return "GET_CLIR";
2987         case RIL_REQUEST_SET_CLIR: return "SET_CLIR";
2988         case RIL_REQUEST_QUERY_CALL_FORWARD_STATUS: return "QUERY_CALL_FORWARD_STATUS";
2989         case RIL_REQUEST_SET_CALL_FORWARD: return "SET_CALL_FORWARD";
2990         case RIL_REQUEST_QUERY_CALL_WAITING: return "QUERY_CALL_WAITING";
2991         case RIL_REQUEST_SET_CALL_WAITING: return "SET_CALL_WAITING";
2992         case RIL_REQUEST_SMS_ACKNOWLEDGE: return "SMS_ACKNOWLEDGE";
2993         case RIL_REQUEST_GET_IMEI: return "GET_IMEI";
2994         case RIL_REQUEST_GET_IMEISV: return "GET_IMEISV";
2995         case RIL_REQUEST_ANSWER: return "ANSWER";
2996         case RIL_REQUEST_DEACTIVATE_DATA_CALL: return "DEACTIVATE_DATA_CALL";
2997         case RIL_REQUEST_QUERY_FACILITY_LOCK: return "QUERY_FACILITY_LOCK";
2998         case RIL_REQUEST_SET_FACILITY_LOCK: return "SET_FACILITY_LOCK";
2999         case RIL_REQUEST_CHANGE_BARRING_PASSWORD: return "CHANGE_BARRING_PASSWORD";
3000         case RIL_REQUEST_QUERY_NETWORK_SELECTION_MODE: return "QUERY_NETWORK_SELECTION_MODE";
3001         case RIL_REQUEST_SET_NETWORK_SELECTION_AUTOMATIC: return "SET_NETWORK_SELECTION_AUTOMATIC";
3002         case RIL_REQUEST_SET_NETWORK_SELECTION_MANUAL: return "SET_NETWORK_SELECTION_MANUAL";
3003         case RIL_REQUEST_QUERY_AVAILABLE_NETWORKS : return "QUERY_AVAILABLE_NETWORKS ";
3004         case RIL_REQUEST_DTMF_START: return "DTMF_START";
3005         case RIL_REQUEST_DTMF_STOP: return "DTMF_STOP";
3006         case RIL_REQUEST_BASEBAND_VERSION: return "BASEBAND_VERSION";
3007         case RIL_REQUEST_SEPARATE_CONNECTION: return "SEPARATE_CONNECTION";
3008         case RIL_REQUEST_SET_PREFERRED_NETWORK_TYPE: return "SET_PREFERRED_NETWORK_TYPE";
3009         case RIL_REQUEST_GET_PREFERRED_NETWORK_TYPE: return "GET_PREFERRED_NETWORK_TYPE";
3010         case RIL_REQUEST_GET_NEIGHBORING_CELL_IDS: return "GET_NEIGHBORING_CELL_IDS";
3011         case RIL_REQUEST_SET_MUTE: return "SET_MUTE";
3012         case RIL_REQUEST_GET_MUTE: return "GET_MUTE";
3013         case RIL_REQUEST_QUERY_CLIP: return "QUERY_CLIP";
3014         case RIL_REQUEST_LAST_DATA_CALL_FAIL_CAUSE: return "LAST_DATA_CALL_FAIL_CAUSE";
3015         case RIL_REQUEST_DATA_CALL_LIST: return "DATA_CALL_LIST";
3016         case RIL_REQUEST_RESET_RADIO: return "RESET_RADIO";
3017         case RIL_REQUEST_OEM_HOOK_RAW: return "OEM_HOOK_RAW";
3018         case RIL_REQUEST_OEM_HOOK_STRINGS: return "OEM_HOOK_STRINGS";
3019         case RIL_REQUEST_SET_BAND_MODE: return "SET_BAND_MODE";
3020         case RIL_REQUEST_QUERY_AVAILABLE_BAND_MODE: return "QUERY_AVAILABLE_BAND_MODE";
3021         case RIL_REQUEST_STK_GET_PROFILE: return "STK_GET_PROFILE";
3022         case RIL_REQUEST_STK_SET_PROFILE: return "STK_SET_PROFILE";
3023         case RIL_REQUEST_STK_SEND_ENVELOPE_COMMAND: return "STK_SEND_ENVELOPE_COMMAND";
3024         case RIL_REQUEST_STK_SEND_TERMINAL_RESPONSE: return "STK_SEND_TERMINAL_RESPONSE";
3025         case RIL_REQUEST_STK_HANDLE_CALL_SETUP_REQUESTED_FROM_SIM: return "STK_HANDLE_CALL_SETUP_REQUESTED_FROM_SIM";
3026         case RIL_REQUEST_SCREEN_STATE: return "SCREEN_STATE";
3027         case RIL_REQUEST_EXPLICIT_CALL_TRANSFER: return "EXPLICIT_CALL_TRANSFER";
3028         case RIL_REQUEST_SET_LOCATION_UPDATES: return "SET_LOCATION_UPDATES";
3029         case RIL_REQUEST_CDMA_SET_SUBSCRIPTION:return"CDMA_SET_SUBSCRIPTION";
3030         case RIL_REQUEST_CDMA_SET_ROAMING_PREFERENCE:return"CDMA_SET_ROAMING_PREFERENCE";
3031         case RIL_REQUEST_CDMA_QUERY_ROAMING_PREFERENCE:return"CDMA_QUERY_ROAMING_PREFERENCE";
3032         case RIL_REQUEST_SET_TTY_MODE:return"SET_TTY_MODE";
3033         case RIL_REQUEST_QUERY_TTY_MODE:return"QUERY_TTY_MODE";
3034         case RIL_REQUEST_CDMA_SET_PREFERRED_VOICE_PRIVACY_MODE:return"CDMA_SET_PREFERRED_VOICE_PRIVACY_MODE";
3035         case RIL_REQUEST_CDMA_QUERY_PREFERRED_VOICE_PRIVACY_MODE:return"CDMA_QUERY_PREFERRED_VOICE_PRIVACY_MODE";
3036         case RIL_REQUEST_CDMA_FLASH:return"CDMA_FLASH";
3037         case RIL_REQUEST_CDMA_BURST_DTMF:return"CDMA_BURST_DTMF";
3038         case RIL_REQUEST_CDMA_SEND_SMS:return"CDMA_SEND_SMS";
3039         case RIL_REQUEST_CDMA_SMS_ACKNOWLEDGE:return"CDMA_SMS_ACKNOWLEDGE";
3040         case RIL_REQUEST_GET_BROADCAST_CONFIG:return"GET_BROADCAST_CONFIG";
3041         case RIL_REQUEST_SET_BROADCAST_CONFIG:return"SET_BROADCAST_CONFIG";
3042         case RIL_REQUEST_CDMA_GET_BROADCAST_CONFIG:return "CDMA_GET_BROADCAST_CONFIG";
3043         case RIL_REQUEST_CDMA_SET_BROADCAST_CONFIG:return "SET_CDMA_BROADCAST_CONFIG";
3044         case RIL_REQUEST_BROADCAST_ACTIVATION:return "BROADCAST_ACTIVATION"; 
3045         case RIL_REQUEST_CDMA_VALIDATE_AKEY: return"CDMA_VALIDATE_AKEY";
3046         case RIL_REQUEST_CDMA_SUBSCRIPTION: return"CDMA_SUBSCRIPTION";
3047         case RIL_REQUEST_CDMA_WRITE_SMS_TO_RUIM: return "CDMA_WRITE_SMS_TO_RUIM";
3048         case RIL_REQUEST_CDMA_DELETE_SMS_ON_RUIM: return "CDMA_DELETE_SMS_ON_RUIM";
3049         case RIL_REQUEST_DEVICE_IDENTITY: return "DEVICE_IDENTITY";
3050         case RIL_REQUEST_EXIT_EMERGENCY_CALLBACK_MODE: return "EXIT_EMERGENCY_CALLBACK_MODE";
3051         case RIL_REQUEST_GET_SMSC_ADDRESS: return "GET_SMSC_ADDRESS";
3052         case RIL_REQUEST_SET_SMSC_ADDRESS: return "SET_SMSC_ADDRESS";
3053         case RIL_UNSOL_RESPONSE_RADIO_STATE_CHANGED: return "UNSOL_RESPONSE_RADIO_STATE_CHANGED";
3054         case RIL_UNSOL_RESPONSE_CALL_STATE_CHANGED: return "UNSOL_RESPONSE_CALL_STATE_CHANGED";
3055         case RIL_UNSOL_RESPONSE_NETWORK_STATE_CHANGED: return "UNSOL_RESPONSE_NETWORK_STATE_CHANGED";
3056         case RIL_UNSOL_RESPONSE_NEW_SMS: return "UNSOL_RESPONSE_NEW_SMS";
3057         case RIL_UNSOL_RESPONSE_NEW_SMS_STATUS_REPORT: return "UNSOL_RESPONSE_NEW_SMS_STATUS_REPORT";
3058         case RIL_UNSOL_RESPONSE_NEW_SMS_ON_SIM: return "UNSOL_RESPONSE_NEW_SMS_ON_SIM";
3059         case RIL_UNSOL_ON_USSD: return "UNSOL_ON_USSD";
3060         case RIL_UNSOL_ON_USSD_REQUEST: return "UNSOL_ON_USSD_REQUEST(obsolete)";
3061         case RIL_UNSOL_NITZ_TIME_RECEIVED: return "UNSOL_NITZ_TIME_RECEIVED";
3062         case RIL_UNSOL_SIGNAL_STRENGTH: return "UNSOL_SIGNAL_STRENGTH";
3063         case RIL_UNSOL_STK_SESSION_END: return "UNSOL_STK_SESSION_END";
3064         case RIL_UNSOL_STK_PROACTIVE_COMMAND: return "UNSOL_STK_PROACTIVE_COMMAND";
3065         case RIL_UNSOL_STK_EVENT_NOTIFY: return "UNSOL_STK_EVENT_NOTIFY";
3066         case RIL_UNSOL_STK_CALL_SETUP: return "UNSOL_STK_CALL_SETUP";
3067         case RIL_UNSOL_SIM_SMS_STORAGE_FULL: return "UNSOL_SIM_SMS_STORAGE_FUL";
3068         case RIL_UNSOL_SIM_REFRESH: return "UNSOL_SIM_REFRESH";
3069         case RIL_UNSOL_DATA_CALL_LIST_CHANGED: return "UNSOL_DATA_CALL_LIST_CHANGED";
3070         case RIL_UNSOL_CALL_RING: return "UNSOL_CALL_RING";
3071         case RIL_UNSOL_RESPONSE_SIM_STATUS_CHANGED: return "UNSOL_RESPONSE_SIM_STATUS_CHANGED";
3072         case RIL_UNSOL_RESPONSE_CDMA_NEW_SMS: return "UNSOL_NEW_CDMA_SMS";
3073         case RIL_UNSOL_RESPONSE_NEW_BROADCAST_SMS: return "UNSOL_NEW_BROADCAST_SMS";
3074         case RIL_UNSOL_CDMA_RUIM_SMS_STORAGE_FULL: return "UNSOL_CDMA_RUIM_SMS_STORAGE_FULL";
3075         case RIL_UNSOL_RESTRICTED_STATE_CHANGED: return "UNSOL_RESTRICTED_STATE_CHANGED";
3076         case RIL_UNSOL_ENTER_EMERGENCY_CALLBACK_MODE: return "UNSOL_ENTER_EMERGENCY_CALLBACK_MODE";
3077         case RIL_UNSOL_CDMA_CALL_WAITING: return "UNSOL_CDMA_CALL_WAITING";
3078         case RIL_UNSOL_CDMA_OTA_PROVISION_STATUS: return "UNSOL_CDMA_OTA_PROVISION_STATUS";
3079         case RIL_UNSOL_CDMA_INFO_REC: return "UNSOL_CDMA_INFO_REC";
3080         case RIL_UNSOL_OEM_HOOK_RAW: return "UNSOL_OEM_HOOK_RAW";
3081         default: return "<unknown request>";
3082     }
3083 }
3084
3085 } /* namespace android */