Add testing files for connect EINPROGRESS error

Author: bukka

tests/streams/connect_einprogress/.gitignore

@@ -0,0 +1,2 @@
+server
+client

tests/streams/connect_einprogress/Makefile

@@ -0,0 +1,15 @@
+CC = gcc
+CFLAGS = -Wall -Wextra
+
+all: server client
+
+server: server.c
+	$(CC) $(CFLAGS) -o server server.c
+
+client: client.c
+	$(CC) $(CFLAGS) -o client client.c
+
+.PHONY: clean
+
+clean:
+	rm -f server client

tests/streams/connect_einprogress/client.c

@@ -0,0 +1,88 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <unistd.h>
+#include <errno.h>
+#include <string.h>
+#include <arpa/inet.h>
+#include <sys/poll.h>
+#include <fcntl.h>
+
+int main() {
+    // Create socket
+    int sockfd = socket(AF_INET, SOCK_STREAM, 0);
+    if (sockfd == -1) {
+        perror("socket");
+        exit(EXIT_FAILURE);
+    }
+
+    // Set server address and port
+    struct sockaddr_in server_addr;
+    server_addr.sin_family = AF_INET;
+    server_addr.sin_port = htons(8089); // Port number
+    inet_aton("127.0.0.1", &server_addr.sin_addr); // IP address of the server
+
+    // Set socket to non-blocking
+    if (fcntl(sockfd, F_SETFL, O_NONBLOCK) < 0) {
+        perror("fcntl");
+        close(sockfd);
+        exit(EXIT_FAILURE);
+    }
+
+    // Connect to server
+    int result = connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr));
+    if (result == -1 && errno == EINPROGRESS) {
+        printf("Connection in progress (EINPROGRESS).\n");
+
+        // Wait for connection using poll
+        struct pollfd fds[1];
+        fds[0].fd = sockfd;
+        fds[0].events = POLLOUT;
+
+        int poll_result = poll(fds, 1, 10000); // 10-second timeout
+        if (poll_result == -1) {
+            perror("poll");
+            close(sockfd);
+            exit(EXIT_FAILURE);
+        } else if (poll_result == 0) {
+            printf("Connection timeout.\n");
+            close(sockfd);
+            exit(EXIT_FAILURE);
+        } else {
+            // Connection established or error occurred
+            if (fds[0].revents & POLLOUT) {
+                int error = 0;
+                socklen_t len = sizeof(error);
+                if (getsockopt(sockfd, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {
+                    perror("getsockopt");
+                    close(sockfd);
+                    exit(EXIT_FAILURE);
+                }
+                if (error != 0) {
+                    fprintf(stderr, "Error in connecting: %s\n", strerror(error));
+                    close(sockfd);
+                    exit(EXIT_FAILURE);
+                }
+                printf("Connection established %d : %d.\n", errno, error);
+            } else {
+                fprintf(stderr, "Unknown error occurred.\n");
+                close(sockfd);
+                exit(EXIT_FAILURE);
+            }
+        }
+    } else if (result == 0) {
+        if (errno == EINPROGRESS) {
+            printf("Connection in progress.\n");
+        } else {
+            printf("Connection established.\n");
+        }
+    } else {
+        perror("connect");
+        exit(EXIT_FAILURE);
+    }
+
+    close(sockfd);
+    return 0;
+}

tests/streams/connect_einprogress/client.php

@@ -0,0 +1,6 @@
+<?php
+
+
+$connection = stream_socket_client("tcp://127.0.0.1:8087", $errno, $errstr, 60, STREAM_CLIENT_CONNECT);
+
+var_dump($connection, $errno, $errstr);

tests/streams/connect_einprogress/rules-down.sh

@@ -0,0 +1,5 @@
+
+sudo iptables -t mangle -D OUTPUT -p tcp --dport 8087 -j MARK --set-mark 123
+sudo tc filter del dev lo protocol ip parent 1:0 prio 1
+sudo tc qdisc del dev lo parent 1:1 handle 10:
+sudo tc qdisc del dev lo root handle 1:

tests/streams/connect_einprogress/rules-up.sh

@@ -0,0 +1,4 @@
+sudo iptables -t mangle -A OUTPUT -p tcp --dport 8087 -j MARK --set-mark 123
+sudo tc qdisc add dev lo root handle 1: prio
+sudo tc qdisc add dev lo parent 1:1 handle 10: netem delay 2s
+sudo tc filter add dev lo protocol ip parent 1:0 prio 1 u32 match mark 123 0xffff flowid 1:1

tests/streams/connect_einprogress/server.c

@@ -0,0 +1,62 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <unistd.h>
+#include <errno.h>
+#include <string.h>
+#include <arpa/inet.h>
+#include <fcntl.h>
+
+int main() {
+    // Create socket
+    int server_fd = socket(AF_INET, SOCK_STREAM, 0);
+    if (server_fd == -1) {
+        perror("socket");
+        exit(EXIT_FAILURE);
+    }
+
+    // Set server address and port
+    struct sockaddr_in server_addr;
+    server_addr.sin_family = AF_INET;
+    server_addr.sin_port = htons(8089); // Port number
+    server_addr.sin_addr.s_addr = INADDR_ANY;
+
+    // Bind socket to address and port
+    if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
+        perror("bind");
+        close(server_fd);
+        exit(EXIT_FAILURE);
+    }
+
+    // Listen for incoming connections
+    if (listen(server_fd, 3) == -1) {
+        perror("listen");
+        close(server_fd);
+        exit(EXIT_FAILURE);
+    }
+
+    printf("Server listening on port 8089...\n");
+
+    // Simulate delay before accepting connections
+    printf("Simulating delay before accepting connections...\n");
+    sleep(20); // 10-second delay
+
+    // // Accept incoming connection
+    // struct sockaddr_in client_addr;
+    // socklen_t addrlen = sizeof(client_addr);
+    // int client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &addrlen);
+    // if (client_fd == -1) {
+    //     perror("accept");
+    //     close(server_fd);
+    //     exit(EXIT_FAILURE);
+    // }
+
+    // printf("Connection accepted from %s:%d\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
+
+    // close(client_fd);
+    close(server_fd);
+    return 0;
+}
+

tests/streams/connect_einprogress/server.php

@@ -0,0 +1,14 @@
+<?php
+
+$server = stream_socket_server('127.0.0.1:8087');
+
+$read = [$server];
+$write = $except = null;
+
+
+stream_select($read, $write, $except, 10);
+sleep(10);
+echo "ready to accept\n";
+$conn = stream_socket_accept($server);
+
+var_dump($conn);