Function conn_cache_push_stream

app/jaws/global/conn_cache.c:171–226

}
	
void conn_cache_push_stream(CONN_CACHE *cache, ACL_ASTREAM *stream,
	int timeout, void (*free_fn)(ACL_ASTREAM*, void*), void *ctx)
{
	const char *key = ACL_VSTREAM_PEER(acl_aio_vstream(stream));
	CONN_POOL *conns;
	CONN *conn;

#if 0
	acl_aio_clean_hooks(stream);
#endif

	/* �鿴��KEY�����ӳؾ���Ƿ���ڣ�����������ã����򴴽��µ� */

	conns = (CONN_POOL*) acl_htable_find(cache->cache, key);
	if (conns == NULL) {
		conns = (CONN_POOL*) acl_mymalloc(sizeof(CONN_POOL));
		conns->conn_cache = cache;
		conns->aio = acl_aio_handle(stream);
		acl_fifo_init(&conns->conns);
		ACL_SAFE_STRNCPY(conns->key, key, sizeof(conns->key));
		acl_htable_enter(cache->cache, key, conns);
	}

#if 0
	/* ��������ӳ��е��������������ƣ��������ͷ���ɵ����Ӷ��� */
	if (acl_fifo_size(&conns->conns) >= cache->conn_limit) {
		conn = acl_fifo_pop(&conns->conns);
		if (conn) {
			conn->info = NULL;
			conn_close(conn);
		}
	}
#endif

	cache->nset++;

	/* �����µ��첽�����ӻ������ */
	conn = (CONN*) acl_mymalloc(sizeof(CONN));
	conn->stream = stream;
	conn->ctx = ctx;
	conn->free_fn = free_fn;

	/* ���������ӳ��� */
	conn->info = acl_fifo_push(&conns->conns, conn);
	conn->conn_pool = conns;

	/* ���ø����Ļص����� */
	acl_aio_ctl(stream,
		ACL_AIO_CTL_READ_HOOK_ADD, read_callback, conn,
		ACL_AIO_CTL_CLOSE_HOOK_ADD, read_close_callback, conn,
		ACL_AIO_CTL_TIMEO_HOOK_ADD, read_timeout_callback, conn,
		ACL_AIO_CTL_TIMEOUT, timeout,
		ACL_AIO_CTL_END);
	/* ��ʼ������������ */
	acl_aio_read(stream);
}

CONN *conn_cache_get_conn(CONN_CACHE *cache, const char *key)