int dna_open_client	(	char *	server_node,
		char *	server_task,
		int	port,
		int	server_protocol,
		void(*)()	read_ast,
		void(*)()	error_ast,
		SRC_TYPES	src_type
	)

Definition at line 733 of file dna.c.

References DNA_CONNECTION::buffer, DNA_CONNECTION::buffer_size, DNA_NET::code, conn_free(), conn_get(), DIM_ERROR, DIM_INFO, dim_print_date_time(), DIMDNSCNERR, DIMDNSCNEST, DIMTCPCNERR, DIMTCPCNEST, dna_close(), Dna_conns, dna_init(), dna_report_error(), dna_start_read(), dna_write_nowait(), DNA_CONNECTION::error_ast, FALSE, find_pend_conn(), get_node_name(), get_proc_name(), id, ins_pend_conn(), Memory::malloc(), Net_conns, DNA_NET::node, OPN_MAGIC, DNA_CONNECTION::protocol, RD_HDR, DNA_CONNECTION::read_ast, READ_HEADER_SIZE, rel_pend_conn(), DNA_CONNECTION::saw_init, sprintf(), SRC_DIC, SRC_DIS, STA_CONN, DNA_CONNECTION::state, str, DNA_NET::task, TCP_RCV_BUF_SIZE, TCPIP, tcpip_close(), tcpip_failure(), tcpip_open_client(), TRUE, and DNA_CONNECTION::writing.

Referenced by handle_dns_info(), open_dns(), retry_dns_connection(), and web_open_server().

{
        register DNA_CONNECTION *dna_connp;
        char str[256];
        register int tcpip_code, conn_id, id;
        DNA_NET local_buffer;
        extern int get_proc_name(char *);
        char src_type_str[64];

        if(server_protocol){}
        dna_init();
/*
        if(!DNA_Initialized) {
                conn_arr_create(SRC_DNA);
                DNA_Initialized = TRUE;
        }
*/
        conn_id = conn_get();
        dna_connp = &Dna_conns[conn_id] ;
/*
        if( !(conn_id = conn_get()) )
                dim_panic("In dna_open_client: No more connections\n");
*/
        dna_connp->protocol = TCPIP;
        dna_connp->error_ast = error_ast;
        tcpip_code = tcpip_open_client(conn_id, server_node, server_task, port);
        if( tcpip_failure(tcpip_code) )
        {
#ifdef VMS
                if(!strstr(server_node,"fidel"))
                {
#endif
                if(!find_pend_conn(server_node, server_task, port, src_type, 0))
                {
                        if(src_type == SRC_DIS)
                                strcpy(src_type_str,"Server");
                        else if(src_type == SRC_DIC)
                                strcpy(src_type_str,"Client");
                        else
                                strcpy(src_type_str,"Unknown type");
                        sprintf( str,"%s Connecting to %s on %s", 
                                src_type_str, server_task, server_node );
                        if(!strcmp(server_task,"DIM_DNS"))
                                dna_report_error( conn_id, tcpip_code, str, DIM_ERROR, DIMDNSCNERR );
                        else
                                dna_report_error( conn_id, tcpip_code, str, DIM_ERROR, DIMTCPCNERR );
                        ins_pend_conn(server_node, server_task, port, src_type, 0, 0);
                }
#ifdef VMS
                }
#endif
                tcpip_close(conn_id);
                conn_free( conn_id );
                return(0);
        }
        if( (id = find_pend_conn(server_node, server_task, port, src_type, 0)) )
        {
                if(src_type == SRC_DIS)
                        strcpy(src_type_str,"Server");
                else if(src_type == SRC_DIC)
                        strcpy(src_type_str,"Client");
                else
                        strcpy(src_type_str,"Unknown type");
                sprintf( str,"%s Connection established to", src_type_str);
                if(!strcmp(server_task,"DIM_DNS"))
                        dna_report_error( conn_id, -1, str, DIM_INFO, DIMDNSCNEST );
                else
                        dna_report_error( conn_id, -1, str, DIM_INFO, DIMTCPCNEST );
                rel_pend_conn(id, 0);
        }
        dna_connp->state = RD_HDR;
        dna_connp->writing = FALSE;
        dna_connp->buffer = (int *)malloc((size_t)TCP_RCV_BUF_SIZE);
/*
        if(!dna_connp->buffer)
        {
                printf("Error in DNA - open_client malloc returned 0\n");
                fflush(stdout);
        }
*/
        dna_connp->buffer_size = TCP_RCV_BUF_SIZE;
        dna_connp->read_ast = read_ast;
        dna_connp->saw_init = TRUE;     /* we send it! */
        dna_start_read(conn_id, READ_HEADER_SIZE);
        local_buffer.code = (int)htovl(OPN_MAGIC);
        get_node_name(local_buffer.node);
        get_proc_name(local_buffer.task);
        tcpip_code = dna_write_nowait(conn_id, &local_buffer, sizeof(local_buffer));
        if (tcpip_failure(tcpip_code))
        {
                dim_print_date_time();
                printf(" Client Establishing Connection: Couldn't write to Conn %3d : Server %s@%s\n",conn_id,
                        Net_conns[conn_id].task, Net_conns[conn_id].node);
                fflush(stdout);
                dna_close(conn_id);
                return(0);
        }
        read_ast(conn_id, NULL, 0, STA_CONN);
        return(conn_id);
}

Here is the call graph for this function:

Here is the caller graph for this function: