`

Android日志系统驱动程序Logger源代码分析

 
阅读更多

我们知道，在Android系统中，提供了一个轻量级的日志系统，这个日志系统是以驱动程序的形式实现在内核空间的，而在用户空间分别提供了Java接口和C/C++接口来使用这个日志系统，取决于你编写的是Android应用程序还是系统组件。在前面的文章浅谈Android系统开发中LOG的使用中，已经简要地介绍了在Android应用程序开发中Log的使用方法，在这一篇文章中，我们将更进一步地分析Logger驱动程序的源代码，使得我们对Android日志系统有一个深刻的认识。

既然Android 日志系统是以驱动程序的形式实现在内核空间的，我们就需要获取Android内核源代码来分析了，请参照前面在Ubuntu上下载、编译和安装Android最新源代码和在Ubuntu上下载、编译和安装Android最新内核源代码（Linux Kernel）两篇文章，下载好Android源代码工程。Logger驱动程序主要由两个文件构成，分别是：

kernel/common/drivers/staging/android/logger.h

kernel/common/drivers/staging/android/logger.c

接下来，我们将分别介绍Logger驱动程序的相关数据结构，然后对Logger驱动程序源代码进行情景分析，分别日志系统初始化情景、日志读取情景和日志写入情景。

一.Logger驱动程序的相关数据结构。

我们首先来看logger.h头文件的内容：

view plain
  1. #ifndef_LINUX_LOGGER_H
  2. #define_LINUX_LOGGER_H
  4. #include<linux/types.h>
  5. #include<linux/ioctl.h>
  7. structlogger_entry{
  8. __u16len;/*lengthofthepayload*/
  9. __u16__pad;/*nomatterwhat,weget2bytesofpadding*/
  10. __s32pid;/*generatingprocess'spid*/
  11. __s32tid;/*generatingprocess'stid*/
  12. __s32sec;/*secondssinceEpoch*/
  13. __s32nsec;/*nanoseconds*/
  14. charmsg[0];/*theentry'spayload*/
  15. };
  17. #defineLOGGER_LOG_RADIO"log_radio"/*radio-relatedmessages*/
  18. #defineLOGGER_LOG_EVENTS"log_events"/*system/hardwareevents*/
  19. #defineLOGGER_LOG_MAIN"log_main"/*everythingelse*/
  21. #defineLOGGER_ENTRY_MAX_LEN(4*1024)
  22. #defineLOGGER_ENTRY_MAX_PAYLOAD\
  23. (LOGGER_ENTRY_MAX_LEN-sizeof(structlogger_entry))
  25. #define__LOGGERIO0xAE
  27. #defineLOGGER_GET_LOG_BUF_SIZE_IO(__LOGGERIO,1)/*sizeoflog*/
  28. #defineLOGGER_GET_LOG_LEN_IO(__LOGGERIO,2)/*usedloglen*/
  29. #defineLOGGER_GET_NEXT_ENTRY_LEN_IO(__LOGGERIO,3)/*nextentrylen*/
  30. #defineLOGGER_FLUSH_LOG_IO(__LOGGERIO,4)/*flushlog*/
  32. #endif/*_LINUX_LOGGER_H*/
struct logger_entry是一个用于描述一条Log记录的结构体。len成员变量记录了这条记录的有效负载的长度，有效负载指定的日志记录本身的长度，但是不包括用于描述这个记录的struct logger_entry结构体。回忆一下我们调用android.util.Log接口来使用日志系统时，会指定日志的优先级别Priority、Tag字符串以及Msg字符串，Priority + Tag + Msg三者内容的长度加起来就是记录的有效负载长度了。__pad成员变量是用来对齐结构体的。pid和tid成员变量分别用来记录是哪条进程写入了这条记录。sec和nsec成员变量记录日志写的时间。msg成员变量记录的就有效负载的内容了，它的大小由len成员变量来确定。

接着定义两个宏：

#define LOGGER_ENTRY_MAX_LEN (4*1024)

#define LOGGER_ENTRY_MAX_PAYLOAD \

(LOGGER_ENTRY_MAX_LEN - sizeof(struct logger_entry))

从这两个宏可以看出，每条日志记录的有效负载长度加上结构体logger_entry的长度不能超过4K个字节。

logger.h文件中还定义了其它宏，读者可以自己分析，在下面的分析中，碰到时，我们也会详细解释。

再来看logger.c文件中，其它相关数据结构的定义：

view plain
  1. /*
  2. *structlogger_log-representsaspecificlog,suchas'main'or'radio'
  3. *
  4. *Thisstructurelivesfrommoduleinsertionuntilmoduleremoval,soitdoes
  5. *notneedadditionalreferencecounting.Thestructureisprotectedbythe
  6. *mutex'mutex'.
  7. */
  8. structlogger_log{
  9. unsignedchar*buffer;/*theringbufferitself*/
  10. structmiscdevicemisc;/*miscdevicerepresentingthelog*/
  11. wait_queue_head_twq;/*waitqueueforreaders*/
  12. structlist_headreaders;/*thislog'sreaders*/
  13. structmutexmutex;/*mutexprotectingbuffer*/
  14. size_tw_off;/*currentwriteheadoffset*/
  15. size_thead;/*newreadersstarthere*/
  16. size_tsize;/*sizeofthelog*/
  17. };
  19. /*
  20. *structlogger_reader-aloggingdeviceopenforreading
  21. *
  22. *Thisobjectlivesfromopentorelease,sowedon'tneedadditional
  23. *referencecounting.Thestructureisprotectedbylog->mutex.
  24. */
  25. structlogger_reader{
  26. structlogger_log*log;/*associatedlog*/
  27. structlist_headlist;/*entryinlogger_log'slist*/
  28. size_tr_off;/*currentreadheadoffset*/
  29. };
  31. /*logger_offset-returnsindex'n'intothelogvia(optimized)modulus*/
  32. #definelogger_offset(n)((n)&(log->size-1))
结构体struct logger_log就是真正用来保存日志的地方了。buffer成员变量变是用保存日志信息的内存缓冲区，它的大小由size成员变量确定。从misc成员变量可以看出，logger驱动程序使用的设备属于misc类型的设备，通过在Android模拟器上执行cat /proc/devices命令（可参考在Ubuntu上下载、编译和安装Android最新内核源代码（Linux Kernel）一文），可以看出，misc类型设备的主设备号是10。关于主设备号的相关知识，可以参考Android学习启动篇一文中提到的Linux Driver Development一书。wq成员变量是一个等待队列，用于保存正在等待读取日志的进程。readers成员变量用来保存当前正在读取日志的进程，正在读取日志的进程由结构体logger_reader来描述。mutex成员变量是一个互斥量，用来保护log的并发访问。可以看出，这里的日志系统的读写问题，其实是一个生产者-消费者的问题，因此，需要互斥量来保护log的并发访问。 w_off成员变量用来记录下一条日志应该从哪里开始写。head成员变量用来表示打开日志文件中，应该从哪一个位置开始读取日志。

结构体struct logger_reader用来表示一个读取日志的进程，log成员变量指向要读取的日志缓冲区。list成员变量用来连接其它读者进程。r_off成员变量表示当前要读取的日志在缓冲区中的位置。

struct logger_log结构体中用于保存日志信息的内存缓冲区buffer是一个循环使用的环形缓冲区，缓冲区中保存的内容是以struct logger_entry为单位的，每个单位的组成为：

struct logger_entry | priority | tag | msg

由于是内存缓冲区buffer是一个循环使用的环形缓冲区，给定一个偏移值，它在buffer中的位置由下logger_offset来确定：

#define logger_offset(n) ((n) & (log->size - 1))

二. Logger驱动程序模块的初始化过程分析。

继续看logger.c文件，定义了三个日志设备：

view plain
  1. /*
  2. *Definesalogstructurewithname'NAME'andasizeof'SIZE'bytes,which
  3. *mustbeapoweroftwo,greaterthanLOGGER_ENTRY_MAX_LEN,andlessthan
  4. *LONG_MAXminusLOGGER_ENTRY_MAX_LEN.
  5. */
  6. #defineDEFINE_LOGGER_DEVICE(VAR,NAME,SIZE)\
  7. staticunsignedchar_buf_##VAR[SIZE];\
  8. staticstructlogger_logVAR={\
  9. .buffer=_buf_##VAR,\
  10. .misc={\
  11. .minor=MISC_DYNAMIC_MINOR,\
  12. .name=NAME,\
  13. .fops=&logger_fops,\
  14. .parent=NULL,\
  15. },\
  16. .wq=__WAIT_QUEUE_HEAD_INITIALIZER(VAR.wq),\
  17. .readers=LIST_HEAD_INIT(VAR.readers),\
  18. .mutex=__MUTEX_INITIALIZER(VAR.mutex),\
  19. .w_off=0,\
  20. .head=0,\
  21. .size=SIZE,\
  22. };
  24. DEFINE_LOGGER_DEVICE(log_main,LOGGER_LOG_MAIN,64*1024)
  25. DEFINE_LOGGER_DEVICE(log_events,LOGGER_LOG_EVENTS,256*1024)
  26. DEFINE_LOGGER_DEVICE(log_radio,LOGGER_LOG_RADIO,64*1024)
分别是log_main、log_events和log_radio，名称分别LOGGER_LOG_MAIN、LOGGER_LOG_EVENTS和LOGGER_LOG_RADIO，它们的次设备号为MISC_DYNAMIC_MINOR，即为在注册时动态分配。在logger.h文件中，有这三个宏的定义：

#define LOGGER_LOG_RADIO "log_radio"/* radio-related messages */
#define LOGGER_LOG_EVENTS "log_events"/* system/hardware events */
#define LOGGER_LOG_MAIN "log_main"/* everything else */

注释说明了这三个日志设备的用途。注册的日志设备文件操作方法为logger_fops：

view plain
  1. staticstructfile_operationslogger_fops={
  2. .owner=THIS_MODULE,
  3. .read=logger_read,
  4. .aio_write=logger_aio_write,
  5. .poll=logger_poll,
  6. .unlocked_ioctl=logger_ioctl,
  7. .compat_ioctl=logger_ioctl,
  8. .open=logger_open,
  9. .release=logger_release,
  10. };

日志驱动程序模块的初始化函数为logger_init：

view plain
  1. staticint__initlogger_init(void)
  2. {
  3. intret;
  5. ret=init_log(&log_main);
  6. if(unlikely(ret))
  7. gotoout;
  9. ret=init_log(&log_events);
  10. if(unlikely(ret))
  11. gotoout;
  13. ret=init_log(&log_radio);
  14. if(unlikely(ret))
  15. gotoout;
  17. out:
  18. returnret;
  19. }
  20. device_initcall(logger_init);
logger_init函数通过调用init_log函数来初始化了上述提到的三个日志设备：
view plain
  1. staticint__initinit_log(structlogger_log*log)
  2. {
  3. intret;
  5. ret=misc_register(&log->misc);
  6. if(unlikely(ret)){
  7. printk(KERN_ERR"logger:failedtoregistermisc"
  8. "deviceforlog'%s'!\n",log->misc.name);
  9. returnret;
  10. }
  12. printk(KERN_INFO"logger:created%luKlog'%s'\n",
  13. (unsignedlong)log->size>>10,log->misc.name);
  15. return0;
  16. }
init_log函数主要调用了misc_register函数来注册misc设备，misc_register函数定义在kernel/common/drivers/char/misc.c文件中：
view plain
  1. /**
  2. *misc_register-registeramiscellaneousdevice
  3. *@misc:devicestructure
  4. *
  5. *Registeramiscellaneousdevicewiththekernel.Iftheminor
  6. *numberissetto%MISC_DYNAMIC_MINORaminornumberisassigned
  7. *andplacedintheminorfieldofthestructure.Forothercases
  8. *theminornumberrequestedisused.
  9. *
  10. *Thestructurepassedislinkedintothekernelandmaynotbe
  11. *destroyeduntilithasbeenunregistered.
  12. *
  13. *Azeroisreturnedonsuccessandanegativeerrnocodefor
  14. *failure.
  15. */
  17. intmisc_register(structmiscdevice*misc)
  18. {
  19. structmiscdevice*c;
  20. dev_tdev;
  21. interr=0;
  23. INIT_LIST_HEAD(&misc->list);
  25. mutex_lock(&misc_mtx);
  26. list_for_each_entry(c,&misc_list,list){
  27. if(c->minor==misc->minor){
  28. mutex_unlock(&misc_mtx);
  29. return-EBUSY;
  30. }
  31. }
  33. if(misc->minor==MISC_DYNAMIC_MINOR){
  34. inti=DYNAMIC_MINORS;
  35. while(--i>=0)
  36. if((misc_minors[i>>3]&(1<<(i&7)))==0)
  37. break;
  38. if(i<0){
  39. mutex_unlock(&misc_mtx);
  40. return-EBUSY;
  41. }
  42. misc->minor=i;
  43. }
  45. if(misc->minor<DYNAMIC_MINORS)
  46. misc_minors[misc->minor>>3]|=1<<(misc->minor&7);
  47. dev=MKDEV(MISC_MAJOR,misc->minor);
  49. misc->this_device=device_create(misc_class,misc->parent,dev,NULL,
  50. "%s",misc->name);
  51. if(IS_ERR(misc->this_device)){
  52. err=PTR_ERR(misc->this_device);
  53. gotoout;
  54. }
  56. /*
  57. *Addittothefront,sothatlaterdevicescan"override"
  58. *earlierdefaults
  59. */
  60. list_add(&misc->list,&misc_list);
  61. out:
  62. mutex_unlock(&misc_mtx);
  63. returnerr;
  64. }
注册完成后，通过device_create创建设备文件节点。这里，将创建/dev/log/main、/dev/log/events和/dev/log/radio三个设备文件，这样，用户空间就可以通过读写这三个文件和驱动程序进行交互。

三. Logger驱动程序的日志记录读取过程分析。

继续看logger.c 文件，注册的读取日志设备文件的方法为logger_read：

view plain
  1. /*
  2. *logger_read-ourlog'sread()method
  3. *
  4. *Behavior:
  5. *
  6. *-O_NONBLOCKworks
  7. *-Iftherearenologentriestoread,blocksuntillogiswrittento
  8. *-Atomicallyreadsexactlyonelogentry
  9. *
  10. *OptimalreadsizeisLOGGER_ENTRY_MAX_LEN.WillseterrnotoEINVALifread
  11. *bufferisinsufficienttoholdnextentry.
  12. */
  13. staticssize_tlogger_read(structfile*file,char__user*buf,
  14. size_tcount,loff_t*pos)
  15. {
  16. structlogger_reader*reader=file->private_data;
  17. structlogger_log*log=reader->log;
  18. ssize_tret;
  19. DEFINE_WAIT(wait);
  21. start:
  22. while(1){
  23. prepare_to_wait(&log->wq,&wait,TASK_INTERRUPTIBLE);
  25. mutex_lock(&log->mutex);
  26. ret=(log->w_off==reader->r_off);
  27. mutex_unlock(&log->mutex);
  28. if(!ret)
  29. break;
  31. if(file->f_flags&O_NONBLOCK){
  32. ret=-EAGAIN;
  33. break;
  34. }
  36. if(signal_pending(current)){
  37. ret=-EINTR;
  38. break;
  39. }
  41. schedule();
  42. }
  44. finish_wait(&log->wq,&wait);
  45. if(ret)
  46. returnret;
  48. mutex_lock(&log->mutex);
  50. /*istherestillsomethingtoreadordidwerace?*/
  51. if(unlikely(log->w_off==reader->r_off)){
  52. mutex_unlock(&log->mutex);
  53. gotostart;
  54. }
  56. /*getthesizeofthenextentry*/
  57. ret=get_entry_len(log,reader->r_off);
  58. if(count<ret){
  59. ret=-EINVAL;
  60. gotoout;
  61. }
  63. /*getexactlyoneentryfromthelog*/
  64. ret=do_read_log_to_user(log,reader,buf,ret);
  66. out:
  67. mutex_unlock(&log->mutex);
  69. returnret;
  70. }
注意，在函数开始的地方，表示读取日志上下文的struct logger_reader是保存在文件指针的private_data成员变量里面的，这是在打开设备文件时设置的，设备文件打开方法为logger_open：
view plain
  1. /*
  2. *logger_open-thelog'sopen()fileoperation
  3. *
  4. *Notehownearano-opthisisinthewrite-onlycase.Keepitthatway!
  5. */
  6. staticintlogger_open(structinode*inode,structfile*file)
  7. {
  8. structlogger_log*log;
  9. intret;
  11. ret=nonseekable_open(inode,file);
  12. if(ret)
  13. returnret;
  15. log=get_log_from_minor(MINOR(inode->i_rdev));
  16. if(!log)
  17. return-ENODEV;
  19. if(file->f_mode&FMODE_READ){
  20. structlogger_reader*reader;
  22. reader=kmalloc(sizeof(structlogger_reader),GFP_KERNEL);
  23. if(!reader)
  24. return-ENOMEM;
  26. reader->log=log;
  27. INIT_LIST_HEAD(&reader->list);
  29. mutex_lock(&log->mutex);
  30. reader->r_off=log->head;
  31. list_add_tail(&reader->list,&log->readers);
  32. mutex_unlock(&log->mutex);
  34. file->private_data=reader;
  35. }else
  36. file->private_data=log;
  38. return0;
  39. }
新打开日志设备文件时，是从log->head位置开始读取日志的，保存在struct logger_reader的成员变量r_off中。

start标号处的while循环是在等待日志可读，如果已经没有新的日志可读了，那么就要读进程就要进入休眠状态，等待新的日志写入后再唤醒，这是通过prepare_wait和schedule两个调用来实现的。如果没有新的日志可读，并且设备文件不是以非阻塞O_NONBLOCK的方式打开或者这时有信号要处理（signal_pending(current)），那么就直接返回，不再等待新的日志写入。判断当前是否有新的日志可读的方法是：

ret = (log->w_off == reader->r_off);

即判断当前缓冲区的写入位置和当前读进程的读取位置是否相等，如果不相等，则说明有新的日志可读。

继续向下看，如果有新的日志可读，那么就，首先通过get_entry_len来获取下一条可读的日志记录的长度，从这里可以看出，日志读取进程是以日志记录为单位进行读取的，一次只读取一条记录。get_entry_len的函数实现如下：

view plain
  1. /*
  2. *get_entry_len-Grabsthelengthofthepayloadofthenextentrystarting
  3. *from'off'.
  4. *
  5. *Callerneedstoholdlog->mutex.
  6. */
  7. static__u32get_entry_len(structlogger_log*log,size_toff)
  8. {
  9. __u16val;
  11. switch(log->size-off){
  12. case1:
  13. memcpy(&val,log->buffer+off,1);
  14. memcpy(((char*)&val)+1,log->buffer,1);
  15. break;
  16. default:
  17. memcpy(&val,log->buffer+off,2);
  18. }
  20. returnsizeof(structlogger_entry)+val;
  21. }
上面我们提到，每一条日志记录是由两大部分组成的，一个用于描述这条日志记录的结构体struct logger_entry，另一个是记录体本身，即有效负载。结构体struct logger_entry的长度是固定的，只要知道有效负载的长度，就可以知道整条日志记录的长度了。而有效负载的长度是记录在结构体struct logger_entry的成员变量len中，而len成员变量的地址与struct logger_entry的地址相同，因此，只需要读取记录的开始位置的两个字节就可以了。又由于日志记录缓冲区是循环使用的，这两个节字有可能是第一个字节存放在缓冲区最后一个字节，而第二个字节存放在缓冲区的第一个节，除此之外，这两个字节都是连在一起的。因此，分两种情况来考虑，对于前者，分别通过读取缓冲区最后一个字节和第一个字节来得到日志记录的有效负载长度到本地变量val中，对于后者，直接读取连续两个字节的值到本地变量val中。这两种情况是通过判断日志缓冲区的大小和要读取的日志记录在缓冲区中的位置的差值来区别的，如果相差1，就说明是前一种情况了。最后，把有效负载的长度val加上struct logger_entry的长度就得到了要读取的日志记录的总长度了。

接着往下看，得到了要读取的记录的长度，就调用do_read_log_to_user函数来执行真正的读取动作：

view plain
  1. staticssize_tdo_read_log_to_user(structlogger_log*log,
  2. structlogger_reader*reader,
  3. char__user*buf,
  4. size_tcount)
  5. {
  6. size_tlen;
  8. /*
  9. *Wereadfromthelogintwodisjointoperations.First,wereadfrom
  10. *thecurrentreadheadoffsetupto'count'bytesortotheendof
  11. *thelog,whichevercomesfirst.
  12. */
  13. len=min(count,log->size-reader->r_off);
  14. if(copy_to_user(buf,log->buffer+reader->r_off,len))
  15. return-EFAULT;
  17. /*
  18. *Second,wereadanyremainingbytes,startingbackattheheadof
  19. *thelog.
  20. */
  21. if(count!=len)
  22. if(copy_to_user(buf+len,log->buffer,count-len))
  23. return-EFAULT;
  25. reader->r_off=logger_offset(reader->r_off+count);
  27. returncount;
  28. }
这个函数简单地调用copy_to_user函数来把位于内核空间的日志缓冲区指定的内容拷贝到用户空间的内存缓冲区就可以了，同时，把当前读取日志进程的上下文信息中的读偏移r_off前进到下一条日志记录的开始的位置上。

四. Logger驱动程序的日志记录写入过程分析。

继续看logger.c 文件，注册的写入日志设备文件的方法为logger_aio_write：

view plain
  1. /*
  2. *logger_aio_write-ourwritemethod,implementingsupportforwrite(),
  3. *writev(),andaio_write().Writesareourfastpath,andwetrytooptimize
  4. *themaboveallelse.
  5. */
  6. ssize_tlogger_aio_write(structkiocb*iocb,conststructiovec*iov,
  7. unsignedlongnr_segs,loff_tppos)
  8. {
  9. structlogger_log*log=file_get_log(iocb->ki_filp);
  10. size_torig=log->w_off;
  11. structlogger_entryheader;
  12. structtimespecnow;
  13. ssize_tret=0;
  15. now=current_kernel_time();
  17. header.pid=current->tgid;
  18. header.tid=current->pid;
  19. header.sec=now.tv_sec;
  20. header.nsec=now.tv_nsec;
  21. header.len=min_t(size_t,iocb->ki_left,LOGGER_ENTRY_MAX_PAYLOAD);
  23. /*nullwritessucceed,returnzero*/
  24. if(unlikely(!header.len))
  25. return0;
  27. mutex_lock(&log->mutex);
  29. /*
  30. *Fixupanyreaders,pullingthemforwardtothefirstreadable
  31. *entryafter(whatwillbe)thenewwriteoffset.Wedothisnow
  32. *becauseifwepartiallyfail,wecanendupwithclobberedlog
  33. *entriesthatencroachonreadablebuffer.
  34. */
  35. fix_up_readers(log,sizeof(structlogger_entry)+header.len);
  37. do_write_log(log,&header,sizeof(structlogger_entry));
  39. while(nr_segs-->0){
  40. size_tlen;
  41. ssize_tnr;
  43. /*figureouthowmuchofthisvectorwecankeep*/
  44. len=min_t(size_t,iov->iov_len,header.len-ret);
  46. /*writeoutthissegment'spayload*/
  47. nr=do_write_log_from_user(log,iov->iov_base,len);
  48. if(unlikely(nr<0)){
  49. log->w_off=orig;
  50. mutex_unlock(&log->mutex);
  51. returnnr;
  52. }
  54. iov++;
  55. ret+=nr;
  56. }
  58. mutex_unlock(&log->mutex);
  60. /*wakeupanyblockedreaders*/
  61. wake_up_interruptible(&log->wq);
  63. returnret;
  64. }
输入的参数iocb表示io上下文，iov表示要写入的内容，长度为nr_segs，表示有nr_segs个段的内容要写入。我们知道，每个要写入的日志的结构形式为：

struct logger_entry | priority | tag | msg

其中， priority、tag和msg这三个段的内容是由iov参数从用户空间传递下来的，分别对应iov里面的三个元素。而logger_entry是由内核空间来构造的：

struct logger_entry header;
struct timespec now;

now = current_kernel_time();

header.pid = current->tgid;
header.tid = current->pid;
header.sec = now.tv_sec;
header.nsec = now.tv_nsec;
header.len = min_t(size_t, iocb->ki_left, LOGGER_ENTRY_MAX_PAYLOAD);

然后调用do_write_log首先把logger_entry结构体写入到日志缓冲区中：

view plain
  1. /*
  2. *do_write_log-writes'len'bytesfrom'buf'to'log'
  3. *
  4. *Thecallerneedstoholdlog->mutex.
  5. */
  6. staticvoiddo_write_log(structlogger_log*log,constvoid*buf,size_tcount)
  7. {
  8. size_tlen;
  10. len=min(count,log->size-log->w_off);
  11. memcpy(log->buffer+log->w_off,buf,len);
  13. if(count!=len)
  14. memcpy(log->buffer,buf+len,count-len);
  16. log->w_off=logger_offset(log->w_off+count);
  18. }
由于logger_entry是内核堆栈空间分配的，直接用memcpy拷贝就可以了。

接着，通过一个while循环把iov的内容写入到日志缓冲区中，也就是日志的优先级别priority、日志Tag和日志主体Msg：

view plain
  1. while(nr_segs-->0){
  2. size_tlen;
  3. ssize_tnr;
  5. /*figureouthowmuchofthisvectorwecankeep*/
  6. len=min_t(size_t,iov->iov_len,header.len-ret);
  8. /*writeoutthissegment'spayload*/
  9. nr=do_write_log_from_user(log,iov->iov_base,len);
  10. if(unlikely(nr<0)){
  11. log->w_off=orig;
  12. mutex_unlock(&log->mutex);
  13. returnnr;
  14. }
  16. iov++;
  17. ret+=nr;
  18. }
由于iov的内容是由用户空间传下来的，需要调用do_write_log_from_user来写入：
view plain
  1. staticssize_tdo_write_log_from_user(structlogger_log*log,
  2. constvoid__user*buf,size_tcount)
  3. {
  4. size_tlen;
  6. len=min(count,log->size-log->w_off);
  7. if(len&&copy_from_user(log->buffer+log->w_off,buf,len))
  8. return-EFAULT;
  10. if(count!=len)
  11. if(copy_from_user(log->buffer,buf+len,count-len))
  12. return-EFAULT;
  14. log->w_off=logger_offset(log->w_off+count);
  16. returncount;
  17. }
这里，我们还漏了一个重要的步骤：
view plain
  1. /*
  2. *Fixupanyreaders,pullingthemforwardtothefirstreadable
  3. *entryafter(whatwillbe)thenewwriteoffset.Wedothisnow
  4. *becauseifwepartiallyfail,wecanendupwithclobberedlog
  5. *entriesthatencroachonreadablebuffer.
  6. */
  7. fix_up_readers(log,sizeof(structlogger_entry)+header.len);
为什么要调用fix_up_reader这个函数呢？这个函数又是作什么用的呢？是这样的，由于日志缓冲区是循环使用的，即旧的日志记录如果没有及时读取，而缓冲区的内容又已经用完时，就需要覆盖旧的记录来容纳新的记录。而这部分将要被覆盖的内容，有可能是某些reader的下一次要读取的日志所在的位置，以及为新的reader准备的日志开始读取位置head所在的位置。因此，需要调整这些位置，使它们能够指向一个新的有效的位置。我们来看一下fix_up_reader函数的实现：
view plain
  1. /*
  2. *fix_up_readers-walkthelistofallreadersand"fixup"anywhowere
  3. *lappedbythewriter;alsodothesameforthedefault"starthead".
  4. *Wedothisby"pullingforward"thereadersandstartheadtothefirst
  5. *entryafterthenewwritehead.
  6. *
  7. *Thecallerneedstoholdlog->mutex.
  8. */
  9. staticvoidfix_up_readers(structlogger_log*log,size_tlen)
  10. {
  11. size_told=log->w_off;
  12. size_tnew=logger_offset(old+len);
  13. structlogger_reader*reader;
  15. if(clock_interval(old,new,log->head))
  16. log->head=get_next_entry(log,log->head,len);
  18. list_for_each_entry(reader,&log->readers,list)
  19. if(clock_interval(old,new,reader->r_off))
  20. reader->r_off=get_next_entry(log,reader->r_off,len);
  21. }
判断log->head和所有读者reader的当前读偏移reader->r_off是否在被覆盖的区域内，如果是，就需要调用get_next_entry来取得下一个有效的记录的起始位置来调整当前位置：
view plain
  1. /*
  2. *get_next_entry-returntheoffsetofthefirstvalidentryatleast'len'
  3. *bytesafter'off'.
  4. *
  5. *Callermustholdlog->mutex.
  6. */
  7. staticsize_tget_next_entry(structlogger_log*log,size_toff,size_tlen)
  8. {
  9. size_tcount=0;
  11. do{
  12. size_tnr=get_entry_len(log,off);
  13. off=logger_offset(off+nr);
  14. count+=nr;
  15. }while(count<len);
  17. returnoff;
  18. }
而判断log->head和所有读者reader的当前读偏移reader->r_off是否在被覆盖的区域内，是通过clock_interval函数来实现的：
view plain
  1. /*
  2. *clock_interval-isa<c<binmod-space?Putanotherway,doestheline
  3. *fromatobcrossc?
  4. */
  5. staticinlineintclock_interval(size_ta,size_tb,size_tc)
  6. {
  7. if(b<a){
  8. if(a<c||b>=c)
  9. return1;
  10. }else{
  11. if(a<c&&b>=c)
  12. return1;
  13. }
  15. return0;
  16. }
最后，日志写入完毕，还需要唤醒正在等待新日志的reader进程:

/* wake up any blocked readers */
wake_up_interruptible(&log->wq);

至此， Logger驱动程序的主要逻辑就分析完成了，还有其它的一些接口，如logger_poll、logger_ioctl和logger_release函数，比较简单，读取可以自行分析。这里还需要提到的一点是，由于Logger驱动程序模块在退出系统时，是不会卸载的，所以这个模块没有module_exit函数，而对于模块里面定义的对象，也没有用对引用计数技术。

这篇文章着重介绍了Android日志系统在内核空间的实现，在下一篇文章中，我们将接着介绍在用户空间中，提供给Android应用程序使用的Java和C/C++ LOG调用接口的实现过程，敬请关注。


我们知道，在Android系统中，提供了一个轻量级的日志系统，这个日志系统是以驱动程序的形式实现在内核空间的，而在用户空间分别提供了Java接口和C/C++接口来使用这个日志系统，取决于你编写的是Android应用程序还是系统组件。在前面的文章浅谈Android系统开发中LOG的使用中，已经简要地介绍了在Android应用程序开发中Log的使用方法，在这一篇文章中，我们将更进一步地分析Logger驱动程序的源代码，使得我们对Android日志系统有一个深刻的认识。

既然Android 日志系统是以驱动程序的形式实现在内核空间的，我们就需要获取Android内核源代码来分析了，请参照前面在Ubuntu上下载、编译和安装Android最新源代码和在Ubuntu上下载、编译和安装Android最新内核源代码（Linux Kernel）两篇文章，下载好Android源代码工程。Logger驱动程序主要由两个文件构成，分别是：

kernel/common/drivers/staging/android/logger.h

kernel/common/drivers/staging/android/logger.c

接下来，我们将分别介绍Logger驱动程序的相关数据结构，然后对Logger驱动程序源代码进行情景分析，分别日志系统初始化情景、日志读取情景和日志写入情景。

一.Logger驱动程序的相关数据结构。

我们首先来看logger.h头文件的内容：

view plain
  1. #ifndef_LINUX_LOGGER_H
  2. #define_LINUX_LOGGER_H
  4. #include<linux/types.h>
  5. #include<linux/ioctl.h>
  7. structlogger_entry{
  8. __u16len;/*lengthofthepayload*/
  9. __u16__pad;/*nomatterwhat,weget2bytesofpadding*/
  10. __s32pid;/*generatingprocess'spid*/
  11. __s32tid;/*generatingprocess'stid*/
  12. __s32sec;/*secondssinceEpoch*/
  13. __s32nsec;/*nanoseconds*/
  14. charmsg[0];/*theentry'spayload*/
  15. };
  17. #defineLOGGER_LOG_RADIO"log_radio"/*radio-relatedmessages*/
  18. #defineLOGGER_LOG_EVENTS"log_events"/*system/hardwareevents*/
  19. #defineLOGGER_LOG_MAIN"log_main"/*everythingelse*/
  21. #defineLOGGER_ENTRY_MAX_LEN(4*1024)
  22. #defineLOGGER_ENTRY_MAX_PAYLOAD\
  23. (LOGGER_ENTRY_MAX_LEN-sizeof(structlogger_entry))
  25. #define__LOGGERIO0xAE
  27. #defineLOGGER_GET_LOG_BUF_SIZE_IO(__LOGGERIO,1)/*sizeoflog*/
  28. #defineLOGGER_GET_LOG_LEN_IO(__LOGGERIO,2)/*usedloglen*/
  29. #defineLOGGER_GET_NEXT_ENTRY_LEN_IO(__LOGGERIO,3)/*nextentrylen*/
  30. #defineLOGGER_FLUSH_LOG_IO(__LOGGERIO,4)/*flushlog*/
  32. #endif/*_LINUX_LOGGER_H*/
struct logger_entry是一个用于描述一条Log记录的结构体。len成员变量记录了这条记录的有效负载的长度，有效负载指定的日志记录本身的长度，但是不包括用于描述这个记录的struct logger_entry结构体。回忆一下我们调用android.util.Log接口来使用日志系统时，会指定日志的优先级别Priority、Tag字符串以及Msg字符串，Priority + Tag + Msg三者内容的长度加起来就是记录的有效负载长度了。__pad成员变量是用来对齐结构体的。pid和tid成员变量分别用来记录是哪条进程写入了这条记录。sec和nsec成员变量记录日志写的时间。msg成员变量记录的就有效负载的内容了，它的大小由len成员变量来确定。

接着定义两个宏：

#define LOGGER_ENTRY_MAX_LEN (4*1024)

#define LOGGER_ENTRY_MAX_PAYLOAD \

(LOGGER_ENTRY_MAX_LEN - sizeof(struct logger_entry))

从这两个宏可以看出，每条日志记录的有效负载长度加上结构体logger_entry的长度不能超过4K个字节。

logger.h文件中还定义了其它宏，读者可以自己分析，在下面的分析中，碰到时，我们也会详细解释。

再来看logger.c文件中，其它相关数据结构的定义：

view plain
  1. /*
  2. *structlogger_log-representsaspecificlog,suchas'main'or'radio'
  3. *
  4. *Thisstructurelivesfrommoduleinsertionuntilmoduleremoval,soitdoes
  5. *notneedadditionalreferencecounting.Thestructureisprotectedbythe
  6. *mutex'mutex'.
  7. */
  8. structlogger_log{
  9. unsignedchar*buffer;/*theringbufferitself*/
  10. structmiscdevicemisc;/*miscdevicerepresentingthelog*/
  11. wait_queue_head_twq;/*waitqueueforreaders*/
  12. structlist_headreaders;/*thislog'sreaders*/
  13. structmutexmutex;/*mutexprotectingbuffer*/
  14. size_tw_off;/*currentwriteheadoffset*/
  15. size_thead;/*newreadersstarthere*/
  16. size_tsize;/*sizeofthelog*/
  17. };
  19. /*
  20. *structlogger_reader-aloggingdeviceopenforreading
  21. *
  22. *Thisobjectlivesfromopentorelease,sowedon'tneedadditional
  23. *referencecounting.Thestructureisprotectedbylog->mutex.
  24. */
  25. structlogger_reader{
  26. structlogger_log*log;/*associatedlog*/
  27. structlist_headlist;/*entryinlogger_log'slist*/
  28. size_tr_off;/*currentreadheadoffset*/
  29. };
  31. /*logger_offset-returnsindex'n'intothelogvia(optimized)modulus*/
  32. #definelogger_offset(n)((n)&(log->size-1))
结构体struct logger_log就是真正用来保存日志的地方了。buffer成员变量变是用保存日志信息的内存缓冲区，它的大小由size成员变量确定。从misc成员变量可以看出，logger驱动程序使用的设备属于misc类型的设备，通过在Android模拟器上执行cat /proc/devices命令（可参考在Ubuntu上下载、编译和安装Android最新内核源代码（Linux Kernel）一文），可以看出，misc类型设备的主设备号是10。关于主设备号的相关知识，可以参考Android学习启动篇一文中提到的Linux Driver Development一书。wq成员变量是一个等待队列，用于保存正在等待读取日志的进程。readers成员变量用来保存当前正在读取日志的进程，正在读取日志的进程由结构体logger_reader来描述。mutex成员变量是一个互斥量，用来保护log的并发访问。可以看出，这里的日志系统的读写问题，其实是一个生产者-消费者的问题，因此，需要互斥量来保护log的并发访问。 w_off成员变量用来记录下一条日志应该从哪里开始写。head成员变量用来表示打开日志文件中，应该从哪一个位置开始读取日志。

结构体struct logger_reader用来表示一个读取日志的进程，log成员变量指向要读取的日志缓冲区。list成员变量用来连接其它读者进程。r_off成员变量表示当前要读取的日志在缓冲区中的位置。

struct logger_log结构体中用于保存日志信息的内存缓冲区buffer是一个循环使用的环形缓冲区，缓冲区中保存的内容是以struct logger_entry为单位的，每个单位的组成为：

struct logger_entry | priority | tag | msg

由于是内存缓冲区buffer是一个循环使用的环形缓冲区，给定一个偏移值，它在buffer中的位置由下logger_offset来确定：

#define logger_offset(n) ((n) & (log->size - 1))

二. Logger驱动程序模块的初始化过程分析。

继续看logger.c文件，定义了三个日志设备：

view plain
  1. /*
  2. *Definesalogstructurewithname'NAME'andasizeof'SIZE'bytes,which
  3. *mustbeapoweroftwo,greaterthanLOGGER_ENTRY_MAX_LEN,andlessthan
  4. *LONG_MAXminusLOGGER_ENTRY_MAX_LEN.
  5. */
  6. #defineDEFINE_LOGGER_DEVICE(VAR,NAME,SIZE)\
  7. staticunsignedchar_buf_##VAR[SIZE];\
  8. staticstructlogger_logVAR={\
  9. .buffer=_buf_##VAR,\
  10. .misc={\
  11. .minor=MISC_DYNAMIC_MINOR,\
  12. .name=NAME,\
  13. .fops=&logger_fops,\
  14. .parent=NULL,\
  15. },\
  16. .wq=__WAIT_QUEUE_HEAD_INITIALIZER(VAR.wq),\
  17. .readers=LIST_HEAD_INIT(VAR.readers),\
  18. .mutex=__MUTEX_INITIALIZER(VAR.mutex),\
  19. .w_off=0,\
  20. .head=0,\
  21. .size=SIZE,\
  22. };
  24. DEFINE_LOGGER_DEVICE(log_main,LOGGER_LOG_MAIN,64*1024)
  25. DEFINE_LOGGER_DEVICE(log_events,LOGGER_LOG_EVENTS,256*1024)
  26. DEFINE_LOGGER_DEVICE(log_radio,LOGGER_LOG_RADIO,64*1024)
分别是log_main、log_events和log_radio，名称分别LOGGER_LOG_MAIN、LOGGER_LOG_EVENTS和LOGGER_LOG_RADIO，它们的次设备号为MISC_DYNAMIC_MINOR，即为在注册时动态分配。在logger.h文件中，有这三个宏的定义：

#define LOGGER_LOG_RADIO "log_radio"/* radio-related messages */
#define LOGGER_LOG_EVENTS "log_events"/* system/hardware events */
#define LOGGER_LOG_MAIN "log_main"/* everything else */

注释说明了这三个日志设备的用途。注册的日志设备文件操作方法为logger_fops：

view plain
  1. staticstructfile_operationslogger_fops={
  2. .owner=THIS_MODULE,
  3. .read=logger_read,
  4. .aio_write=logger_aio_write,
  5. .poll=logger_poll,
  6. .unlocked_ioctl=logger_ioctl,
  7. .compat_ioctl=logger_ioctl,
  8. .open=logger_open,
  9. .release=logger_release,
  10. };

日志驱动程序模块的初始化函数为logger_init：

view plain
  1. staticint__initlogger_init(void)
  2. {
  3. intret;
  5. ret=init_log(&log_main);
  6. if(unlikely(ret))
  7. gotoout;
  9. ret=init_log(&log_events);
  10. if(unlikely(ret))
  11. gotoout;
  13. ret=init_log(&log_radio);
  14. if(unlikely(ret))
  15. gotoout;
  17. out:
  18. returnret;
  19. }
  20. device_initcall(logger_init);
logger_init函数通过调用init_log函数来初始化了上述提到的三个日志设备：
view plain
  1. staticint__initinit_log(structlogger_log*log)
  2. {
  3. intret;
  5. ret=misc_register(&log->misc);
  6. if(unlikely(ret)){
  7. printk(KERN_ERR"logger:failedtoregistermisc"
  8. "deviceforlog'%s'!\n",log->misc.name);
  9. returnret;
  10. }
  12. printk(KERN_INFO"logger:created%luKlog'%s'\n",
  13. (unsignedlong)log->size>>10,log->misc.name);
  15. return0;
  16. }
init_log函数主要调用了misc_register函数来注册misc设备，misc_register函数定义在kernel/common/drivers/char/misc.c文件中：
view plain
  1. /**
  2. *misc_register-registeramiscellaneousdevice
  3. *@misc:devicestructure
  4. *
  5. *Registeramiscellaneousdevicewiththekernel.Iftheminor
  6. *numberissetto%MISC_DYNAMIC_MINORaminornumberisassigned
  7. *andplacedintheminorfieldofthestructure.Forothercases
  8. *theminornumberrequestedisused.
  9. *
  10. *Thestructurepassedislinkedintothekernelandmaynotbe
  11. *destroyeduntilithasbeenunregistered.
  12. *
  13. *Azeroisreturnedonsuccessandanegativeerrnocodefor
  14. *failure.
  15. */
  17. intmisc_register(structmiscdevice*misc)
  18. {
  19. structmiscdevice*c;
  20. dev_tdev;
  21. interr=0;
  23. INIT_LIST_HEAD(&misc->list);
  25. mutex_lock(&misc_mtx);
  26. list_for_each_entry(c,&misc_list,list){
  27. if(c->minor==misc->minor){
  28. mutex_unlock(&misc_mtx);
  29. return-EBUSY;
  30. }
  31. }
  33. if(misc->minor==MISC_DYNAMIC_MINOR){
  34. inti=DYNAMIC_MINORS;
  35. while(--i>=0)
  36. if((misc_minors[i>>3]&(1<<(i&7)))==0)
  37. break;
  38. if(i<0){
  39. mutex_unlock(&misc_mtx);
  40. return-EBUSY;
  41. }
  42. misc->minor=i;
  43. }
  45. if(misc->minor<DYNAMIC_MINORS)
  46. misc_minors[misc->minor>>3]|=1<<(misc->minor&7);
  47. dev=MKDEV(MISC_MAJOR,misc->minor);
  49. misc->this_device=device_create(misc_class,misc->parent,dev,NULL,
  50. "%s",misc->name);
  51. if(IS_ERR(misc->this_device)){
  52. err=PTR_ERR(misc->this_device);
  53. gotoout;
  54. }
  56. /*
  57. *Addittothefront,sothatlaterdevicescan"override"
  58. *earlierdefaults
  59. */
  60. list_add(&misc->list,&misc_list);
  61. out:
  62. mutex_unlock(&misc_mtx);
  63. returnerr;
  64. }
注册完成后，通过device_create创建设备文件节点。这里，将创建/dev/log/main、/dev/log/events和/dev/log/radio三个设备文件，这样，用户空间就可以通过读写这三个文件和驱动程序进行交互。

三. Logger驱动程序的日志记录读取过程分析。

继续看logger.c 文件，注册的读取日志设备文件的方法为logger_read：

view plain
  1. /*
  2. *logger_read-ourlog'sread()method
  3. *
  4. *Behavior:
  5. *
  6. *-O_NONBLOCKworks
  7. *-Iftherearenologentriestoread,blocksuntillogiswrittento
  8. *-Atomicallyreadsexactlyonelogentry
  9. *
  10. *OptimalreadsizeisLOGGER_ENTRY_MAX_LEN.WillseterrnotoEINVALifread
  11. *bufferisinsufficienttoholdnextentry.
  12. */
  13. staticssize_tlogger_read(structfile*file,char__user*buf,
  14. size_tcount,loff_t*pos)
  15. {
  16. structlogger_reader*reader=file->private_data;
  17. structlogger_log*log=reader->log;
  18. ssize_tret;
  19. DEFINE_WAIT(wait);
  21. start:
  22. while(1){
  23. prepare_to_wait(&log->wq,&wait,TASK_INTERRUPTIBLE);
  25. mutex_lock(&log->mutex);
  26. ret=(log->w_off==reader->r_off);
  27. mutex_unlock(&log->mutex);
  28. if(!ret)
  29. break;
  31. if(file->f_flags&O_NONBLOCK){
  32. ret=-EAGAIN;
  33. break;
  34. }
  36. if(signal_pending(current)){
  37. ret=-EINTR;
  38. break;
  39. }
  41. schedule();
  42. }
  44. finish_wait(&log->wq,&wait);
  45. if(ret)
  46. returnret;
  48. mutex_lock(&log->mutex);
  50. /*istherestillsomethingtoreadordidwerace?*/
  51. if(unlikely(log->w_off==reader->r_off)){
  52. mutex_unlock(&log->mutex);
  53. gotostart;
  54. }
  56. /*getthesizeofthenextentry*/
  57. ret=get_entry_len(log,reader->r_off);
  58. if(count<ret){
  59. ret=-EINVAL;
  60. gotoout;
  61. }
  63. /*getexactlyoneentryfromthelog*/
  64. ret=do_read_log_to_user(log,reader,buf,ret);
  66. out:
  67. mutex_unlock(&log->mutex);
  69. returnret;
  70. }
注意，在函数开始的地方，表示读取日志上下文的struct logger_reader是保存在文件指针的private_data成员变量里面的，这是在打开设备文件时设置的，设备文件打开方法为logger_open：
view plain
  1. /*
  2. *logger_open-thelog'sopen()fileoperation
  3. *
  4. *Notehownearano-opthisisinthewrite-onlycase.Keepitthatway!
  5. */
  6. staticintlogger_open(structinode*inode,structfile*file)
  7. {
  8. structlogger_log*log;
  9. intret;
  11. ret=nonseekable_open(inode,file);
  12. if(ret)
  13. returnret;
  15. log=get_log_from_minor(MINOR(inode->i_rdev));
  16. if(!log)
  17. return-ENODEV;
  19. if(file->f_mode&FMODE_READ){
  20. structlogger_reader*reader;
  22. reader=kmalloc(sizeof(structlogger_reader),GFP_KERNEL);
  23. if(!reader)
  24. return-ENOMEM;
  26. reader->log=log;
  27. INIT_LIST_HEAD(&reader->list);
  29. mutex_lock(&log->mutex);
  30. reader->r_off=log->head;
  31. list_add_tail(&reader->list,&log->readers);
  32. mutex_unlock(&log->mutex);
  34. file->private_data=reader;
  35. }else
  36. file->private_data=log;
  38. return0;
  39. }
新打开日志设备文件时，是从log->head位置开始读取日志的，保存在struct logger_reader的成员变量r_off中。

start标号处的while循环是在等待日志可读，如果已经没有新的日志可读了，那么就要读进程就要进入休眠状态，等待新的日志写入后再唤醒，这是通过prepare_wait和schedule两个调用来实现的。如果没有新的日志可读，并且设备文件不是以非阻塞O_NONBLOCK的方式打开或者这时有信号要处理（signal_pending(current)），那么就直接返回，不再等待新的日志写入。判断当前是否有新的日志可读的方法是：

ret = (log->w_off == reader->r_off);

即判断当前缓冲区的写入位置和当前读进程的读取位置是否相等，如果不相等，则说明有新的日志可读。

继续向下看，如果有新的日志可读，那么就，首先通过get_entry_len来获取下一条可读的日志记录的长度，从这里可以看出，日志读取进程是以日志记录为单位进行读取的，一次只读取一条记录。get_entry_len的函数实现如下：

view plain
  1. /*
  2. *get_entry_len-Grabsthelengthofthepayloadofthenextentrystarting
  3. *from'off'.
  4. *
  5. *Callerneedstoholdlog->mutex.
  6. */
  7. static__u32get_entry_len(structlogger_log*log,size_toff)
  8. {
  9. __u16val;
  11. switch(log->size-off){
  12. case1:
  13. memcpy(&val,log->buffer+off,1);
  14. memcpy(((char*)&val)+1,log->buffer,1);
  15. break;
  16. default:
  17. memcpy(&val,log->buffer+off,2);
  18. }
  20. returnsizeof(structlogger_entry)+val;
  21. }
上面我们提到，每一条日志记录是由两大部分组成的，一个用于描述这条日志记录的结构体struct logger_entry，另一个是记录体本身，即有效负载。结构体struct logger_entry的长度是固定的，只要知道有效负载的长度，就可以知道整条日志记录的长度了。而有效负载的长度是记录在结构体struct logger_entry的成员变量len中，而len成员变量的地址与struct logger_entry的地址相同，因此，只需要读取记录的开始位置的两个字节就可以了。又由于日志记录缓冲区是循环使用的，这两个节字有可能是第一个字节存放在缓冲区最后一个字节，而第二个字节存放在缓冲区的第一个节，除此之外，这两个字节都是连在一起的。因此，分两种情况来考虑，对于前者，分别通过读取缓冲区最后一个字节和第一个字节来得到日志记录的有效负载长度到本地变量val中，对于后者，直接读取连续两个字节的值到本地变量val中。这两种情况是通过判断日志缓冲区的大小和要读取的日志记录在缓冲区中的位置的差值来区别的，如果相差1，就说明是前一种情况了。最后，把有效负载的长度val加上struct logger_entry的长度就得到了要读取的日志记录的总长度了。

接着往下看，得到了要读取的记录的长度，就调用do_read_log_to_user函数来执行真正的读取动作：

view plain
  1. staticssize_tdo_read_log_to_user(structlogger_log*log,
  2. structlogger_reader*reader,
  3. char__user*buf,
  4. size_tcount)
  5. {
  6. size_tlen;
  8. /*
  9. *Wereadfromthelogintwodisjointoperations.First,wereadfrom
  10. *thecurrentreadheadoffsetupto'count'bytesortotheendof
  11. *thelog,whichevercomesfirst.
  12. */
  13. len=min(count,log->size-reader->r_off);
  14. if(copy_to_user(buf,log->buffer+reader->r_off,len))
  15. return-EFAULT;
  17. /*
  18. *Second,wereadanyremainingbytes,startingbackattheheadof
  19. *thelog.
  20. */
  21. if(count!=len)
  22. if(copy_to_user(buf+len,log->buffer,count-len))
  23. return-EFAULT;
  25. reader->r_off=logger_offset(reader->r_off+count);
  27. returncount;
  28. }
这个函数简单地调用copy_to_user函数来把位于内核空间的日志缓冲区指定的内容拷贝到用户空间的内存缓冲区就可以了，同时，把当前读取日志进程的上下文信息中的读偏移r_off前进到下一条日志记录的开始的位置上。

四. Logger驱动程序的日志记录写入过程分析。

继续看logger.c 文件，注册的写入日志设备文件的方法为logger_aio_write：

view plain
  1. /*
  2. *logger_aio_write-ourwritemethod,implementingsupportforwrite(),
  3. *writev(),andaio_write().Writesareourfastpath,andwetrytooptimize
  4. *themaboveallelse.
  5. */
  6. ssize_tlogger_aio_write(structkiocb*iocb,conststructiovec*iov,
  7. unsignedlongnr_segs,loff_tppos)
  8. {
  9. structlogger_log*log=file_get_log(iocb->ki_filp);
  10. size_torig=log->w_off;
  11. structlogger_entryheader;
  12. structtimespecnow;
  13. ssize_tret=0;
  15. now=current_kernel_time();
  17. header.pid=current->tgid;
  18. header.tid=current->pid;
  19. header.sec=now.tv_sec;
  20. header.nsec=now.tv_nsec;
  21. header.len=min_t(size_t,iocb->ki_left,LOGGER_ENTRY_MAX_PAYLOAD);
  23. /*nullwritessucceed,returnzero*/
  24. if(unlikely(!header.len))
  25. return0;
  27. mutex_lock(&log->mutex);
  29. /*
  30. *Fixupanyreaders,pullingthemforwardtothefirstreadable
  31. *entryafter(whatwillbe)thenewwriteoffset.Wedothisnow
  32. *becauseifwepartiallyfail,wecanendupwithclobberedlog
  33. *entriesthatencroachonreadablebuffer.
  34. */
  35. fix_up_readers(log,sizeof(structlogger_entry)+header.len);
  37. do_write_log(log,&header,sizeof(structlogger_entry));
  39. while(nr_segs-->0){
  40. size_tlen;
  41. ssize_tnr;
  43. /*figureouthowmuchofthisvectorwecankeep*/
  44. len=min_t(size_t,iov->iov_len,header.len-ret);
  46. /*writeoutthissegment'spayload*/
  47. nr=do_write_log_from_user(log,iov->iov_base,len);
  48. if(unlikely(nr<0)){
  49. log->w_off=orig;
  50. mutex_unlock(&log->mutex);
  51. returnnr;
  52. }
  54. iov++;
  55. ret+=nr;
  56. }
  58. mutex_unlock(&log->mutex);
  60. /*wakeupanyblockedreaders*/
  61. wake_up_interruptible(&log->wq);
  63. returnret;
  64. }
输入的参数iocb表示io上下文，iov表示要写入的内容，长度为nr_segs，表示有nr_segs个段的内容要写入。我们知道，每个要写入的日志的结构形式为：

struct logger_entry | priority | tag | msg

其中， priority、tag和msg这三个段的内容是由iov参数从用户空间传递下来的，分别对应iov里面的三个元素。而logger_entry是由内核空间来构造的：

struct logger_entry header;
struct timespec now;

now = current_kernel_time();

header.pid = current->tgid;
header.tid = current->pid;
header.sec = now.tv_sec;
header.nsec = now.tv_nsec;
header.len = min_t(size_t, iocb->ki_left, LOGGER_ENTRY_MAX_PAYLOAD);

然后调用do_write_log首先把logger_entry结构体写入到日志缓冲区中：

view plain
  1. /*
  2. *do_write_log-writes'len'bytesfrom'buf'to'log'
  3. *
  4. *Thecallerneedstoholdlog->mutex.
  5. */
  6. staticvoiddo_write_log(structlogger_log*log,constvoid*buf,size_tcount)
  7. {
  8. size_tlen;
  10. len=min(count,log->size-log->w_off);
  11. memcpy(log->buffer+log->w_off,buf,len);
  13. if(count!=len)
  14. memcpy(log->buffer,buf+len,count-len);
  16. log->w_off=logger_offset(log->w_off+count);
  18. }
由于logger_entry是内核堆栈空间分配的，直接用memcpy拷贝就可以了。

接着，通过一个while循环把iov的内容写入到日志缓冲区中，也就是日志的优先级别priority、日志Tag和日志主体Msg：

view plain
  1. while(nr_segs-->0){
  2. size_tlen;
  3. ssize_tnr;
  5. /*figureouthowmuchofthisvectorwecankeep*/
  6. len=min_t(size_t,iov->iov_len,header.len-ret);
  8. /*writeoutthissegment'spayload*/
  9. nr=do_write_log_from_user(log,iov->iov_base,len);
  10. if(unlikely(nr<0)){
  11. log->w_off=orig;
  12. mutex_unlock(&log->mutex);
  13. returnnr;
  14. }
  16. iov++;
  17. ret+=nr;
  18. }
由于iov的内容是由用户空间传下来的，需要调用do_write_log_from_user来写入：
view plain
  1. staticssize_tdo_write_log_from_user(structlogger_log*log,
  2. constvoid__user*buf,size_tcount)
  3. {
  4. size_tlen;
  6. len=min(count,log->size-log->w_off);
  7. if(len&&copy_from_user(log->buffer+log->w_off,buf,len))
  8. return-EFAULT;
  10. if(count!=len)
  11. if(copy_from_user(log->buffer,buf+len,count-len))
  12. return-EFAULT;
  14. log->w_off=logger_offset(log->w_off+count);
  16. returncount;
  17. }
这里，我们还漏了一个重要的步骤：
view plain
  1. /*
  2. *Fixupanyreaders,pullingthemforwardtothefirstreadable
  3. *entryafter(whatwillbe)thenewwriteoffset.Wedothisnow
  4. *becauseifwepartiallyfail,wecanendupwithclobberedlog
  5. *entriesthatencroachonreadablebuffer.
  6. */
  7. fix_up_readers(log,sizeof(structlogger_entry)+header.len);
为什么要调用fix_up_reader这个函数呢？这个函数又是作什么用的呢？是这样的，由于日志缓冲区是循环使用的，即旧的日志记录如果没有及时读取，而缓冲区的内容又已经用完时，就需要覆盖旧的记录来容纳新的记录。而这部分将要被覆盖的内容，有可能是某些reader的下一次要读取的日志所在的位置，以及为新的reader准备的日志开始读取位置head所在的位置。因此，需要调整这些位置，使它们能够指向一个新的有效的位置。我们来看一下fix_up_reader函数的实现：
view plain
  1. /*
  2. *fix_up_readers-walkthelistofallreadersand"fixup"anywhowere
  3. *lappedbythewriter;alsodothesameforthedefault"starthead".
  4. *Wedothisby"pullingforward"thereadersandstartheadtothefirst
  5. *entryafterthenewwritehead.
  6. *
  7. *Thecallerneedstoholdlog->mutex.
  8. */
  9. staticvoidfix_up_readers(structlogger_log*log,size_tlen)
  10. {
  11. size_told=log->w_off;
  12. size_tnew=logger_offset(old+len);
  13. structlogger_reader*reader;
  15. if(clock_interval(old,new,log->head))
  16. log->head=get_next_entry(log,log->head,len);
  18. list_for_each_entry(reader,&log->readers,list)
  19. if(clock_interval(old,new,reader->r_off))
  20. reader->r_off=get_next_entry(log,reader->r_off,len);
  21. }
判断log->head和所有读者reader的当前读偏移reader->r_off是否在被覆盖的区域内，如果是，就需要调用get_next_entry来取得下一个有效的记录的起始位置来调整当前位置：
view plain
  1. /*
  2. *get_next_entry-returntheoffsetofthefirstvalidentryatleast'len'
  3. *bytesafter'off'.
  4. *
  5. *Callermustholdlog->mutex.
  6. */
  7. staticsize_tget_next_entry(structlogger_log*log,size_toff,size_tlen)
  8. {
  9. size_tcount=0;
  11. do{
  12. size_tnr=get_entry_len(log,off);
  13. off=logger_offset(off+nr);
  14. count+=nr;
  15. }while(count<len);
  17. returnoff;
  18. }
而判断log->head和所有读者reader的当前读偏移reader->r_off是否在被覆盖的区域内，是通过clock_interval函数来实现的：
view plain
  1. /*
  2. *clock_interval-isa<c<binmod-space?Putanotherway,doestheline
  3. *fromatobcrossc?
  4. */
  5. staticinlineintclock_interval(size_ta,size_tb,size_tc)
  6. {
  7. if(b<a){
  8. if(a<c||b>=c)
  9. return1;
  10. }else{
  11. if(a<c&&b>=c)
  12. return1;
  13. }
  15. return0;
  16. }
最后，日志写入完毕，还需要唤醒正在等待新日志的reader进程:

/* wake up any blocked readers */
wake_up_interruptible(&log->wq);

至此， Logger驱动程序的主要逻辑就分析完成了，还有其它的一些接口，如logger_poll、logger_ioctl和logger_release函数，比较简单，读取可以自行分析。这里还需要提到的一点是，由于Logger驱动程序模块在退出系统时，是不会卸载的，所以这个模块没有module_exit函数，而对于模块里面定义的对象，也没有用对引用计数技术。

这篇文章着重介绍了Android日志系统在内核空间的实现，在下一篇文章中，我们将接着介绍在用户空间中，提供给Android应用程序使用的Java和C/C++ LOG调用接口的实现过程，敬请关注。

分享到：
| Android应用程序启动过程源代码分析
评论
发表评论

您还没有登录,请您登录后再发表评论

Global site tag (gtag.js) - Google Analytics