开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > TCP/IP协议栈 > 查看源码
locsock.c
资源名称：export.zip　[点击查看]
上传用户：hepax88
上传日期：2007-01-03
资源大小：1101k
文件大小：4k
源码类别：

TCP/IP协议栈

开发平台：

Visual C++

locsock.c：源码内容
  1. #include <errno.h>
  2. #include "global.h"
  3. #include "mbuf.h"
  4. #include "socket.h"
  5. #include "usock.h"
  7. int
  8. so_los(struct usock *up,int protocol)
  9. {
  10. up->cb.local = (struct loc *) callocw(1,sizeof(struct loc));
  11. up->cb.local->peer = up; /* connect to self */
  12. up->type = TYPE_LOCAL_STREAM;
  13. up->cb.local->hiwat = LOCSFLOW;
  14. return 0;
  15. }
  16. int
  17. so_lod(struct usock *up,int protocol)
  18. {
  19. up->cb.local = (struct loc *) callocw(1,sizeof(struct loc));
  20. up->cb.local->peer = up; /* connect to self */
  21. up->type = TYPE_LOCAL_DGRAM;
  22. up->cb.local->hiwat = LOCDFLOW;
  23. return 0;
  24. }
  25. int
  26. so_lo_recv(
  27. struct usock *up,
  28. struct mbuf **bpp,
  29. struct sockaddr *from,
  30. int *fromlen
  31. ){
  32. int s;
  34. while(up->cb.local != NULL && up->cb.local->q == NULL
  35.   && up->cb.local->peer != NULL){
  36. if(up->noblock){
  37. errno = EWOULDBLOCK;
  38. return -1;
  39. } else if((errno = kwait(up)) != 0){
  40. return -1;
  41. }
  42. }
  43. if(up->cb.local == NULL){
  44. /* Socket went away */
  45. errno = EBADF;
  46. return -1;
  47. }
  48. if(up->cb.local->q == NULL &&
  49.    up->cb.local->peer == NULL){
  50. errno = ENOTCONN;
  51. return -1;
  52. }
  53. /* For datagram sockets, this will return the
  54.  * first packet on the queue. For stream sockets,
  55.  * this will return everything.
  56.  */
  57. *bpp = dequeue(&up->cb.local->q);
  58. if(up->cb.local->q == NULL && (up->cb.local->flags & LOC_SHUTDOWN)){
  59. s = up->index;
  60. close_s(s);
  61. }
  62. ksignal(up,0);
  63. return len_p(*bpp);
  64. }
  65. int
  66. so_los_send(
  67. struct usock *up,
  68. struct mbuf **bpp,
  69. struct sockaddr *to
  70. ){
  71. if(up->cb.local->peer == NULL){
  72. free_p(bpp);
  73. errno = ENOTCONN;
  74. return -1;
  75. }
  76. append(&up->cb.local->peer->cb.local->q,bpp);
  77. ksignal(up->cb.local->peer,0);
  78. /* If high water mark has been reached, block */
  79. while(up->cb.local->peer != NULL &&
  80.       len_p(up->cb.local->peer->cb.local->q) >=
  81.       up->cb.local->peer->cb.local->hiwat){
  82. if(up->noblock){
  83. errno = EWOULDBLOCK;
  84. return -1;
  85. } else if((errno = kwait(up->cb.local->peer)) != 0){
  86. return -1;
  87. }
  88. }
  89. if(up->cb.local->peer == NULL){
  90. errno = ENOTCONN;
  91. return -1;
  92. }
  93. return 0;
  94. }
  95. int
  96. so_lod_send(
  97. struct usock *up,
  98. struct mbuf **bpp,
  99. struct sockaddr *to
  100. ){
  101. if(up->cb.local->peer == NULL){
  102. free_p(bpp);
  103. errno = ENOTCONN;
  104. return -1;
  105. }
  106. enqueue(&up->cb.local->peer->cb.local->q,bpp);
  107. ksignal(up->cb.local->peer,0);
  108. /* If high water mark has been reached, block */
  109. while(up->cb.local->peer != NULL &&
  110.       len_q(up->cb.local->peer->cb.local->q) >=
  111.       up->cb.local->peer->cb.local->hiwat){
  112. if(up->noblock){
  113. errno = EWOULDBLOCK;
  114. return -1;
  115. } else if((errno = kwait(up->cb.local->peer)) != 0){
  116. return -1;
  117. }
  118. }
  119. if(up->cb.local->peer == NULL){
  120. errno = ENOTCONN;
  121. return -1;
  122. }
  123. return 0;
  124. }
  125. int
  126. so_lod_qlen(struct usock *up,int rtx)
  127. {
  128. int len;
  130. switch(rtx){
  131. case 0:
  132. len = len_q(up->cb.local->q);
  133. break;
  134. case 1:
  135. if(up->cb.local->peer != NULL)
  136. len = len_q(up->cb.local->peer->cb.local->q);
  137. break;
  138. }
  139. return len;
  140. }
  141. int
  142. so_los_qlen(struct usock *up,int rtx)
  143. {
  144. int len;
  146. switch(rtx){
  147. case 0:
  148. len = len_p(up->cb.local->q);
  149. break;
  150. case 1:
  151. if(up->cb.local->peer != NULL)
  152. len = len_p(up->cb.local->peer->cb.local->q);
  153. break;
  154. }
  155. return len;
  156. }
  157. int
  158. so_loc_shut(struct usock *up,int how)
  159. {
  160. int s;
  162. s = up->index;
  164. if(up->cb.local->q == NULL)
  165. close_s(s);
  166. else
  167. up->cb.local->flags = LOC_SHUTDOWN;
  168. return 0;
  169. }
  170. int
  171. so_loc_close(struct usock *up)
  172. {
  173. if(up->cb.local->peer != NULL){
  174. up->cb.local->peer->cb.local->peer = NULL;
  175. ksignal(up->cb.local->peer,0);
  176. }
  177. free_q(&up->cb.local->q);
  178. free(up->cb.local);
  179. return 0;
  180. }
  181. char *
  182. lopsocket(struct sockaddr *p)
  183. {
  184. return "";
  185. }
  186. so_loc_stat(struct usock *up)
  187. {
  188. int s;
  190. s = up->index;
  192. printf("Inqlen: %d packetsn",socklen(s,0));
  193. printf("Outqlen: %d packetsn",socklen(s,1));
  194. return 0;
  195. }