svc.c File Reference

#include <wintirpc.h>
#include <reentrant.h>
#include <sys/types.h>
#include <assert.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <rpc/rpc.h>
#include "rpc_com.h"

Include dependency graph for svc.c:

Go to the source code of this file.

Classes
struct	svc_callout

Macros
#define	RQCRED_SIZE   400 /* this size is excessive */
#define	SVC_VERSQUIET   0x0001 /* keep quiet about vers mismatch */
#define	version_keepquiet(xp)   ((u_long)(xp)->xp_p3 & SVC_VERSQUIET)
#define	max(a, b)   (a > b ? a : b)

Functions
static struct svc_callout *	svc_find (rpcprog_t, rpcvers_t, struct svc_callout **, char *)
static void	__xprt_do_unregister (SVCXPRT *xprt, bool_t dolock)
void	xprt_register (SVCXPRT *xprt)
void	xprt_unregister (SVCXPRT *xprt)
void	__xprt_unregister_unlocked (SVCXPRT *xprt)
bool_t	svc_reg (SVCXPRT *xprt, const rpcprog_t prog, const rpcvers_t vers, void *dispatch, const struct netconfig *nconf)
void	svc_unreg (rpcprog_t prog, const rpcvers_t vers) const
bool_t	svc_sendreply (SVCXPRT *xprt, xdrproc_t xdr_results, void *xdr_location)
void	svcerr_noproc (SVCXPRT *xprt)
void	svcerr_decode (SVCXPRT *xprt)
void	svcerr_systemerr (SVCXPRT *xprt)
void	svcerr_auth (SVCXPRT *xprt, enum auth_stat why)
void	svcerr_weakauth (SVCXPRT *xprt)
void	svcerr_noprog (SVCXPRT *xprt)
void	svcerr_progvers (SVCXPRT *xprt, rpcvers_t low_vers, rpcvers_t high_vers)
void	svc_getreq (int rdfds)
void	svc_getreqset (fd_set *readfds)
void	svc_getreq_common (SOCKET fd)
void	svc_getreq_poll (struct pollfd *pfdp, int pollretval)
bool_t	rpc_control (int what, void *arg)

Variables
static struct svc_callout *	svc_head
rwlock_t	svc_lock
rwlock_t	svc_fd_lock

Macro Definition Documentation

#define max	(		a,
			b
	)		(a > b ? a : b)

Definition at line 63 of file svc.c.

Referenced by __ext4_ext_check(), basic_filebuf< _CharT, _Traits >::_M_allocate_buffers(), _M_append_sum(), _M_append_sum_pos(), vector< CTestInfo >::_M_compute_next_size(), __BVECTOR_QUALIFIED::_M_fill_insert(), _Deque_base< _Tp, _Alloc >::_M_initialize_map(), deque< _Tp, >::_M_reallocate_map(), basic_filebuf< _CharT, _Traits >::_M_setup_codecvt(), _mesa_get_format_max_bits(), _mesa_max_buffer_index(), _mesa_pack_rgba_span_float(), _mesa_scale_and_bias_depth_uint(), _readex_expect_async(), _S_apply_to_pieces(), _Stl_expand_array(), _Strftime(), _tnl_draw_prims(), _tpopen(), AbbrevStr(), ACTION_RecurseSearchDirectory(), action_RegDeleteTreeA(), add_chunk(), add_dir_child(), add_func_desc(), add_index(), add_line_to_buffer(), add_name(), add_option(), add_var_desc(), KeyTranslator::AddGlobalDef(), AddRun(), adns__findlabel_start(), adns__update_expires(), af_glyph_hints_align_strong_points(), af_latin_hints_link_segments(), alloc_user_entry(), append_data(), arc2polybezier(), arial_enum_proc(), arial_enum_procw(), Array_indexOf(), ata_check_unit(), ata_send_ioctl(), AtaSetTransferMode(), AVIFILE_ReadBlock(), balance_data_chunk(), bdf_cmap_char_index(), bdf_cmap_char_next(), bezier_deviation_squared(), bin_search(), bitmap_info_size(), BlpDeviceCompare(), Brush(), calc_thumb_dimensions(), Mapdesc::calcPartialVelocity(), calculate_dds_file_size(), calculate_dds_surface_size(), CalculateBitmapSize(), CBDropDown(), CC_PaintLumBar(), CC_RGBtoHSL(), CdRomDeviceControlDispatch(), CdRomInitDevice(), CdRomPickDvdRegion(), NumPutGetTest::check_get_float(), check_height_font_enumproc(), check_ilhead_data(), check_index_bounds(), check_keywords(), check_output_buffer_space(), check_with_margin(), CheckListWndProc(), ChildWndProc(), choose_font(), ClassInterpretSenseInfo(), ClassSendDeviceIoControlSynchronous(), clean_space_cache_chunk(), ClipOrCenterRectToMonitor(), CmpInitializeHive(), CmpOpenHiveFiles(), co_IntGetScrollBarInfo(), co_IntSetScrollInfo(), co_WinPosGetMinMaxInfo(), codeview_add_type(), color_key_arbfp(), ColorRGBToHLS(), ColorsProc(), CombineRgn(), COMBOEX_ReSize(), CompBattGetBatteryInformation(), CompositeMonikerMarshalImpl_UnmarshalInterface(), compress2(), ComputeCompatibleFormat(), CUiWindow< CStatusBar >::ComputeContentBounds(), CUiSplitPanel::ComputeContentBounds(), CUiMeasure::ComputeMeasure(), CUiBox::ComputeMinimalSize(), CUiSplitPanel::ComputeMinimalSize(), ConCfgReadUserSettings(), ConDrvReadConsole(), ConDrvSetConsoleCursorInfo(), ConioGetIntersection(), ConioGetUnion(), ConioWriteConsole(), CONSOLE_SCREEN_BUFFER_Initialize(), ConSrvApplyUserSettings(), ConSrvReadUserSettings(), ConSrvTermReadStream(), cp2range(), cpu_blitter_clear(), create_child_window(), create_taskdialog_template(), CreateProcessInternalW(), CRYPT_AsnDecodeMaximum(), CRYPT_AsnDecodeSequence(), CRYPT_LMhash(), ctrl_container_resize(), ctrl_resize(), CURSORICON_GetCursorDataFromBMI(), customctrl_resize(), d3d8_device_prepare_index_buffer(), d3d8_device_prepare_vertex_buffer(), d3d9_device_prepare_index_buffer(), d3d9_device_prepare_vertex_buffer(), d3d_device_prepare_index_buffer(), d3d_device_prepare_vertex_buffer(), d3d_execute_buffer_SetExecuteData(), d3drm_array_reserve(), d3dx9_base_effect_get_int(), d3dx9_base_effect_set_vector(), D3DXCheckTextureRequirements(), D3DXCheckVolumeTextureRequirements(), D3DXSHRotateZ(), DATETIME_IncreaseField(), ddraw_find_decl(), ddraw_surface_create(), DECLARE_INTERFACE_(), DefWndDoSizeMove(), DefWndHandleWindowPosChanging(), DefWndStartSizeMove(), KeyTranslator::DeleteAllDefs(), DequeueFreeTransferPacket(), device_clear_render_targets(), device_get_fvf_declaration(), devinst_RegDeleteTreeW(), DIALOG_NEW_DlgProc(), DIB_BitmapInfoSize(), DispatchEx_GetDispID(), DispatchEx_InvokeEx(), DispCallFunc(), TMapLoader::Display(), Display_OnVScroll(), do_write_file(), dotest_spi_iconhorizontalspacing(), dotest_spi_iconverticalspacing(), DPA_CreateEx(), DPA_DeletePtr(), DPA_Grow(), draw_chunk_bar_V(), DrawTextFromClipboard(), CImgAreaWindow::drawZoomFrame(), DrvLineTo(), DSA_Create(), EDIT_AdjustFormatRect(), EDIT_BuildLineDefs_ML(), EDIT_ConfinePoint(), EDIT_EM_LineScroll_internal(), EDIT_EM_Scroll(), EDIT_GetLineRect(), EDIT_PaintLine(), EDIT_WM_Copy(), EDIT_WM_Paint(), EMFDRV_ArcChordPie(), EMFDRV_ExtTextOut(), EMFDRV_LineTo(), EMFDRV_UpdateBBox(), EngLineTo(), enum_font_data_proc(), enum_fullname_data_proc(), enum_ms_shell_dlg2_proc(), enum_ms_shell_dlg_proc(), Erase(), expr_common_type(), ext4_ext_max_entries(), Fast486FpuAdd(), fdi_Zipinflate_codes(), FILEDLG95_LOOKIN_Init(), fill_ip4routetable(), FillTMEx(), FilterInstanceSetup(), find_arb_pshader(), find_arb_vshader(), find_builtin_prop(), find_entry_by_id(), find_entry_by_name(), find_glsl_pshader(), find_glsl_vshader(), find_html_symbol(), find_new_dup_stripes(), find_pe_resource(), FindFonts(), FindMUIEntriesOfPage(), FindMUIErrorEntries(), FindMUIStringEntries(), NumPutGetTest::fix_float_long(), FloatDown(), flush_partial_stripe(), format_insert(), format_string(), FormatMessageA(), FormatMessageW(), FreeLdrEnumerateBootEntries(), FrLdrHeapAllocateEx(), FsdSetFsLabelInformation(), GdipCreateLineBrushFromRect(), GdipGetPathWorldBounds(), get_builtin_func(), get_builtin_id(), get_constants_desc(), get_dir_last_child(), get_escaped_string(), get_geoinfo_dataptr(), get_nextvalue(), get_olemisc_value(), get_points_bounds(), get_pointsize_minmax(), get_selection_rect(), get_superblock_size(), get_table_size(), get_tag_desc(), get_target_info(), get_vertical_line_count(), CMenuBand::GetBandInfo(), GetClipboardDataDimensions(), GetDeviceData(), CSysPagerWnd::GetSize(), GraphCtrl_InvalidateCtrl(), GreGradientFill(), grow_output_buffer(), GuiConsoleHandleScroll(), GuiConsoleUpdateSelection(), guiProgress(), gxv_kern_subtable_fmt3_validate(), gz_comp(), gz_load(), handle_readdir(), hash_table_destroy(), HEADER_ChangeItemOrder(), HEXEDIT_Update(), HistoryRecallHistory(), HLPFILE_Uncompress_Phrases40(), IAVIStream_fnWrite(), ICSeqCompressFrameStart(), IdeSendCommand(), IFileDialog2_fnSetFileTypeIndex(), III_dequantize_sample(), IKsPin_PrepareStreamHeader(), image_list_init(), ImageList_Create(), IMAGELIST_InternalExpandBitmaps(), ImageList_Merge(), IncreaseMftSize(), inflate_table(), TConfig::init_aliases(), init_argb_conversion_info(), InitD3D9ResourceManager(), CACLCustomMRU::Initialize(), InitializeContextEx(), InitializePool(), InitMetrics(), __BVECTOR_QUALIFIED::insert(), InstallEngineTiming_GetInstallProgress(), IntCalculateThumb(), IntEngGradientFillRect(), IntEngLineTo(), IntEngPolyline(), IntersectRect(), IntGdiLineTo(), IntGdiPolygon(), IntHideMousePointer(), IntMapWindowPoints(), IntRectangle(), IntRequestFontSize(), IntResolveDesktop(), IntRoundRect(), IntScrollDrawSizeGrip(), IntScrollGetScrollBarRect(), IntShowMousePointer(), IoGetDeviceInterfaces(), IPropertyStorage_fnWriteMultiple(), is_comctl32_class(), is_cp_event(), iterator_frameditems_absolute(), KeSetTimeIncrement(), layout_merge_segments(), layout_recall_merge(), LayoutProc(), LineInputRecallHistory(), CUSBQueue::LinkInterruptQueueHead(), LISTBOX_FindFileStrPos(), LISTBOX_FindStringPos(), LISTBOX_GetMaxTopIndex(), LISTBOX_MoveCaret(), LISTBOX_SetTopItem(), LISTBOX_WindowProc(), ListBoxWndProc_common(), LISTVIEW_AddGroupSelection(), LISTVIEW_CalculateItemHeight(), LISTVIEW_CalculateItemWidth(), LISTVIEW_GetAreaRect(), LISTVIEW_GetCountPerColumn(), LISTVIEW_GetCountPerRow(), LISTVIEW_GetItemMetrics(), LISTVIEW_MarqueeHighlight(), LISTVIEW_Notify(), LISTVIEW_RedrawItems(), LISTVIEW_SetColumnWidth(), LISTVIEW_SetGroupSelection(), LISTVIEW_SetItemCount(), LISTVIEW_UpdateHScroll(), LISTVIEW_UpdateSize(), LISTVIEW_UpdateVScroll(), load_cube_texture_from_dds(), load_texture_from_dds(), load_volume_texture_from_dds(), LoadIniFile(), log_file(), TMapLoader::LookForPart(), KeyTranslator::LookOnGlobal(), lookup_assembly(), lookup_style_tbl(), MACRO_CreateButton(), MainWndProc(), MapWindowPoints(), Math_max(), MaxTest::max1(), MaxTest::max2(), ME_BeginRow(), ME_DrawParaDecoration(), ME_DrawParagraph(), ME_DrawTableBorders(), ME_HandleMessage(), ME_InsertRowStart(), ME_PostSetScrollRangeVisibility(), ME_ProtectPartialTableDeletion(), ME_RunOfsFromCharOfs(), ME_ScrollAbs(), ME_StreamOutRTF(), ME_WmCreate(), ME_WrapMarkedParagraphs(), ME_WrapTextParagraph(), measure_ranges_callback(), memcpy_max(), memp_init(), MENU_CalcItemSize(), MENU_DrawMenuItem(), MENU_MenuBarCalcSize(), MENU_PopupMenuCalcSize(), MenuInit(), METAFILE_AllocateRecord(), METAFILE_GraphicsDeleted(), MFDRV_WriteRecord(), MiEnablePagingOfDriver(), MiFindInitializationCode(), MiInitializeMemoryEvents(), MiLocateKernelSections(), AlgTest::min_max(), MiTrimMemoryConsumer(), MiWriteProtectSystemImage(), mixerGetControlDetailsA(), MmAdjustWorkingSetSize(), MmArmInitSystem(), mmioAdvance(), MmMapViewOfSection(), SelectionModel::ModifyDestRect(), MONTHCAL_SetMaxSelCount(), MONTHCAL_UpdateSize(), move_across_subvols(), mru_RegDeleteTreeA(), MSI_IterateRecords(), MsiEnumComponentCostsW(), MUIDefaultKeyboardLayout(), MUIGetGeoID(), MUIGetLayoutsList(), MUIGetOEMCodePage(), myRegDeleteTreeA(), myRegDeleteTreeW(), NdrFullPointerQueryRefId(), near_match(), nearest_texel_location(), NEtoSW(), notify_measureitem(), NtGdiEllipse(), NtGdiGetBoundsRect(), NtGdiPolyPolyDraw(), NumPutGetTest::num_put_float(), NWtoSE(), ObpAllocateObject(), on_wm_initdialog(), CAttributesDialog::OnEdit1(), CAttributesDialog::OnEdit2(), OnLink(), CMainWindow::OnLink(), CUiSplitPanel::OnParentSize(), OnScroll(), CGridView::OnVScroll(), OnVScroll(), OptionsProc(), strstreambuf::overflow(), package_RegDeleteTreeW(), PAGER_PositionChildWnd(), paraformat_proc(), parse_ctab_constant_type(), parse_encoding_name(), parse_vertex_colors(), ParseMinMaxQuantifier(), patch_offset_get_filepatches(), patch_offset_get_files(), patch_offset_modify_db(), PATH_CreatePath(), pattern_fork(), pbuf_memfind(), pcf_cmap_char_index(), pcf_cmap_char_next(), pfr_cmap_char_index(), pfr_cmap_char_next(), pfr_face_init(), pfr_lookup_bitmap_data(), poll_isset(), POLYGONFILL_FillScanLineWinding(), POLYGONFILL_MakeEdge(), POLYGONFILL_UpdateScanline(), pool_alloc(), pqDelete(), prepare_raid5_write(), prepare_raid6_write(), PROGRESS_Draw(), ProgressCountdown(), ProgressTimeOutStringHandler(), PropertyHandler_Level(), protect_superblocks(), ps_dimension_add_t1stem(), ArcTessellator::pwl(), query_reg_path(), QuerySizeFix(), QueryTimeout(), CUSBQueue::QueueHeadInterruptCompletion(), quirk_apple_glsl_constants(), quirk_r200_constants(), ranges_add(), ranges_shift(), RawMountVolume(), read_data_raid5(), read_data_raid6(), read_file(), read_reply(), readerinput_grow(), REBAR_CalcHorzBand(), REBAR_CalcVertBand(), REBAR_LayoutRow(), REBAR_NCCalcSize(), REBAR_SetBandsHeight(), REBAR_ShrinkBandsLTR(), REBAR_ShrinkBandsRTL(), REBAR_SizeChildrenToHeight(), REBAR_ValidateBand(), RECTL_bClipRectBySize(), RECTL_bIntersectRect(), RECTL_bUnionRect(), RecycleBin5_Create(), RegDeleteTreeW(), REGION_CropRegion(), REGION_IntersectO(), REGION_RegionOp(), REGION_SetPolyPolygonRgn(), REGION_UnionRegion(), remove_target_tasks(), Replace(), basic_string< _CharT, _Traits, _Alloc >::reserve(), reserve(), resize_9x(), resize_table(), ResizeTextConsole(), ResizeWnd(), round_child_height(), RpnpEvaluateStack(), RQueryServiceConfig2A(), RQueryServiceConfig2W(), RtlIsTextUnicode(), RtlpClassifyChars(), RtlpCollapsePath(), s_mp_add(), s_mp_sub(), scan_revoke_records(), ScmDeleteRegKey(), ScmSetFailureActions(), SCROLL_GetThumbVal(), scrollbar_test_default(), scrub_chunk(), scrub_chunk_raid56_stripe_run(), scrub_extent(), scrub_extent_raid10(), SdbpGetLongPathName(), set_avg(), set_bumpmat_arbfp(), set_constants(), set_rename_information(), SEtoNW(), SelectionModel::SetSrcAndDestRectFromPoints(), SETUP_CreateInterfaceList(), shader_arb_load_constants_f(), shader_arb_select(), shader_arb_update_float_pixel_constants(), shader_arb_update_float_vertex_constants(), shader_find_free_input_register(), shader_glsl_alloc(), shader_glsl_generate_patch_constant_setup(), shader_glsl_generate_transform_feedback_varyings(), shader_glsl_load_constants(), shader_glsl_pointsize_uniform(), shader_reg_maps_add_tgsm(), shader_set_limits(), SHQueryValueExA(), SHQueryValueExW(), SoftModalMessageBox(), SOFTWARE_GdipDrawThinPath(), source_new(), space_list_add2(), SpiFixupValues(), SpiGetSet(), stabs_find_ref(), StackDropProc(), Defragment::Start(), start_balance(), state_arb_specularenable(), state_pscale(), state_psizemin_arb(), state_psizemin_ext(), state_psizemin_w(), state_texfactor_arbfp(), state_tss_constant_arbfp(), STATUSBAR_ComputeHeight(), STATUSBAR_DrawSizeGrip(), STATUSBAR_SetMinHeight(), sti_compar(), StorageImpl_StreamSetSize(), store_user_dirid(), strstreambuf::strstreambuf(), SubstituteVars(), KeyTranslator::SwitchTo(), SWtoNE(), symt_new_array(), SYSLINK_WrapLine(), system(), T1_Get_Kerning(), TAB_SetItemBounds(), taskdialog_init_button(), tcp_current_ssthresh(), tcp_initialize_rcv_mss(), tcp_moderate_sndbuf(), tcp_recalc_ssthresh(), tcp_select_initial_window(), Subdivider::tessellate(), test_basic_video(), test_boundsrect(), test_CreateIcon(), test_float_limits(), test_format_rect(), test_GetPwrDiskSpindownRange(), test_GetSystemMetrics(), test_GetSystemPreferredUILanguages(), test_GetUserPreferredUILanguages(), test_hotspot(), test_hv_scroll_2(), test_integral_limits(), test_integral_limits_base(), test_marshal_LPSAFEARRAY(), test_mbs_help(), test_not_full(), test_PBM_STEPIT(), test_pen_thickness(), test_rasenum(), test_scroll(), test_scroll_messages(), test_setpos(), test_SHQueryValueEx(), test_SPI_SETNONCLIENTMETRICS(), test_tab(), TestEventConcurrent(), TestEventsGeneration(), TestLockBytes_SetSize(), TestSynchronizeExecution(), tex_bumpenvlum_arbfp(), TEXTMODE_BUFFER_Initialize(), textrange_setend(), texture_apply_base_level(), texture_init(), TIME_SetEventInternal(), TOOLBAR_DrawButton(), TOOLBAR_GetIdealSize(), TOOLBAR_GetImageListCount(), TOOLBAR_LButtonDown(), TOOLBAR_MeasureButton(), TOOLBAR_SetButtonSize(), TOOLTIPS_CalcTipSize(), TOOLTIPS_Show(), TRACKBAR_SetRangeMax(), TransactedSnapshotImpl_StreamWriteAt(), transform_color(), TREEVIEW_Command(), TREEVIEW_EditLabel(), TREEVIEW_EnsureVisible(), TREEVIEW_UpdateDispInfo(), TREEVIEW_UpdateScrollBars(), TREEVIEW_VScroll(), triangle(), TRIO_ARGS2(), TRIO_ARGS5(), tt_face_get_kerning(), type_buffer_alignment(), UDFAddXSpaceBitmap(), UDFCompleteMount(), UDFEjectReqWaiter(), UDFGetDiskInfo(), UDFGetFreeSpace(), UDFLoadLogicalVolInt(), UDFQueryFsFullSizeInfo(), UDFQueryFsSizeInfo(), UDFReadAndProcessFullToc(), UDFReadDiscTrackInfo(), UDFReadEntityID_Domain(), UDFRelocateSector(), UDFRemapPacket(), UDFUnmapRange(), UDFUpdateLogicalVol(), UDFUpdateLogicalVolInt(), UDFUpdateVolIdent(), UDFUseStandard(), UDFVerifyXSpaceBitmap(), UmaMgrInitialize(), uncompress2(), UniataAhciDetect(), UniataAhciSetupCmdPtr(), UniataQueueRequest(), UnionRect(), update_min_band_height(), update_preview_sizes(), update_table_size(), UpdateSelection(), CStartButton::UpdateSize(), UpdateWindowScrollState(), USB2_AllocateTimeForEndpoint(), UsbAudioGetDataRanges(), USBPORT_UpdateAllocatedBwTt(), USBSTOR_FdoHandleDeviceRelations(), UserClipCursor(), usp10_array_reserve(), UXTHEME_LoadImage(), validate_indices(), VARIANT_FormatNumber(), VARIANT_UserMarshal(), VerQueryValueW(), vfatMakeFullName(), VGADDI_ComputePointerRect(), VGADDI_IntersectRect(), VGADDIIntersectRect(), VgaMarkForUpdate(), vgaNEtoSW(), vgaNWtoSE(), vgaSEtoNW(), vgaSWtoNE(), VidBiosScrollWindow(), volumetexture_init(), walk_parameter_dep(), warp_check(), WCacheInit__(), weld_dec3n(), weld_float16_2(), weld_float16_4(), weld_float2(), weld_float3(), weld_float4(), weld_short2(), weld_short4(), weld_ubyte4(), weld_udec3(), weld_ushort2n(), weld_ushort4n(), whilePaintingL(), WhoamiGroups(), WhoamiPrintTable(), wined3d_array_reserve(), wined3d_cs_st_require_space(), wined3d_device_update_texture(), wined3d_get_device_caps(), wined3d_sampler_desc_from_sampler_states(), wined3d_swapchain_desc_from_present_parameters(), wined3d_texture_get_level_depth(), wined3d_texture_get_level_height(), wined3d_texture_get_level_pow2_height(), wined3d_texture_get_level_pow2_width(), wined3d_texture_get_level_width(), wined3d_texture_init(), WINHELP_ButtonBoxWndProc(), WINHELP_GetPopupWindowInfo(), WinPosFixupFlags(), WinPosGetMinMaxInfo(), WinPrev_OnDraw(), WndProc(), write_file2(), write_new_procformatstring_type(), x86_64_find_runtime_function(), xbuf_resize(), xHalExamineMBR(), xHalIoReadPartitionTable(), xHalIoSetPartitionInformation(), xHalIoWritePartitionTable(), xmlParseNmtoken(), xmlParseStringName(), xmlSaveUri(), xmlSplitQName(), xprt_register(), xsltGetProfileInformation(), xsltNumberFormat(), xsltSaveProfiling(), and zoomTo().

#define RQCRED_SIZE   400 /* this size is excessive */

Definition at line 57 of file svc.c.

Referenced by svc_getreq_common().

#define SVC_VERSQUIET   0x0001 /* keep quiet about vers mismatch */

Definition at line 59 of file svc.c.

#define version_keepquiet

(

xp

)

((u_long)(xp)->xp_p3 & SVC_VERSQUIET)

Definition at line 60 of file svc.c.

Function Documentation

static void __xprt_do_unregister ( SVCXPRT *  xprt, bool_t  dolock  )

static

Definition at line 143 of file svc.c.

Referenced by __xprt_unregister_unlocked(), and xprt_unregister().

{
  SOCKET sock;

  assert (xprt != NULL);

  sock = xprt->xp_fd;

#ifndef _WIN32
  if (dolock)
    rwlock_wrlock (&svc_fd_lock);
  if ((sock < FD_SETSIZE) && (__svc_xports[sock] == xprt)) {
    __svc_xports[sock] = NULL;
    FD_CLR (sock, &svc_fdset);
    if (sock >= svc_maxfd) {
      for (svc_maxfd--; svc_maxfd >= 0; svc_maxfd--)
        if (__svc_xports[svc_maxfd])
          break;
    }
  }
  if (dolock)
    rwlock_unlock (&svc_fd_lock);
#else
  fprintf(stderr, "%s: Yikes!  Figure out __svc_xports[] issue!!\n", __FUNCTION__);
#endif
}

void __xprt_unregister_unlocked

(

SVCXPRT *

xprt

)

Definition at line 134 of file svc.c.

Referenced by __svc_clean_idle().

{
  __xprt_do_unregister (xprt, FALSE);
}

bool_t rpc_control	(	int	what,
		void *	arg
	)

Definition at line 784 of file svc.c.

{
  int val;

  switch (what)
    {
    case RPC_SVC_CONNMAXREC_SET:
      val = *(int *) arg;
      if (val <= 0)
    return FALSE;
      __svc_maxrec = val;
      return TRUE;
    case RPC_SVC_CONNMAXREC_GET:
      *(int *) arg = __svc_maxrec;
      return TRUE;
    default:
      break;
    }
  return FALSE;
}

static struct svc_callout * svc_find ( rpcprog_t  prog, rpcvers_t  vers, struct svc_callout **  prev, char *  netid  )

static

Definition at line 370 of file svc.c.

Referenced by svc_reg(), and svc_unreg().

{
  struct svc_callout *s, *p;

  assert (prev != NULL);

  p = NULL;
  for (s = svc_head; s != NULL; s = s->sc_next)
    {
      if (((s->sc_prog == prog) && (s->sc_vers == vers)) &&
      ((netid == NULL) || (s->sc_netid == NULL) ||
       (strcmp (netid, s->sc_netid) == 0)))
    break;
      p = s;
    }
  *prev = p;
  return (s);
}

void svc_getreq

(

int

rdfds

)

Definition at line 604 of file svc.c.

{
  fd_set readfds;

  FD_ZERO (&readfds);
  //XXX Windows!! readfds.fds_bits[0] = rdfds;
  svc_getreqset (&readfds);
}

void svc_getreq_common

(

SOCKET

fd

)

Definition at line 641 of file svc.c.

Referenced by clnt_raw_call(), svc_getreq_poll(), and svc_getreqset().

{
  SVCXPRT *xprt;
  struct svc_req r;
  struct rpc_msg msg;
  int prog_found;
  rpcvers_t low_vers;
  rpcvers_t high_vers;
  enum xprt_stat stat;
  char cred_area[2 * MAX_AUTH_BYTES + RQCRED_SIZE];

  msg.rm_call.cb_cred.oa_base = cred_area;
  msg.rm_call.cb_verf.oa_base = &(cred_area[MAX_AUTH_BYTES]);
  r.rq_clntcred = &(cred_area[2 * MAX_AUTH_BYTES]);

  rwlock_rdlock (&svc_fd_lock);
  xprt = __svc_xports[fd];
  rwlock_unlock (&svc_fd_lock);
  if (xprt == NULL)
    /* But do we control sock? */
    return;
  /* now receive msgs from xprtprt (support batch calls) */
  do
    {
      if (SVC_RECV (xprt, &msg))
    {

      /* now find the exported program and call it */
      struct svc_callout *s;
      enum auth_stat why;

      r.rq_xprt = xprt;
      r.rq_prog = msg.rm_call.cb_prog;
      r.rq_vers = msg.rm_call.cb_vers;
      r.rq_proc = msg.rm_call.cb_proc;
      r.rq_cred = msg.rm_call.cb_cred;
      /* first authenticate the message */
      if ((why = _authenticate (&r, &msg)) != AUTH_OK)
        {
          svcerr_auth (xprt, why);
          goto call_done;
        }
      /* now match message with a registered service */
      prog_found = FALSE;
      low_vers = (rpcvers_t) - 1L;
      high_vers = (rpcvers_t) 0L;
      for (s = svc_head; s != NULL; s = s->sc_next)
        {
          if (s->sc_prog == r.rq_prog)
        {
          if (s->sc_vers == r.rq_vers)
            {
              (*s->sc_dispatch) (&r, xprt);
              goto call_done;
            }       /* found correct version */
          prog_found = TRUE;
          if (s->sc_vers < low_vers)
            low_vers = s->sc_vers;
          if (s->sc_vers > high_vers)
            high_vers = s->sc_vers;
        }       /* found correct program */
        }
      /*
       * if we got here, the program or version
       * is not served ...
       */
      if (prog_found)
        svcerr_progvers (xprt, low_vers, high_vers);
      else
        svcerr_noprog (xprt);
      /* Fall through to ... */
    }
      /*
       * Check if the xprt has been disconnected in a
       * recursive call in the service dispatch routine.
       * If so, then break.
       */
      rwlock_rdlock (&svc_fd_lock);
      
      if (xprt != __svc_xports[fd])
    {
      rwlock_unlock (&svc_fd_lock);
      break;
    }
      rwlock_unlock (&svc_fd_lock);
    call_done:
      if ((stat = SVC_STAT (xprt)) == XPRT_DIED)
    {
      SVC_DESTROY (xprt);
      break;
    }
    else if ((xprt->xp_auth != NULL) 
#ifdef HAVE_LIBGSSAPI
        && (xprt->xp_auth->svc_ah_ops != &svc_auth_gss_ops)
#endif
    ) {
      xprt->xp_auth = NULL;
    }
    }
  while (stat == XPRT_MOREREQS);
}

void svc_getreq_poll	(	struct pollfd *	pfdp,
		int	pollretval
	)

Definition at line 745 of file svc.c.

{
  int i;
  int fds_found;

  for (i = fds_found = 0; fds_found < pollretval; i++)
    {
      struct pollfd *p = &pfdp[i];

      if (p->revents)
    {
      /* fd has input waiting */
      fds_found++;
      /*
       *      We assume that this function is only called
       *      via someone _select()ing from svc_fdset or
       *      _poll()ing from svc_pollset[].  Thus it's safe
       *      to handle the POLLNVAL event by simply turning
       *      the corresponding bit off in svc_fdset.  The
       *      svc_pollset[] array is derived from svc_fdset
       *      and so will also be updated eventually.
       *
       *      XXX Should we do an xprt_unregister() instead?
       */
      if (p->revents & POLLNVAL)
        {
          rwlock_wrlock (&svc_fd_lock);
          FD_CLR (p->fd, &svc_fdset);
          rwlock_unlock (&svc_fd_lock);
        }
      else
        svc_getreq_common (p->fd);
    }
    }
}

void svc_getreqset

(

fd_set *

readfds

)

Definition at line 615 of file svc.c.

Referenced by svc_getreq(), and svc_run().

{
#ifndef _WIN32
  int bit, fd;
  fd_mask mask, *maskp;
  int sock;

  assert (readfds != NULL);

  maskp = readfds->fds_bits;
  for (sock = 0; sock < FD_SETSIZE; sock += NFDBITS)
    {
      for (mask = *maskp++; (bit = ffs (mask)) != 0; mask ^= (1 << (bit - 1)))
    {
      /* sock has input waiting */
      fd = sock + bit - 1;
      svc_getreq_common (fd);
    }
    }
#else
    fprintf(stderr, "%s: Yikes!\n", __FUNCTION__);
#endif
}

bool_t svc_reg	(	SVCXPRT *	xprt,
		const rpcprog_t	prog,
		const rpcvers_t	vers,
		void *	dispatch,
		const struct netconfig *	nconf
	)

Definition at line 178 of file svc.c.

Referenced by rpc_reg(), svc_create(), and svc_tp_create().

{
  bool_t dummy;
  struct svc_callout *prev;
  struct svc_callout *s;
  struct netconfig *tnconf;
  char *netid = NULL;
  int flag = 0;

/* VARIABLES PROTECTED BY svc_lock: s, prev, svc_head */
  if (xprt->xp_netid)
    {
      netid = strdup (xprt->xp_netid);
      flag = 1;
    }
  else if (nconf && nconf->nc_netid)
    {
      netid = strdup (nconf->nc_netid);
      flag = 1;
    }
  else if ((tnconf = __rpcgettp (xprt->xp_fd)) != NULL)
    {
      netid = strdup (tnconf->nc_netid);
      flag = 1;
      freenetconfigent (tnconf);
    }               /* must have been created with svc_raw_create */
  if ((netid == NULL) && (flag == 1))
    {
      return (FALSE);
    }

  rwlock_wrlock (&svc_lock);
  if ((s = svc_find (prog, vers, &prev, netid)) != NULL)
    {
      if (netid)
    free (netid);
      if (s->sc_dispatch == dispatch)
    goto rpcb_it;       /* he is registering another xptr */
      rwlock_unlock (&svc_lock);
      return (FALSE);
    }
  s = mem_alloc (sizeof (struct svc_callout));
  if (s == NULL)
    {
      if (netid)
    free (netid);
      rwlock_unlock (&svc_lock);
      return (FALSE);
    }

  s->sc_prog = prog;
  s->sc_vers = vers;
  s->sc_dispatch = dispatch;
  s->sc_netid = netid;
  s->sc_next = svc_head;
  svc_head = s;

  if ((xprt->xp_netid == NULL) && (flag == 1) && netid)
    ((SVCXPRT *) xprt)->xp_netid = strdup (netid);

rpcb_it:
  rwlock_unlock (&svc_lock);
  /* now register the information with the local binder service */
  if (nconf)
    {
      /*LINTED const castaway */
      dummy = rpcb_set (prog, vers, (struct netconfig *) nconf,
            &((SVCXPRT *) xprt)->xp_ltaddr);
      return (dummy);
    }
  return (TRUE);
}

bool_t svc_sendreply	(	SVCXPRT *	xprt,
		xdrproc_t	xdr_results,
		void *	xdr_location
	)

Definition at line 399 of file svc.c.

Referenced by _svcauth_gss(), and universal().

{
  struct rpc_msg rply;

  assert (xprt != NULL);

  rply.rm_direction = REPLY;
  rply.rm_reply.rp_stat = MSG_ACCEPTED;
  rply.acpted_rply.ar_verf = xprt->xp_verf;
  rply.acpted_rply.ar_stat = SUCCESS;
  rply.acpted_rply.ar_results.where = xdr_location;
  rply.acpted_rply.ar_results.proc = xdr_results;
  return (SVC_REPLY (xprt, &rply));
}

void svc_unreg	(	rpcprog_t	prog,
		const rpcvers_t	vers
	)		const

Definition at line 260 of file svc.c.

{
  struct svc_callout *prev;
  struct svc_callout *s;

  /* unregister the information anyway */
  (void) rpcb_unset (prog, vers, NULL);
  rwlock_wrlock (&svc_lock);
  while ((s = svc_find (prog, vers, &prev, NULL)) != NULL)
    {
      if (prev == NULL)
    {
      svc_head = s->sc_next;
    }
      else
    {
      prev->sc_next = s->sc_next;
    }
      s->sc_next = NULL;
      if (s->sc_netid)
    mem_free (s->sc_netid, sizeof (s->sc_netid) + 1);
      mem_free (s, sizeof (struct svc_callout));
    }
  rwlock_unlock (&svc_lock);
}

void svcerr_auth	(	SVCXPRT *	xprt,
		enum auth_stat	why
	)

Definition at line 517 of file svc.c.

Referenced by svc_getreq_common(), and svcerr_weakauth().

{
  struct rpc_msg rply;

  assert (xprt != NULL);

  rply.rm_direction = REPLY;
  rply.rm_reply.rp_stat = MSG_DENIED;
  rply.rjcted_rply.rj_stat = AUTH_ERROR;
  rply.rjcted_rply.rj_why = why;
  SVC_REPLY (xprt, &rply);
}

void svcerr_decode

(

SVCXPRT *

xprt

)

Definition at line 439 of file svc.c.

Referenced by universal().

{
  struct rpc_msg rply;

  assert (xprt != NULL);

  rply.rm_direction = REPLY;
  rply.rm_reply.rp_stat = MSG_ACCEPTED;
  rply.acpted_rply.ar_verf = xprt->xp_verf;
  rply.acpted_rply.ar_stat = GARBAGE_ARGS;
  SVC_REPLY (xprt, &rply);
}

void svcerr_noproc

(

SVCXPRT *

xprt

)

Definition at line 421 of file svc.c.

{
  struct rpc_msg rply;

  assert (xprt != NULL);

  rply.rm_direction = REPLY;
  rply.rm_reply.rp_stat = MSG_ACCEPTED;
  rply.acpted_rply.ar_verf = xprt->xp_verf;
  rply.acpted_rply.ar_stat = PROC_UNAVAIL;
  SVC_REPLY (xprt, &rply);
}

void svcerr_noprog

(

SVCXPRT *

xprt

)

Definition at line 549 of file svc.c.

Referenced by svc_getreq_common().

{
  struct rpc_msg rply;

  assert (xprt != NULL);

  rply.rm_direction = REPLY;
  rply.rm_reply.rp_stat = MSG_ACCEPTED;
  rply.acpted_rply.ar_verf = xprt->xp_verf;
  rply.acpted_rply.ar_stat = PROG_UNAVAIL;
  SVC_REPLY (xprt, &rply);
}

void svcerr_progvers	(	SVCXPRT *	xprt,
		rpcvers_t	low_vers,
		rpcvers_t	high_vers
	)

Definition at line 567 of file svc.c.

Referenced by svc_getreq_common().

{
  struct rpc_msg rply;

  assert (xprt != NULL);

  rply.rm_direction = REPLY;
  rply.rm_reply.rp_stat = MSG_ACCEPTED;
  rply.acpted_rply.ar_verf = xprt->xp_verf;
  rply.acpted_rply.ar_stat = PROG_MISMATCH;
  rply.acpted_rply.ar_vers.low = (u_int32_t) low_vers;
  rply.acpted_rply.ar_vers.high = (u_int32_t) high_vers;
  SVC_REPLY (xprt, &rply);
}

void svcerr_systemerr

(

SVCXPRT *

xprt

)

Definition at line 457 of file svc.c.

{
  struct rpc_msg rply;

  assert (xprt != NULL);

  rply.rm_direction = REPLY;
  rply.rm_reply.rp_stat = MSG_ACCEPTED;
  rply.acpted_rply.ar_verf = xprt->xp_verf;
  rply.acpted_rply.ar_stat = SYSTEM_ERR;
  SVC_REPLY (xprt, &rply);
}

void svcerr_weakauth

(

SVCXPRT *

xprt

)

Definition at line 536 of file svc.c.

{

  assert (xprt != NULL);

  svcerr_auth (xprt, AUTH_TOOWEAK);
}

void xprt_register

(

SVCXPRT *

xprt

)

Definition at line 97 of file svc.c.

Referenced by makefd_xprt(), svc_dg_create(), svc_raw_create(), and svc_vc_create().

{
  SOCKET sock;

  assert (xprt != NULL);

  sock = xprt->xp_fd;

  rwlock_wrlock (&svc_fd_lock);
  if (__svc_xports == NULL) {
      __svc_xports = (SVCXPRT **) mem_alloc (FD_SETSIZE * sizeof (SVCXPRT *));
      if (__svc_xports == NULL) {
        // XXX Give an error indication?
        return;
      }
      memset (__svc_xports, 0, FD_SETSIZE * sizeof (SVCXPRT *));
  }
#ifndef _WIN32
  if (sock < FD_SETSIZE) {
    __svc_xports[sock] = xprt;
    FD_SET (sock, &svc_fdset);
    svc_maxfd = max (svc_maxfd, sock);
  }
#else
  fprintf(stderr, "%s: Yikes!  Figure out __svc_xports[] issue!!\n", __FUNCTION__);
#endif
  rwlock_unlock (&svc_fd_lock);
}

void xprt_unregister

(

SVCXPRT *

xprt

)

Definition at line 128 of file svc.c.

Referenced by svc_dg_destroy(), and svc_vc_destroy().

{
  __xprt_do_unregister (xprt, TRUE);
}

Variable Documentation

rwlock_t svc_fd_lock

Definition at line 22 of file mt_misc.c.

struct svc_callout * svc_head

static

Referenced by svc_find(), svc_getreq_common(), svc_reg(), and svc_unreg().

rwlock_t svc_lock

Definition at line 19 of file mt_misc.c.