aboutsummaryrefslogtreecommitdiff
path: root/tests/check/libs/gstnettimeprovider.c
diff options
context:
space:
mode:
Diffstat (limited to 'tests/check/libs/gstnettimeprovider.c')
-rw-r--r--tests/check/libs/gstnettimeprovider.c35
1 files changed, 14 insertions, 21 deletions
diff --git a/tests/check/libs/gstnettimeprovider.c b/tests/check/libs/gstnettimeprovider.c
index 1e63270..49bfee0 100644
--- a/tests/check/libs/gstnettimeprovider.c
+++ b/tests/check/libs/gstnettimeprovider.c
@@ -57,9 +57,10 @@ GST_START_TEST (test_functioning)
GstNetTimePacket *packet;
GstClock *clock;
GstClockTime local;
- struct sockaddr_in servaddr;
- gint port = -1, sockfd, ret;
- socklen_t len;
+ GSocketAddress *server_addr;
+ GInetAddress *addr;
+ GSocket *socket;
+ gint port = -1;
clock = gst_system_clock_obtain ();
fail_unless (clock != NULL, "failed to get system clock");
@@ -69,33 +70,24 @@ GST_START_TEST (test_functioning)
g_object_get (ntp, "port", &port, NULL);
fail_unless (port > 0);
- sockfd = socket (AF_INET, SOCK_DGRAM, 0);
- fail_if (sockfd < 0, "socket failed");
+ socket = g_socket_new (G_SOCKET_FAMILY_IPV4, G_SOCKET_TYPE_DATAGRAM,
+ G_SOCKET_PROTOCOL_UDP, NULL);
+ fail_unless (socket != NULL, "could not create socket");
- memset (&servaddr, 0, sizeof (servaddr));
- servaddr.sin_family = AF_INET;
- servaddr.sin_port = htons (port);
-#ifndef G_OS_WIN32
- inet_aton ("127.0.0.1", &servaddr.sin_addr);
-#else
- servaddr.sin_addr.s_addr = inet_addr ("127.0.0.1");
-#endif
+ addr = g_inet_address_new_from_string ("127.0.0.1");
+ server_addr = g_inet_socket_address_new (addr, port);
+ g_object_unref (addr);
packet = gst_net_time_packet_new (NULL);
fail_unless (packet != NULL, "failed to create packet");
packet->local_time = local = gst_clock_get_time (clock);
- len = sizeof (servaddr);
- ret = gst_net_time_packet_send (packet, sockfd,
- (struct sockaddr *) &servaddr, len);
-
- fail_unless (ret == GST_NET_TIME_PACKET_SIZE, "failed to send packet");
+ fail_unless (gst_net_time_packet_send (packet, socket, server_addr, NULL));
g_free (packet);
- packet = gst_net_time_packet_receive (sockfd, (struct sockaddr *) &servaddr,
- &len);
+ packet = gst_net_time_packet_receive (socket, NULL, NULL);
fail_unless (packet != NULL, "failed to receive packet");
fail_unless (packet->local_time == local, "local time is not the same");
@@ -105,7 +97,8 @@ GST_START_TEST (test_functioning)
g_free (packet);
- close (sockfd);
+ g_object_unref (socket);
+ g_object_unref (server_addr);
gst_object_unref (ntp);
gst_object_unref (clock);