Caches NamePlusRecord BER; works well
[yaz-moved-to-github.git] / src / spipe.c
index 52c922a..a4f8f5f 100644 (file)
@@ -1,5 +1,5 @@
 /* This file is part of the YAZ toolkit.
- * Copyright (C) 1995-2010 Index Data
+ * Copyright (C) Index Data
  * See the file LICENSE for details.
  */
 
@@ -125,7 +125,7 @@ yaz_spipe_t yaz_spipe_create(int port_to_use, WRBUF *err_msg)
 #endif
         fd_set write_set;
 
-        // create server socket
+        /* create server socket */
         p->m_socket = socket(AF_INET, SOCK_STREAM, 0);
         if (p->m_socket == YAZ_INVALID_SOCKET)
         {
@@ -137,7 +137,7 @@ yaz_spipe_t yaz_spipe_create(int port_to_use, WRBUF *err_msg)
 #ifndef WIN32
         {
             unsigned long one = 1;
-            if (setsockopt(p->m_socket, SOL_SOCKET, SO_REUSEADDR, (char*) 
+            if (setsockopt(p->m_socket, SOL_SOCKET, SO_REUSEADDR, (char*)
                            &one, sizeof(one)))
             {
                 if (err_msg)
@@ -147,12 +147,12 @@ yaz_spipe_t yaz_spipe_create(int port_to_use, WRBUF *err_msg)
             }
         }
 #endif
-        // bind server socket
+        /* bind server socket */
         add.sin_family = AF_INET;
         add.sin_port = htons(port_to_use);
         add.sin_addr.s_addr = INADDR_ANY;
         addr = ( struct sockaddr *) &add;
-        
+
         if (bind(p->m_socket, addr, sizeof(struct sockaddr_in)))
         {
             if (err_msg)
@@ -160,7 +160,7 @@ yaz_spipe_t yaz_spipe_create(int port_to_use, WRBUF *err_msg)
             yaz_spipe_destroy(p);
             return 0;
         }
-        
+
         if (listen(p->m_socket, 3) < 0)
         {
             if (err_msg)
@@ -169,7 +169,7 @@ yaz_spipe_t yaz_spipe_create(int port_to_use, WRBUF *err_msg)
             return 0;
         }
 
-        // client socket
+        /* client socket */
         tmpadd = (unsigned) inet_addr("127.0.0.1");
         if (!tmpadd)
         {
@@ -178,7 +178,7 @@ yaz_spipe_t yaz_spipe_create(int port_to_use, WRBUF *err_msg)
             yaz_spipe_destroy(p);
             return 0;
         }
-        
+
         memcpy(&add.sin_addr.s_addr, &tmpadd, sizeof(struct in_addr));
         p->m_fd[1] = socket(AF_INET, SOCK_STREAM, 0);
         if (p->m_fd[1] == YAZ_INVALID_SOCKET)
@@ -194,9 +194,9 @@ yaz_spipe_t yaz_spipe_create(int port_to_use, WRBUF *err_msg)
         {
             if (
 #ifdef WIN32
-            WSAGetLastError() != WSAEWOULDBLOCK
+                WSAGetLastError() != WSAEWOULDBLOCK
 #else
-            errno != EINPROGRESS
+                errno != EINPROGRESS
 #endif
                 )
             {