[andre neves]

please read my question: http://forums.alliedmods.net/showthread.php?t=171856

[joropito]

Originally Posted by Bugsy The main difference is this inc/module combo uses a thinking entity to monitor changes to trigger forwards and the windows-only module gets notified by the OS of changes so no looping/set_task/thinking-ent. The overall functionality is the same.

Why not to check on ServerFrame for socket data available using select with non-blocking sockets? It will be smoothest for the socket operation.

I've made that modification in sockets module just for testing purposes and it works like a charm.

[DjOptimuS]

It is posible to restrict the socket to accept connections from one IP only ? Thank you.

[Javivi]

Hello bugsy, good job.

Sometimes a non-blocking socket can return EINPROGRESS at connect, so that check will fail and the socket won't be created ( but it should be created, and then checked with socket_is_writable to see when the socket is ready for sending data )

PHP Code:

    if ( ( ( connect(sock, (struct sockaddr*)&server , sizeof( server ) ) ) == SOCKET_ERROR ) && ( GetSocketError() != WOULDBLOCK ) ) 
    {
            *err = GetSocketError(); 
            return -1;
    } 


Joaquim's version works fine

PHP Code:

    // Not, let's try to open a connection to the server
    contr = connect(sock, (struct sockaddr*)&server, sizeof( server));
    
    /*
    if (contr < 0) {
            // If an error occured cancel
            params[4] = 3;  //error while connecting
            return -1;
    }
    */ 


[Bugsy]

I partially rewrote this module eliminating the need for the sockets_forwards.inc file, as recommended by joropito. The module will now monitor socket events\changes without any type of looping\checking within the .inc or plugin. It is working under WinXP, can someone compile\test under linux?

[Arkshine]

No idea if it loads/works.

[Bugsy]

Originally Posted by Arkshine No idea if it loads/works.

I didn't post the new one yet, just seeing if I had any takers on a compile test. Ill post in a few

[Bugsy]

Here it is, thanks in advance.

[Arkshine]

Needs to be tested.

[Bugsy]

Originally Posted by Arkshine Needs to be tested.

Here's a little plugin I put together to quickly test the module, example #2 above also works if you have a separate sockets tester app to work with (AMXX Studio sockets terminal works good for Windows)

To test Server\Client functionality, do commands in this order:
1. Listen (use only once, this creates a listening socket)
2. Connect (can be repeated, each time a new client is created)
3. SendData (can be repeated, will send from most recent connected client)

To quickly test an HTTP request use Test command.

PHP Code:

#include <amxmodx>
#include <sockets2>

const TEST_PORT = 234;

new g_Socket;

public plugin_init() 
{
    register_concmd( "Test" , "QuickTest" );
    register_concmd( "Connect" , "TestConnect" );
    register_concmd( "Listen" , "TestListen" );
    register_concmd( "SendData" , "TestSend" );
}

public QuickTest()
{
    new iError;
    new iSocket = socket_open( "www.google.com" , 80 , SOCKET_TCP , iError );
    
    server_print( "Connecting on=%d Error=%d" , iSocket , iError );
}

public TestConnect()
{
    new szIP[ 16 ] , iError;
    get_user_ip( 0 , szIP , charsmax( szIP ) , 1 );
    
    g_Socket = socket_open( szIP , TEST_PORT , SOCKET_TCP , iError );
    
    server_print( "Connecting on=%d Error=%d" , g_Socket , iError );
}

public TestListen()
{
    new szIP[ 16 ] , iError , iSocket;
    get_user_ip( 0 , szIP , charsmax( szIP ) , 1 );

    iSocket = socket_listen( szIP , TEST_PORT , SOCKET_TCP , iError ); 
    
    server_print( "Listening on=%d Error=%d" , iSocket , iError );
}

public TestSend()
{
    server_print( "Sending data on=%d" , g_Socket );
    socket_send( g_Socket , "Hello there" , 12 ); 
}

public Socket_Connected( iSocket )
{
    server_print( "Connected on=%d" , iSocket );
    socket_send( iSocket , "GET /index.html HTTP/1.1^r^nHost: www.google.com^r^n^r^n" , 128 );
}

public Socket_ConnectionRequest( iSocket )
{
    new iError;

    if ( ( g_Socket = socket_accept( iSocket , iError ) ) )
        server_print( "Connect Request on=%d, Accepted request, new socket=%d" , iSocket , g_Socket );
}

public Socket_IncomingData( iSocket , iBytes )
{
    new szData[ 1024 ] , iGet = socket_recv( iSocket , szData , sizeof( szData ) );
    
    server_print( "Data Arrived on %d | Total Bytes=%d | Bytes-read=%d | Data=%s" , iSocket , iBytes , iGet , szData );
}

public Socket_Disconnected( iSocket )
{
    server_print( "Disconnected=%d" ,iSocket );
}