| 149 | } |
| 150 | |
| 151 | void |
| 152 | MC::new_connection(NetVConnection *netvc, EThread *thread) |
| 153 | { |
| 154 | nvc = netvc; |
| 155 | mutex = new_ProxyMutex(); |
| 156 | rbuf = new_MIOBuffer(MAX_IOBUFFER_SIZE); |
| 157 | rbuf->water_mark = TSMEMCACHE_TMP_CMD_BUFFER_SIZE; |
| 158 | reader = rbuf->alloc_reader(); |
| 159 | wbuf = new_empty_MIOBuffer(BUFFER_SIZE_INDEX_32K); |
| 160 | cbuf = 0; |
| 161 | writer = wbuf->alloc_reader(); |
| 162 | SCOPED_MUTEX_LOCK(lock, mutex, thread); |
| 163 | rvio = nvc->do_io_read(this, INT64_MAX, rbuf); |
| 164 | wvio = nvc->do_io_write(this, 0, writer); |
| 165 | header.magic = TSMEMCACHE_HEADER_MAGIC; |
| 166 | read_from_client(); |
| 167 | } |
| 168 | |
| 169 | int |
| 170 | MC::die() |
no test coverage detected