- 论坛徽章:
- 0
|
我在redhat linux server 2.1 上编译一个多线程的PROC程序(基本上是由oracle公司提
供的例子改造的)，
我将其例子中的main函数改为main_test函数，自己加了一个main函数，每个三秒钟调用
一次main_test;
出现两个令我迷惑的问题：
1.经过几分钟的测试(运行后)出现Error while trying to retrieve text for error
ORA-12540;
2.我用top命令观察进程情况，发现其内存在增长：
PID USER PRI NI SIZE RSS SHARE STAT %CPU %MEM TIME COMMAND
开始：
16567 oracle 15 0 18536 18M 3704 S 1.8 1.8 0:00 thread_demo
一段时间后：
16567 oracle 15 0 31932 31M 3704 S 2.7 3.1 0:00 thread_demo
又一段时间后：
16567 oracle 15 0 39636 38M 3704 S 3.7 3.8 0:00 thread_demo
又一段时间后:
16567 oracle 15 0 44796 43M 3704 S 1.1 4.3 0:01 thread_demo
又一段时间后:
16567 oracle 15 0 51680 50M 3704 S 0.7 5.0 0:01 thread_demo
又一段时间后:
16567 oracle 15 0 57700 56M 3704 S 2.5 5.6 0:01 thread_demo
又一段时间后:
16567 oracle 15 0 62864 61M 3704 S 1.7 6.1 0:01 thread_demo
又一段时间后:
16567 oracle 15 0 69912 68M 3704 S 1.9 6.7 0:01 thread_demo
又一段时间后:
16567 oracle 15 0 73172 71M 3704 S 1.7 7.1 0:01 thread_demo
又一段时间后,程序自动退出:
Error while trying to retrieve text for error ORA-12540;
#include <stdio.h>;
#include <stdlib.h>;
#include <string.h>;
#include
<sqlca.h>;
#define _EXC_OS_ _EXC__UNIX
#define _CMA_OS_
_CMA__UNIX
#ifdef DCE_THREADS
#include <pthread.h>;
#else
#include
<pthread.h>;
typedef void* pthread_addr_t;
typedef void*
(*pthread_startroutine_t) (void*);
#define pthread_attr_default (const
pthread_attr_t *)NULL
#endif
/* Function prototypes */
void err_report();
void do_transaction();
void get_transaction();
void logon();
void
logoff();
#define CONNINFO "ora/ora@ora9"
#define THREADS 40
struct
parameters
{
sql_context * ctx;
int thread_id;
};
typedef
struct parameters parameters;
struct timeval tp1;
struct timeval tp2;
/***************************************
* Main
***************************************/
main_test()
{
sql_context
ctx[THREADS];
pthread_t thread_id[THREADS];
pthread_addr_t status;
parameters params[THREADS];
int i;
EXEC SQL ENABLE THREADS;
EXEC SQL
WHENEVER SQLERROR DO err_report(sqlca);
if(gettimeofday(&tp1, (void*)NULL)
== -1)
{
perror("First: " ;
exit(0);
}
/* Create THREADS
sessions by connecting THREADS times */
for(i=0;i<THREADS;i++)
{
printf("Start Session %d....",i);
EXEC SQL CONTEXT ALLOCATE :ctx;
logon(ctx,CONNINFO);
}
/*Spawn threads*/
for(i=0;i<THREADS;i++)
{
params.ctx=ctx;
params.thread_id=i;
if
(pthread_create(&thread_id,pthread_attr_default,
(pthread_startroutine_t)do_transaction,
(pthread_addr_t) ¶ms))
printf("Cant create thread %d\n",i);
else
printf("Created
Thread %d\n", i);
}
/* Logoff sessions....*/
for(i=0;i<THREADS;i++)
{
/*wait for thread to end */
if
(pthread_join(thread_id,&status))
printf("Error when waiting for
thread % to terminate\n", i);
else
printf("stopped\n";
printf("Detach thread...";
if (pthread_detach(thread_id))
printf("Error detaching thread! \n";
else
printf("Detached!\n";
/*if(i==THREADS-1) */ /*注：此处的if语句原来是有的，oracle的例子当中，
但是因为在运行中出现超出最大连接数，我才删掉的*/
{
logoff(ctx);
EXEC SQL CONTEXT FREE :ctx;
}
}
if(gettimeofday(&tp2, (void*)NULL) == -1)
{
perror("Second: ";
exit(0);
}
printf(" \n\nTHE TOTAL TIME TAKEN FOR THE PROGRAM EXECUTION
= %f \n\n", (float)(tp2.tv_sec - tp1.tv_sec) + ((float)(tp2.tv_usec -
tp1.tv_usec)/1000000.0));
}
/***********************************************************************
*
Function: do_transaction
* Description: This functions executes SELECT 5
times and calls COMMIT.
***********************************************************************/
void
do_transaction(params)
parameters *params;
{
struct sqlca sqlca;
int
src_count;
sql_context ctx=params->;ctx;
int no;
struct {
char name[10];
float salary;
float comm;
}emp_record;
EXEC SQL WHENEVER SQLERROR DO
err_report(sqlca);
EXEC SQL CONTEXT USE :ctx;
printf("Thread %d
executing transaction\n",params->;thread_id);
EXEC SQL COMMIT;
for(no=101;no<105;no++)
{
EXEC SQL SELECT ename,sal,comm INTO
:emp_record FROM emp WHERE empno= :no;
printf("雇员名： %s, 实发工资
： %6.2f\n",emp_record.name,emp_record.salary+emp_record.comm);
}
}
/**************************************************************
* Function:
err_report
* Description: This routine prints out the most recent error
**************************************************************/
void
err_report(sqlca)
struct sqlca sqlca;
{
if (sqlca.sqlcode < 0)
printf("\n%.*s\n\n",sqlca.sqlerrm.sqlerrml,sqlca.sqlerrm.sqlerrmc);
exit(1);
}
/************************************************************
*
Function: logon
* Description: Logs on to the database as USERNAME/PASSWORD
************************************************************/
void
logon(ctx,connect_info)
sql_context ctx;
char * connect_info;
{
EXEC SQL
WHENEVER SQLERROR DO err_report(sqlca);
EXEC SQL CONTEXT USE :ctx;
EXEC
SQL CONNECT :connect_info;
printf("Connected!\n";
}
/***************************************************
* Function: logoff
*
Description: This routine logs off the database
***************************************************/
void logoff(ctx)
sql_context ctx;
{
EXEC SQL WHENEVER SQLERROR DO err_report(sqlca);
EXEC SQL CONTEXT USE :ctx;
EXEC SQL COMMIT WORK RELEASE;
printf("Logged
off!\n";
}
main()
{
time_t start;
int i=0;
while(1)
{
main_test();
sleep(3);
}
}
数据库端的表数据为：
EMPNO ENAME SAL COMM
---------- ---------- -------- --------
101 kilter 4100.00 2000.00
102 jorhn 4100.00 1000.00
103 kiven 3100.00 500.00
104 yangzi 3100.00 500.00
105 mafeng 2500.00 500.00
106 guli 3500.00 800.00 |
|
免费注册
发表于 2004-02-07 14:18
