attach是什么
在讲这个之前，我们先来点大家都知道的东西，当我们感觉线程一直卡在某个地方，想知道卡在哪里，首先想到的是进行线程dump，而常用的命令是jstack <pid>，我们就可以看到如下线程栈了
大家是否注意过上面圈起来的两个线程，”attach listener”和“signal dispatcher”，这两个线程是我们这次要讲的attach机制的关键，先偷偷告诉各位，其实attach listener这个线程在jvm起来的时候可能并没有的，后面会细说。
那attach机制是什么？说简单点就是jvm提供一种jvm进程间通信的能力，能让一个进程传命令给另外一个进程，并让它执行内部的一些操作，比如说我们为了让另外一个jvm进程把线程dump出来，那么我们跑了一个jstack的进程，然后传了个pid的参数，告诉它要哪个进程进行线程dump，既然是两个进程，那肯定涉及到进程间通信，以及传输协议的定义，比如要执行什么操作，传了什么参数等。
attach能做些什么
总结起来说，比如内存dump，线程dump，类信息统计(比如加载的类及大小以及实例个数等)，动态加载agent(使用过btrace的应该不陌生)，动态设置vm flag(但是并不是所有的flag都可以设置的，因为有些flag是在jvm启动过程中使用的，是一次性的)，打印vm flag，获取系统属性等，这些对应的源码(attachlistener.cpp)如下
<code>01</code>
<code>static</code> <code>attachoperationfunctioninfo funcs[] = {</code>
<code>02</code>
<code></code><code>{ &quot;agentproperties&quot;, get_agent_properties },</code>
<code>03</code>
<code></code><code>{ &quot;datadump&quot;, data_dump },</code>
<code>04</code>
<code></code><code>{ &quot;dumpheap&quot;, dump_heap },</code>
<code>05</code>
<code></code><code>{ &quot;load&quot;, jvmtiexport::load_agent_library },</code>
<code>06</code>
<code></code><code>{ &quot;properties&quot;, get_system_properties },</code>
<code>07</code>
<code></code><code>{ &quot;threaddump&quot;, thread_dump },</code>
<code>08</code>
<code></code><code>{ &quot;inspectheap&quot;, heap_inspection },</code>
<code>09</code>
<code></code><code>{ &quot;setflag&quot;, set_flag },</code>
<code>10</code>
<code></code><code>{ &quot;printflag&quot;, print_flag },</code>
<code>11</code>
<code></code><code>{ &quot;jcmd&quot;, jcmd },</code>
<code>12</code>
<code></code><code>{ null, null }</code>
<code>13</code>
<code>};</code>
后面是命令对应的处理函数。
attach在jvm里如何实现的
attach listener线程的创建
前面也提到了，jvm在启动过程中可能并没有启动attach listener这个线程，可以通过jvm参数来启动，代码（threads::create_vm）如下：
<code>if</code> <code>(!disableattachmechanism) {</code>
<code></code><code>if</code> <code>(startattachlistener || attachlistener::init_at_startup()) {</code>
<code></code><code>attachlistener::init();</code>
<code></code><code>}</code>
<code>bool attachlistener::init_at_startup() {</code>
<code></code><code>if</code> <code>(reducesignalusage) {</code>
<code></code><code>return</code> <code>true</code><code>;</code>
<code></code><code>}</code><code>else</code> <code>{</code>
<code></code><code>return</code> <code>false</code><code>;</code>
<code>}</code>
其中disableattachmechanism，startattachlistener ，reducesignalusage均默认是false(globals.hpp)
<code>1</code>
<code>product(bool, disableattachmechanism,</code><code>false</code><code>, \</code>
<code>2</code>
<code></code><code>&quot;disable mechanism that allows tools to attach to</code><code>this</code> <code>vm&rdquo;)</code>
<code>3</code>
<code>product(bool, startattachlistener,</code><code>false</code><code>, \</code>
<code>4</code>
<code></code><code>&quot;always start attach listener at vm startup&quot;)</code>
<code>5</code>
<code>product(bool, reducesignalusage,</code><code>false</code><code>, \</code>
<code>6</code>
<code></code><code>&quot;reduce the use of os signals in java and/or the vm&rdquo;)</code>
因此attachlistener::init()并不会被执行，而attach listener线程正是在此方法里创建的
<code>// starts the attach listener thread</code>
<code>void</code> <code>attachlistener::init() {</code>
<code></code><code>exception_mark;</code>
<code></code><code>klassoop k = systemdictionary::resolve_or_fail(vmsymbols::java_lang_thread(),</code><code>true</code><code>, check);</code>
<code></code><code>instanceklasshandle klass (thread, k);</code>
<code></code><code>instancehandle thread_oop = klass-&gt;allocate_instance_handle(check);</code>
<code></code><code>const</code> <code>char</code> <code>thread_name[] = &quot;attach listener&quot;;</code>
<code></code><code>handle string = java_lang_string::create_from_str(thread_name, check);</code>
<code></code><code>// initialize thread_oop to put it into the system threadgroup</code>
<code></code><code>handle thread_group (thread, universe::system_thread_group());</code>
<code></code><code>javavalue result(t_void);</code>
<code>14</code>
<code></code><code>javacalls::call_special(&amp;result, thread_oop,</code>
<code>15</code>
<code></code><code>klass,</code>
<code>16</code>
<code></code><code>vmsymbols::object_initializer_name(),</code>
<code>17</code>
<code></code><code>vmsymbols::threadgroup_string_void_signature(),</code>
<code>18</code>
<code></code><code>thread_group,</code>
<code>19</code>
<code></code><code>string,</code>
<code>20</code>
<code></code><code>check);</code>
<code>21</code>
<code>22</code>
<code></code><code>klasshandle group(thread, systemdictionary::threadgroup_klass());</code>
<code>23</code>
<code></code><code>javacalls::call_special(&amp;result,</code>
<code>24</code>
<code>25</code>
<code></code><code>group,</code>
<code>26</code>
<code></code><code>vmsymbols::add_method_name(),</code>
<code>27</code>
<code></code><code>vmsymbols::thread_void_signature(),</code>
<code>28</code>
<code></code><code>thread_oop,</code><code>// arg 1</code>
<code>29</code>
<code>30</code>
<code>31</code>
<code></code><code>{ mutexlocker mu(threads_lock);</code>
<code>32</code>
<code></code><code>javathread* listener_thread =</code><code>new</code><code>javathread(&amp;attach_listener_thread_entry);</code>
<code>33</code>
<code>34</code>
<code></code><code>// check that thread and osthread were created</code>
<code>35</code>
<code></code><code>if</code> <code>(listener_thread == null || listener_thread-&gt;osthread() == null) {</code>
<code>36</code>
<code></code><code>vm_exit_during_initialization(&quot;java.lang.outofmemoryerror&quot;,</code>
<code>37</code>
<code></code><code>&quot;unable to create</code><code>new</code> <code>native</code><code>thread&quot;);</code>
<code>38</code>
<code>39</code>
<code>40</code>
<code></code><code>java_lang_thread::set_thread(thread_oop(), listener_thread);</code>
<code>41</code>
<code></code><code>java_lang_thread::set_daemon(thread_oop());</code>
<code>42</code>
<code>43</code>
<code></code><code>listener_thread-&gt;set_threadobj(thread_oop());</code>
<code>44</code>
<code></code><code>threads::add(listener_thread);</code>
<code>45</code>
<code></code><code>thread::start(listener_thread);</code>
<code>46</code>
<code>47</code>
既然在启动的时候不会创建这个线程，那么我们在上面看到的那个线程是怎么创建的呢，这个就要关注另外一个线程“signal dispatcher”了，顾名思义是处理信号的，这个线程是在jvm启动的时候就会创建的，具体代码就不说了。
下面以jstack的实现来说明触发attach这一机制进行的过程，jstack命令的实现其实是一个叫做jstack.java的类，查看jstack代码后会走到下面的方法里
<code>private</code> <code>static</code> <code>void</code> <code>runthreaddump(string pid, string args[])</code><code>throws</code> <code>exception {</code>
<code></code><code>virtualmachine vm =</code><code>null</code><code>;</code>
<code></code><code>try</code> <code>{</code>
<code></code><code>vm = virtualmachine.attach(pid);</code>
<code></code><code>}</code><code>catch</code> <code>(exception x) {</code>
<code></code><code>string msg = x.getmessage();</code>
<code></code><code>if</code> <code>(msg !=</code><code>null</code><code>) {</code>
<code></code><code>system.err.println(pid + &quot;: &quot; + msg);</code>
<code></code><code>x.printstacktrace();</code>
<code></code><code>if</code> <code>((x</code><code>instanceof</code> <code>attachnotsupportedexception) &amp;&amp;</code>
<code></code><code>(loadsaclass() !=</code><code>null</code><code>)) {</code>
<code></code><code>system.err.println(&quot;the -f option can be used when the target &quot; +</code>
<code></code><code>&quot;process is not responding&quot;);</code>
<code></code><code>system.exit(</code><code>1</code><code>);</code>
<code></code><code>// cast to hotspotvirtualmachine as this is implementation specific</code>
<code></code><code>// method.</code>
<code></code><code>inputstream in = ((hotspotvirtualmachine)vm).remotedatadump((object[])args);</code>
<code></code><code>// read to eof and just print output</code>
<code></code><code>byte</code> <code>b[] =</code><code>new</code> <code>byte</code><code>[</code><code>256</code><code>];</code>
<code></code><code>int</code> <code>n;</code>
<code></code><code>do</code> <code>{</code>
<code></code><code>n = in.read(b);</code>
<code></code><code>if</code> <code>(n &gt;</code><code>0</code><code>) {</code>
<code></code><code>string s =</code><code>new</code> <code>string(b,</code><code>0</code><code>, n, &quot;utf-</code><code>8</code><code>&quot;);</code>
<code></code><code>system.out.print(s);</code>
<code></code><code>}</code><code>while</code> <code>(n &gt;</code><code>0</code><code>);</code>
<code></code><code>in.close();</code>
<code></code><code>vm.detach();</code>
请注意virtualmachine.attach(pid);这行代码，触发attach pid的关键，如果是在linux下会走到下面的构造函数
<code>linuxvirtualmachine(attachprovider provider, string vmid)</code>
<code></code><code>throws</code> <code>attachnotsupportedexception, ioexception</code>
<code></code><code>{</code>
<code></code><code>super</code><code>(provider, vmid);</code>
<code></code><code>// this provider only understands pids</code>
<code></code><code>int</code> <code>pid;</code>
<code></code><code>pid = integer.parseint(vmid);</code>
<code></code><code>}</code><code>catch</code> <code>(numberformatexception x) {</code>
<code></code><code>throw</code> <code>new</code> <code>attachnotsupportedexception(&quot;invalid process identifier&quot;);</code>
<code></code><code>// find the socket file. if not found then we attempt to start the</code>
<code></code><code>// attach mechanism in the target vm by sending it a quit signal.</code>
<code></code><code>// then we attempt to find the socket file again.</code>
<code></code><code>path = findsocketfile(pid);</code>
<code></code><code>if</code> <code>(path ==</code><code>null</code><code>) {</code>
<code></code><code>file f = createattachfile(pid);</code>
<code></code><code>// on linuxthreads each thread is a process and we don't have the</code>
<code></code><code>// pid of the vmthread which has sigquit unblocked. to workaround</code>
<code></code><code>// this we get the pid of the &quot;manager thread&quot; that is created</code>
<code></code><code>// by the first call to pthread_create. this is parent of all</code>
<code></code><code>// threads (except the initial thread).</code>
<code></code><code>if</code> <code>(islinuxthreads) {</code>
<code></code><code>int</code> <code>mpid;</code>
<code></code><code>mpid = getlinuxthreadsmanager(pid);</code>
<code></code><code>}</code><code>catch</code> <code>(ioexception x) {</code>
<code></code><code>throw</code> <code>new</code> <code>attachnotsupportedexception(x.getmessage());</code>
<code></code><code>assert</code><code>(mpid &gt;=</code><code>1</code><code>);</code>
<code></code><code>sendquittochildrenof(mpid);</code>
<code></code><code>sendquitto(pid);</code>
<code></code><code>// give the target vm time to start the attach mechanism</code>
<code></code><code>int</code> <code>i =</code><code>0</code><code>;</code>
<code></code><code>long</code> <code>delay =</code><code>200</code><code>;</code>
<code></code><code>int</code> <code>retries = (</code><code>int</code><code>)(attachtimeout() / delay);</code>
<code></code><code>thread.sleep(delay);</code>
<code></code><code>}</code><code>catch</code> <code>(interruptedexception x) { }</code>
<code>48</code>
<code></code><code>i++;</code>
<code>49</code>
<code></code><code>}</code><code>while</code> <code>(i &lt;= retries &amp;&amp; path ==</code><code>null</code><code>);</code>
<code>50</code>
<code>51</code>
<code></code><code>throw</code> <code>new</code> <code>attachnotsupportedexception(</code>
<code>52</code>
<code></code><code>&quot;unable to open socket file: target process not responding &quot; +</code>
<code>53</code>
<code></code><code>&quot;or hotspot vm not loaded&quot;);</code>
<code>54</code>
<code>55</code>
<code></code><code>}</code><code>finally</code> <code>{</code>
<code>56</code>
<code></code><code>f.delete();</code>
<code>57</code>
<code>58</code>
<code>59</code>
<code>60</code>
<code></code><code>// check that the file owner/permission to avoid attaching to</code>
<code>61</code>
<code></code><code>// bogus process</code>
<code>62</code>
<code></code><code>checkpermissions(path);</code>
<code>63</code>
<code>64</code>
<code></code><code>// check that we can connect to the process</code>
<code>65</code>
<code></code><code>// - this ensures we throw the permission denied error now rather than</code>
<code>66</code>
<code></code><code>// later when we attempt to enqueue a command.</code>
<code>67</code>
<code></code><code>int</code> <code>s = socket();</code>
<code>68</code>
<code>69</code>
<code></code><code>connect(s, path);</code>
<code>70</code>
<code>71</code>
<code></code><code>close(s);</code>
<code>72</code>
<code>73</code>
这里要解释下代码了，首先看到调用了createattachfile方法在目标进程的cwd目录下创建了一个文件/proc/<pid>/cwd/.attach_pid<pid>，这个在后面的信号处理过程中会取出来做判断(为了安全)，另外我们知道在linux下线程是用进程实现的，在jvm启动过程中会创建很多线程，比如我们上面的信号线程，也就是会看到很多的pid(应该是lwp)，那么如何找到这个信号处理线程呢，从上面实现来看是找到我们传进去的pid的父进程，然后给它的所有子进程都发送一个sigquit信号，而jvm里除了vm thread，其他线程都设置了对此信号的屏蔽，因此收不到该信号，于是该信号就传给了“signal dispatcher”，在传完之后作轮询等待看目标进程是否创建了某个文件，attachtimeout默认超时时间是5000ms，可通过设置系统变量sun.tools.attach.attachtimeout来指定，下面是signal dispatcher线程的entry实现
<code>static</code> <code>void</code> <code>signal_thread_entry(javathread* thread, traps) {</code>
<code></code><code>os::set_priority(thread, nearmaxpriority);</code>
<code></code><code>while</code> <code>(</code><code>true</code><code>) {</code>
<code></code><code>int</code> <code>sig;</code>
<code></code><code>// fixme : currently we have not decieded what should be the status</code>
<code></code><code>// for this java thread blocked here. once we decide about</code>
<code></code><code>// that we should fix this.</code>
<code></code><code>sig = os::signal_wait();</code>
<code></code><code>if</code> <code>(sig == os::sigexitnum_pd()) {</code>
<code></code><code>// terminate the signal thread</code>
<code></code><code>return</code><code>;</code>
<code></code><code>switch</code> <code>(sig) {</code>
<code></code><code>case</code> <code>sigbreak: {</code>
<code></code><code>// check if the signal is a trigger to start the attach listener - in that</code>
<code></code><code>// case don't print stack traces.</code>
<code></code><code>if</code> <code>(!disableattachmechanism &amp;&amp; attachlistener::is_init_trigger()) {</code>
<code></code><code>continue</code><code>;</code>
<code></code><code>// print stack traces</code>
<code></code><code>// any sigbreak operations added here should make sure to flush</code>
<code></code><code>// the output stream (e.g. tty-&gt;flush()) after output. see 4803766.</code>
<code></code><code>// each module also prints an extra carriage return after its output.</code>
<code></code><code>vm_printthreads op;</code>
<code></code><code>vmthread::execute(&amp;op);</code>
<code></code><code>vm_printjni jni_op;</code>
<code></code><code>vmthread::execute(&amp;jni_op);</code>
<code></code><code>vm_finddeadlocks op1(tty);</code>
<code></code><code>vmthread::execute(&amp;op1);</code>
<code></code><code>universe::print_heap_at_sigbreak();</code>
<code></code><code>if</code> <code>(printclasshistogram) {</code>
<code></code><code>vm_gc_heapinspection op1(gclog_or_tty,</code><code>true</code> <code>/* force full gc before heap inspection */,</code>
<code></code><code>true /* need_prologue */</code><code>);</code>
<code></code><code>if</code> <code>(jvmtiexport::should_post_data_dump()) {</code>
<code></code><code>jvmtiexport::post_data_dump();</code>
<code></code><code>break</code><code>;</code>
<code></code><code>&hellip;.</code>
当信号是sigbreak(在jvm里做了#define，其实就是sigquit)的时候，就会触发attachlistener::is_init_trigger()的执行
<code>bool attachlistener::is_init_trigger() {</code>
<code></code><code>if</code> <code>(init_at_startup() || is_initialized()) {</code>
<code></code><code>return</code> <code>false</code><code>;</code><code>// initialized at startup or already initialized</code>
<code></code><code>char</code> <code>fn[path_max+</code><code>1</code><code>];</code>
<code></code><code>sprintf(fn, &quot;.attach_pid%d&quot;, os::current_process_id());</code>
<code></code><code>int</code> <code>ret;</code>
<code></code><code>struct stat64 st;</code>
<code></code><code>restartable(::stat64(fn, &amp;st), ret);</code>
<code></code><code>if</code> <code>(ret == -</code><code>1</code><code>) {</code>
<code></code><code>snprintf(fn, sizeof(fn), &quot;%s/.attach_pid%d&quot;,</code>
<code></code><code>os::get_temp_directory(), os::current_process_id());</code>
<code></code><code>if</code> <code>(ret ==</code><code>0</code><code>) {</code>
<code></code><code>// simple check to avoid starting the attach mechanism when</code>
<code></code><code>// a bogus user creates the file</code>
<code></code><code>if</code> <code>(st.st_uid == geteuid()) {</code>
<code></code><code>init();</code>
一开始会判断当前进程目录下是否有个.attach_pid<pid>文件（前面提到了），如果没有就会在/tmp下创建一个/tmp/.attach_pid<pid>，当那个文件的uid和自己的uid是一致的情况下（为了安全）再调用init方法
此时水落石出了，看到创建了一个线程，并且取名为attach listener。再看看其子类linuxattachlistener的init方法
<code>int</code> <code>linuxattachlistener::init() {</code>
<code></code><code>char</code> <code>path[unix_path_max];</code><code>// socket file</code>
<code></code><code>char</code> <code>initial_path[unix_path_max];</code><code>// socket file during setup</code>
<code></code><code>int</code> <code>listener;</code><code>// listener socket (file descriptor)</code>
<code></code><code>// register function to cleanup</code>
<code></code><code>::atexit(listener_cleanup);</code>
<code></code><code>int</code> <code>n = snprintf(path, unix_path_max, &quot;%s/.java_pid%d&quot;,</code>
<code></code><code>if</code> <code>(n &lt; (</code><code>int</code><code>)unix_path_max) {</code>
<code></code><code>n = snprintf(initial_path, unix_path_max, &quot;%s.tmp&quot;, path);</code>
<code></code><code>if</code> <code>(n &gt;= (</code><code>int</code><code>)unix_path_max) {</code>
<code></code><code>return</code> <code>-</code><code>1</code><code>;</code>
<code></code><code>// create the listener socket</code>
<code></code><code>listener = ::socket(pf_unix, sock_stream,</code><code>0</code><code>);</code>
<code></code><code>if</code> <code>(listener == -</code><code>1</code><code>) {</code>
<code></code><code>// bind socket</code>
<code></code><code>struct sockaddr_un addr;</code>
<code></code><code>addr.sun_family = af_unix;</code>
<code></code><code>strcpy(addr.sun_path, initial_path);</code>
<code></code><code>::unlink(initial_path);</code>
<code></code><code>int</code> <code>res = ::bind(listener, (struct sockaddr*)&amp;addr, sizeof(addr));</code>
<code></code><code>if</code> <code>(res == -</code><code>1</code><code>) {</code>
<code></code><code>restartable(::close(listener), res);</code>
<code></code><code>// put in listen mode, set permissions, and rename into place</code>
<code></code><code>res = ::listen(listener,</code><code>5</code><code>);</code>
<code></code><code>if</code> <code>(res ==</code><code>0</code><code>) {</code>
<code></code><code>restartable(::chmod(initial_path, s_iread|s_iwrite), res);</code>
<code></code><code>res = ::rename(initial_path, path);</code>
<code></code><code>set_path(path);</code>
<code></code><code>set_listener(listener);</code>
<code></code><code>return</code> <code>0</code><code>;</code>
看到其创建了一个监听套接字，并创建了一个文件/tmp/.java_pid<pid>，这个文件就是客户端之前一直在轮询等待的文件，随着这个文件的生成，意味着attach的过程圆满结束了。
attach listener接收请求
看看它的entry实现attach_listener_thread_entry
<code>static</code> <code>void</code> <code>attach_listener_thread_entry(javathread* thread, traps) {</code>
<code></code><code>thread-&gt;record_stack_base_and_size();</code>
<code></code><code>if</code> <code>(attachlistener::pd_init() !=</code><code>0</code><code>) {</code>
<code></code><code>attachlistener::set_initialized();</code>
<code></code><code>for</code> <code>(;;) {</code>
<code></code><code>attachoperation* op = attachlistener::dequeue();</code>
<code></code><code>if</code> <code>(op == null) {</code>
<code></code><code>return</code><code>;</code><code>// dequeue failed or shutdown</code>
<code></code><code>resourcemark rm;</code>
<code></code><code>bufferedstream st;</code>
<code></code><code>jint res = jni_ok;</code>
<code></code><code>// handle special detachall operation</code>
<code></code><code>if</code> <code>(strcmp(op-&gt;name(), attachoperation::detachall_operation_name()) ==</code><code>0</code><code>) {</code>
<code></code><code>attachlistener::detachall();</code>
<code></code><code>// find the function to dispatch too</code>
<code></code><code>attachoperationfunctioninfo* info = null;</code>
<code></code><code>for</code> <code>(</code><code>int</code> <code>i=</code><code>0</code><code>; funcs[i].name != null; i++) {</code>
<code></code><code>const</code> <code>char</code><code>* name = funcs[i].name;</code>
<code></code><code>assert</code><code>(strlen(name) &lt;= attachoperation::name_length_max, &quot;operation &lt;= name_length_max&quot;);</code>
<code></code><code>if</code> <code>(strcmp(op-&gt;name(), name) ==</code><code>0</code><code>) {</code>
<code></code><code>info = &amp;(funcs[i]);</code>
<code></code><code>// check for platform dependent attach operation</code>
<code></code><code>if</code> <code>(info == null) {</code>
<code></code><code>info = attachlistener::pd_find_operation(op-&gt;name());</code>
<code></code><code>if</code> <code>(info != null) {</code>
<code></code><code>// dispatch to the function that implements this operation</code>
<code></code><code>res = (info-&gt;func)(op, &amp;st);</code>
<code></code><code>st.print(&quot;operation %s not recognized!&quot;, op-&gt;name());</code>
<code></code><code>res = jni_err;</code>
<code></code><code>// operation complete - send result and output to client</code>
<code></code><code>op-&gt;complete(res, &amp;st);</code>
从代码来看就是从队列里不断取attachoperation，然后找到请求命令对应的方法进行执行，比如我们一开始说的jstack命令，找到 { “threaddump”, thread_dump }的映射关系，然后执行thread_dump方法 再来看看其要调用的attachlistener::dequeue()
<code>attachoperation* attachlistener::dequeue() {</code>
<code></code><code>javathread* thread = javathread::current();</code>
<code></code><code>threadblockinvm tbivm(thread);</code>
<code></code><code>thread-&gt;set_suspend_equivalent();</code>
<code></code><code>// cleared by handle_special_suspend_equivalent_condition() or</code>
<code></code><code>// java_suspend_self() via check_and_wait_while_suspended()</code>
<code></code><code>attachoperation* op = linuxattachlistener::dequeue();</code>
<code></code><code>// were we externally suspended while we were waiting?</code>
<code></code><code>thread-&gt;check_and_wait_while_suspended();</code>
<code></code><code>return</code> <code>op;</code>
最终调用的是linuxattachlistener::dequeue()
<a href="http://ifeve.com/jvm-attach/#viewsource">查看源代码</a>
<code>linuxattachoperation* linuxattachlistener::dequeue() {</code>
<code></code><code>int</code> <code>s;</code>
<code></code><code>// wait for client to connect</code>
<code></code><code>struct sockaddr addr;</code>
<code></code><code>socklen_t len = sizeof(addr);</code>
<code></code><code>restartable(::accept(listener(), &amp;addr, &amp;len), s);</code>
<code></code><code>if</code> <code>(s == -</code><code>1</code><code>) {</code>
<code></code><code>return</code> <code>null;</code><code>// log a warning?</code>
<code></code><code>// get the credentials of the peer and check the effective uid/guid</code>
<code></code><code>// - check with jeff on this.</code>
<code></code><code>struct ucred cred_info;</code>
<code></code><code>socklen_t optlen = sizeof(cred_info);</code>
<code></code><code>if</code> <code>(::getsockopt(s, sol_socket, so_peercred, (</code><code>void</code><code>*)&amp;cred_info, &amp;optlen) == -</code><code>1</code><code>) {</code>
<code></code><code>int</code> <code>res;</code>
<code></code><code>restartable(::close(s), res);</code>
<code></code><code>uid_t euid = geteuid();</code>
<code></code><code>gid_t egid = getegid();</code>
<code></code><code>if</code> <code>(cred_info.uid != euid || cred_info.gid != egid) {</code>
<code></code><code>// peer credential look okay so we read the request</code>
<code></code><code>linuxattachoperation* op = read_request(s);</code>
我们看到如果没有请求的话，会一直accept在那里，当来了请求，然后就会创建一个套接字，并读取数据，构建出linuxattachoperation返回并执行。
整个过程就这样了，从attach线程创建到接收请求，处理请求，希望对大家有帮助。