本文整理汇总了C++中socketPtr函数的典型用法代码示例。如果您正苦于以下问题:C++ socketPtr函数的具体用法?C++ socketPtr怎么用?C++ socketPtr使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了socketPtr函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C++代码示例。
示例1: socketRegisterInterest
PUBLIC void socketRegisterInterest(int sid, int handlerMask)
{
WebsSocket *sp;
assert(socketPtr(sid));
sp = socketPtr(sid);
sp->handlerMask = handlerMask;
if (sp->flags & SOCKET_BUFFERED_READ) {
sp->handlerMask |= SOCKET_READABLE;
}
if (sp->flags & SOCKET_BUFFERED_WRITE) {
sp->handlerMask |= SOCKET_WRITABLE;
}
}
开发者ID:thomasonegd,项目名称:goahead,代码行数:14,代码来源:socket.c
示例2: socketWrite
/*
Write to a socket. Absorb as much data as the socket can buffer. Block if the socket is in blocking mode. Returns -1
on error, otherwise the number of bytes written.
*/
PUBLIC ssize socketWrite(int sid, void *buf, ssize bufsize)
{
WebsSocket *sp;
ssize len, written, sofar;
int errCode;
if (buf == 0 || (sp = socketPtr(sid)) == NULL) {
return -1;
}
if (sp->flags & SOCKET_EOF) {
return -1;
}
len = bufsize;
sofar = 0;
while (len > 0) {
if ((written = send(sp->sock, (char*) buf + sofar, (int) len, 0)) < 0) {
errCode = socketGetError();
if (errCode == EINTR) {
continue;
} else if (errCode == EWOULDBLOCK || errCode == EAGAIN) {
if (sofar) {
/*
If some data was written, we mask the EAGAIN for this time. Caller should recall and then
will get a negative return code with EAGAIN.
*/
return sofar;
}
}
return -errCode;
}
len -= written;
sofar += written;
}
return sofar;
}
开发者ID:EMali2HF,项目名称:goahead,代码行数:39,代码来源:socket.c
示例3: behavior
/*
Set the TCP delay behavior (nagle algorithm)
*/
PUBLIC int socketSetNoDelay(int sid, bool on)
{
WebsSocket *sp;
int oldDelay;
if ((sp = socketPtr(sid)) == NULL) {
assert(0);
return 0;
}
oldDelay = sp->flags & SOCKET_NODELAY;
if (on) {
sp->flags |= SOCKET_NODELAY;
} else {
sp->flags &= ~(SOCKET_NODELAY);
}
#if ME_WIN_LIKE
{
BOOL noDelay;
noDelay = on ? 1 : 0;
setsockopt(sp->sock, IPPROTO_TCP, TCP_NODELAY, (FAR char*) &noDelay, sizeof(BOOL));
}
#else
{
int noDelay;
noDelay = on ? 1 : 0;
setsockopt(sp->sock, IPPROTO_TCP, TCP_NODELAY, (char*) &noDelay, sizeof(int));
}
#endif /* ME_WIN_LIKE */
return oldDelay;
}
开发者ID:thomasonegd,项目名称:goahead,代码行数:33,代码来源:socket.c
示例4: socketWrite
/*
Write to a socket. Absorb as much data as the socket can buffer. Block if the socket is in blocking mode. Returns -1
on error, otherwise the number of bytes written.
*/
PUBLIC ssize socketWrite(int sid, void *buf, ssize bufsize)
{
WebsSocket *sp;
ssize len, written, sofar;
int errCode;
if (buf == 0 || (sp = socketPtr(sid)) == NULL) {
return -1;
}
if (sp->flags & SOCKET_EOF) {
return -1;
}
len = bufsize;
sofar = 0;
while (len > 0) {
if ((written = send(sp->sock, (char*) buf + sofar, (int) len, 0)) < 0) {
errCode = socketGetError();
if (errCode == EINTR) {
continue;
} else if (errCode == EWOULDBLOCK || errCode == EAGAIN) {
return sofar;
}
return -errCode;
}
len -= written;
sofar += written;
}
return sofar;
}
开发者ID:thomasonegd,项目名称:goahead,代码行数:33,代码来源:socket.c
示例5: socketSetBufferSize
void socketSetBufferSize(int sid, int in, int line, int out)
{
socket_t *sp;
if ((sp = socketPtr(sid)) == NULL) {
return;
}
if (in >= 0) {
ringqClose(&sp->inBuf);
in++;
ringqOpen(&sp->inBuf, in, in);
}
if (line >= 0) {
ringqClose(&sp->lineBuf);
line++;
ringqOpen(&sp->lineBuf, line, line);
}
if (out >= 0) {
ringqClose(&sp->outBuf);
out++;
ringqOpen(&sp->outBuf, out, out);
}
}
开发者ID:sd-eblana,项目名称:bawx,代码行数:26,代码来源:sock.c
示例6: socketEof
/*
Read from a socket. Return the number of bytes read if successful. This may be less than the requested "bufsize" and
may be zero. This routine may block if the socket is in blocking mode.
Return -1 for errors or EOF. Distinguish between error and EOF via socketEof().
*/
PUBLIC ssize socketRead(int sid, void *buf, ssize bufsize)
{
WebsSocket *sp;
ssize bytes;
int errCode;
assert(buf);
assert(bufsize > 0);
if ((sp = socketPtr(sid)) == NULL) {
return -1;
}
if (sp->flags & SOCKET_EOF) {
return -1;
}
if ((bytes = recv(sp->sock, buf, (int) bufsize, 0)) < 0) {
errCode = socketGetError();
if (errCode == EAGAIN || errCode == EWOULDBLOCK) {
bytes = 0;
} else {
/* Conn reset or Some other error */
sp->flags |= SOCKET_EOF;
bytes = -errCode;
}
} else if (bytes == 0) {
sp->flags |= SOCKET_EOF;
bytes = -1;
}
return bytes;
}
开发者ID:thomasonegd,项目名称:goahead,代码行数:36,代码来源:socket.c
示例7: socketGetInput
int socketGetInput(int sid, char *buf, int toRead, int *errCode)
{
struct sockaddr_in server;
socket_t *sp;
int len, bytesRead;
a_assert(buf);
a_assert(errCode);
*errCode = 0;
if ((sp = socketPtr(sid)) == NULL) {
return -1;
}
/*
* If we have previously seen an EOF condition, then just return
*/
if (sp->flags & SOCKET_EOF) {
return 0;
}
#if ((defined (WIN) || defined (CE)) && (!defined (LITTLEFOOT) && !defined (WEBS)))
if ( !(sp->flags & SOCKET_BLOCK)
&& ! socketWaitForEvent(sp, FD_CONNECT, errCode)) {
return -1;
}
#endif
/*
* Read the data
*/
if (sp->flags & SOCKET_DATAGRAM) {
len = sizeof(server);
bytesRead = recvfrom(sp->sock, buf, toRead, 0,
(struct sockaddr *) &server, &len);
} else {
bytesRead = recv(sp->sock, buf, toRead, 0);
}
/*
* BUG 01865 -- CPU utilization hangs on Windows. The original code used
* the 'errno' global variable, which is not set by the winsock functions
* as it is under *nix platforms. We use the platform independent
* socketGetError() function instead, which does handle Windows correctly.
* Other, *nix compatible platforms should work as well, since on those
* platforms, socketGetError() just returns the value of errno.
* Thanks to Jonathan Burgoyne for the fix.
*/
if (bytesRead < 0)
{
*errCode = socketGetError();
if (*errCode == ECONNRESET)
{
sp->flags |= SOCKET_CONNRESET;
return 0;
}
return -1;
}
return bytesRead;
}
开发者ID:qwerty1023,项目名称:wive-rtnl-firmware,代码行数:60,代码来源:sockGen.c
示例8: sslRead
/*
Return the number of bytes read. Return -1 on errors and EOF.
*/
PUBLIC ssize sslRead(Webs *wp, void *buf, ssize len)
{
Nano *np;
WebsSocket *sp;
sbyte4 nbytes, count;
int rc;
np = (Nano*) wp->ssl;
assert(np);
if (!np->connected && (rc = nanoHandshake(wp)) <= 0) {
return rc;
}
while (1) {
/*
This will do the actual blocking I/O
*/
rc = SSL_recv(np->handle, buf, (sbyte4) len, &nbytes, 0);
logmsg(5, "NanoSSL: ssl_read %d", rc);
if (rc < 0) {
if (rc != ERR_TCP_READ_ERROR) {
sp = socketPtr(wp->sid);
sp->flags |= SOCKET_EOF;
}
return -1;
}
break;
}
SSL_recvPending(np->handle, &count);
if (count > 0) {
socketReservice(wp->wid);
}
return nbytes;
}
开发者ID:Eric--Zhou,项目名称:goahead,代码行数:37,代码来源:nanossl.c
示例9: sslFree
PUBLIC void sslFree(Webs *wp)
{
Ms *ms;
WebsSocket *sp;
uchar *buf;
int len;
ms = wp->ssl;
if (ms) {
assert(wp->sid >= 0);
if ((sp = socketPtr(wp->sid)) == 0) {
return;
}
if (!(sp->flags & SOCKET_EOF)) {
/*
Flush data. Append a closure alert to any buffered output data, and try to send it.
Don't bother retrying or blocking, we're just closing anyway.
*/
matrixSslEncodeClosureAlert(ms->handle);
if ((len = matrixSslGetOutdata(ms->handle, &buf)) > 0) {
sslWrite(wp, buf, len);
}
}
if (ms->handle) {
matrixSslDeleteSession(ms->handle);
}
wfree(ms);
wp->ssl = 0;
}
}
开发者ID:Eric--Zhou,项目名称:goahead,代码行数:30,代码来源:matrixssl.c
示例10: innerRead
/*
Return number of bytes read. Return -1 on errors and EOF.
*/
static ssize innerRead(Webs *wp, char *buf, ssize size)
{
Ms *ms;
uchar *mbuf;
ssize nbytes;
int msize, readMore;
ms = (Ms*) wp->ssl;
do {
if ((msize = matrixSslGetReadbuf(ms->handle, &mbuf)) < 0) {
return -1;
}
readMore = 0;
if ((nbytes = socketRead(wp->sid, mbuf, msize)) < 0) {
return nbytes;
} else if (nbytes > 0) {
nbytes = processIncoming(wp, buf, size, nbytes, &readMore);
if (nbytes < 0) {
sp = socketPtr(wp->sid);
sp->flags |= SOCKET_EOF;
return nbytes;
}
if (nbytes > 0) {
return nbytes;
}
}
} while (readMore);
return 0;
}
开发者ID:Eric--Zhou,项目名称:goahead,代码行数:32,代码来源:matrixssl.c
示例11: socketGets
int socketGets(int sid, char_t **buf)
{
socket_t *sp;
ringq_t *lq;
char c;
int rc, len;
a_assert(buf);
*buf = NULL;
if ((sp = socketPtr(sid)) == NULL) {
return -1;
}
lq = &sp->lineBuf;
while (1) {
if ((rc = socketRead(sid, &c, 1)) < 0) {
return rc;
}
if (rc == 0) {
/*
* If there is a partial line and we are at EOF, pretend we saw a '\n'
*/
if (ringqLen(lq) > 0 && (sp->flags & SOCKET_EOF)) {
c = '\n';
} else {
return -1;
}
}
/*
* Validate length of request. Ignore long strings without newlines to
* safeguard against long URL attacks.
*/
if (ringqLen(lq) > E_MAX_REQUEST) {
c = '\n';
}
/*
* If a newline is seen, return the data excluding the new line to the
* caller. If carriage return is seen, just eat it.
*/
if (c == '\n') {
len = ringqLen(lq);
if (len > 0) {
*buf = ballocAscToUni((char *)lq->servp, len);
} else {
*buf = NULL;
}
ringqFlush(lq);
return len;
} else if (c == '\r') {
continue;
}
ringqPutcA(lq, c);
}
return 0;
}
开发者ID:vonnyfly,项目名称:http_server_for_wince,代码行数:59,代码来源:sock.c
示例12: socketSetBlock
/*
Set the socket blocking mode. Return the previous mode.
*/
PUBLIC int socketSetBlock(int sid, int on)
{
WebsSocket *sp;
int oldBlock;
if ((sp = socketPtr(sid)) == NULL) {
assert(0);
return 0;
}
oldBlock = (sp->flags & SOCKET_BLOCK);
sp->flags &= ~(SOCKET_BLOCK);
if (on) {
sp->flags |= SOCKET_BLOCK;
}
/*
Put the socket into block / non-blocking mode
*/
if (sp->flags & SOCKET_BLOCK) {
#if ME_WIN_LIKE
ulong flag = !on;
ioctlsocket(sp->sock, FIONBIO, &flag);
#elif ECOS
int off;
off = 0;
ioctl(sp->sock, FIONBIO, &off);
#elif VXWORKS
int iflag = !on;
ioctl(sp->sock, FIONBIO, (int) &iflag);
#elif TIDSP
setsockopt((SOCKET)sp->sock, SOL_SOCKET, SO_BLOCKING, &on, sizeof(on));
#else
fcntl(sp->sock, F_SETFL, fcntl(sp->sock, F_GETFL) & ~O_NONBLOCK);
#endif
} else {
#if ME_WIN_LIKE
ulong flag = !on;
int rc = ioctlsocket(sp->sock, FIONBIO, &flag);
rc = rc;
#elif ECOS
int on = 1;
ioctl(sp->sock, FIONBIO, &on);
#elif VXWORKS
int iflag = !on;
ioctl(sp->sock, FIONBIO, (int) &iflag);
#elif TIDSP
setsockopt((SOCKET)sp->sock, SOL_SOCKET, SO_BLOCKING, &on, sizeof(on));
#else
fcntl(sp->sock, F_SETFL, fcntl(sp->sock, F_GETFL) | O_NONBLOCK);
#endif
}
#if MACOSX
/* Prevent SIGPIPE when writing to closed socket on OS X */
int iflag = 1;
setsockopt(sp->sock, SOL_SOCKET, SO_NOSIGPIPE, (void*) &iflag, sizeof(iflag));
#endif
return oldBlock;
}
开发者ID:thomasonegd,项目名称:goahead,代码行数:61,代码来源:socket.c
示例13: socketGetHandle
int socketGetHandle(int sid)
{
socket_t *sp;
if ((sp = socketPtr(sid)) == NULL) {
return -1;
}
return sp->sock;
}
开发者ID:sd-eblana,项目名称:bawx,代码行数:9,代码来源:sock.c
示例14: socketCanWrite
int socketCanWrite(int sid)
{
socket_t *sp;
if ((sp = socketPtr(sid)) == NULL) {
return -1;
}
return sp->outBuf.buflen - ringqLen(&sp->outBuf) - 1;
}
开发者ID:sd-eblana,项目名称:bawx,代码行数:9,代码来源:sock.c
示例15: socketEof
int socketEof(int sid)
{
socket_t *sp;
if ((sp = socketPtr(sid)) == NULL) {
return -1;
}
return sp->flags & SOCKET_EOF;
}
开发者ID:sd-eblana,项目名称:bawx,代码行数:9,代码来源:sock.c
示例16: socketGetPort
int socketGetPort(int sid)
{
socket_t *sp;
if ((sp = socketPtr(sid)) == NULL) {
return -1;
}
return sp->port;
}
开发者ID:sd-eblana,项目名称:bawx,代码行数:9,代码来源:sock.c
示例17: socketReservice
PUBLIC void socketReservice(int sid)
{
WebsSocket *sp;
if ((sp = socketPtr(sid)) == NULL) {
return;
}
sp->flags |= SOCKET_RESERVICE;
}
开发者ID:thomasonegd,项目名称:goahead,代码行数:9,代码来源:socket.c
示例18: socketGetHandle
/*
Return the underlying socket handle
*/
PUBLIC Socket socketGetHandle(int sid)
{
WebsSocket *sp;
if ((sp = socketPtr(sid)) == NULL) {
return -1;
}
return sp->sock;
}
开发者ID:thomasonegd,项目名称:goahead,代码行数:12,代码来源:socket.c
示例19: socketCloseConnection
PUBLIC void socketCloseConnection(int sid)
{
WebsSocket *sp;
if ((sp = socketPtr(sid)) == NULL) {
return;
}
socketFree(sid);
}
开发者ID:thomasonegd,项目名称:goahead,代码行数:9,代码来源:socket.c
示例20: socketIsV6
PUBLIC bool socketIsV6(int sid)
{
WebsSocket *sp;
if ((sp = socketPtr(sid)) == NULL) {
return 0;
}
return sp->ip && ipv6(sp->ip);
}
开发者ID:thomasonegd,项目名称:goahead,代码行数:9,代码来源:socket.c
注:本文中的socketPtr函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论