Home
last modified time | relevance | path

Searched refs:RECEIVE_TIMEOUT (Results 1 – 24 of 24) sorted by relevance

/dports/java/avis/avis-1.2.0/server/src/test/org/avis/router/
H A DSimpleClient.java69 protected static final int RECEIVE_TIMEOUT = 5000; field in SimpleClient
153 return receive (RECEIVE_TIMEOUT); in receive()
221 return receive (type, RECEIVE_TIMEOUT); in receive()
316 close (RECEIVE_TIMEOUT); in close()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/net/
H A DDomainPeer.java53 socket.setAttribute(DomainSocket.RECEIVE_TIMEOUT, timeoutMs); in setReadTimeout()
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/mqtt/source/
H A Dmqtt-source.c27 #define RECEIVE_TIMEOUT 1000 macro
199 gint rc = MQTTClient_receive(self->client, &topicName, &topicLen, &message, RECEIVE_TIMEOUT); in _fetch()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/native/src/org/apache/hadoop/net/unix/
H A DDomainSocket.c44 #define RECEIVE_TIMEOUT org_apache_hadoop_net_unix_DomainSocket_RECEIVE_TIMEOUT macro
454 ((jthr = setAttribute0(env, fd, RECEIVE_TIMEOUT, DEFAULT_RECEIVE_TIMEOUT)))) { in Java_org_apache_hadoop_net_unix_DomainSocket_connect0()
499 case RECEIVE_TIMEOUT: in setAttribute0()
577 case RECEIVE_TIMEOUT: in Java_org_apache_hadoop_net_unix_DomainSocket_getAttribute0()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/shortcircuit/
H A DDomainSocketFactory.java165 sock.setAttribute(DomainSocket.RECEIVE_TIMEOUT, socketTimeout); in createSocket()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/net/unix/
H A DTestDomainSocket.java293 serv.setAttribute(DomainSocket.RECEIVE_TIMEOUT, newTimeout); in testServerOptions()
294 int nextTimeout = serv.getAttribute(DomainSocket.RECEIVE_TIMEOUT); in testServerOptions()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/unix/
H A DDomainSocket.java294 public static final int RECEIVE_TIMEOUT = 4; field in DomainSocket
/dports/sysutils/moosefs2-cgi/moosefs-2.0.91/mfsmount/
H A Dmastercomm.c105 #define RECEIVE_TIMEOUT 10 macro
1378 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout in fs_receive_thread()
1501 r = tcptoread(fd,rec->ibuff+rcvd,65536,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
1522 r = tcptoread(fd,rec->ibuff+rcvd,size-rcvd,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
/dports/sysutils/moosefs2-cgiserv/moosefs-2.0.91/mfsmount/
H A Dmastercomm.c105 #define RECEIVE_TIMEOUT 10 macro
1378 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout in fs_receive_thread()
1501 r = tcptoread(fd,rec->ibuff+rcvd,65536,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
1522 r = tcptoread(fd,rec->ibuff+rcvd,size-rcvd,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
/dports/sysutils/moosefs2-metalogger/moosefs-2.0.91/mfsmount/
H A Dmastercomm.c105 #define RECEIVE_TIMEOUT 10 macro
1378 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout in fs_receive_thread()
1501 r = tcptoread(fd,rec->ibuff+rcvd,65536,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
1522 r = tcptoread(fd,rec->ibuff+rcvd,size-rcvd,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
/dports/sysutils/moosefs2-netdump/moosefs-2.0.91/mfsmount/
H A Dmastercomm.c105 #define RECEIVE_TIMEOUT 10 macro
1378 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout in fs_receive_thread()
1501 r = tcptoread(fd,rec->ibuff+rcvd,65536,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
1522 r = tcptoread(fd,rec->ibuff+rcvd,size-rcvd,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
/dports/sysutils/moosefs2-master/moosefs-2.0.91/mfsmount/
H A Dmastercomm.c105 #define RECEIVE_TIMEOUT 10 macro
1378 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout in fs_receive_thread()
1501 r = tcptoread(fd,rec->ibuff+rcvd,65536,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
1522 r = tcptoread(fd,rec->ibuff+rcvd,size-rcvd,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
/dports/sysutils/moosefs2-chunkserver/moosefs-2.0.91/mfsmount/
H A Dmastercomm.c105 #define RECEIVE_TIMEOUT 10 macro
1378 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout in fs_receive_thread()
1501 r = tcptoread(fd,rec->ibuff+rcvd,65536,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
1522 r = tcptoread(fd,rec->ibuff+rcvd,size-rcvd,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
/dports/sysutils/moosefs2-client/moosefs-2.0.91/mfsmount/
H A Dmastercomm.c105 #define RECEIVE_TIMEOUT 10 macro
1378 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout in fs_receive_thread()
1501 r = tcptoread(fd,rec->ibuff+rcvd,65536,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
1522 r = tcptoread(fd,rec->ibuff+rcvd,size-rcvd,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
/dports/sysutils/moosefs2-cli/moosefs-2.0.91/mfsmount/
H A Dmastercomm.c105 #define RECEIVE_TIMEOUT 10 macro
1378 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout in fs_receive_thread()
1501 r = tcptoread(fd,rec->ibuff+rcvd,65536,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
1522 r = tcptoread(fd,rec->ibuff+rcvd,size-rcvd,RECEIVE_TIMEOUT*1000); in fs_receive_thread()
/dports/sysutils/moosefs3-netdump/moosefs-3.0.116/mfsclient/
H A Dmastercomm.c162 #define RECEIVE_TIMEOUT 10 macro
2294 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout
2376 r = tcptoread(fd,msgbuff,size,RECEIVE_TIMEOUT*1000);
2496 r = tcptoread(fd,rec->ibuff+rcvd,toread,RECEIVE_TIMEOUT*1000);
/dports/sysutils/moosefs3-client/moosefs-3.0.116/mfsclient/
H A Dmastercomm.c162 #define RECEIVE_TIMEOUT 10 macro
2294 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout
2376 r = tcptoread(fd,msgbuff,size,RECEIVE_TIMEOUT*1000);
2496 r = tcptoread(fd,rec->ibuff+rcvd,toread,RECEIVE_TIMEOUT*1000);
/dports/sysutils/moosefs3-cgi/moosefs-3.0.116/mfsclient/
H A Dmastercomm.c162 #define RECEIVE_TIMEOUT 10 macro
2294 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout
2376 r = tcptoread(fd,msgbuff,size,RECEIVE_TIMEOUT*1000);
2496 r = tcptoread(fd,rec->ibuff+rcvd,toread,RECEIVE_TIMEOUT*1000);
/dports/sysutils/moosefs3-cgiserv/moosefs-3.0.116/mfsclient/
H A Dmastercomm.c162 #define RECEIVE_TIMEOUT 10 macro
2294 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout
2376 r = tcptoread(fd,msgbuff,size,RECEIVE_TIMEOUT*1000);
2496 r = tcptoread(fd,rec->ibuff+rcvd,toread,RECEIVE_TIMEOUT*1000);
/dports/sysutils/moosefs3-chunkserver/moosefs-3.0.116/mfsclient/
H A Dmastercomm.c162 #define RECEIVE_TIMEOUT 10 macro
2294 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout
2376 r = tcptoread(fd,msgbuff,size,RECEIVE_TIMEOUT*1000);
2496 r = tcptoread(fd,rec->ibuff+rcvd,toread,RECEIVE_TIMEOUT*1000);
/dports/sysutils/moosefs3-cli/moosefs-3.0.116/mfsclient/
H A Dmastercomm.c162 #define RECEIVE_TIMEOUT 10 macro
2294 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout
2376 r = tcptoread(fd,msgbuff,size,RECEIVE_TIMEOUT*1000);
2496 r = tcptoread(fd,rec->ibuff+rcvd,toread,RECEIVE_TIMEOUT*1000);
/dports/sysutils/moosefs3-metalogger/moosefs-3.0.116/mfsclient/
H A Dmastercomm.c162 #define RECEIVE_TIMEOUT 10 macro
2294 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout
2376 r = tcptoread(fd,msgbuff,size,RECEIVE_TIMEOUT*1000);
2496 r = tcptoread(fd,rec->ibuff+rcvd,toread,RECEIVE_TIMEOUT*1000);
/dports/sysutils/moosefs3-master/moosefs-3.0.116/mfsclient/
H A Dmastercomm.c162 #define RECEIVE_TIMEOUT 10 macro
2294 r = tcptoread(fd,hdr,12,RECEIVE_TIMEOUT*1000); // read timeout
2376 r = tcptoread(fd,msgbuff,size,RECEIVE_TIMEOUT*1000);
2496 r = tcptoread(fd,rec->ibuff+rcvd,toread,RECEIVE_TIMEOUT*1000);
/dports/sysutils/lizardfs/lizardfs-3.12.0/src/mount/
H A Dmastercomm.cc85 #define RECEIVE_TIMEOUT 10 macro
1056 int r = tcptoread(fd, appendPointer, size, RECEIVE_TIMEOUT * 1000); in fs_append_from_master()