White space formatting fixes

Closes: <https://github.com/nginx/unit/pull/1062>

src/java/nginx/unit/websocket/Util.java

@@ -332,7 +332,7 @@ public class Util {
 
     public static List<DecoderEntry> getDecoders(
             List<Class<? extends Decoder>> decoderClazzes)
-                    throws DeploymentException{
+                    throws DeploymentException {
 
         List<DecoderEntry> result = new ArrayList<>();
         if (decoderClazzes != null) {

src/java/nginx/unit/websocket/server/WsSessionListener.java

@@ -19,7 +19,7 @@ package nginx.unit.websocket.server;
 import javax.servlet.http.HttpSessionEvent;
 import javax.servlet.http.HttpSessionListener;
 
-public class WsSessionListener implements HttpSessionListener{
+public class WsSessionListener implements HttpSessionListener {
 
     private final WsServerContainer wsServerContainer;
 

src/nodejs/unit-http/websocket_connection.js

@@ -36,11 +36,11 @@ var idCounter = 0;
 function WebSocketConnection(socket, extensions, protocol, maskOutgoingPackets, config) {
     this._debug = utils.BufferingLogger('websocket:connection', ++idCounter);
     this._debug('constructor');
-    
+
     if (this._debug.enabled) {
         instrumentSocketForDebugging(this, socket);
     }
-    
+
     // Superclass Constructor
     EventEmitter.call(this);
 
@@ -432,8 +432,8 @@ WebSocketConnection.prototype.processFrame = function(frame) {
                 // logic to emit the ping frame: this is only done when a listener is known to exist
                 // Expose a function allowing the user to override the default ping() behavior
                 var cancelled = false;
-                var cancel = function() { 
-                  cancelled = true; 
+                var cancel = function() {
+                  cancelled = true;
                 };
                 this.emit('ping', cancel, frame.binaryPayload);
 

src/nodejs/unit-http/websocket_request.js

@@ -247,7 +247,7 @@ WebSocketRequest.prototype.parseCookies = function(str) {
 
 WebSocketRequest.prototype.accept = function(acceptedProtocol, allowedOrigin, cookies) {
     this._verifyResolution();
-    
+
     // TODO: Handle extensions
 
     var protocolFullCase;
@@ -418,7 +418,7 @@ WebSocketRequest.prototype.accept = function(acceptedProtocol, allowedOrigin, co
     // if (negotiatedExtensions) {
     //     response += 'Sec-WebSocket-Extensions: ' + negotiatedExtensions.join(', ') + '\r\n';
     // }
-    
+
     // Mark the request resolved now so that the user can't call accept or
     // reject a second time.
     this._resolved = true;
@@ -447,12 +447,12 @@ WebSocketRequest.prototype.accept = function(acceptedProtocol, allowedOrigin, co
 
 WebSocketRequest.prototype.reject = function(status, reason, extraHeaders) {
     this._verifyResolution();
-    
+
     // Mark the request resolved now so that the user can't call accept or
     // reject a second time.
     this._resolved = true;
     this.emit('requestResolved', this);
-    
+
     if (typeof(status) !== 'number') {
         status = 403;
     }

src/nxt_clone.c

@@ -152,7 +152,7 @@ nxt_clone_credential_map_set(nxt_task_t *task, const char* mapfile, pid_t pid,
                 return NXT_ERROR;
             }
 
-            if (i+1 < map->size) {
+            if (i + 1 < map->size) {
                 *p++ = '\n';
 
             } else {
@@ -382,13 +382,13 @@ nxt_clone_vldt_credential_gidmap(nxt_task_t *task,
             m = map->map[j];
 
             if (!base_ok && creds->base_gid >= (nxt_gid_t) m.container
-                && creds->base_gid < (nxt_gid_t) (m.container+m.size))
+                && creds->base_gid < (nxt_gid_t) (m.container + m.size))
             {
                 base_ok = 1;
             }
 
             if (creds->gids[i] >= (nxt_gid_t) m.container
-                && creds->gids[i] < (nxt_gid_t) (m.container+m.size))
+                && creds->gids[i] < (nxt_gid_t) (m.container + m.size))
             {
                 gid_ok = 1;
                 break;
@@ -405,7 +405,7 @@ nxt_clone_vldt_credential_gidmap(nxt_task_t *task,
             m = map->map[i];
 
             if (creds->base_gid >= (nxt_gid_t) m.container
-                && creds->base_gid < (nxt_gid_t) (m.container+m.size))
+                && creds->base_gid < (nxt_gid_t) (m.container + m.size))
             {
                 base_ok = 1;
                 break;

src/nxt_openssl.c

@@ -73,7 +73,7 @@ static nxt_int_t nxt_ssl_conf_commands(nxt_task_t *task, SSL_CTX *ctx,
 static nxt_int_t nxt_tls_ticket_keys(nxt_task_t *task, SSL_CTX *ctx,
     nxt_tls_init_t *tls_init, nxt_mp_t *mp);
 static int nxt_tls_ticket_key_callback(SSL *s, unsigned char *name,
-    unsigned char *iv, EVP_CIPHER_CTX *ectx,HMAC_CTX *hctx, int enc);
+    unsigned char *iv, EVP_CIPHER_CTX *ectx, HMAC_CTX *hctx, int enc);
 #endif
 static void nxt_ssl_session_cache(SSL_CTX *ctx, size_t cache_size,
     time_t timeout);

src/nxt_router.c

@@ -2971,7 +2971,7 @@ nxt_router_tls_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg,
 
     mp = tmcf->router_conf->mem_pool;
 
-    if (tls->socket_conf->tls == NULL){
+    if (tls->socket_conf->tls == NULL) {
         tlscf = nxt_mp_zget(mp, sizeof(nxt_tls_conf_t));
         if (nxt_slow_path(tlscf == NULL)) {
             goto fail;

src/nxt_socket.c

@@ -322,15 +322,15 @@ nxt_socket_error(nxt_socket_t s)
 
     err = 0;
     len = sizeof(int);
-    /*  
-     * Linux and BSDs return 0 and store a pending error in the err argument; 
+    /*
+     * Linux and BSDs return 0 and store a pending error in the err argument;
      * Solaris returns -1 and sets the errno.
-     */  
+     */
     ret = getsockopt(s, SOL_SOCKET, SO_ERROR, (void *) &err, &len);
 
     if (nxt_slow_path(ret == -1)) {
         err = nxt_errno;
-    }   
+    }
 
     return err;
 }