package SharedSocket;

use strict;
use warnings;
use threads;
use threads::shared;

use IO::Socket::INET;
use Storable;

sub new(){
    my $class = shift;
    die("Not an instance method") if ref($class);

    
    my $self = &share(bless({},$class));
    $self->{"closed"} = 0;
    
    my $socket = new IO::Socket::INET(@_) or die("SharedSocket $!");
    $socket->autoflush(1);
    
    $self->{"closed"} = 0;

    $self->{"socket_fd"} = $socket->fileno;
    print("[SharedSocket::ctor] fd: " . $self->{"socket_fd"} . "\n");
    
    return $self;
}


sub send{
    my ($self, $msg) = @_;
    die("Not a static method") if ref(!$self);
    
    print("[SharedSocket::send] fd: " . $self->{"socket_fd"} . "\n");
    open(my $socket, ">&=", $self->{"socket_fd"}) or die("SharedSocket $!");
    Storable::fd_nstore($msg, $socket);
}


sub receive{
    my ($self) = @_;
    die("Not a static method") if ref(!$self);
     

    print("[SharedSocket::receive] fd: " . $self->{"socket_fd"} . "\n");
    open(my $socket, "<&=", $self->{"socket_fd"}) or die("SharedSocket $!");
    my $msg = Storable::fd_retrieve($socket);
    
    return $msg;
}

sub close{
    my ($self) = @_;
    die("Not a static method") if ref(!$self);
    
    lock($self);
    return if($self->{"closed"});
    
    open(my $socket, "+<&=", $self->{"socket_fd"}) or die("SharedSocket $!");
    $socket->close(); 
    $self->{"closed"} = 1;
}

##</code><code>##

[SharedSocket::ctor] fd: 4
[SharedSocket::send] fd: 4
SharedSocket Bad file descriptor at SharedSocket.pm line xx.