Dear all,
I have attached the simple code where I have made an attempt at
setting the TIPC socket to work in the non-blocking mode. But, I notice that
the recv() call is actually waiting for the matching send to be executed. Is
there a better way of doing the same? Does TIPC support non-blocking
sockets?Thanks, Krishna Chaitanya K -- In the middle of difficulty, lies opportunity
/* ------------------------------------------------------------------------
//
// client_tipc.c
//
// Short description: This progrem sends a hello world message, then
// waits for an acknowledge before exiting.
// ------------------------------------------------------------------------
//
// Copyright (c) 2003, Ericsson Research Canada
// All rights reserved.
// Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions are met:
//
// Redistributions of source code must retain the above copyright notice, this
// list of conditions and the following disclaimer.
// Redistributions in binary form must reproduce the above copyright notice,
// this list of conditions and the following disclaimer in the documentation
// and/or other materials provided with the distribution.
// Neither the name of Ericsson Research Canada nor the names of its
// contributors may be used to endorse or promote products derived from this
// software without specific prior written permission.
//
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
// AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
// IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
// ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
// LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
// CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
// SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
// CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
// ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
// POSSIBILITY OF SUCH DAMAGE.
//
// ------------------------------------------------------------------------
//
// Created 2000-09-30 by Jon Maloy
//
// ------------------------------------------------------------------------
//
// $Id: client_tipc.c,v 1.4 2005/09/20 20:23:15 ajstephens Exp $
//
// Revision history:
// ----------------
// Rev Date Rev by Reason
// --- ---- ------ ------
//
// PA1 2000-09-30 Jon Maloy Created
// PA2 2004-03-25 M. Pourzandi Simplified to support a simple hello message
//
// ------------------------------------------------------------------------
*/
#include <sys/types.h>
#include <sys/socket.h>
#include <stdlib.h>
#include <stdio.h>
#include <assert.h>
#include <string.h>
#include <sys/param.h>
#include <sys/poll.h>
#include <sys/ioctl.h>
#include <netdb.h>
#include <errno.h>
#include <fcntl.h>
#include <tipc.h>
#include <unistd.h>
#include <sys/time.h>
#include <ctype.h>
#define SERVER_TYPE 18888
#define SERVER_INST 17
#define TIMEOUT 500000
#define FOREVER ~0
#define XSetNonblockSocket(_s_) \
fcntl(_s_, F_SETFL, fcntl(_s_, F_GETFL) | O_NONBLOCK)
void wait_for_server(struct tipc_name* name,int wait)
{
struct sockaddr_tipc topsrv;
/* struct tipc_subscr subscr = {{name->type,name->instance,name->instance},
wait,TIPC_SUB_SERVICE,{}};
*/
struct tipc_event event;
struct tipc_subscr subscr = {{SERVER_TYPE,0,100},
TIMEOUT,
TIPC_SUB_SERVICE,
{2,2,2,2,2,2,2,2}};
struct tipc_subscr net_subscr = {{0,0,~0},
FOREVER,
TIPC_SUB_PORTS,
{3,3,3,3,3,3,3,3}};
int sd = socket (AF_TIPC, SOCK_SEQPACKET,0);
assert(sd > 0);
memset(&topsrv,0,sizeof(topsrv));
topsrv.family = AF_TIPC;
topsrv.addrtype = TIPC_ADDR_NAME;
topsrv.addr.name.name.type = TIPC_TOP_SRV;
topsrv.addr.name.name.instance = TIPC_TOP_SRV;
/* Connect to topology server: */
if (0 > connect(sd,(struct sockaddr*)&topsrv,sizeof(topsrv))){
perror("failed to connect to topology server");
exit(1);
}
printf("Connected to topology server\n");
if (send(sd,&subscr,sizeof(subscr),0) != sizeof(subscr)){
perror("failed to send subscription");
exit(1);
}
printf("subscr Sent\n ");
if (send(sd,&net_subscr,sizeof(net_subscr),0) != sizeof(net_subscr)){
perror("failed to send network subscription");
}
printf("Network subscr sent\n ");
/* Now wait for the subscription to fire: */
if (recv(sd,&event,sizeof(event),0) != sizeof(event)){
perror("Failed to receive event");
exit(1);
}
if (event.event != TIPC_PUBLISHED){
printf("Server %u,%u not published within %u [s]\n",
name->type,name->instance,wait/1000);
exit(1);
}
close(sd);
}
int main(int argc, char* argv[], char* dummy[])
{
struct sockaddr_tipc server_addr;
int sd = socket (AF_TIPC, SOCK_SEQPACKET,0);
server_addr.family = AF_TIPC;
server_addr.addrtype = TIPC_ADDR_NAME;
server_addr.addr.name.name.type = SERVER_TYPE;
server_addr.addr.name.name.instance = SERVER_INST;
server_addr.addr.name.domain = 0;
printf("****** TIPC client hello world program started ******\n\n");
#if 1
wait_for_server(&server_addr.addr.name.name,10000);
#endif
/* Send connectionless "hello" message: */
printf("back in main \n");
char buf[40] = {"Hello World"};
if (connect(sd, (struct sockaddr *)&server_addr,
sizeof(server_addr)) != 0) {
perror("Connect failed");
}
printf("Client: Connection established\n");
if (XSetNonblockSocket (sd) != 0)
{
printf ("Unable to create non-blocking socket:\n");
printf("errno : %d\n",errno);
}
sleep(5);
if (0 > send(sd,buf,strlen(buf)+1,0)){
perror("Client: Failed to send");
}
printf("Client: Sent msg \"%s\" \n", buf);
printf("\n****** TIPC client hello program finished ******\n");
exit(0);
}
server_tipc
Description: Binary data
------------------------------------------------------------------------- This SF.net email is sponsored by DB2 Express Download DB2 Express C - the FREE version of DB2 express and take control of your XML. No limits. Just data. Click to get it now. http://sourceforge.net/powerbar/db2/
_______________________________________________ tipc-discussion mailing list tipc-discussion@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/tipc-discussion
