LCOV - code coverage report
Current view: top level - source4/torture/nbt - winsbench.c (source / functions) Hit Total Coverage
Test: coverage report for master 2b515b7d Lines: 4 160 2.5 %
Date: 2024-02-28 12:06:22 Functions: 1 10 10.0 %

          Line data    Source code
       1             : /* 
       2             :    Unix SMB/CIFS implementation.
       3             : 
       4             :    WINS benchmark test
       5             : 
       6             :    Copyright (C) Andrew Tridgell 2005
       7             :    
       8             :    This program is free software; you can redistribute it and/or modify
       9             :    it under the terms of the GNU General Public License as published by
      10             :    the Free Software Foundation; either version 3 of the License, or
      11             :    (at your option) any later version.
      12             :    
      13             :    This program is distributed in the hope that it will be useful,
      14             :    but WITHOUT ANY WARRANTY; without even the implied warranty of
      15             :    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      16             :    GNU General Public License for more details.
      17             :    
      18             :    You should have received a copy of the GNU General Public License
      19             :    along with this program.  If not, see <http://www.gnu.org/licenses/>.
      20             : */
      21             : 
      22             : #include "includes.h"
      23             : #include "lib/events/events.h"
      24             : #include "lib/socket/socket.h"
      25             : #include "libcli/resolve/resolve.h"
      26             : #include "system/network.h"
      27             : #include "lib/socket/netif.h"
      28             : #include "torture/torture.h"
      29             : #include "torture/nbt/proto.h"
      30             : #include "param/param.h"
      31             : 
      32             : struct wins_state {
      33             :         int num_names;
      34             :         bool *registered;
      35             :         int pass_count;
      36             :         int fail_count;
      37             :         const char *wins_server;
      38             :         uint16_t wins_port;
      39             :         const char *my_ip;
      40             :         uint32_t ttl;
      41             : };
      42             : 
      43             : struct idx_state {
      44             :         int idx;
      45             :         struct wins_state *state;
      46             : };
      47             : 
      48           0 : static struct nbt_name generate_name(TALLOC_CTX *tctx, int idx)
      49             : {
      50           0 :         struct nbt_name name;
      51           0 :         name.name       = talloc_asprintf(tctx, "WINSBench%6u", idx);
      52           0 :         name.type       = 0x4;
      53           0 :         name.scope      = NULL;
      54           0 :         return name;
      55             : }
      56             : 
      57           0 : static void register_handler(struct nbt_name_request *req)
      58             : {
      59           0 :         struct idx_state *istate = talloc_get_type(req->async.private_data, struct idx_state);
      60           0 :         struct wins_state *state = istate->state;
      61           0 :         struct nbt_name_register io;
      62           0 :         NTSTATUS status;
      63             : 
      64           0 :         status = nbt_name_register_recv(req, istate, &io);
      65           0 :         if (!NT_STATUS_IS_OK(status) || io.out.rcode != NBT_RCODE_OK) {
      66           0 :                 state->fail_count++;
      67             :         } else {
      68           0 :                 state->pass_count++;
      69           0 :                 state->registered[istate->idx] = true;
      70             :         }
      71           0 :         talloc_free(istate);    
      72           0 : }
      73             : 
      74             : /*
      75             :   generate a registration
      76             : */
      77           0 : static void generate_register(struct nbt_name_socket *nbtsock, struct wins_state *state, int idx)
      78             : {
      79           0 :         struct nbt_name_register io;
      80           0 :         TALLOC_CTX *tmp_ctx = talloc_new(state);
      81           0 :         struct nbt_name_request *req;
      82           0 :         struct idx_state *istate;
      83             : 
      84           0 :         istate = talloc(nbtsock, struct idx_state);
      85           0 :         istate->idx = idx;
      86           0 :         istate->state = state;
      87             : 
      88           0 :         io.in.name            = generate_name(tmp_ctx, idx);
      89           0 :         io.in.dest_addr       = state->wins_server;
      90           0 :         io.in.dest_port       = state->wins_port;
      91           0 :         io.in.address         = state->my_ip;
      92           0 :         io.in.nb_flags        = NBT_NODE_H;
      93           0 :         io.in.register_demand = false;
      94           0 :         io.in.broadcast       = false;
      95           0 :         io.in.multi_homed     = false;
      96           0 :         io.in.ttl             = state->ttl;
      97           0 :         io.in.timeout         = 2;
      98           0 :         io.in.retries         = 1;
      99             : 
     100           0 :         req = nbt_name_register_send(nbtsock, &io);
     101             : 
     102           0 :         req->async.fn = register_handler;
     103           0 :         req->async.private_data = istate;
     104             : 
     105           0 :         talloc_free(tmp_ctx);
     106           0 : }
     107             : 
     108             : 
     109           0 : static void release_handler(struct nbt_name_request *req)
     110             : {
     111           0 :         struct idx_state *istate = talloc_get_type(req->async.private_data, struct idx_state);
     112           0 :         struct wins_state *state = istate->state;
     113           0 :         struct nbt_name_release io;
     114           0 :         NTSTATUS status;
     115             : 
     116           0 :         status = nbt_name_release_recv(req, istate, &io);
     117           0 :         if (state->registered[istate->idx] && 
     118           0 :             (!NT_STATUS_IS_OK(status) || io.out.rcode != NBT_RCODE_OK)) {
     119           0 :                 state->fail_count++;
     120             :         } else {
     121           0 :                 state->pass_count++;
     122           0 :                 state->registered[istate->idx] = false;
     123             :         }
     124           0 :         talloc_free(istate);    
     125           0 : }
     126             : 
     127             : /*
     128             :   generate a name release
     129             : */
     130           0 : static void generate_release(struct nbt_name_socket *nbtsock, struct wins_state *state, int idx)
     131             : {
     132           0 :         struct nbt_name_release io;
     133           0 :         TALLOC_CTX *tmp_ctx = talloc_new(state);
     134           0 :         struct nbt_name_request *req;
     135           0 :         struct idx_state *istate;
     136             : 
     137           0 :         istate = talloc(nbtsock, struct idx_state);
     138           0 :         istate->idx = idx;
     139           0 :         istate->state = state;
     140             : 
     141           0 :         io.in.name            = generate_name(tmp_ctx, idx);
     142           0 :         io.in.dest_port       = state->wins_port;
     143           0 :         io.in.dest_addr       = state->wins_server;
     144           0 :         io.in.address         = state->my_ip;
     145           0 :         io.in.nb_flags        = NBT_NODE_H;
     146           0 :         io.in.broadcast       = false;
     147           0 :         io.in.timeout         = 2;
     148           0 :         io.in.retries         = 1;
     149             : 
     150           0 :         req = nbt_name_release_send(nbtsock, &io);
     151             : 
     152           0 :         req->async.fn = release_handler;
     153           0 :         req->async.private_data = istate;
     154             : 
     155           0 :         talloc_free(tmp_ctx);
     156           0 : }
     157             : 
     158             : 
     159           0 : static void query_handler(struct nbt_name_request *req)
     160             : {
     161           0 :         struct idx_state *istate = talloc_get_type(req->async.private_data, struct idx_state);
     162           0 :         struct wins_state *state = istate->state;
     163           0 :         struct nbt_name_query io;
     164           0 :         NTSTATUS status;
     165             : 
     166           0 :         status = nbt_name_query_recv(req, istate, &io);
     167           0 :         if (!NT_STATUS_IS_OK(status) && state->registered[istate->idx]) {
     168           0 :                 state->fail_count++;
     169             :         } else {
     170           0 :                 state->pass_count++;
     171             :         }
     172           0 :         talloc_free(istate);    
     173           0 : }
     174             : 
     175             : /*
     176             :   generate a name query
     177             : */
     178           0 : static void generate_query(struct nbt_name_socket *nbtsock, struct wins_state *state, int idx)
     179             : {
     180           0 :         struct nbt_name_query io;
     181           0 :         TALLOC_CTX *tmp_ctx = talloc_new(state);
     182           0 :         struct nbt_name_request *req;
     183           0 :         struct idx_state *istate;
     184             : 
     185           0 :         istate = talloc(nbtsock, struct idx_state);
     186           0 :         istate->idx = idx;
     187           0 :         istate->state = state;
     188             : 
     189           0 :         io.in.name            = generate_name(tmp_ctx, idx);
     190           0 :         io.in.dest_addr       = state->wins_server;
     191           0 :         io.in.dest_port       = state->wins_port;
     192           0 :         io.in.broadcast       = false;
     193           0 :         io.in.wins_lookup     = true;
     194           0 :         io.in.timeout         = 2;
     195           0 :         io.in.retries         = 1;
     196             : 
     197           0 :         req = nbt_name_query_send(nbtsock, &io);
     198             : 
     199           0 :         req->async.fn = query_handler;
     200           0 :         req->async.private_data = istate;
     201             : 
     202           0 :         talloc_free(tmp_ctx);
     203           0 : }
     204             : 
     205             : /*
     206             :   generate one WINS request
     207             : */
     208           0 : static void generate_request(struct nbt_name_socket *nbtsock, struct wins_state *state, int idx)
     209             : {
     210           0 :         if (random() % 5 == 0) {
     211           0 :                 generate_register(nbtsock, state, idx);
     212           0 :                 return;
     213             :         }
     214             : 
     215           0 :         if (random() % 20 == 0) {
     216           0 :                 generate_release(nbtsock, state, idx);
     217           0 :                 return;
     218             :         }
     219             : 
     220           0 :         generate_query(nbtsock, state, idx);
     221             : }
     222             : 
     223             : /*
     224             :   benchmark simple name queries
     225             : */
     226           0 : static bool bench_wins(struct torture_context *tctx)
     227             : {
     228           0 :         struct nbt_name_socket *nbtsock = nbt_name_socket_init(tctx, tctx->ev);
     229           0 :         int num_sent=0;
     230           0 :         struct timeval tv = timeval_current();
     231           0 :         bool ret = true;
     232           0 :         int timelimit = torture_setting_int(tctx, "timelimit", 5);
     233           0 :         struct wins_state *state;
     234           0 :         extern int torture_entries;
     235           0 :         struct socket_address *my_ip;
     236           0 :         struct nbt_name name;
     237           0 :         const char *address;
     238           0 :         struct interface *ifaces;
     239             : 
     240           0 :         if (!torture_nbt_get_name(tctx, &name, &address))
     241           0 :                 return false;
     242             : 
     243           0 :         state = talloc_zero(nbtsock, struct wins_state);
     244             : 
     245           0 :         state->num_names = torture_entries;
     246           0 :         state->registered = talloc_zero_array(state, bool, state->num_names);
     247           0 :         state->wins_server = address;
     248           0 :         state->wins_port = lpcfg_nbt_port(tctx->lp_ctx);
     249           0 :         load_interface_list(tctx, tctx->lp_ctx, &ifaces);
     250           0 :         state->my_ip = talloc_strdup(tctx, iface_list_best_ip(ifaces, address));
     251           0 :         state->ttl = timelimit;
     252             : 
     253           0 :         my_ip = socket_address_from_strings(nbtsock, nbtsock->sock->backend_name, 
     254             :                                             state->my_ip, 0);
     255             : 
     256           0 :         socket_listen(nbtsock->sock, my_ip, 0, 0);
     257             : 
     258           0 :         torture_comment(tctx, "Running for %d seconds\n", timelimit);
     259           0 :         while (timeval_elapsed(&tv) < timelimit) {
     260           0 :                 while (num_sent - (state->pass_count+state->fail_count) < 10) {
     261           0 :                         generate_request(nbtsock, state, num_sent % state->num_names);
     262           0 :                         num_sent++;
     263           0 :                         if (num_sent % 50 == 0) {
     264           0 :                                 if (torture_setting_bool(tctx, "progress", true)) {
     265           0 :                                         torture_comment(tctx, "%.1f queries per second (%d failures)  \r", 
     266           0 :                                                state->pass_count / timeval_elapsed(&tv),
     267             :                                                state->fail_count);
     268           0 :                                         fflush(stdout);
     269             :                                 }
     270             :                         }
     271             :                 }
     272             : 
     273           0 :                 tevent_loop_once(nbtsock->event_ctx);
     274             :         }
     275             : 
     276           0 :         while (num_sent != (state->pass_count + state->fail_count)) {
     277           0 :                 tevent_loop_once(nbtsock->event_ctx);
     278             :         }
     279             : 
     280           0 :         torture_comment(tctx, "%.1f queries per second (%d failures)  \n", 
     281           0 :                state->pass_count / timeval_elapsed(&tv),
     282             :                state->fail_count);
     283             : 
     284           0 :         talloc_free(nbtsock);
     285           0 :         return ret;
     286             : }
     287             : 
     288             : 
     289             : /*
     290             :   benchmark how fast a WINS server can respond to a mixture of
     291             :   registration/refresh/release and name query requests
     292             : */
     293        2379 : struct torture_suite *torture_bench_wins(TALLOC_CTX *mem_ctx)
     294             : {
     295        2379 :         struct torture_suite *suite = torture_suite_create(mem_ctx, "bench-wins");
     296             : 
     297        2379 :         torture_suite_add_simple_test(suite, "wins", bench_wins);
     298             : 
     299        2379 :         return suite;
     300             : }

Generated by: LCOV version 1.14