Lines Matching defs:sockfd

166     PRFileDesc *sockfd;    /* socket to read from/write to    */
213 * read data from sockfd into buf
216 readn(PRFileDesc *sockfd, char *buf, int len)
231 bytes = PR_Recv(sockfd, buf + offset, rem, 0,
240 if (PR_NT_CancelIo(sockfd) != PR_SUCCESS)
254 * write data from buf to sockfd
257 writen(PRFileDesc *sockfd, char *buf, int len)
266 bytes = PR_Send(sockfd, buf + offset, rem, 0,
286 PRFileDesc *sockfd;
290 sockfd = scp->sockfd;
304 if (readn(sockfd, in_buf->data, bytes) < bytes) {
313 if (PR_Shutdown(sockfd, PR_SHUTDOWN_RCV) < 0) {
318 if (writen(sockfd, in_buf->data, bytes) < bytes) {
327 if (PR_Shutdown(sockfd, PR_SHUTDOWN_BOTH) < 0) {
333 PR_Close(sockfd);
408 PRFileDesc *sockfd, *newsockfd;
414 if ((sockfd = PR_OpenTCPSocket(server_domain)) == NULL) {
431 while (PR_Bind(sockfd, &netaddr) < 0) {
443 if (PR_Listen(sockfd, 32) < 0) {
449 if (PR_GetSockName(sockfd, &netaddr) < 0) {
478 if ((newsockfd = PR_Accept(sockfd, addrp,
493 scp->sockfd = newsockfd;
511 if (sockfd) {
512 PR_Close(sockfd);
536 PRFileDesc *sockfd;
546 if ((sockfd = PR_OpenUDPSocket(server_domain)) == NULL) {
563 while (PR_Bind(sockfd, &netaddr) < 0) {
575 if (PR_GetSockName(sockfd, &netaddr) < 0) {
623 rv = PR_RecvFrom(sockfd, in_buf->data, bytes, 0, &netaddr,
631 rv = PR_SendTo(sockfd, in_buf->data, bytes, 0, &netaddr,
639 PR_Close(sockfd);
663 PRFileDesc *sockfd;
685 if ((sockfd = PR_OpenTCPSocket(client_domain)) == NULL) {
690 if (PR_Connect(sockfd, &netaddr,PR_INTERVAL_NO_TIMEOUT) < 0){
708 if (writen(sockfd, out_buf->data, bytes) < bytes) {
715 if (readn(sockfd, in_buf->data, bytes) < bytes) {
732 if (PR_Shutdown(sockfd, PR_SHUTDOWN_BOTH) < 0) {
736 PR_Close(sockfd);
766 PRFileDesc *sockfd;
785 if ((sockfd = PR_OpenUDPSocket(client_domain)) == NULL) {
802 if (PR_Bind(sockfd, &netaddr) < 0) {
808 if (PR_GetSockName(sockfd, &netaddr) < 0) {
820 if (PR_Connect(sockfd, &netaddr,PR_INTERVAL_NO_TIMEOUT) < 0){
838 rv = PR_Send(sockfd, out_buf->data, bytes, 0,
841 rv = PR_SendTo(sockfd, out_buf->data, bytes, 0, &netaddr,
849 rv = PR_Recv(sockfd, in_buf->data, bytes, 0,
852 rv = PR_RecvFrom(sockfd, in_buf->data, bytes, 0, &netaddr,
868 PR_Close(sockfd);
1140 PRFileDesc *sockfd;
1164 if ((sockfd = PR_NewTCPSocket()) == NULL) {
1170 if (PR_Connect(sockfd, &netaddr,PR_INTERVAL_NO_TIMEOUT) < 0){
1178 if (readn(sockfd, small_buf, SMALL_FILE_SIZE + SMALL_FILE_HEADER_SIZE)
1203 if (readn(sockfd, large_buf, LARGE_FILE_SIZE) != LARGE_FILE_SIZE) {
1226 if (readn(sockfd, small_buf, rlen) != rlen) {
1260 if (readn(sockfd, large_buf, rlen) != rlen) {
1293 if (readn(sockfd, small_buf, rlen) != rlen) {
1318 if (readn(sockfd, small_buf, rlen) != rlen) {
1344 if (readn(sockfd, large_buf, rlen) != rlen) {
1370 if (readn(sockfd, small_buf, rlen) != rlen) {
1408 if (readn(sockfd, large_buf, rlen) != rlen) {
1436 if (readn(sockfd, large_buf, rlen) != rlen) {
1468 PR_Close(sockfd);
1492 PRFileDesc *sockfd;
1499 sockfd = scp->sockfd;
1516 bytes = PR_TransmitFile(sockfd, local_small_file_fd, small_file_header,
1525 bytes = PR_TransmitFile(sockfd, local_large_file_fd, NULL, 0,
1548 bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
1572 bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
1595 bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
1617 bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
1639 bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
1661 bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
1683 bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
1706 bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_CLOSE_SOCKET,
1738 PRFileDesc *sockfd = NULL, *newsockfd;
1751 if ((sockfd = PR_OpenTCPSocket(PR_AF_INET)) == NULL) {
1765 while (PR_Bind(sockfd, &netaddr) < 0) {
1777 if (PR_Listen(sockfd, 32) < 0) {
1783 if (PR_GetSockName(sockfd, &netaddr) < 0) {
1806 if ((newsockfd = PR_Accept(sockfd, addrp,
1841 scp->sockfd = newsockfd;
1872 if (sockfd) {
1873 PR_Close(sockfd);