免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
最近访问板块 发新帖
查看: 1743 | 回复: 0

[C++] Linux下如何创建线程来建立和断开连接? [复制链接]

论坛徽章:
0
发表于 2010-01-29 14:07 |显示全部楼层
10可用积分
我用GTK编了个程序,当点击“发送”按钮时调用一个发送程序向客户机发送消息,点击“停止”按钮时停止发送;可是当我启动发送程序后点击“停止”按钮却没法停止程序,这是怎么回事啊?我的发送和停止函数是这样写的:

void send_clicked(GtkWidget *widget,gpointer data)
{
strcpy(iptext,gtk_entry_get_text(GTK_ENTRY(iptxt)));//get ip to iptext
strcpy(porttext,gtk_entry_get_text(GTK_ENTRY(porttxt)));//get port to porttext
//system("/sock";

extern SocketSend sock;  
int count=0;
sock.StartSock();
sock.CallServer(iptext,atoi(porttext));

while(count <10)
{
signal(SIGALRM, timer);
while(alarm(3))
      pause();
count++;
}

}
void stop_clicked(GtkWidget *widget,gpointer data)
{
//system("/startoracle.sh start";
//system("/sock";
sock.Close();
}

class SocketSend
{
public:
      class probebuff
        {
          public:
  std::string str;
  int len;
};

int sockfd;
int ConnectTime;
char buf[MAXDATASIZE];
struct hostent *host;
struct sockaddr_in serv_addr;
        
public:

int StartSock()//400hang
{
if ((sockfd=socket(AF_INET,SOCK_STREAM,0)) <0)
{
perror("socket error!";
exit(1);
}
return 0;
}

int Close()
        {
    close(sockfd);
            return 0;
        }
bool CallServer(const char *serverIp,int CallPort)
{
//设置连接服务器的协议族,端口号,服务器端的地址等
serv_addr.sin_family=AF_INET;
serv_addr.sin_port=htons(CallPort);
serv_addr.sin_addr.s_addr = inet_addr(serverIp);
bzero(&(serv_addr.sin_zero),;
ConnectTime=0;
while (connect(sockfd, (struct sockaddr *)&serv_addr,sizeof(serv_addr)) == -1&&              ConnectTime <=MaxConnectTimes)
{  
ConnectTime++;
if(ConnectTime <=MaxConnectTimes)
return 1; //连接成功
else
                              { perror("connect?error!";//连接失败,连接超时
                                exit(1);
return 0;
                              }
}
}
int SendBuff(string BuffInfo)
{  
static struct senddata
{
char buff[1024];
int len;
}data;               

          probebuff gProbeBuff1;
//进入临界区 将全局变量的内容写到要发送的变量中,不过往全局变量中写可能也要加临界区
string storeInfo="";
                storeInfo=BuffInfo;
gProbeBuff1.str+=storeInfo;
                gProbeBuff1.len=gProbeBuff1.str.size();

    strcpy(data.buff,gProbeBuff1.str.c_str());
            data.len = gProbeBuff1.len;

        if(send(sockfd, data.buff, data.len+1, 0) <0)
    {
  printf("send to server error!\n";
  exit(1);
      }
        else
    {
  printf("send to server success!\n";
      }
  return 1;
}

};

您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

DTCC2020中国数据库技术大会 限时8.5折

【架构革新 高效可控】2020年8月17日~19日第十一届中国数据库技术大会将在北京隆重召开。

大会设置2大主会场,20+技术专场,将邀请超百位行业专家,重点围绕数据架构、AI与大数据、传统企业数据库实践和国产开源数据库等内容展开分享和探讨,为广大数据领域从业人士提供一场年度盛会和交流平台。

http://dtcc.it168.com


大会官网>>
  

北京盛拓优讯信息技术有限公司. 版权所有 16024965号-6 北京市公安局海淀分局网监中心备案编号:11010802020122
中国互联网协会会员  联系我们:huangweiwei@it168.com
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP