Przeglądaj źródła

[retry] Add timer_init() wrapper function

Standardise on using timer_init() to initialise an embedded retry
timer, to match the coding style used by other embedded objects.

Signed-off-by: Michael Brown <mcb30@ipxe.org>
tags/v1.20.1
Michael Brown 14 lat temu
rodzic
commit
c760ac3022

+ 12
- 0
src/include/ipxe/retry.h Wyświetl plik

51
 	void ( * expired ) ( struct retry_timer *timer, int over );
51
 	void ( * expired ) ( struct retry_timer *timer, int over );
52
 };
52
 };
53
 
53
 
54
+/**
55
+ * Initialise a timer
56
+ *
57
+ * @v timer		Retry timer
58
+ * @v expired		Timer expired callback
59
+ */
60
+static inline __attribute__ (( always_inline )) void
61
+timer_init ( struct retry_timer *timer,
62
+	     void ( * expired ) ( struct retry_timer *timer, int over ) ) {
63
+	timer->expired = expired;
64
+}
65
+
54
 extern void start_timer ( struct retry_timer *timer );
66
 extern void start_timer ( struct retry_timer *timer );
55
 extern void start_timer_fixed ( struct retry_timer *timer,
67
 extern void start_timer_fixed ( struct retry_timer *timer,
56
 				unsigned long timeout );
68
 				unsigned long timeout );

+ 1
- 1
src/net/aoe.c Wyświetl plik

439
 	if ( ! aoe )
439
 	if ( ! aoe )
440
 		return -ENOMEM;
440
 		return -ENOMEM;
441
 	ref_init ( &aoe->refcnt, aoe_free );
441
 	ref_init ( &aoe->refcnt, aoe_free );
442
+	timer_init ( &aoe->timer, aoe_timer_expired );
442
 	aoe->netdev = netdev_get ( netdev );
443
 	aoe->netdev = netdev_get ( netdev );
443
 	memcpy ( aoe->target, netdev->ll_broadcast, sizeof ( aoe->target ) );
444
 	memcpy ( aoe->target, netdev->ll_broadcast, sizeof ( aoe->target ) );
444
 	aoe->tag = AOE_TAG_MAGIC;
445
 	aoe->tag = AOE_TAG_MAGIC;
445
-	aoe->timer.expired = aoe_timer_expired;
446
 
446
 
447
 	/* Parse root path */
447
 	/* Parse root path */
448
 	if ( ( rc = aoe_parse_root_path ( aoe, root_path ) ) != 0 )
448
 	if ( ( rc = aoe_parse_root_path ( aoe, root_path ) ) != 0 )

+ 1
- 1
src/net/infiniband/ib_mi.c Wyświetl plik

281
 	madx = zalloc ( sizeof ( *madx ) );
281
 	madx = zalloc ( sizeof ( *madx ) );
282
 	if ( ! madx )
282
 	if ( ! madx )
283
 		return NULL;
283
 		return NULL;
284
+	timer_init ( &madx->timer, ib_mi_timer_expired );
284
 	madx->mi = mi;
285
 	madx->mi = mi;
285
-	madx->timer.expired = ib_mi_timer_expired;
286
 	madx->op = op;
286
 	madx->op = op;
287
 
287
 
288
 	/* Determine address vector */
288
 	/* Determine address vector */

+ 1
- 1
src/net/ipv4.c Wyświetl plik

224
 		free_iob ( iobuf );
224
 		free_iob ( iobuf );
225
 
225
 
226
 		/* Set the reassembly timer */
226
 		/* Set the reassembly timer */
227
+		timer_init ( &fragbuf->frag_timer, ipv4_frag_expired );
227
 		fragbuf->frag_timer.timeout = IP_FRAG_TIMEOUT;
228
 		fragbuf->frag_timer.timeout = IP_FRAG_TIMEOUT;
228
-		fragbuf->frag_timer.expired = ipv4_frag_expired;
229
 		start_timer ( &fragbuf->frag_timer );
229
 		start_timer ( &fragbuf->frag_timer );
230
 
230
 
231
 		/* Add the fragment buffer to the list of fragment buffers */
231
 		/* Add the fragment buffer to the list of fragment buffers */

+ 1
- 1
src/net/tcp.c Wyświetl plik

226
 	DBGC ( tcp, "TCP %p allocated\n", tcp );
226
 	DBGC ( tcp, "TCP %p allocated\n", tcp );
227
 	ref_init ( &tcp->refcnt, NULL );
227
 	ref_init ( &tcp->refcnt, NULL );
228
 	xfer_init ( &tcp->xfer, &tcp_xfer_operations, &tcp->refcnt );
228
 	xfer_init ( &tcp->xfer, &tcp_xfer_operations, &tcp->refcnt );
229
+	timer_init ( &tcp->timer, tcp_expired );
229
 	tcp->prev_tcp_state = TCP_CLOSED;
230
 	tcp->prev_tcp_state = TCP_CLOSED;
230
 	tcp->tcp_state = TCP_STATE_SENT ( TCP_SYN );
231
 	tcp->tcp_state = TCP_STATE_SENT ( TCP_SYN );
231
 	tcp_dump_state ( tcp );
232
 	tcp_dump_state ( tcp );
232
 	tcp->snd_seq = random();
233
 	tcp->snd_seq = random();
233
 	INIT_LIST_HEAD ( &tcp->queue );
234
 	INIT_LIST_HEAD ( &tcp->queue );
234
-	tcp->timer.expired = tcp_expired;
235
 	memcpy ( &tcp->peer, st_peer, sizeof ( tcp->peer ) );
235
 	memcpy ( &tcp->peer, st_peer, sizeof ( tcp->peer ) );
236
 
236
 
237
 	/* Bind to local port */
237
 	/* Bind to local port */

+ 2
- 2
src/net/udp/dhcp.c Wyświetl plik

1442
 	ref_init ( &dhcp->refcnt, dhcp_free );
1442
 	ref_init ( &dhcp->refcnt, dhcp_free );
1443
 	job_init ( &dhcp->job, &dhcp_job_operations, &dhcp->refcnt );
1443
 	job_init ( &dhcp->job, &dhcp_job_operations, &dhcp->refcnt );
1444
 	xfer_init ( &dhcp->xfer, &dhcp_xfer_operations, &dhcp->refcnt );
1444
 	xfer_init ( &dhcp->xfer, &dhcp_xfer_operations, &dhcp->refcnt );
1445
+	timer_init ( &dhcp->timer, dhcp_timer_expired );
1445
 	dhcp->netdev = netdev_get ( netdev );
1446
 	dhcp->netdev = netdev_get ( netdev );
1446
 	dhcp->local.sin_family = AF_INET;
1447
 	dhcp->local.sin_family = AF_INET;
1447
 	dhcp->local.sin_port = htons ( BOOTPC_PORT );
1448
 	dhcp->local.sin_port = htons ( BOOTPC_PORT );
1448
-	dhcp->timer.expired = dhcp_timer_expired;
1449
 
1449
 
1450
 	/* Instantiate child objects and attach to our interfaces */
1450
 	/* Instantiate child objects and attach to our interfaces */
1451
 	if ( ( rc = xfer_open_socket ( &dhcp->xfer, SOCK_DGRAM, &dhcp_peer,
1451
 	if ( ( rc = xfer_open_socket ( &dhcp->xfer, SOCK_DGRAM, &dhcp_peer,
1545
 	ref_init ( &dhcp->refcnt, dhcp_free );
1545
 	ref_init ( &dhcp->refcnt, dhcp_free );
1546
 	job_init ( &dhcp->job, &dhcp_job_operations, &dhcp->refcnt );
1546
 	job_init ( &dhcp->job, &dhcp_job_operations, &dhcp->refcnt );
1547
 	xfer_init ( &dhcp->xfer, &dhcp_xfer_operations, &dhcp->refcnt );
1547
 	xfer_init ( &dhcp->xfer, &dhcp_xfer_operations, &dhcp->refcnt );
1548
+	timer_init ( &dhcp->timer, dhcp_timer_expired );
1548
 	dhcp->netdev = netdev_get ( netdev );
1549
 	dhcp->netdev = netdev_get ( netdev );
1549
 	dhcp->local.sin_family = AF_INET;
1550
 	dhcp->local.sin_family = AF_INET;
1550
 	fetch_ipv4_setting ( netdev_settings ( netdev ), &ip_setting,
1551
 	fetch_ipv4_setting ( netdev_settings ( netdev ), &ip_setting,
1551
 			     &dhcp->local.sin_addr );
1552
 			     &dhcp->local.sin_addr );
1552
 	dhcp->local.sin_port = htons ( BOOTPC_PORT );
1553
 	dhcp->local.sin_port = htons ( BOOTPC_PORT );
1553
 	dhcp->pxe_type = cpu_to_le16 ( pxe_type );
1554
 	dhcp->pxe_type = cpu_to_le16 ( pxe_type );
1554
-	dhcp->timer.expired = dhcp_timer_expired;
1555
 
1555
 
1556
 	/* Construct PXE boot server IP address lists */
1556
 	/* Construct PXE boot server IP address lists */
1557
 	pxe_discovery_control =
1557
 	pxe_discovery_control =

+ 1
- 1
src/net/udp/dns.c Wyświetl plik

506
 	ref_init ( &dns->refcnt, NULL );
506
 	ref_init ( &dns->refcnt, NULL );
507
 	resolv_init ( &dns->resolv, &null_resolv_ops, &dns->refcnt );
507
 	resolv_init ( &dns->resolv, &null_resolv_ops, &dns->refcnt );
508
 	xfer_init ( &dns->socket, &dns_socket_operations, &dns->refcnt );
508
 	xfer_init ( &dns->socket, &dns_socket_operations, &dns->refcnt );
509
-	dns->timer.expired = dns_timer_expired;
509
+	timer_init ( &dns->timer, dns_timer_expired );
510
 	memcpy ( &dns->sa, sa, sizeof ( dns->sa ) );
510
 	memcpy ( &dns->sa, sa, sizeof ( dns->sa ) );
511
 
511
 
512
 	/* Create query */
512
 	/* Create query */

+ 2
- 2
src/net/udp/slam.c Wyświetl plik

753
 	xfer_init ( &slam->socket, &slam_socket_operations, &slam->refcnt );
753
 	xfer_init ( &slam->socket, &slam_socket_operations, &slam->refcnt );
754
 	xfer_init ( &slam->mc_socket, &slam_mc_socket_operations,
754
 	xfer_init ( &slam->mc_socket, &slam_mc_socket_operations,
755
 		    &slam->refcnt );
755
 		    &slam->refcnt );
756
-	slam->master_timer.expired = slam_master_timer_expired;
757
-	slam->slave_timer.expired = slam_slave_timer_expired;
756
+	timer_init ( &slam->master_timer, slam_master_timer_expired );
757
+	timer_init ( &slam->slave_timer, slam_slave_timer_expired );
758
 	/* Fake an invalid cached header of { 0x00, ... } */
758
 	/* Fake an invalid cached header of { 0x00, ... } */
759
 	slam->header_len = 1;
759
 	slam->header_len = 1;
760
 	/* Fake parameters for initial NACK */
760
 	/* Fake parameters for initial NACK */

+ 2
- 2
src/net/udp/tftp.c Wyświetl plik

1136
 		return -ENOMEM;
1136
 		return -ENOMEM;
1137
 	ref_init ( &tftp->refcnt, tftp_free );
1137
 	ref_init ( &tftp->refcnt, tftp_free );
1138
 	xfer_init ( &tftp->xfer, &tftp_xfer_operations, &tftp->refcnt );
1138
 	xfer_init ( &tftp->xfer, &tftp_xfer_operations, &tftp->refcnt );
1139
-	tftp->uri = uri_get ( uri );
1140
 	xfer_init ( &tftp->socket, &tftp_socket_operations, &tftp->refcnt );
1139
 	xfer_init ( &tftp->socket, &tftp_socket_operations, &tftp->refcnt );
1141
 	xfer_init ( &tftp->mc_socket, &tftp_mc_socket_operations,
1140
 	xfer_init ( &tftp->mc_socket, &tftp_mc_socket_operations,
1142
 		    &tftp->refcnt );
1141
 		    &tftp->refcnt );
1142
+	timer_init ( &tftp->timer, tftp_timer_expired );
1143
+	tftp->uri = uri_get ( uri );
1143
 	tftp->blksize = TFTP_DEFAULT_BLKSIZE;
1144
 	tftp->blksize = TFTP_DEFAULT_BLKSIZE;
1144
 	tftp->flags = flags;
1145
 	tftp->flags = flags;
1145
-	tftp->timer.expired = tftp_timer_expired;
1146
 
1146
 
1147
 	/* Open socket */
1147
 	/* Open socket */
1148
 	tftp->port = uri_port ( tftp->uri, default_port );
1148
 	tftp->port = uri_port ( tftp->uri, default_port );

Ładowanie…
Anuluj
Zapisz